Complete Offline Wallet Display & Edit

mih_ui/lib/mih_hive/hive_adapters.dart

@@ -1,6 +1,7 @@
 // hive_adapters.dart
 import 'package:hive_ce/hive_ce.dart';
 import 'package:mzansi_innovation_hub/mih_objects/app_user.dart';
+import 'package:mzansi_innovation_hub/mih_objects/appointment.dart';
 import 'package:mzansi_innovation_hub/mih_objects/business.dart';
 import 'package:mzansi_innovation_hub/mih_objects/business_employee.dart';
 import 'package:mzansi_innovation_hub/mih_objects/business_user.dart';
@@ -16,5 +17,6 @@ import 'package:mzansi_innovation_hub/mih_objects/user_consent.dart';
   AdapterSpec<ProfileLink>(),
   AdapterSpec<BusinessEmployee>(),
   AdapterSpec<MIHLoyaltyCard>(),
+  AdapterSpec<Appointment>(),
 ])
 part 'hive_adapters.g.dart';

mih_ui/lib/mih_hive/hive_adapters.g.dart

@@ -357,13 +357,14 @@ class MIHLoyaltyCardAdapter extends TypeAdapter<MIHLoyaltyCard> {
       favourite: fields[4] as String,
       priority_index: (fields[5] as num).toInt(),
       nickname: fields[6] as String,
+      offline_id: fields[7] as String?,
     );
   }
 
   @override
   void write(BinaryWriter writer, MIHLoyaltyCard obj) {
     writer
-      ..writeByte(7)
+      ..writeByte(8)
       ..writeByte(0)
       ..write(obj.idloyalty_cards)
       ..writeByte(1)
@@ -377,7 +378,9 @@ class MIHLoyaltyCardAdapter extends TypeAdapter<MIHLoyaltyCard> {
       ..writeByte(5)
       ..write(obj.priority_index)
       ..writeByte(6)
-      ..write(obj.nickname);
+      ..write(obj.nickname)
+      ..writeByte(7)
+      ..write(obj.offline_id);
   }
 
   @override
@@ -390,3 +393,52 @@ class MIHLoyaltyCardAdapter extends TypeAdapter<MIHLoyaltyCard> {
           runtimeType == other.runtimeType &&
           typeId == other.typeId;
 }
+
+class AppointmentAdapter extends TypeAdapter<Appointment> {
+  @override
+  final typeId = 7;
+
+  @override
+  Appointment read(BinaryReader reader) {
+    final numOfFields = reader.readByte();
+    final fields = <int, dynamic>{
+      for (int i = 0; i < numOfFields; i++) reader.readByte(): reader.read(),
+    };
+    return Appointment(
+      idappointments: (fields[0] as num).toInt(),
+      app_id: fields[1] as String,
+      business_id: fields[2] as String,
+      date_time: fields[3] as String,
+      title: fields[4] as String,
+      description: fields[5] as String,
+    );
+  }
+
+  @override
+  void write(BinaryWriter writer, Appointment obj) {
+    writer
+      ..writeByte(6)
+      ..writeByte(0)
+      ..write(obj.idappointments)
+      ..writeByte(1)
+      ..write(obj.app_id)
+      ..writeByte(2)
+      ..write(obj.business_id)
+      ..writeByte(3)
+      ..write(obj.date_time)
+      ..writeByte(4)
+      ..write(obj.title)
+      ..writeByte(5)
+      ..write(obj.description);
+  }
+
+  @override
+  int get hashCode => typeId.hashCode;
+
+  @override
+  bool operator ==(Object other) =>
+      identical(this, other) ||
+      other is AppointmentAdapter &&
+          runtimeType == other.runtimeType &&
+          typeId == other.typeId;
+}

mih_ui/lib/mih_hive/hive_adapters.g.yaml

@@ -1,7 +1,7 @@
 # Generated by Hive CE
 # Manual modifications may be necessary for certain migrations
 # Check in to version control
-nextTypeId: 7
+nextTypeId: 8
 types:
   AppUser:
     typeId: 0
@@ -127,7 +127,7 @@ types:
         index: 7
   MIHLoyaltyCard:
     typeId: 6
-    nextIndex: 7
+    nextIndex: 8
     fields:
       idloyalty_cards:
         index: 0
@@ -143,3 +143,21 @@ types:
         index: 5
       nickname:
         index: 6
+      offline_id:
+        index: 7
+  Appointment:
+    typeId: 7
+    nextIndex: 6
+    fields:
+      idappointments:
+        index: 0
+      app_id:
+        index: 1
+      business_id:
+        index: 2
+      date_time:
+        index: 3
+      title:
+        index: 4
+      description:
+        index: 5

mih_ui/lib/mih_hive/mih_calendar_hive_data.dart

@@ -0,0 +1,33 @@
+import 'package:hive_ce_flutter/hive_ce_flutter.dart';
+import 'package:mzansi_innovation_hub/mih_objects/appointment.dart';
+
+class MihCalendarHiveData {
+  final Box<Appointment> _personalAppointmentBox =
+      Hive.box<Appointment>('personal_calendar_box');
+  final Box<Appointment> _businessAppointmentBox =
+      Hive.box<Appointment>('business_calendar_box');
+
+  List<Appointment> getCachedPersonalAppointments() {
+    final appointments = _personalAppointmentBox.values.toList();
+    appointments.sort((a, b) {
+      final dateA = DateTime.parse(a.date_time);
+      final dateB = DateTime.parse(b.date_time);
+      return dateB.compareTo(dateA);
+    });
+    return appointments;
+  }
+
+  List<Appointment> getCachedBusinessAppointments() {
+    final appointments = _businessAppointmentBox.values.toList();
+    appointments.sort((a, b) {
+      final dateA = DateTime.parse(a.date_time);
+      final dateB = DateTime.parse(b.date_time);
+      return dateB.compareTo(dateA);
+    });
+    return appointments;
+  }
+
+  Future<bool> syncCalendarDataWithServer() async {
+    return false;
+  }
+}

mih_ui/lib/mih_hive/mzansi_wallet_hive_data.dart

@@ -3,12 +3,15 @@ import 'package:ken_logger/ken_logger.dart';
 import 'package:mzansi_innovation_hub/mih_objects/loyalty_card.dart';
 import 'package:mzansi_innovation_hub/mih_providers/mzansi_profile_provider.dart';
 import 'package:mzansi_innovation_hub/mih_services/mih_mzansi_wallet_services.dart';
+import 'package:uuid/uuid.dart';
 
 class MzansiWalletHiveData {
   final Box<MIHLoyaltyCard> _loyaltyCardBox =
       Hive.box<MIHLoyaltyCard>('loyalty_card_box');
   final Box<MIHLoyaltyCard> _favLoyaltyCardBox =
       Hive.box<MIHLoyaltyCard>('fav_loyalty_card_box');
+  final Box<Map> _modificationsQueue =
+      Hive.box<Map>('wallet_modifications_queue');
 
   // Get Offline Data
   List<MIHLoyaltyCard> getCachedLoyaltyCards() {
@@ -19,10 +22,116 @@ class MzansiWalletHiveData {
 
   List<MIHLoyaltyCard> getCachedFavLoyaltyCards() {
     final cards = _favLoyaltyCardBox.values.toList();
-    cards.sort((a, b) => a.shop_name.compareTo(b.shop_name));
+    cards.sort((a, b) => a.priority_index.compareTo(b.priority_index));
     return cards;
   }
 
+  // Set Offline Data
+  Future<void> addLoyaltyCardLocally(MIHLoyaltyCard newCard) async {
+    await _loyaltyCardBox.put(newCard.offline_id, newCard);
+
+    if (newCard.favourite == "Yes") {
+      await _favLoyaltyCardBox.put(newCard.offline_id, newCard);
+    }
+    KenLogger.success("New Card Saved Locally.");
+  }
+
+  Future<void> deleteLoyaltyCardLocally(MIHLoyaltyCard deleteCard) async {
+    dynamic mainTargetKey;
+    dynamic favTargetKey;
+    for (var key in _loyaltyCardBox.keys) {
+      final card = _loyaltyCardBox.get(key);
+      if (card != null) {
+        if (deleteCard.idloyalty_cards != 0 &&
+            card.idloyalty_cards == deleteCard.idloyalty_cards) {
+          mainTargetKey = key;
+          break;
+        } else if (deleteCard.idloyalty_cards == 0 &&
+            card.offline_id == deleteCard.offline_id) {
+          mainTargetKey = key;
+          break;
+        }
+      }
+    }
+    for (var key in _favLoyaltyCardBox.keys) {
+      final card = _favLoyaltyCardBox.get(key);
+      if (card != null) {
+        if (deleteCard.idloyalty_cards != 0 &&
+            card.idloyalty_cards == deleteCard.idloyalty_cards) {
+          favTargetKey = key;
+          break;
+        } else if (deleteCard.idloyalty_cards == 0 &&
+            card.offline_id == deleteCard.offline_id) {
+          favTargetKey = key;
+          break;
+        }
+      }
+    }
+    if (mainTargetKey != null) {
+      await _loyaltyCardBox.delete(mainTargetKey);
+      KenLogger.success("Card Deleted Locally.");
+    }
+    if (favTargetKey != null) {
+      await _favLoyaltyCardBox.delete(favTargetKey);
+      KenLogger.success("Fav Card Deleted Locally.");
+    }
+  }
+
+  Future<void> updateLoyaltyCardLocally(MIHLoyaltyCard updatedCard) async {
+    dynamic mainTargetKey;
+    dynamic favTargetKey;
+    for (var key in _loyaltyCardBox.keys) {
+      final card = _loyaltyCardBox.get(key);
+      if (card != null) {
+        if (updatedCard.idloyalty_cards != 0 &&
+            card.idloyalty_cards == updatedCard.idloyalty_cards) {
+          mainTargetKey = key;
+          break;
+        } else if (updatedCard.idloyalty_cards == 0 &&
+            card.offline_id == updatedCard.offline_id) {
+          mainTargetKey = key;
+          break;
+        }
+      }
+    }
+    for (var key in _favLoyaltyCardBox.keys) {
+      final card = _favLoyaltyCardBox.get(key);
+      if (card != null) {
+        if (updatedCard.idloyalty_cards != 0 &&
+            card.idloyalty_cards == updatedCard.idloyalty_cards) {
+          favTargetKey = key;
+          break;
+        } else if (updatedCard.idloyalty_cards == 0 &&
+            card.offline_id == updatedCard.offline_id) {
+          favTargetKey = key;
+          break;
+        }
+      }
+    }
+    if (mainTargetKey != null) {
+      await _loyaltyCardBox.put(mainTargetKey, updatedCard);
+      KenLogger.success("Card Udpdated Locally.");
+    }
+    if (favTargetKey != null) {
+      if (updatedCard.favourite == "Yes") {
+        await _favLoyaltyCardBox.put(favTargetKey, updatedCard);
+        KenLogger.success("Fav Card Updated Locally.");
+      } else {
+        await _favLoyaltyCardBox.delete(favTargetKey);
+        KenLogger.success("Fav Card Removed Locally.");
+      }
+    } else {
+      if (updatedCard.offline_id == null) {
+        final String uniqueKey = const Uuid().v4();
+        await _favLoyaltyCardBox.put(uniqueKey, updatedCard);
+        KenLogger.success("Fav Card Added Locally.");
+      } else {
+        await _favLoyaltyCardBox.put(updatedCard.offline_id, updatedCard);
+        KenLogger.success("Fav Card Added Locally.");
+      }
+    }
+  }
+
   // Cache data for offline use
   Future<void> cacheFavLoyaltyCardsData(
       List<MIHLoyaltyCard> remoteLoyaltyCards) async {
@@ -51,9 +160,122 @@ class MzansiWalletHiveData {
       cacheFavLoyaltyCardsData(remoteFavLoyaltyCards);
       return true;
     } catch (error) {
-      KenLogger.warning("MIH App Operating in Offline Mode. Sync Paused");
+      KenLogger.warning("MIH App Operating in Offline Mode. Sync Paused.");
       return false;
       // KenLogger.warning("App operating offline mode. Sync paused: $error");
     }
   }
+
+  // Modicfications processing
+  Future<void> queueAddModification(MIHLoyaltyCard newCardData) async {
+    await _modificationsQueue.add({
+      'action': 'ADD',
+      'payload': newCardData,
+    });
+    KenLogger.warning("Add Card Queued For Online Sync");
+  }
+
+  Future<void> queueDeleteModification(MIHLoyaltyCard deleteCardData) async {
+    await _modificationsQueue.add({
+      'action': 'DELETE',
+      'payload': deleteCardData,
+    });
+    KenLogger.warning("Delete Card Queued For Online Sync");
+  }
+
+  Future<void> queueUpdateModification(MIHLoyaltyCard updatedCardData) async {
+    await _modificationsQueue.add({
+      'action': 'UPDATE',
+      'payload': updatedCardData,
+    });
+    KenLogger.warning("Update Card Queued For Online Sync");
+  }
+
+  Future<bool> processModificationsQueue(
+      MzansiProfileProvider profileProvider) async {
+    if (_modificationsQueue.isEmpty) {
+      return true;
+    }
+    final List<dynamic> queueKeys = _modificationsQueue.keys.toList();
+    for (var taskKey in queueKeys) {
+      final task = _modificationsQueue.get(taskKey);
+      if (task == null) {
+        continue;
+      }
+      final String action = task['action'];
+      final MIHLoyaltyCard taskCard = task['payload'];
+      KenLogger.warning(
+          "Card Details: id=${taskCard.idloyalty_cards}, shop=${taskCard.shop_name}, Nunber=${taskCard.card_number}, offline_id=${taskCard.offline_id}");
+      if (action == 'ADD') {
+        dynamic deleteCardTaskKey;
+        for (var entry in _modificationsQueue.toMap().entries) {
+          if (entry.value['action'] == 'DELETE' &&
+              entry.value['payload'].offline_id == taskCard.offline_id) {
+            deleteCardTaskKey = entry.key;
+            break;
+          }
+        }
+
+        if (deleteCardTaskKey != null) {
+          await _modificationsQueue.delete(taskKey); // Remove 'ADD'
+          await _modificationsQueue
+              .delete(deleteCardTaskKey); // Remove 'DELETE'
+          KenLogger.success(
+              "Offline add & delete cancelled out. Queue cleaned.");
+          continue;
+        }
+
+        final responseCode = await MIHMzansiWalletApis.addLoyaltyCardAPICallV2(
+          profileProvider.user!.app_id,
+          taskCard.shop_name,
+          taskCard.card_number,
+          taskCard.favourite,
+          taskCard.priority_index,
+          taskCard.nickname,
+        );
+        if (responseCode != null && responseCode == 201) {
+          await _modificationsQueue.delete(taskKey);
+          KenLogger.success("Add New Local Card to MIH Server");
+        } else {
+          KenLogger.warning("MIH App Operating in Offline Mode. Sync Paused");
+          return false;
+        }
+      }
+      if (action == 'DELETE') {
+        final responseCode =
+            await MIHMzansiWalletApis.deleteLoyaltyCardAPICallV2(
+          taskCard.idloyalty_cards,
+        );
+        if (responseCode != null && responseCode == 200) {
+          await _modificationsQueue.delete(taskKey);
+          KenLogger.success("Delete Local Card from MIH Server");
+        } else {
+          KenLogger.warning("MIH App Operating in Offline Mode. Sync Paused");
+          return false;
+        }
+      }
+      if (action == 'UPDATE') {
+        final responseCode =
+            await MIHMzansiWalletApis.updateLoyaltyCardAPICallV2(
+          taskCard.idloyalty_cards,
+          taskCard.favourite,
+          taskCard.priority_index,
+          taskCard.nickname,
+          taskCard.card_number,
+        );
+        if (responseCode != null && responseCode == 200) {
+          await _modificationsQueue.delete(taskKey);
+          KenLogger.success("Update Local Card from MIH Server");
+        } else {
+          KenLogger.warning("MIH App Operating in Offline Mode. Sync Paused");
+          return false;
+        }
+      }
+    }
+    return true;
+  }
+
+  bool isModificationNotEmpty() {
+    return _modificationsQueue.values.toList().isNotEmpty;
+  }
 }