X-Git-Url: https://git.realraum.at/?p=svn42.git;a=blobdiff_plain;f=go%2Fr3-eventbroker_zmq%2Fpresence.go;fp=go%2Fr3-eventbroker_zmq%2Fpresence.go;h=aac99f51348d57ddfdd8b5ca83415ea151d4c4df;hp=154c6d23dbc2d0de9fdd9d4f32695db8a3865a0e;hb=417e9a91ef92b248513da9f2be83519d37c599e7;hpb=837698930d5eea7c100a1233ee1d92e71896bb5d diff --git a/go/r3-eventbroker_zmq/presence.go b/go/r3-eventbroker_zmq/presence.go index 154c6d2..aac99f5 100644 --- a/go/r3-eventbroker_zmq/presence.go +++ b/go/r3-eventbroker_zmq/presence.go @@ -6,13 +6,9 @@ import ( "time" //~ "./brain" pubsub "github.com/tuxychandru/pubsub" + "./r3events" ) -type PresenceUpdate struct { - Present bool - Ts int64 -} - type doorstate struct { locked bool shut bool @@ -30,20 +26,20 @@ func MetaEventRoutine_Presence(ps *pubsub.PubSub) { new_presence := last_presence ts := time.Now().Unix() switch evnt := event.(type) { - case SomethingReallyIsMoving: + case r3events.SomethingReallyIsMoving: if evnt.Movement { last_movement = evnt.Ts } else { last_movement = 0 } - case ButtonPressUpdate: + case r3events.ButtonPressUpdate: last_buttonpress = evnt.Ts new_presence = true //~ case DoorCommandEvent: //~ last_door_cmd = &evnt - case DoorLockUpdate: + case r3events.DoorLockUpdate: doorstatemap[evnt.DoorID]=doorstate{locked:evnt.Locked, shut:doorstatemap[evnt.DoorID].shut} - case DoorAjarUpdate: + case r3events.DoorAjarUpdate: doorstatemap[evnt.DoorID]=doorstate{locked:doorstatemap[evnt.DoorID].locked, shut:evnt.Shut} } @@ -66,7 +62,7 @@ func MetaEventRoutine_Presence(ps *pubsub.PubSub) { if new_presence != last_presence { last_presence = new_presence - ps.Pub(PresenceUpdate{new_presence, ts} , "presence") + ps.Pub(r3events.PresenceUpdate{new_presence, ts} , "presence") } } } \ No newline at end of file