Derive clean session property from client id and QoS level (#13)

wnagele · web-flow · commit 9e796bc68765 · 2025-08-28T12:58:25.000-04:00
diff --git a/api/remote/remote.go b/api/remote/remote.go
@@ -35,6 +35,7 @@ func (r *Remote) Run(ctx context.Context) error {
 	if r.Password != "" {
 		opts.SetPassword(r.Password)
 	}
+	opts.SetCleanSession(r.ClientID == "" || r.QoS == 0)
 
 	opts.OnConnect = func(c mqtt.Client) {
 		log.Println("MQTT connected")
diff --git a/main.go b/main.go
@@ -28,7 +28,7 @@ func initConfig() {
 	viper.SetDefault("srv6_net", "fc00::/56")
 	viper.SetDefault("socket_path", "/var/run/galactic/agent.sock")
 	viper.SetDefault("mqtt_url", "tcp://mqtt:1883")
-	viper.SetDefault("mqtt_qos", 0)
+	viper.SetDefault("mqtt_qos", 1)
 	viper.SetDefault("mqtt_topic_receive", "galactic/default/receive")
 	viper.SetDefault("mqtt_topic_send", "galactic/default/send")
 	if configFile != "" {

Original file line number	Diff line number	Diff line change
`@@ -35,6 +35,7 @@ func (r *Remote) Run(ctx context.Context) error {`
`35`	`35`	`if r.Password != "" {`
`36`	`36`	`opts.SetPassword(r.Password)`
`37`	`37`	`}`
	`38`	`+ opts.SetCleanSession(r.ClientID == "" \|\| r.QoS == 0)`
`38`	`39`
`39`	`40`	`opts.OnConnect = func(c mqtt.Client) {`
`40`	`41`	`log.Println("MQTT connected")`