add last will and comment disconnect

pkg/mqtt/client.go

@@ -68,10 +68,11 @@ func NewClient(options *ClientOptions) Client {
 	}
 	mqttOptions := mqtt.NewClientOptions().
 		AddBroker(options.MqttUrl).
-		SetClientID("digitalstrom-mqtt-" + uuid.New().String()).
+		SetClientID("digitalstrom-mqtt-"+uuid.New().String()).
 		SetOrderMatters(false).
 		SetUsername(options.Username).
 		SetPassword(options.Password).
+		SetWill(serverStatus, Offline, QOS, true).
 		SetAutoReconnect(true).
 		SetReconnectingHandler(func(client mqtt.Client, opts *mqtt.ClientOptions) {
 			log.Info().Str("url", options.MqttUrl).Msg("Reconnecting to MQTT server.")
@@ -119,10 +120,10 @@ func (c *client) Connect() error {
 }
 
 func (c *client) Disconnect() error {
-	log.Info().Msg("Publishing Offline status to MQTT server.")
-	if err := c.publishServerStatus(Offline); err != nil {
-		return err
-	}
+	//log.Info().Msg("Publishing Offline status to MQTT server.")
+	//if err := c.publishServerStatus(Offline); err != nil {
+	//	return err
+	//}
 	c.mqttClient.Disconnect(uint(c.options.DisconnectTimeout.Milliseconds()))
 	log.Info().Msg("Disconnected from MQTT server.")
 	return nil