go/r3-eventbroker_zmq/sockettoevent.go

   1 // (c) Bernhard Tittelbach, 2013
   2
   3 package main
   4
   5 import (
   6     "regexp"
   7     "strconv"
   8     "time"
   9     //~ "./brain"
  10     pubsub "github.com/tuxychandru/pubsub"
  11     zmq "github.com/vaughan0/go-zmq"
  12     "log"
  13     "./r3events"
  14     )
  15
  16 var (
  17         re_presence_    *regexp.Regexp     = regexp.MustCompile("Presence: (yes|no)(?:, (opened|closed), (.+))?")
  18         re_state_      *regexp.Regexp     = regexp.MustCompile("State: (closed|opened|manual movement|error|reset|timeout after open|timeout after close|opening|closing).*")
  19         re_status_      *regexp.Regexp     = regexp.MustCompile("Status: (closed|opened), (closed|opened|manual movement|error|reset|timeout after open|timeout after close|opening|closing), (ajar|shut).*")
  20         re_infocard_      *regexp.Regexp     = regexp.MustCompile("Info\\(card\\): card\\(([a-fA-F0-9]+)\\) (found|not found).*")
  21         re_cardid_      *regexp.Regexp     = regexp.MustCompile("card\\(([a-fA-F0-9]+)\\)")
  22         re_infoajar_      *regexp.Regexp     = regexp.MustCompile("Info\\(ajar\\): door is now (ajar|shut)")
  23         re_command_     *regexp.Regexp     = regexp.MustCompile("(open|close|toggle|reset)(?: +(Card|Phone|SSH|ssh))?(?: +(.+))?")
  24         re_button_      *regexp.Regexp     = regexp.MustCompile("PanicButton|button\\d?")
  25         re_temp_        *regexp.Regexp     = regexp.MustCompile("temp0: (\\d+\\.\\d+)")
  26         re_photo_       *regexp.Regexp     = regexp.MustCompile("photo0: (\\d+)")
  27 )
  28
  29
  30 func parseSocketInputLine_State(lines [][]byte, ps *pubsub.PubSub, ts int64) {
  31     switch string(lines[0]) {
  32         case "closed":
  33             ps.Pub(r3events.DoorLockUpdate{true, ts}, "door")
  34         case "opened":
  35             ps.Pub(r3events.DoorLockUpdate{false, ts}, "door")
  36         case "manual":   //movement
  37         case "error":
  38         case "reset":
  39             ps.Pub(r3events.DoorLockUpdate{true, ts}, "door")
  40         case "timeout":   //after open | after close
  41         case "opening":
  42         case "closing":
  43         default:
  44             if Syslog_ != nil {Syslog_.Print("parseSocketInputLine_State: Unexpected State:", lines)}
  45     }
  46 }
  47
  48
  49 func ParseSocketInputLine(lines [][]byte, ps *pubsub.PubSub, keylookup_socket *zmq.Socket) { //, brn *brain.Brain) {
  50     ts := time.Now().Unix()
  51     if len(lines) < 1 { return }
  52     log.Printf("ParseSocketInputLine: %s %s",string(lines[0]), lines[1:])
  53     switch string(lines[0]) {
  54         case "State:":
  55             if len(lines) < 2 { return }
  56             parseSocketInputLine_State(lines[1:], ps, ts)
  57         case "Status:":
  58             if len(lines) < 3 { return }
  59             ps.Pub(r3events.DoorLockUpdate{string(lines[1]) == "closed,", ts}, "door")
  60             ps.Pub(r3events.DoorAjarUpdate{string(lines[len(lines)-1]) == "shut", ts}, "door")
  61         case "Info(card):":
  62             if len(lines) < 3 { return }
  63             if string(lines[2]) != "found" { return }
  64             match_cardid := re_cardid_.FindSubmatch(lines[1])
  65             if len(match_cardid) > 1 {
  66                 // PreCondition: same thread/goroutinge as created keylookup_socket !!!!
  67                 nick, err := LookupCardIdNick(keylookup_socket, match_cardid[1])
  68                 if err != nil {
  69                     Syslog_.Print("CardID Lookup Error",err)
  70                     nick = "Unresolvable KeyID"
  71                 }
  72                 // new event: toggle by user nick using card
  73                 ps.Pub(r3events.DoorCommandEvent{"toggle", "Card", nick, ts},"doorcmd")
  74             }
  75         case "Info(ajar):":
  76             if len(lines) < 5 { return }
  77             ps.Pub(r3events.DoorAjarUpdate{string(lines[4]) == "shut", ts}, "door")
  78         case "open", "close", "toggle", "reset":
  79             ps.Pub(r3events.DoorCommandEvent{string(lines[0]), string(lines[1]), string(lines[2]), ts},"doorcmd")
  80         case "photo0":
  81             newphoto, err := strconv.ParseInt(string(lines[1]), 10, 32)
  82             if err == nil {
  83                 // brn.Oboite("photo0", newphoto)
  84                 ps.Pub(r3events.IlluminationSensorUpdate{0, newphoto, ts}, "sensors")
  85             }
  86         case "IlluminationSensorUpdate","TempSensorUpdate":
  87             //try decode r3event
  88             evnt, err := r3events.UnmarshalByteByte2Event(lines)
  89             if err == nil {ps.Pub(evnt, "sensors")}
  90         case "MovementSensorUpdate" :
  91             //try decode r3event
  92             evnt, err := r3events.UnmarshalByteByte2Event(lines)
  93             if err == nil {ps.Pub(evnt, "movement")}
  94         case "BoreDoomButtonPressEvent" :
  95             //try decode r3event
  96             evnt, err := r3events.UnmarshalByteByte2Event(lines)
  97             if err == nil {ps.Pub(evnt, "buttons")}
  98     }
  99 }
 100
 101 func MakeTimeTick(ps *pubsub.PubSub) {
 102     ps.Pub(r3events.TimeTick{time.Now().Unix()},"time")
 103 }
 104
 105     //~ match_presence := re_presence_.FindStringSubmatch(line)
 106     //~ match_status := re_status_.FindStringSubmatch(line)
 107     //~ match_command := re_command_.FindStringSubmatch(line)
 108     //~ match_button := re_button_.FindStringSubmatch(line)
 109     //~ match_temp := re_temp_.FindStringSubmatch(line)
 110     //~ match_photo := re_photo_.FindStringSubmatch(line)
 111         //~ if match_button != nil {
 112         //~ // brn.Oboite("button0", ts)
 113         //~ ps.Pub(BoreDoomButtonPressEvent{0, ts}, "buttons")
 114         //~ } else if match_temp != nil {
 115                 //~ newtemp, err := strconv.ParseFloat((match_temp[1]), 32)
 116                 //~ if err == nil {
 117             //~ // brn.Oboite( "temp0", newtemp)
 118             //~ ps.Pub(TempSensorUpdate{0, newtemp, ts}, "sensors")
 119                 //~ }
 120         //~ } else if match_photo != nil {
 121                 //~ newphoto, err := strconv.ParseInt(match_photo[1], 10, 32)
 122                 //~ if err == nil {
 123             //~ // brn.Oboite("photo0", newphoto)
 124             //~ ps.Pub(IlluminationSensorUpdate{0, newphoto, ts}, "sensors")
 125                 //~ }
 126         //~ } else if line == "movement" {
 127         //~ // brn.Oboite("movement", ts)
 128         //~ ps.Pub(MovementSensorUpdate{0, ts}, "movements")
 129         //~ }