//~ "./brain"
pubsub "github.com/tuxychandru/pubsub"
zmq "github.com/vaughan0/go-zmq"
- r3events "svn.spreadspace.org/realraum/go.svn/r3-eventbroker_zmq/r3events"
+ r3events "svn.spreadspace.org/realraum/go.svn/r3events"
)
var (
ps.Pub(r3events.DoorLockUpdate{true, ts}, "door")
case "opened":
ps.Pub(r3events.DoorLockUpdate{false, ts}, "door")
- case "manual": //movement
+ case "manual", "manual_movement": //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
+ case "timeout", "timeout_after_open", "timeout_after_close":
ps.Pub(r3events.DoorProblemEvent{10, ts}, "door")
case "opening":
case "closing":
parseSocketInputLine_State(lines[1:], ps, ts)
case "Status:":
if len(lines) < 3 { return }
- ps.Pub(r3events.DoorLockUpdate{string(lines[1]) == "closed,", ts}, "door")
+ if len(lines[1]) < 4 { return }
+ ps.Pub(r3events.DoorLockUpdate{string(lines[1])[0:4] != "open", ts}, "door")
ps.Pub(r3events.DoorAjarUpdate{string(lines[len(lines)-1]) == "shut", ts}, "door")
case "Info(card):":
if len(lines) < 3 { return }