mqtt-gateway v0.5.2

Author: stfnmllr

gateway/cs.go

@@ -2,6 +2,7 @@ package gateway
 
 import (
 	"fmt"
+	"log"
 	"sync"
 
 	"github.com/pico-cs/go-client/client"
@@ -105,7 +106,14 @@ func (cs *CS) unsubscribe() {
 	cs.gateway.unsubscribe(cs, joinTopic("cs", cs.name, "enabled", "set"))
 }
 
-func (cs *CS) pushHandler(msg string) {} // TODO: push messages
+func (cs *CS) pushHandler(msg client.Msg, err error) {
+	// TODO: push messages
+	if err != nil {
+		log.Printf("push message: %s", msg)
+	} else {
+		log.Printf("push message error: %s", err)
+	}
+}
 
 func (cs *CS) getEnabled(client *client.Client) hndFn {
 	return func(payload any) (any, error) {

go.mod

@@ -7,8 +7,8 @@ go 1.19
 
 require (
 	github.com/eclipse/paho.mqtt.golang v1.4.2
-	github.com/pico-cs/go-client v0.2.0
-	golang.org/x/exp v0.0.0-20221212164502-fae10dda9338
+	github.com/pico-cs/go-client v0.2.2
+	golang.org/x/exp v0.0.0-20221217163422-3c43f8badb15
 	gopkg.in/yaml.v3 v3.0.1
 )
 

go.sum

@@ -6,15 +6,15 @@ github.com/eclipse/paho.mqtt.golang v1.4.2/go.mod h1:JGt0RsEwEX+Xa/agj90YJ9d9DH2
 github.com/gorilla/websocket v1.4.2/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
 github.com/gorilla/websocket v1.5.0 h1:PPwGk2jz7EePpoHN/+ClbZu8SPxiqlu12wZP/3sWmnc=
 github.com/gorilla/websocket v1.5.0/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
-github.com/pico-cs/go-client v0.2.0 h1:6V1zrNsavnnStYYTLjBY7m8LtB5/MECAHqDheoX0lCA=
-github.com/pico-cs/go-client v0.2.0/go.mod h1:4Z8xyRjxNujQrxWQsmZp+kq9JyU7vFonXwm44KpeR84=
+github.com/pico-cs/go-client v0.2.2 h1:y682p6Gbs51qHYAFUctIzz/xoQrkB3D174Uz78BS+J0=
+github.com/pico-cs/go-client v0.2.2/go.mod h1:ty2wUvjX3bS2gK/dgpGFOjBUFwijDvX+WnHFB5wVKQg=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/stretchr/testify v1.7.0 h1:nwc3DEeHmmLAfoZucVR881uASk0Mfjw8xYJ99tb5CcY=
 go.bug.st/serial v1.4.1 h1:AwYUNixVf90XymNeJaUkMrPp+GZQe3RMFQmpVdHIUK8=
 go.bug.st/serial v1.4.1/go.mod h1:z8CesKorE90Qr/oRSJiEuvzYRKol9r/anJZEb5kt304=
 golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
-golang.org/x/exp v0.0.0-20221212164502-fae10dda9338 h1:OvjRkcNHnf6/W5FZXSxODbxwD+X7fspczG7Jn/xQVD4=
-golang.org/x/exp v0.0.0-20221212164502-fae10dda9338/go.mod h1:CxIveKay+FTh1D0yPZemJVgC/95VzuuOLq5Qi4xnoYc=
+golang.org/x/exp v0.0.0-20221217163422-3c43f8badb15 h1:5oN1Pz/eDhCpbMbLstvIPa0b/BEQo6g6nwV3pLjfM6w=
+golang.org/x/exp v0.0.0-20221217163422-3c43f8badb15/go.mod h1:CxIveKay+FTh1D0yPZemJVgC/95VzuuOLq5Qi4xnoYc=
 golang.org/x/net v0.0.0-20200425230154-ff2c4b7c35a0/go.mod h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A=
 golang.org/x/net v0.4.0 h1:Q5QPcMlvfxFTAPV0+07Xz/MpK9NTXu2VDUuy0FeMfaU=
 golang.org/x/net v0.4.0/go.mod h1:MBQ8lrhLObU/6UmLb4fmbmk5OcyYmqtbGd/9yIeKjEE=