X-Git-Url: https://git.realraum.at/?p=svn42.git;a=blobdiff_plain;f=go%2Fr3-eventbroker_zmq%2Fsockettoevent.go;h=d8de48e4078eb2dcb91de8f43abe4a5504172d2a;hp=7831ab88a035e14faaf2b2e28031bfb891f0f161;hb=164e7321f68ca53bdbb6f69ca10c8b99af923c46;hpb=0b67c3a83d670df97ef1af07f47365a11cb0da65 diff --git a/go/r3-eventbroker_zmq/sockettoevent.go b/go/r3-eventbroker_zmq/sockettoevent.go index 7831ab8..d8de48e 100644 --- a/go/r3-eventbroker_zmq/sockettoevent.go +++ b/go/r3-eventbroker_zmq/sockettoevent.go @@ -38,8 +38,13 @@ func parseSocketInputLine_State(lines [][]byte, ps *pubsub.PubSub, ts int64) { ps.Pub(r3events.DoorProblemEvent{100, ts}, "door") case "reset": ps.Pub(r3events.DoorLockUpdate{true, ts}, "door") - case "timeout", "timeout_after_open", "timeout_after_close": + case "timeout_after_open": ps.Pub(r3events.DoorProblemEvent{10, ts}, "door") + ps.Pub(r3events.DoorLockUpdate{false, ts}, "door") + case "timeout_after_close": + ps.Pub(r3events.DoorProblemEvent{20, ts}, "door") + // can't say for sure that door is locked if we ran into timeout while closing + //~ ps.Pub(r3events.DoorLockUpdate{true, ts}, "door") case "opening": case "closing": default: