61 every interfaces didnt always appears on userspace page (#77)

* Send approx value to decimal attribute choose to avoid discrepancies on large double * Send publish on every topic if not received once * increase timer to have a temporary solution --------- Co-authored-by: Damien Albisson <[email protected]>
Panduza · Jun 26, 2024 · 8084647 · 8084647
1 parent c427770
commit 8084647
Show file tree

Hide file tree

Showing 3 changed files with 30 additions and 9 deletions.
diff --git a/lib/pages/after_setup_pages/userspace_page.dart b/lib/pages/after_setup_pages/userspace_page.dart
@@ -34,6 +34,7 @@ class _UserspacePageState extends State<UserspacePage> {
   Map<int, InterfaceConnection> channel = {}; 
 
   StreamSubscription<List<MqttReceivedMessage<MqttMessage>>>? mqttSubscription;
+  Timer? timer;
 
 
   bool interfaceAlreadyRegistered(InterfaceConnection ic) {
@@ -59,22 +60,33 @@ class _UserspacePageState extends State<UserspacePage> {
   @override
   void dispose() {
     mqttSubscription!.cancel();
+    timer?.cancel();
 
     super.dispose();
   }
 
+  void sendMessageToPza() {
+    MqttClientPayloadBuilder builder = MqttClientPayloadBuilder();
+    builder.addString('*');
+    final payload = builder.payload;
+    try {
+      widget.brokerConnectionInfo.client
+        .publishMessage('pza', MqttQos.atLeastOnce, payload!);
+    } catch(e) {
+      // If publish failed (means the person quitt to fastly the page)
+    }
+  }
+
   @override
   void initState() {
     super.initState();
 
     widget.brokerConnectionInfo.client
           .subscribe('pza/+/+/+/atts/info', MqttQos.atLeastOnce);
 
-    MqttClientPayloadBuilder builder = MqttClientPayloadBuilder();
-    builder.addString('*');
-    final payload = builder.payload;
-    widget.brokerConnectionInfo.client
-        .publishMessage('pza', MqttQos.atLeastOnce, payload!);
+    sendMessageToPza();
+
+    timer = Timer.periodic(Duration(seconds: 2), (Timer t) => sendMessageToPza());
 
     Future.delayed(const Duration(milliseconds: 1), () async {
       // Run your async function here
@@ -130,7 +142,7 @@ class _UserspacePageState extends State<UserspacePage> {
 
     final ic = interfaces[index];
     final type = ic.info["type"];
-    
+
     switch (type) {
       case "blc":
         return IcBlc(ic);

diff --git a/lib/widgets/userspace_widgets/ic_blc.dart b/lib/widgets/userspace_widgets/ic_blc.dart
@@ -206,7 +206,7 @@ class _IcBlcState extends State<IcBlc> {
     super.initState();
 
     // subscribe to info and atts ?
-    Future.delayed(const Duration(milliseconds: 1), initializeMqttSubscription);
+    Future.delayed(const Duration(milliseconds: 500), initializeMqttSubscription);
   }
 
   @override
@@ -259,6 +259,9 @@ class _IcBlcState extends State<IcBlc> {
         if (_currentValueEff != _currentValueReq) {
           MqttClientPayloadBuilder builder = MqttClientPayloadBuilder();
 
+          // Send a current value approx to decimal attribute 
+          _currentValueReq = num.parse(_currentValueReq!.toStringAsFixed(_currentDecimals)).toDouble();
+
           Map<String, dynamic> data = {
             "current": {"value": _currentValueReq!}
           };

diff --git a/lib/widgets/userspace_widgets/ic_bpc.dart b/lib/widgets/userspace_widgets/ic_bpc.dart
@@ -52,7 +52,7 @@ class _IcBpcState extends State<IcBpc> {
             MqttPublishPayload.bytesToStringAsString(recMess.payload.message);
 
         var jsonObject = json.decode(pt);
-        
+
         setState(() {
           for (MapEntry<String, dynamic> atts in jsonObject.entries) {
             for (MapEntry<String, dynamic> field in atts.value.entries) {
@@ -147,7 +147,7 @@ class _IcBpcState extends State<IcBpc> {
     super.initState();
 
     // subscribe to info and atts ?
-    Future.delayed(const Duration(milliseconds: 1), initializeMqttSubscription);
+    Future.delayed(const Duration(milliseconds: 500), initializeMqttSubscription);
   }
 
   @override
@@ -178,6 +178,9 @@ class _IcBpcState extends State<IcBpc> {
         if (_voltageValueEff != _voltageValueReq) {
           MqttClientPayloadBuilder builder = MqttClientPayloadBuilder();
 
+          // Send a voltage value approx to decimal attribute 
+          _voltageValueReq = num.parse(_voltageValueReq!.toStringAsFixed(_voltageDecimal)).toDouble();
+
           Map<String, dynamic> data = {
             "voltage": {"value": _voltageValueReq!}
           };
@@ -195,6 +198,9 @@ class _IcBpcState extends State<IcBpc> {
         if (_currentValueEff != _currentValueReq) {
           MqttClientPayloadBuilder builder = MqttClientPayloadBuilder();
 
+          // Send a current value approx to decimal attribute 
+          _currentValueReq = num.parse(_currentValueReq!.toStringAsFixed(_currentDecimal)).toDouble();
+
           Map<String, dynamic> data = {
             "current": {"value": _currentValueReq!}
           };