//~ "./brain"
pubsub "github.com/tuxychandru/pubsub"
zmq "github.com/vaughan0/go-zmq"
- "./r3events"
+ r3events "svn.spreadspace.org/realraum/go.svn/r3-eventbroker_zmq/r3events"
)
var (
ps.Pub(r3events.DoorLockUpdate{false, ts}, "door")
case "manual": //movement
case "error":
+ ps.Pub(r3events.DoorProblemEvent{100, ts}, "door")
case "reset":
ps.Pub(r3events.DoorLockUpdate{true, ts}, "door")
case "timeout": //after open | after close
+ ps.Pub(r3events.DoorProblemEvent{10, ts}, "door")
case "opening":
case "closing":
default:
//~ if err == nil {
//~ 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 "BoreDoomButtonPressEvent" :
- //try decode r3event
- evnt, err := r3events.UnmarshalByteByte2Event(lines)
- if err == nil {ps.Pub(evnt, "buttons")}
+ default:
+ evnt, pubsubcat, err := r3events.UnmarshalByteByte2Event(lines)
+ if err == nil {
+ ps.Pub(evnt, pubsubcat)
+ }
}
}