From 29375417ae272c22e21680ee47b2b79a231bcbb9 Mon Sep 17 00:00:00 2001 From: leandrofars Date: Mon, 13 May 2024 13:31:39 -0300 Subject: [PATCH] fix(mqtt): deal with error to get password --- .../services/mtp/mqtt-adapter/internal/bridge/bridge.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/backend/services/mtp/mqtt-adapter/internal/bridge/bridge.go b/backend/services/mtp/mqtt-adapter/internal/bridge/bridge.go index 487a85e..e90ceae 100644 --- a/backend/services/mtp/mqtt-adapter/internal/bridge/bridge.go +++ b/backend/services/mtp/mqtt-adapter/internal/bridge/bridge.go @@ -283,6 +283,11 @@ func tcpInfo(conn *net.TCPConn) (*unix.TCPInfo, error) { } func (b *Bridge) setMqttPassword() { - entry, _ := b.kv.Get(b.Ctx, b.Mqtt.Username) + entry, err := b.kv.Get(b.Ctx, b.Mqtt.Username) + if err != nil { + log.Printf("Error getting key %s: %v", b.Mqtt.Username, err) + return + } + b.Mqtt.Password = string(entry.Value()) }