home/diun
2
0
Fork 0
mirror of https://github.com/wahyd4/diun.git synced 2026-08-09 05:16:03 +10:00
Code Issues Packages Projects Releases Wiki Activity

MQTT Reconnection Log Spam (#240) (#241)

Browse Source
This commit is contained in:
aschoelzhorn
2020-12-16 08:06:30 +00:00
committed by GitHub
parent cbb2eb05bd
commit 3543bbf454
1 changed files with 12 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/notif/mqtt/client.go
+12 -7
View File
@@ -16,9 +16,10 @@ import (
// Client represents an active mqtt notification object
type Client struct {
*notifier.Notifier
cfg *model.NotifMqtt
meta model.Meta
logger zerolog.Logger
cfg *model.NotifMqtt
meta model.Meta
logger zerolog.Logger
mqttClient MQTT.Client
}
// New creates a new mqtt notification instance
@@ -54,9 +55,13 @@ func (c *Client) Send(entry model.NotifEntry) error {
opts.Username = username
opts.Password = password
var client = MQTT.NewClient(opts)
if token := client.Connect(); token.Wait() && token.Error() != nil {
return token.Error()
if c.mqttClient == nil {
c.mqttClient = MQTT.NewClient(opts)
}
if !c.mqttClient.IsConnected() {
if token := c.mqttClient.Connect(); token.Wait() && token.Error() != nil {
return token.Error()
}
}
message, err := json.Marshal(struct {
@@ -84,7 +89,7 @@ func (c *Client) Send(entry model.NotifEntry) error {
return err
}
token := client.Publish(c.cfg.Topic, byte(c.cfg.QoS), false, message)
token := c.mqttClient.Publish(c.cfg.Topic, byte(c.cfg.QoS), false, message)
token.Wait()
return token.Error()
}