X-Git-Url: https://git.realraum.at/?a=blobdiff_plain;f=go%2Fr3-eventbroker_zmq%2Fpresence.go;h=3677b277cabcac88dfb74fb06719cf7c4ba14fd3;hb=91ed9fe7c53c26cad5771ef4727da01eae932fa0;hp=a87933225d1e9da6c993ad8058b04dbad3a8f29a;hpb=b40171692bb6090aae3e75c4eb355ce077a61a89;p=svn42.git diff --git a/go/r3-eventbroker_zmq/presence.go b/go/r3-eventbroker_zmq/presence.go index a879332..3677b27 100644 --- a/go/r3-eventbroker_zmq/presence.go +++ b/go/r3-eventbroker_zmq/presence.go @@ -6,50 +6,65 @@ import ( "time" //~ "./brain" pubsub "github.com/tuxychandru/pubsub" - r3events "svn.spreadspace.org/realraum/go.svn/r3-eventbroker_zmq/r3events" + r3events "svn.spreadspace.org/realraum/go.svn/r3events" ) -func MetaEventRoutine_Presence(ps *pubsub.PubSub) { - //~ var last_door_cmd *DoorCommandEvent +func MetaEventRoutine_Presence(ps *pubsub.PubSub, movement_timeout, button_timeout int64) { + var last_door_cmd *r3events.DoorCommandEvent var last_presence bool - var last_movement, last_buttonpress int64 + var last_event_indicating_presence, last_frontlock_use int64 var front_locked, front_shut, back_shut bool = true, true, true events_chan := ps.Sub("door", "doorcmd", "buttons", "movement") defer ps.Unsub(events_chan, "door", "doorcmd", "buttons", "movement") for event := range(events_chan) { - //~ Debug_.Printf("Presence: %s - %s", event, doorstatemap) + Debug_.Printf("Presence prior: %t : %T %+v", last_presence, event, event) new_presence := last_presence ts := time.Now().Unix() switch evnt := event.(type) { case r3events.SomethingReallyIsMoving: if evnt.Movement { - last_movement = evnt.Ts + //ignore movements that happened just after locking door + if (evnt.Ts - last_event_indicating_presence) > movement_timeout { + new_presence = true + } + last_event_indicating_presence = evnt.Ts } else { - last_movement = 0 + if last_presence { Syslog_.Printf("Presence: Mhh, SomethingReallyIsMoving{%+v} received but presence still true. Quite still a bunch we have here.", evnt) } + if front_locked && front_shut && back_shut && evnt.Confidence >= 20 && last_event_indicating_presence > 1800 { + new_presence = false + } } case r3events.BoreDoomButtonPressEvent: - last_buttonpress = evnt.Ts new_presence = true - //~ case DoorCommandEvent: - //~ last_door_cmd = &evnt + last_event_indicating_presence = evnt.Ts + case r3events.DoorCommandEvent: + last_door_cmd = &evnt case r3events.DoorLockUpdate: front_locked = evnt.Locked + last_frontlock_use = evnt.Ts + last_event_indicating_presence = evnt.Ts case r3events.DoorAjarUpdate: - front_shut = evnt.Shut + if front_shut == false && evnt.Shut && front_locked && evnt.Ts - last_frontlock_use > 2 { + Syslog_.Print("Presence: ignoring frontdoor ajar event, since obviously someone is fooling around with the microswitch while the door is still open") + } else { + front_shut = evnt.Shut + } + last_event_indicating_presence = evnt.Ts case r3events.BackdoorAjarUpdate: back_shut = evnt.Shut + last_event_indicating_presence = evnt.Ts } - any_door_unlocked := ! front_locked + any_door_unlocked := (front_locked == false) any_door_ajar := ! (front_shut && back_shut) if new_presence != last_presence { //... skip state check .. we had a definite presence event } else if any_door_unlocked || any_door_ajar { new_presence = true - } else if last_movement != 0 || ts - last_buttonpress < 200 { + } else if last_door_cmd.Using == "Button" { new_presence = true } else { new_presence = false