feat: support for caching of objects properly

Author: nickelskevin

flutter/iot_receiver/ios/Podfile.lock

@@ -127,7 +127,7 @@ SPEC CHECKSUMS:
   DKImagePickerController: b512c28220a2b8ac7419f21c491fc8534b7601ac
   DKPhotoGallery: fdfad5125a9fdda9cc57df834d49df790dbb4179
   file_picker: 817ab1d8cd2da9d2da412a417162deee3500fc95
-  Flutter: 50d75fe2f02b26cc09d224853bb45737f8b3214a
+  Flutter: f04841e97a9d0b0a8025694d0796dd46242b2854
   flutter_keychain: 01aabf894ffe8b01adfda1d9df21c210c1b4b452
   MTBBarcodeScanner: f453b33c4b7dfe545d8c6484ed744d55671788cb
   package_info_plus: 6c92f08e1f853dc01228d6f553146438dafcd14e

flutter/iot_receiver/lib/main.dart

@@ -42,8 +42,8 @@ Future<AtClientPreference> loadAtClientPreference() async {
     ..hiveStoragePath = dir.path
     ..commitLogPath = dir.path
     ..isLocalStoreRequired = true
-    ..syncIntervalMins = 1;
-  // ..fetchOfflineNotifications = true;
+    ..syncIntervalMins = 1
+    ..fetchOfflineNotifications = true;
 }
 
 class MyApp extends StatefulWidget {

flutter/iot_receiver/lib/screens/device_owners_screen.dart

@@ -21,7 +21,7 @@ class _DeviceOwnersScreenState extends State<DeviceOwnersScreen> {
 
   @override
   Widget build(BuildContext context) {
-    _hrO2DataService.getDeviceOwners();
+    // _hrO2DataService.getDeviceOwners();
     return Scaffold(
       appBar: NewGradientAppBar(
         title: const AutoSizeText(

flutter/iot_receiver/lib/services/hro2_data_service.dart

@@ -41,10 +41,11 @@ class Hro2DataService {
 
   Future<List<HrO2Device>> getDevices() async {
     List<HrO2Device> hrO2DeviceList = [];
-    // var atClient = AtClientManager.getInstance().atClient;
     var keys = await AtClientManager.getInstance()
         .atClient
         .getAtKeys(regex: AppConstants.deviceKey);
+    _logger.info('getDevices keys ${keys.toString()}');
+
     for (var element in keys) {
       var data = await AtClientManager.getInstance().atClient.get(element);
       _logger.info('getDevices got ${data.value}');
@@ -113,8 +114,12 @@ class Hro2DataService {
   }
 
   Future<bool> putReceiver(HrO2Receiver hrO2Receiver) async {
+    Metadata metadata = Metadata()
+      // ..ttl = 10000
+      ..ttr = -1;
     AtKey atKey = AtKey()
       ..sharedWith = hrO2Receiver.receiverAtsign
+      ..metadata = metadata
       ..key = AppConstants.receiverKey;
     var value = jsonEncode(hrO2Receiver);
     var success =
@@ -149,7 +154,8 @@ class Hro2DataService {
     List<HrO2DataOwner> hrO2DataOwnerList = [];
     var keys = await AtClientManager.getInstance()
         .atClient
-        .getAtKeys(regex: AppConstants.dataOwnerKey, sharedBy: "@mwcmanager");
+        .getAtKeys(regex: AppConstants.dataOwnerKey);
+    _logger.info('getDataOwners keys $keys');
     for (var element in keys) {
       var data = await AtClientManager.getInstance().atClient.get(element);
       _logger.info('getDataOwners got ${data.value}');
@@ -160,16 +166,20 @@ class Hro2DataService {
       } catch (error) {
         // found some dirty data, consider deleting
         _logger.severe('getDataOwners error $error for ${element.key}');
-        await AtClientManager.getInstance().atClient.delete(element);
+        // await AtClientManager.getInstance().atClient.delete(element);
       }
     }
     return hrO2DataOwnerList;
   }
 
   Future<bool> putDataOwner(HrO2DataOwner hrO2DataOwner) async {
-    AtClientManager.getInstance().syncService.sync();
+    // AtClientManager.getInstance().syncService.sync();
+    Metadata metadata = Metadata()
+      // ..ttl = 10000
+      ..ttr = -1;
     AtKey atKey = AtKey()
       ..sharedWith = hrO2DataOwner.dataOwnerAtsign
+      ..metadata = metadata
       ..key = AppConstants.dataOwnerKey;
     var success = await AtClientManager.getInstance()
         .atClient
@@ -225,8 +235,12 @@ class Hro2DataService {
   }
 
   Future<bool> putDeviceOwner(HrO2DeviceOwner hrO2DeviceOwner) async {
+    Metadata metadata = Metadata()
+      // ..ttl = 10000
+      ..ttr = -1;
     AtKey atKey = AtKey()
       ..key = AppConstants.deviceOwnerKey
+      ..metadata = metadata
       ..sharedWith = hrO2DeviceOwner.deviceOwnerAtsign;
     var response = await AtClientManager.getInstance()
         .atClient
@@ -255,27 +269,40 @@ class Hro2DataService {
   }
 
   Future<bool> updateDeviceReceivers(HrO2Device hrO2Device) async {
-    // update the device list of HrO2Receiver objects
+    // update the device list of recipients from HrO2Receiver objects
+    Metadata metadata = Metadata()
+      // ..ttl = 10000
+      ..ttr = -1;
     AtKey atKey = AtKey()
       ..sharedWith = hrO2Device.deviceAtsign
+      ..metadata = metadata
       ..key = AppConstants.receiverListKey;
     List<HrO2Receiver> receiverList = await getReceivers();
     var success = await AtClientManager.getInstance()
         .atClient
         .put(atKey, jsonEncode(receiverList));
+    _logger.info('updateDeviceReceivers key = $atKey');
+    _logger.info(
+        'updateDeviceReceivers receiverList = ${jsonEncode(receiverList)}');
     _logger.info('updateDeviceReceivers success = $success');
     return success;
   }
 
   Future<bool> updateDeviceDataOwners(HrO2Device hrO2Device) async {
-    // update the device list of HrO2DataOwner objects
+    // update the device list of recipients from HrO2DataOwner objects
+    Metadata metadata = Metadata()
+      // ..ttl = 10000
+      ..ttr = -1;
     AtKey atKey = AtKey()
       ..sharedWith = hrO2Device.deviceAtsign
+      ..metadata = metadata
       ..key = AppConstants.dataOwnerListKey;
     List<HrO2DataOwner> owners = await getDataOwners();
+    _logger.info('updateDeviceDataOwners found = ${owners.toString()}');
     var success = await AtClientManager.getInstance()
         .atClient
         .put(atKey, jsonEncode(owners));
+    _logger.info('updateDeviceDataOwners key = $atKey');
     _logger.info('updateDeviceDataOwners success = $success');
     return success;
   }