MQTT: fix missing birth message on reconnect

toxuin · toxuin · commit c17b7ce6fa03 · 2022-09-20T15:34:45.000-06:00
diff --git a/buses/mqtt/mqtt.go b/buses/mqtt/mqtt.go
@@ -31,6 +31,7 @@ func (mqtt *Bus) Initialize(config config.MqttConfig) {
 
 	mqttOpts.OnConnect = func(client MQTT.Client) {
 		fmt.Printf("MQTT: CONNECTED TO %s\n", config.Server)
+		mqtt.SendMessage(config.TopicRoot+"/alarmserver", `{ "status": "up" }`)
 	}
 
 	mqttOpts.SetConnectionLostHandler(func(client MQTT.Client, err error) {
@@ -50,8 +51,6 @@ func (mqtt *Bus) Initialize(config config.MqttConfig) {
 	if token := mqtt.client.Connect(); token.Wait() && token.Error() != nil {
 		panic(token.Error())
 	}
-
-	mqtt.SendMessage(config.TopicRoot+"/alarmserver", `{ "status": "up" }`)
 }
 
 func (mqtt *Bus) SendMessage(topic string, payload interface{}) {

Original file line number	Diff line number	Diff line change
`@@ -31,6 +31,7 @@ func (mqtt *Bus) Initialize(config config.MqttConfig) {`
`31`	`31`
`32`	`32`	`mqttOpts.OnConnect = func(client MQTT.Client) {`
`33`	`33`	`fmt.Printf("MQTT: CONNECTED TO %s\n", config.Server)`
	`34`	+ mqtt.SendMessage(config.TopicRoot+"/alarmserver", `{ "status": "up" }`)
`34`	`35`	`}`
`35`	`36`
`36`	`37`	`mqttOpts.SetConnectionLostHandler(func(client MQTT.Client, err error) {`
`@@ -50,8 +51,6 @@ func (mqtt *Bus) Initialize(config config.MqttConfig) {`
`50`	`51`	`if token := mqtt.client.Connect(); token.Wait() && token.Error() != nil {`
`51`	`52`	`panic(token.Error())`
`52`	`53`	`}`
`53`		`-`
`54`		- mqtt.SendMessage(config.TopicRoot+"/alarmserver", `{ "status": "up" }`)
`55`	`54`	`}`
`56`	`55`
`57`	`56`	`func (mqtt *Bus) SendMessage(topic string, payload interface{}) {`