r3-netstatus/main.go

   1 package main
   2
   3 import (
   4         "./spaceapi"
   5     "./r3xmppbot"
   6     //pubsub "github.com/tuxychandru/pubsub"
   7     "flag"
   8         "bufio"
   9         "fmt"
  10         "net"
  11         "net/http"
  12         "net/url"
  13         "regexp"
  14         "time"
  15     "strconv"
  16 )
  17
  18 type SpaceState struct {
  19         present           bool
  20         buttonpress_until int64
  21     door_locked bool
  22     door_shut bool
  23 }
  24
  25 var (
  26         re_presence_    *regexp.Regexp     = regexp.MustCompile("Presence: (yes|no)(?:, (opened|closed), (.+))?")
  27         re_status_      *regexp.Regexp     = regexp.MustCompile("Status: (closed|opened), (opening|waiting|closing|idle), (ajar|shut).*")
  28         re_button_      *regexp.Regexp     = regexp.MustCompile("PanicButton|button\\d?")
  29         re_temp_        *regexp.Regexp     = regexp.MustCompile("temp0: (\\d+\\.\\d+)")
  30         re_photo_       *regexp.Regexp     = regexp.MustCompile("photo0: (\\d+)")
  31         re_querystresc_ *regexp.Regexp     = regexp.MustCompile("[^\x30-\x39\x41-\x7E]")
  32         spaceapidata    spaceapi.SpaceInfo = spaceapi.NewSpaceInfo("realraum", "http://realraum.at", "http://realraum.at/logo-red_250x250.png", "http://realraum.at/logo-re_open_100x100.png", "http://realraum.at/logo-re_empty_100x100.png",47.065779129, 15.442322614).AddSpaceAddress("Jakoministr. 16 ground level left, 8010 Graz, Austria")
  33         statusstate     *SpaceState        = new(SpaceState)
  34     presence_socket_path_ string
  35         xmpp_presence_events_chan_     chan interface{}
  36     xmpp_login_ struct {jid string; pass string}
  37     xmpp_bot_authstring_ string
  38 )
  39
  40
  41 var flagvar int
  42 func init() {
  43         flag.StringVar(&xmpp_login_.jid, "xjid", "realrauminfo@realraum.at/Tuer", "XMPP Bot Login JID")
  44         flag.StringVar(&xmpp_login_.pass, "xpass", "", "XMPP Bot Login Password")
  45         flag.StringVar(&xmpp_bot_authstring_, "xbotauth", "", "String that user use to authenticate themselves to the bot")
  46         flag.StringVar(&presence_socket_path_,"presencesocket", "/var/run/tuer/presence.socket",  "Path to presence socket")
  47     flag.Parse()
  48 }
  49
  50
  51 //-------
  52
  53 func updateStatusString() {
  54         var spacestatus string
  55         if statusstate.present {
  56                 if statusstate.buttonpress_until > time.Now().Unix() {
  57                         spacestatus = "Panic! Present&Bored"
  58                 } else {
  59                         spacestatus = "Leute Anwesend"
  60                 }
  61         } else {
  62                 spacestatus = "Keiner Da"
  63         }
  64         spaceapidata.SetStatus(statusstate.present, spacestatus)
  65 }
  66
  67 func publishStateToWeb() {
  68         updateStatusString()
  69         jsondata_b, err := spaceapidata.MakeJSON()
  70         if err != nil {
  71                 fmt.Println("Error:", err)
  72                 return
  73         }
  74         //jsondata_b := re_querystresc_.ReplaceAllFunc(jsondata_b, func(in []byte) []byte {
  75         //      out := make([]byte, 4)
  76         //      out[0] = '%'
  77         //      copy(out[1:], []byte(strconv.FormatInt(int64(in[0]), 16)))
  78         //      return out
  79         //})
  80         jsondata := url.QueryEscape(string(jsondata_b))
  81         resp, err := http.Get("http://www.realraum.at/cgi/status.cgi?pass=jako16&set=" + jsondata)
  82         if err != nil {
  83                 fmt.Println("Error publishing realraum info", err)
  84                 return
  85         }
  86         defer resp.Body.Close()
  87 }
  88
  89 func parseSocketInputLine(line string) {
  90         match_presence := re_presence_.FindStringSubmatch(line)
  91         match_status := re_status_.FindStringSubmatch(line)
  92         match_button := re_button_.FindStringSubmatch(line)
  93         match_temp := re_temp_.FindStringSubmatch(line)
  94         match_photo := re_photo_.FindStringSubmatch(line)
  95
  96         if match_presence != nil {
  97                 statusstate.present = (match_presence[1] == "yes")
  98         statusstate.door_locked = (match_presence[2] == "closed")
  99         //spaceapidata.MergeInSensor(spaceapi.MakeDoorLockSensor("Torwaechter", "Front Door", match_presence[2] == "closed"))
 100         spaceapidata.MergeInSensor(spaceapi.MakeDoorLockSensor("TorwaechterLock", "Türschloß", statusstate.door_locked))
 101                 publishStateToWeb()
 102         xmpp_presence_events_chan_ <- r3xmppbot.PresenceEvent{statusstate.present, statusstate.door_locked, statusstate.door_shut}
 103         } else if match_status != nil {
 104         statusstate.door_locked = (match_status[1] == "closed")
 105         statusstate.door_shut = (match_status[3] == "shut")
 106         spaceapidata.MergeInSensor(spaceapi.MakeDoorLockSensor("TorwaechterLock", "Türschloß", statusstate.door_locked))
 107         spaceapidata.MergeInSensor(spaceapi.MakeDoorLockSensor("TorwaechterAjarSensor", "Türkontakt", statusstate.door_shut))
 108         //spaceapidata.MergeInSensor(spaceapi.MakeDoorAjarSensor("Torwaechter", "Front Door", match_presence[3] == "shut"))
 109         publishStateToWeb()
 110         xmpp_presence_events_chan_ <- r3xmppbot.PresenceEvent{statusstate.present, statusstate.door_locked, statusstate.door_shut}
 111         } else if match_button != nil {
 112                 statusstate.buttonpress_until = time.Now().Unix() + 3600
 113                 spaceapidata.AddSpaceEvent("PanicButton", "check-in", "The button has been pressed")
 114                 publishStateToWeb()
 115         xmpp_presence_events_chan_ <- "The button has been pressed ! Propably someone is bored and need company ! ;-)"
 116         } else if match_temp != nil {
 117                 newtemp, err := strconv.ParseFloat((match_temp[1]), 32)
 118                 if err == nil {
 119             spaceapidata.MergeInSensor(spaceapi.MakeTempCSensor("Temp0","Decke",newtemp))
 120                 }
 121         } else if match_photo != nil {
 122                 newphoto, err := strconv.ParseInt(match_photo[1], 10, 32)
 123                 if err == nil {
 124                         spaceapidata.MergeInSensor(spaceapi.MakeIlluminationSensor("Photodiode","Decke","1024V/5V",newphoto))
 125                 }
 126         }
 127 }
 128
 129 func readFromUSocket(path string, c chan string) {
 130 ReOpenSocket:
 131         for {
 132                 presence_socket, err := net.Dial("unix", path)
 133                 if err != nil {
 134                         //Waiting on Socket
 135                         time.Sleep(5 * time.Second)
 136                         continue ReOpenSocket
 137                 }
 138                 presence_reader := bufio.NewReader(presence_socket)
 139                 for {
 140                         line, err := presence_reader.ReadString('\n')
 141                         if err != nil {
 142                                 //Socket closed
 143                                 presence_socket.Close()
 144                                 continue ReOpenSocket
 145                         }
 146                         c <- line
 147                 }
 148         }
 149 }
 150
 151 func main() {
 152         spaceapidata.AddSpaceFeed("calendar", "http://grical.realraum.at/s/?query=!realraum&view=rss")
 153         spaceapidata.AddSpaceFeed("blog", "https://plus.google.com/113737596421797426873")
 154         spaceapidata.AddSpaceFeed("wiki", "http://realraum.at/wiki")
 155         spaceapidata.AddSpaceContactInfo("+43780700888524", "irc://irc.oftc.net/#realraum", "realraum@realraum.at", "realraum@realraum.at", "realraum@realraum.at", "vorstand@realraum.at")
 156
 157     var err error
 158     var bot *r3xmppbot.XmppBot
 159     bot, xmpp_presence_events_chan_, err = r3xmppbot.NewStartedBot(xmpp_login_.jid, xmpp_login_.pass, xmpp_bot_authstring_, true)
 160     if err != nil {
 161         fmt.Println(err)
 162         return
 163     }
 164     defer bot.StopBot()
 165
 166     //~ presence_events <- PresenceEvent{true, true, true}
 167     //~ presence_events <- PresenceEvent{true, true, false}
 168     //~ presence_events <- PresenceEvent{true, false, false}
 169
 170
 171     eventqueue := make(chan string)
 172     defer close(eventqueue)
 173
 174         ticker := time.NewTicker(time.Duration(7) * time.Minute)
 175         go readFromUSocket(presence_socket_path_, eventqueue)
 176         for {
 177                 select {
 178                 case e := <-eventqueue:
 179                         parseSocketInputLine(e)
 180                 case <-ticker.C:
 181                         publishStateToWeb()
 182                 }
 183         }
 184 }
 185
 186 /* TODO:
 187 * Read config from an .ini file
 188  */