From bf000a65c58ebe193dcb64fc8c5c17a05d726cb2 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Leandro=20Ant=C3=B4nio=20Farias=20Machado?= Date: Sun, 7 May 2023 10:55:15 -0300 Subject: [PATCH] chore: page for broker SYS info --- backend/services/mochi/cmd/main.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/backend/services/mochi/cmd/main.go b/backend/services/mochi/cmd/main.go index db3a4b7..bb54dac 100644 --- a/backend/services/mochi/cmd/main.go +++ b/backend/services/mochi/cmd/main.go @@ -38,7 +38,7 @@ func main() { tcpAddr := flag.String("tcp", ":1883", "network address for TCP listener") redisAddr := flag.String("redis", "172.17.0.2:6379", "host address of redis db") wsAddr := flag.String("ws", "", "network address for Websocket listener") - infoAddr := flag.String("info", "", "network address for web info dashboard listener") + infoAddr := flag.String("info", ":8080", "network address for web info dashboard listener") path := flag.String("path", "", "path to data auth file") flag.Parse() @@ -158,8 +158,7 @@ func (h *MyHook) OnDisconnect(cl *mqtt.Client, err error, expire bool) { } if clUser != "" { - sn := strings.Split(clUser, "-") - err := server.Publish("oktopus/disconnect", []byte(sn[1]), false, 1) + err := server.Publish("oktopus/disconnect", []byte(clUser), false, 1) if err != nil { log.Println("server publish error: ", err) }