diff options
| author | xengineering <me@xengineering.eu> | 2026-03-27 14:46:04 +0100 |
|---|---|---|
| committer | xengineering <me@xengineering.eu> | 2026-03-27 14:46:04 +0100 |
| commit | ea47c2fd4eb17cc9ce0dc9fbe6f7d325e8be77b2 (patch) | |
| tree | b19a858d67cab60bf0f4be400d332e972aa6a426 /mqtt.go | |
| parent | 0fb9d297871e57372c469c6e8ca2b43813ed1f52 (diff) | |
| parent | 3158a0a132d6af4de78c9be90e45834350cfd414 (diff) | |
| download | sia-server-ea47c2fd4eb17cc9ce0dc9fbe6f7d325e8be77b2.tar sia-server-ea47c2fd4eb17cc9ce0dc9fbe6f7d325e8be77b2.tar.zst sia-server-ea47c2fd4eb17cc9ce0dc9fbe6f7d325e8be77b2.zip | |
Merge branch 'server-version'
This is required to let the client identify the server version.
Diffstat (limited to 'mqtt.go')
| -rw-r--r-- | mqtt.go | 2 |
1 files changed, 2 insertions, 0 deletions
@@ -46,6 +46,7 @@ func (m MQTTMessage) String() string { func MQTTRun(config MQTTConfig, tx chan MQTTMessage, routes ...Route) { mqttServerHealthTopic = fmt.Sprintf("%s/server/health", config.TopicPrefix) + mqttServerVersionTopic := fmt.Sprintf("%s/server/version", config.TopicPrefix) opts := mqtt.NewClientOptions() opts.AddBroker(config.Broker) @@ -54,6 +55,7 @@ func MQTTRun(config MQTTConfig, tx chan MQTTMessage, routes ...Route) { opts.SetOnConnectHandler(func(c mqtt.Client) { log.Printf("Connected to MQTT broker.") c.Publish(mqttServerHealthTopic, QoS1, true, []byte(`good`)) + c.Publish(mqttServerVersionTopic, QoS1, true, []byte(Version())) for _, route := range routes { topic := config.TopicPrefix + "/" + route.Topic |