1 // (c) Bernhard Tittelbach, 2013
8 pubsub "github.com/tuxychandru/pubsub"
9 r3events "svn.spreadspace.org/realraum/go.svn/r3events"
12 func MetaEventRoutine_Presence(ps *pubsub.PubSub, movement_timeout, button_timeout int64) {
13 //~ var last_door_cmd *r3events.DoorCommandEvent
14 var last_presence bool
15 var last_movement, last_buttonpress, last_frontlock_use int64
16 var front_locked, front_shut, back_shut bool = true, true, true
18 events_chan := ps.Sub("door", "doorcmd", "buttons", "movement")
19 defer ps.Unsub(events_chan, "door", "doorcmd", "buttons", "movement")
21 for event := range(events_chan) {
22 Debug_.Printf("Presence prior: %t : %T %+v", last_presence, event, event)
23 new_presence := last_presence
24 ts := time.Now().Unix()
25 switch evnt := event.(type) {
26 case r3events.SomethingReallyIsMoving:
28 last_movement = evnt.Ts
31 if last_presence { Syslog_.Print("Presence: Mhh, SomethingReallyIsMoving{false} received but presence still true. Quite still a bunch we have here.") }
33 case r3events.BoreDoomButtonPressEvent:
34 last_buttonpress = evnt.Ts
36 case r3events.DoorCommandEvent:
37 //~ last_door_cmd = &evnt
38 case r3events.DoorLockUpdate:
39 front_locked = evnt.Locked
40 last_frontlock_use = evnt.Ts
41 case r3events.DoorAjarUpdate:
42 if front_shut == false && evnt.Shut && front_locked && evnt.Ts - last_frontlock_use > 2 {
43 Syslog_.Print("Presence: ignoring frontdoor ajar event, since obviously someone is fooling around with the microswitch while the door is still open")
45 front_shut = evnt.Shut
47 case r3events.BackdoorAjarUpdate:
51 any_door_unlocked := (front_locked == false)
52 any_door_ajar := ! (front_shut && back_shut)
54 if new_presence != last_presence {
55 //... skip state check .. we had a definite presence event
56 } else if any_door_unlocked || any_door_ajar {
58 } else if ts - last_movement < movement_timeout || ts - last_buttonpress < button_timeout {
63 //~ Debug_.Printf("Presence: new: %s , last:%s", new_presence, last_presence)
64 if new_presence != last_presence {
65 last_presence = new_presence
66 ps.Pub(r3events.PresenceUpdate{new_presence, ts} , "presence")