fix(mqtt): deal with error to get password

This commit is contained in:
leandrofars 2024-05-13 13:31:39 -03:00
parent abf9e92c56
commit 29375417ae

View File

@ -283,6 +283,11 @@ func tcpInfo(conn *net.TCPConn) (*unix.TCPInfo, error) {
} }
func (b *Bridge) setMqttPassword() { 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()) b.Mqtt.Password = string(entry.Value())
} }