Initial implementation for listening to philips hue event stream

go.mod

@@ -10,5 +10,7 @@ require (
 
 require (
 	github.com/gorilla/websocket v1.4.2 // indirect
+	github.com/r3labs/sse/v2 v2.8.1 // indirect
 	golang.org/x/net v0.0.0-20200425230154-ff2c4b7c35a0 // indirect
+	gopkg.in/cenkalti/backoff.v1 v1.1.0 // indirect
 )

go.sum

@@ -1,3 +1,4 @@
+github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/eclipse/paho.mqtt.golang v1.3.5 h1:sWtmgNxYM9P2sP+xEItMozsR3w0cqZFlqnNN1bdl41Y=
 github.com/eclipse/paho.mqtt.golang v1.3.5/go.mod h1:eTzb4gxwwyWpqBUHGQZ4ABAV7+Jgm1PklsYT/eo8Hcc=
 github.com/gorilla/websocket v1.4.2 h1:+/TMaTYc4QFitKJxsQ7Yye35DkWvkdLcvGKqM+x0Ufc=
@@ -6,9 +7,19 @@ github.com/joho/godotenv v1.4.0 h1:3l4+N6zfMWnkbPEXKng2o2/MR5mSwTrBih4ZEkkz1lg=
 github.com/joho/godotenv v1.4.0/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4=
 github.com/kelvins/sunrisesunset v0.0.0-20210220141756-39fa1bd816d5 h1:ouekCqYkMw4QXFCaLyYqjBe99/MUW4Qf3DJhCRh1G18=
 github.com/kelvins/sunrisesunset v0.0.0-20210220141756-39fa1bd816d5/go.mod h1:3oZ7G+fb8Z8KF+KPHxeDO3GWpEjgvk/f+d/yaxmDRT4=
+github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/r3labs/sse/v2 v2.8.1 h1:lZH+W4XOLIq88U5MIHOsLec7+R62uhz3bIi2yn0Sg8o=
+github.com/r3labs/sse/v2 v2.8.1/go.mod h1:Igau6Whc+F17QUgML1fYe1VPZzTV6EMCnYktEmkNJ7I=
+github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
+golang.org/x/net v0.0.0-20191116160921-f9c825593386/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
 golang.org/x/net v0.0.0-20200425230154-ff2c4b7c35a0 h1:Jcxah/M+oLZ/R4/z5RzfPzGbPXnVDPkEDtf2JnuxN+U=
 golang.org/x/net v0.0.0-20200425230154-ff2c4b7c35a0/go.mod h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A=
 golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
 golang.org/x/sys v0.0.0-20200323222414-85ca7c5b95cd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
+gopkg.in/cenkalti/backoff.v1 v1.1.0 h1:Arh75ttbsvlpVA7WtVpH4u9h6Zl46xuptxqLxPiSo4Y=
+gopkg.in/cenkalti/backoff.v1 v1.1.0/go.mod h1:J6Vskwqd+OMVJl8C33mmtxTBs2gyzfv7UDAkHu8BrjI=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

main.go

@@ -2,6 +2,8 @@ package main
 
 import (
 	"bytes"
+	"crypto/tls"
+	"encoding/json"
 	"fmt"
 	"net/http"
 	"os"
@@ -9,9 +11,11 @@ import (
 	"strconv"
 	"strings"
 	"syscall"
+	"time"
 
 	MQTT "github.com/eclipse/paho.mqtt.golang"
 	"github.com/joho/godotenv"
+	"github.com/r3labs/sse/v2"
 )
 
 // This is the default message handler, it just prints out the topic and message
@@ -21,7 +25,7 @@ var defaultHandler MQTT.MessageHandler = func(client MQTT.Client, msg MQTT.Messa
 }
 
 type DeviceStatus struct {
-	Name string
+	Name    string
 	Present bool
 }
 
@@ -41,10 +45,23 @@ func presenceHandler(status chan DeviceStatus) func(MQTT.Client, MQTT.Message) {
 }
 
 type Hue struct {
-	ip string
+	ip    string
 	login string
 }
 
+func (hue *Hue) listenForEvents(events chan *sse.Event) {
+	client := sse.NewClient(fmt.Sprintf("https://%s/eventstream/clip/v2", hue.ip))
+	client.Headers["hue-application-key"] = hue.login
+	client.Connection.Transport = &http.Transport{
+		TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
+	}
+
+	err := client.SubscribeChanRaw(events)
+	if err != nil {
+		panic(err)
+	}
+}
+
 func (hue *Hue) updateFlag(id int, value bool) {
 	url := fmt.Sprintf("http://%s/api/%s/sensors/%d/state", hue.ip, hue.login, id)
 
@@ -67,6 +84,38 @@ func (hue *Hue) updateFlag(id int, value bool) {
 	}
 }
 
+type lastEvent struct {
+	LastEvent string `json:"last_event"`
+}
+
+type owner struct {
+	Rid   string `json:"rid"`
+	Rtype string `json:"rtype"`
+}
+
+type Button struct {
+	Button lastEvent `json:"button"`
+	Id     string    `json:"id"`
+	IdV1   string    `json:"id_v1"`
+	Owner  owner     `json:"owner"`
+	Type   string    `json:"type"`
+}
+
+type on struct {
+	On bool `json:"on"`
+}
+
+type typeInfo struct {
+	Type string `json:"type"`
+}
+
+type Event struct {
+	CreationTime time.Time       `json:"creationtime"`
+	Data         []json.RawMessage `json:"data"`
+	ID           string          `json:"id"`
+	Type         string          `json:"type"`
+}
+
 func main() {
 	_ = godotenv.Load()
 
@@ -97,6 +146,8 @@ func main() {
 
 	// @TODO Discover the bridge here
 	hue := Hue{ip: "10.0.0.146", login: login}
+	events := make(chan *sse.Event)
+	hue.listenForEvents(events)
 
 	opts := MQTT.NewClientOptions().AddBroker(fmt.Sprintf("%s:%s", host, port))
 	opts.SetClientID(clientID)
@@ -134,7 +185,7 @@ events:
 				fmt.Println(key, value)
 				if value {
 					temp = true
-					break;
+					break
 				}
 			}
 
@@ -154,6 +205,27 @@ events:
 
 			fmt.Println("Done")
 
+		case message := <-events:
+			events := []Event{}
+			json.Unmarshal(message.Data, &events)
+
+			for _, event := range events {
+				if event.Type == "update" {
+					for _, data := range event.Data {
+						var typeInfo typeInfo
+						json.Unmarshal(data, &typeInfo)
+
+						switch typeInfo.Type {
+						case "button":
+							fmt.Println("Button")
+							var button Button
+							json.Unmarshal(data, &button)
+							fmt.Println(button)
+						}
+					}
+				}
+			}
+
 		case <-halt:
 			break events
 		}