X-Git-Url: https://git.realraum.at/?p=svn42.git;a=blobdiff_plain;f=go%2Fr3-eventbroker_zmq%2Fsockettoevent.go;h=a6c479d7765ada79ede79bfdff90243ee5e0596f;hp=9e4907ed70319abd19035c4c600cc69f36cac9b3;hb=53647f4ca80b7c4cdbd029ae496dc9a2c4df211d;hpb=d660271629ff32c40cff4fdff4449a39fe950159 diff --git a/go/r3-eventbroker_zmq/sockettoevent.go b/go/r3-eventbroker_zmq/sockettoevent.go index 9e4907e..a6c479d 100644 --- a/go/r3-eventbroker_zmq/sockettoevent.go +++ b/go/r3-eventbroker_zmq/sockettoevent.go @@ -88,6 +88,8 @@ func ParseSocketInputLine(lines [][]byte, ps *pubsub.PubSub, keylookup_socket *z ps.Pub(r3events.DoorCommandEvent{string(lines[0]), string(lines[1]), string(lines[2]), ts},"doorcmd") case "BackdoorInfo(ajar):": ps.Pub(r3events.BackdoorAjarUpdate{string(lines[len(lines)-1]) == "shut", ts},"door") + case "GasLeakAlert": + ps.Pub(r3events.GasLeakAlert{ts},"sensors") case "temp0:","temp1:", "temp2:", "temp3:": sensorid, err := strconv.ParseInt(string(lines[0][4]), 10, 32) if err != nil {return }