From 4bc034c7ab627c50aba7e2ce4da360c14465c150 Mon Sep 17 00:00:00 2001
From: xengineering <me@xengineering.eu>
Date: Sun, 8 Mar 2026 17:27:52 +0100
Subject: Switch completely to connection state machine

This makes use of the state machine in the UI and implements all states
and transitions planned so far.
---
 lib/data.dart | 40 ++++++++++++++++++++++++----------------
 1 file changed, 24 insertions(+), 16 deletions(-)

(limited to 'lib/data.dart')

diff --git a/lib/data.dart b/lib/data.dart
index 415e61e..eaf301a 100644
--- a/lib/data.dart
+++ b/lib/data.dart
@@ -9,11 +9,17 @@ const String topicPrefix = 'sia';
 enum MachineState {
   init,          // user does not want connection MQTT not connected
   disconnected,  // user wants connection but MQTT not (yet) connected
+  unreachable,   // connected to MQTT broker but Sia server not reachable
+  reachable,     // connected to MQTT and Sia server reachable
 }
 
 enum MachineEvent {
   connect,       // user wants to connect
   disconnect,    // user does not want an connection anymore
+  connected,     // connection to MQTT broker established
+  disconnected,  // connection to MQTT broker lost
+  reachable,     // Sia server is reachable via MQTT
+  unreachable,   // Sia server not reachable via MQTT
 }
 
 class AppState with ChangeNotifier {
@@ -23,16 +29,23 @@ class AppState with ChangeNotifier {
     },
     MachineState.disconnected: <MachineEvent, MachineState> {
       MachineEvent.disconnect: MachineState.init,
+      MachineEvent.connected: MachineState.unreachable,
+    },
+    MachineState.unreachable: <MachineEvent, MachineState> {
+      MachineEvent.disconnect: MachineState.init,
+      MachineEvent.disconnected: MachineState.disconnected,
+      MachineEvent.reachable: MachineState.reachable,
+    },
+    MachineState.reachable: <MachineEvent, MachineState> {
+      MachineEvent.disconnect: MachineState.init,
+      MachineEvent.disconnected: MachineState.disconnected,
+      MachineEvent.unreachable: MachineState.unreachable,
     },
   };
   MachineState state = MachineState.init;
 
   Map<String, bool> contacts = <String, bool>{};
   late MqttServerClient _client;
-  bool _brokerConnected = false;
-  bool get brokerConnected => _brokerConnected;
-  bool _serverConnected = false;
-  bool get serverConnected => _serverConnected;
 
   AppState();
 
@@ -105,23 +118,20 @@ class AppState with ChangeNotifier {
   void _onConnected() {
     _client.subscribe('$topicPrefix/contact/+/state', MqttQos.exactlyOnce);
     _client.subscribe('$topicPrefix/server/health', MqttQos.exactlyOnce);
-    _brokerConnected = true;
-    notifyListeners();
+
+    process(MachineEvent.connected);
   }
 
   void _onDisconnected() {
-    _brokerConnected = false;
-    notifyListeners();
+    process(MachineEvent.disconnected);
   }
 
   void _onAutoReconnect() {
-    _brokerConnected = false;
-    notifyListeners();
+    process(MachineEvent.disconnected);
   }
 
   void _onAutoReconnected() {
-    _brokerConnected = true;
-    notifyListeners();
+    process(MachineEvent.connected);
   }
 
   void _onMessage(List<MqttReceivedMessage<MqttMessage>> messages) {
@@ -135,13 +145,11 @@ class AppState with ChangeNotifier {
 
       if (topic == '$topicPrefix/server/health') {
         if (payload == 'good') {
-          _serverConnected = true;
-          notifyListeners();
+          process(MachineEvent.reachable);
         }
 
         if (payload == 'bad') {
-          _serverConnected = false;
-          notifyListeners();
+          process(MachineEvent.unreachable);
         }
       }
 
-- 
cgit v1.3