X-Git-Url: https://git.realraum.at/?a=blobdiff_plain;f=go%2Fr3-eventbroker_zmq%2Fsockettoevent.go;fp=go%2Fr3-eventbroker_zmq%2Fsockettoevent.go;h=34454cc24856cc70680f030f78817449a7f40867;hb=db6096af35c81fac74bacda38c734a76b7bdf9c1;hp=8e202da47e1315cac813bab00601872dcce7cfb7;hpb=417e9a91ef92b248513da9f2be83519d37c599e7;p=svn42.git diff --git a/go/r3-eventbroker_zmq/sockettoevent.go b/go/r3-eventbroker_zmq/sockettoevent.go index 8e202da..34454cc 100644 --- a/go/r3-eventbroker_zmq/sockettoevent.go +++ b/go/r3-eventbroker_zmq/sockettoevent.go @@ -89,6 +89,18 @@ func ParseSocketInputLine(lines [][]byte, ps *pubsub.PubSub, keylookup_socket *z // brn.Oboite("photo0", newphoto) ps.Pub(r3events.IlluminationSensorUpdate{0, newphoto, ts}, "sensors") } + case "IlluminationSensorUpdate","TempSensorUpdate": + //try decode r3event + evnt, err := r3events.UnmarshalByteByte2Event(lines) + if err == nil {ps.Pub(evnt, "sensors")} + case "MovementSensorUpdate" : + //try decode r3event + evnt, err := r3events.UnmarshalByteByte2Event(lines) + if err == nil {ps.Pub(evnt, "movement")} + case "ButtonPressUpdate" : + //try decode r3event + evnt, err := r3events.UnmarshalByteByte2Event(lines) + if err == nil {ps.Pub(evnt, "buttons")} } }