From 58d7c51baa053be8d6d4ec5f409fceef1c7c11b5 Mon Sep 17 00:00:00 2001
From: xengineering <me@xengineering.eu>
Date: Sat, 20 Dec 2025 13:43:31 +0100
Subject: Add MQTT keepalives

This issues ping request / response messages between the Sia server and
the MQTT broker making sure an interrupted connection is noticed.
---
 mqtt.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/mqtt.go b/mqtt.go
index 63e5042..5c1b1ad 100644
--- a/mqtt.go
+++ b/mqtt.go
@@ -15,6 +15,7 @@ const (
 	RETAINED                   = true
 	MQTT_CONNECT_TIMEOUT       = 1 * time.Second
 	MQTT_DISCONNECT_TIMEOUT_US = 500
+	MQTT_KEEPALIVE_PERIOD      = 2 * time.Second
 )
 
 type MQTTMessage struct {
@@ -32,6 +33,7 @@ func MQTTRun(tx chan MQTTMessage) {
 	opts.SetAutoReconnect(true)
 	opts.SetConnectRetry(true)
 	opts.SetConnectTimeout(MQTT_CONNECT_TIMEOUT)
+	opts.SetKeepAlive(MQTT_KEEPALIVE_PERIOD)
 
 	client := mqtt.NewClient(opts)
 
-- 
cgit v1.2.3-70-g09d2