From ef91015005b2e557412f92625132f8a3611afd65 Mon Sep 17 00:00:00 2001 From: Dreaded_X Date: Fri, 16 Sep 2022 18:40:14 +0200 Subject: [PATCH] Initial implementation for listening to philips hue event stream --- go.mod | 2 ++ go.sum | 11 ++++++++ main.go | 78 ++++++++++++++++++++++++++++++++++++++++++++++++++++++--- 3 files changed, 88 insertions(+), 3 deletions(-) diff --git a/go.mod b/go.mod index dea6abb..ff80c66 100644 --- a/go.mod +++ b/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 ) diff --git a/go.sum b/go.sum index 764d1a9..8570765 100644 --- a/go.sum +++ b/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= diff --git a/main.go b/main.go index 82e4775..0a92b6a 100644 --- a/main.go +++ b/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 }