r3-webstatus-spaceapi/main.go

   1 package main
   2
   3 import (
   4         "./spaceapi"
   5         "bufio"
   6         "fmt"
   7         "net"
   8         "net/http"
   9         "net/url"
  10         "regexp"
  11         "time"
  12     "strconv"
  13 )
  14
  15 type SpaceState struct {
  16         present           bool
  17         buttonpress_until int64
  18 }
  19
  20 var (
  21         re_presence_    *regexp.Regexp     = regexp.MustCompile("Presence: (yes|no)(?:, (opened|closed), (.+))?")
  22         re_status_      *regexp.Regexp     = regexp.MustCompile("Status: (closed|opened), (opening|waiting|closing|idle), (ajar|shut).*")
  23         re_button_      *regexp.Regexp     = regexp.MustCompile("PanicButton|button\\d?")
  24         re_temp_        *regexp.Regexp     = regexp.MustCompile("temp0: (\\d+\\.\\d+)")
  25         re_photo_       *regexp.Regexp     = regexp.MustCompile("photo0: (\\d+)")
  26         re_querystresc_ *regexp.Regexp     = regexp.MustCompile("[^\x30-\x39\x41-\x7E]")
  27         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")
  28         statusstate     *SpaceState        = new(SpaceState)
  29 )
  30
  31 //-------
  32
  33 func updateStatusString() {
  34         var spacestatus string
  35         if statusstate.present {
  36                 if statusstate.buttonpress_until > time.Now().Unix() {
  37                         spacestatus = "Panic! Present&Bored"
  38                 } else {
  39                         spacestatus = "Leute Anwesend"
  40                 }
  41         } else {
  42                 spacestatus = "Keiner Da"
  43         }
  44         spaceapidata.SetStatus(statusstate.present, spacestatus)
  45 }
  46
  47 func publishStateToWeb() {
  48         updateStatusString()
  49         jsondata_b, err := spaceapidata.MakeJSON()
  50         if err != nil {
  51                 fmt.Println("Error:", err)
  52                 return
  53         }
  54         //jsondata_b := re_querystresc_.ReplaceAllFunc(jsondata_b, func(in []byte) []byte {
  55         //      out := make([]byte, 4)
  56         //      out[0] = '%'
  57         //      copy(out[1:], []byte(strconv.FormatInt(int64(in[0]), 16)))
  58         //      return out
  59         //})
  60         jsondata := url.QueryEscape(string(jsondata_b))
  61         resp, err := http.Get("http://www.realraum.at/cgi/status.cgi?pass=jako16&set=" + jsondata)
  62         if err != nil {
  63                 fmt.Println("Error publishing realraum info", err)
  64                 return
  65         }
  66         defer resp.Body.Close()
  67 }
  68
  69 func parseSocketInputLine(line string) {
  70         match_presence := re_presence_.FindStringSubmatch(line)
  71         match_status := re_status_.FindStringSubmatch(line)
  72         match_button := re_button_.FindStringSubmatch(line)
  73         match_temp := re_temp_.FindStringSubmatch(line)
  74         match_photo := re_photo_.FindStringSubmatch(line)
  75
  76         if match_presence != nil {
  77                 statusstate.present = (match_presence[1] == "yes")
  78         //spaceapidata.MergeInSensor(spaceapi.MakeDoorLockSensor("Torwaechter", "Front Door", match_presence[2] == "closed"))
  79         spaceapidata.MergeInSensor(spaceapi.MakeDoorLockSensor("TorwaechterLock", "Türschloß", match_presence[2] == "closed"))
  80                 publishStateToWeb()
  81         } else if match_status != nil {
  82         spaceapidata.MergeInSensor(spaceapi.MakeDoorLockSensor("TorwaechterLock", "Türschloß", match_status[1] == "closed"))
  83         spaceapidata.MergeInSensor(spaceapi.MakeDoorLockSensor("TorwaechterAjarSensor", "Türkontakt", match_status[3] == "shut"))
  84         //spaceapidata.MergeInSensor(spaceapi.MakeDoorAjarSensor("Torwaechter", "Front Door", match_presence[3] == "shut"))
  85         } else if match_button != nil {
  86                 statusstate.buttonpress_until = time.Now().Unix() + 3600
  87                 spaceapidata.AddSpaceEvent("PanicButton", "check-in", "The button has been pressed")
  88                 publishStateToWeb()
  89         } else if match_temp != nil {
  90                 newtemp, err := strconv.ParseFloat((match_temp[1]), 32)
  91                 if err == nil {
  92             spaceapidata.MergeInSensor(spaceapi.MakeTempCSensor("Temp0","Decke",newtemp))
  93                 }
  94         } else if match_photo != nil {
  95                 newphoto, err := strconv.ParseInt(match_photo[1], 10, 32)
  96                 if err == nil {
  97                         spaceapidata.MergeInSensor(spaceapi.MakeIlluminationSensor("Photodiode","Decke","1024V/5V",newphoto))
  98                 }
  99         }
 100 }
 101
 102 func readFromUSocket(path string, c chan string) {
 103 ReOpenSocket:
 104         for {
 105                 presence_socket, err := net.Dial("unix", path)
 106                 if err != nil {
 107                         //Waiting on Socket
 108                         time.Sleep(5 * time.Second)
 109                         continue ReOpenSocket
 110                 }
 111                 presence_reader := bufio.NewReader(presence_socket)
 112                 for {
 113                         line, err := presence_reader.ReadString('\n')
 114                         if err != nil {
 115                                 //Socket closed
 116                                 presence_socket.Close()
 117                                 continue ReOpenSocket
 118                         }
 119                         c <- line
 120                 }
 121         }
 122 }
 123
 124 func main() {
 125         spaceapidata.AddSpaceFeed("calendar", "application/rss+xml", "http://grical.realraum.at/s/?query=!realraum&view=rss")
 126         spaceapidata.AddSpaceFeed("google+", "text/html", "https://plus.google.com/113737596421797426873")
 127         spaceapidata.AddSpaceContactInfo("+43780700888524", "irc://irc.oftc.net/#realraum", "realraum@realraum.at", "realraum@realraum.at", "realraum@realraum.at", "vorstand@realraum.at")
 128         eventqueue := make(chan string)
 129         ticker := time.NewTicker(time.Duration(7) * time.Minute)
 130         go readFromUSocket("/var/run/tuer/presence.socket", eventqueue)
 131         for {
 132                 select {
 133                 case e := <-eventqueue:
 134                         parseSocketInputLine(e)
 135                 case <-ticker.C:
 136                         publishStateToWeb()
 137                 }
 138         }
 139 }
 140
 141 /* TODO:
 142 * Read config from an .ini file
 143  */