Testing again the fix with the timer for #3

CyBear-Jinni · Jun 9, 2021 · 9125d97 · 9125d97
1 parent 968e224
commit 9125d97
Showing 1 changed file with 8 additions and 41 deletions.
diff --git a/...features/smart_device/application/usecases/cloud_value_change_u/cloud_value_change_u.dart b/...features/smart_device/application/usecases/cloud_value_change_u/cloud_value_change_u.dart
@@ -19,6 +19,7 @@ class CloudValueChangeU {
 
   static CloudValueChangeU? _cloudValueChangeU;
   CloudValueChangeE? _cloudValueChangeEntity;
+  StreamSubscription<dynamic>? collectionsStream;
 
   void setNewFirebaseAccounInfo(
       FirebaseAccountsInformationD firebaseAccountsInformationD) {
@@ -72,10 +73,16 @@ class CloudValueChangeU {
     }
 
     listenToCollectionChange();
+
+    Timer.periodic(const Duration(minutes: 1), (Timer t) {
+      listenToCollectionChange();
+    });
   }
 
   Future<void> listenToCollectionChange() async {
-    _cloudValueChangeEntity!
+    await collectionsStream?.cancel();
+
+    collectionsStream = _cloudValueChangeEntity!
         .listenToCollectionDataBase()
         .listen((List<Document> documentList) {
       print('Change detected in Firestore');
@@ -115,44 +122,4 @@ class CloudValueChangeU {
       });
     });
   }
-
-  Future<void> listenToDocumentChange() async {
-    _cloudValueChangeEntity!
-        .listenToDocumentDataBase()
-        .listen((Document? document) {
-      final Document firestoreDocument = document!;
-      print('Change detected to Document Firestore');
-
-      final Map<SmartDeviceBaseAbstract, String> devicesNamesThatValueChanged =
-          <SmartDeviceBaseAbstract, String>{};
-
-      MySingleton.getSmartDevicesList()
-          .forEach((SmartDeviceBaseAbstract element) {
-        if (firestoreDocument.map.containsKey(element.id)) {
-          if (element.getDeviceState() != firestoreDocument.map[element.id]) {
-            devicesNamesThatValueChanged[element] =
-                firestoreDocument.map[element.id].toString();
-          }
-        }
-      });
-
-      devicesNamesThatValueChanged.forEach(
-          (SmartDeviceBaseAbstract smartDeviceBaseAbstract, String value) {
-        print('FireBase "${smartDeviceBaseAbstract.id}" have different value,'
-            ' will now change to $value');
-        DeviceActions deviceAction;
-
-        if (value == DeviceActions.on.toString()) {
-          deviceAction = DeviceActions.on;
-        } else if (value == DeviceActions.off.toString()) {
-          deviceAction = DeviceActions.off;
-        } else {
-          deviceAction = EnumHelper.stringToDeviceActions(value)!;
-        }
-
-        ActionsToPreformU.executeDeviceAction(smartDeviceBaseAbstract,
-            deviceAction, DeviceStateGRPC.waitingInFirebase);
-      });
-    });
-  }
 }