X-Git-Url: https://git.realraum.at/?p=svn42.git;a=blobdiff_plain;f=go%2Fr3-eventbroker_zmq%2Fsockettoevent.go;h=9e4907ed70319abd19035c4c600cc69f36cac9b3;hp=d8de48e4078eb2dcb91de8f43abe4a5504172d2a;hb=36c81737d355f02eb05b150472c9bf44fbf46120;hpb=164e7321f68ca53bdbb6f69ca10c8b99af923c46 diff --git a/go/r3-eventbroker_zmq/sockettoevent.go b/go/r3-eventbroker_zmq/sockettoevent.go index d8de48e..9e4907e 100644 --- a/go/r3-eventbroker_zmq/sockettoevent.go +++ b/go/r3-eventbroker_zmq/sockettoevent.go @@ -6,6 +6,7 @@ import ( "regexp" "strconv" "time" + "bytes" //~ "./brain" pubsub "github.com/tuxychandru/pubsub" zmq "github.com/vaughan0/go-zmq" @@ -35,14 +36,14 @@ func parseSocketInputLine_State(lines [][]byte, ps *pubsub.PubSub, ts int64) { case "manual", "manual_movement": //movement ps.Pub(r3events.DoorManualMovementEvent{ts}, "door") case "error": - ps.Pub(r3events.DoorProblemEvent{100, ts}, "door") + ps.Pub(r3events.DoorProblemEvent{100, string(bytes.Join(lines,[]byte(" "))), ts}, "door") case "reset": ps.Pub(r3events.DoorLockUpdate{true, ts}, "door") case "timeout_after_open": - ps.Pub(r3events.DoorProblemEvent{10, ts}, "door") + ps.Pub(r3events.DoorProblemEvent{10, string(lines[0]), ts}, "door") ps.Pub(r3events.DoorLockUpdate{false, ts}, "door") case "timeout_after_close": - ps.Pub(r3events.DoorProblemEvent{20, ts}, "door") + ps.Pub(r3events.DoorProblemEvent{20, string(lines[0]), 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":