58 add debt mgt

FlowHub.DataAccess/IRepositories/IDataAccessRepo.cs

@@ -3,4 +3,5 @@
 public interface IDataAccessRepo
 {
     LiteDatabaseAsync GetDb();
+    void DeleteDB();
 }

FlowHub.DataAccess/IRepositories/IExpendituresRepository.cs

@@ -5,16 +5,15 @@ public interface IExpendituresRepository
     //   Task<List<ExpendituresModel>> GetAllExpendituresAsync();
     event Action OfflineExpendituresListChanged;
     Task<List<ExpendituresModel>> GetAllExpendituresAsync();
-   // List<ExpendituresModel> OnlineExpendituresList { get; set; }
+    // List<ExpendituresModel> OnlineExpendituresList { get; set; }
 
     List<ExpendituresModel> OfflineExpendituresList { get; set; }
- //   Task<List<ExpendituresModel>> GetAllExpFromOnlineAsync(string UserId);
+    //   Task<List<ExpendituresModel>> GetAllExpFromOnlineAsync(string UserId);
     Task<bool> AddExpenditureAsync(ExpendituresModel expenditure);
     Task<bool> UpdateExpenditureAsync(ExpendituresModel expenditure);
     Task<bool> DeleteExpenditureAsync(ExpendituresModel expenditure);
 
     Task SynchronizeExpendituresAsync();
 
     Task DropExpendituresCollection();
-
 }

FlowHub.DataAccess/IRepositories/IIncomeRepository.cs

@@ -4,7 +4,7 @@ public interface IIncomeRepository
 {
     event Action OfflineIncomesListChanged;
     Task<List<IncomeModel>> GetAllIncomesAsync();
-    List<IncomeModel> OfflineIncomesList { get; set ; }
+    List<IncomeModel> OfflineIncomesList { get; set; }
     Task<bool> AddIncomeAsync(IncomeModel income);
     Task<bool> DeleteIncomeAsync(IncomeModel incomeId);
     Task<bool> UpdateIncomeAsync(IncomeModel income);

FlowHub.DataAccess/IRepositories/IUsersRepository.cs

@@ -5,7 +5,7 @@ public interface IUsersRepository
     event Action OfflineUserDataChanged;
     public UsersModel OfflineUser { get; set; }
     public UsersModel OnlineUser { get; set; }
- //   Task<UsersModel> GetUserAsync();
+    //   Task<UsersModel> GetUserAsync();
     Task<UsersModel> GetUserAsync(string UserEmail, string UserPassword);
     Task<UsersModel> GetUserAsync(string UserId);
     Task<UsersModel> GetUserOnlineAsync(UsersModel user);

FlowHub.DataAccess/Platforms/Android/DataAccessRepo.cs

@@ -3,15 +3,35 @@
 // All the code in this file is only included on Android.
 public class DataAccessRepo : IDataAccessRepo
 {
-    LiteDatabaseAsync db ;
+    LiteDatabaseAsync db;
 
     public LiteDatabaseAsync GetDb() //this function returns the path where the db file is saved
     {
         string path;
 
         path = Path.Combine(Environment.GetFolderPath(Environment.SpecialFolder.LocalApplicationData), "SavingTracker.db");
         // string path = Android.OS.Environment.GetExternalStoragePublicDirectory(Android.OS.Environment.DirectoryDocuments).AbsolutePath;
+
         db = new LiteDatabaseAsync(path);
+
         return db;
     }
+    public void DeleteDB()
+    {
+        string path;
+
+        path = Path.Combine(Environment.GetFolderPath(Environment.SpecialFolder.LocalApplicationData), "SavingTracker.db");
+        if (File.Exists(path))
+        {
+            try
+            {
+                File.Delete(path);
+                Debug.WriteLine("File deleted");
+            }
+            catch (IOException e)
+            {
+                Debug.WriteLine(e.Message);
+            }
+        }
+    }
 }

FlowHub.DataAccess/Platforms/Windows/DataAccessRepo.cs

@@ -5,6 +5,12 @@
 public class DataAccessRepo : IDataAccessRepo
 {
     LiteDatabaseAsync db;
+
+    public void DeleteDB()
+    {
+        throw new NotImplementedException();
+    }
+
     public LiteDatabaseAsync GetDb() //this function returns the path where the db file is saved
     {
         string path;

FlowHub.DataAccess/Repositories/DebtRepository.cs

@@ -13,7 +13,7 @@ public class DebtRepository : IDebtRepository
     private readonly IOnlineCredentialsRepository onlineRepository;
     private readonly IUsersRepository usersRepo;
 
-    public List<DebtModel> OfflineDebtList { get ; set ; }
+    public List<DebtModel> OfflineDebtList { get; set; }
     public List<DebtModel> OnlineDebtList { get; set; }
 
     public event Action OfflineDebtListChanged;
@@ -22,7 +22,7 @@ public DebtRepository(IDataAccessRepo dataAccess, IOnlineCredentialsRepository o
     {
         this.dataAccess = dataAccess;
         this.onlineRepository = onlineRepository;
-        this.usersRepo = userRepo;
+        usersRepo = userRepo;
     }
 
     async Task<LiteDatabaseAsync> OpenDB()
@@ -49,6 +49,7 @@ public async Task<List<DebtModel>> GetAllDebtAsync()
                     .Where(x => x.UserId == userId)
                     .OrderByDescending(x => x.UpdateDateTime)
                     .ToListAsync();
+                OfflineDebtList ??= Enumerable.Empty<DebtModel>().ToList();
                 return OfflineDebtList;
             }
         }
@@ -99,7 +100,7 @@ async Task LoadOnlineDB()
                 Debug.WriteLine($"Exception Message {ex.Message}");
             }
         }
-        var filtersDebt= Builders<DebtModel>.Filter.Eq("UserId", usersRepo.OnlineUser.Id) &
+        var filtersDebt = Builders<DebtModel>.Filter.Eq("UserId", usersRepo.OnlineUser.Id) &
             Builders<DebtModel>.Filter.Eq("Currency", usersRepo.OfflineUser.UserCurrency);
 
         AllDebtsOnline ??= DBOnline.GetCollection<DebtModel>(DebtsCollectionName);
@@ -130,15 +131,15 @@ public async Task SynchronizeDebtsAsync()
             Dictionary<string, DebtModel> OnlineDebtDict = OnlineDebtList.ToDictionary(x => x.Id, x => x);
             Dictionary<string, DebtModel> OfflineDebtDict = OfflineDebtList.ToDictionary(x => x.Id, x => x);
 
-            foreach(var itemID in OfflineDebtDict.Keys.Intersect(OnlineDebtDict.Keys))
+            foreach (var itemID in OfflineDebtDict.Keys.Intersect(OnlineDebtDict.Keys))
             {
                 var offlineItem = OfflineDebtDict[itemID];
                 var onlineItem = OnlineDebtDict[itemID];
-                if (offlineItem.UpdateDateTime > onlineItem.UpdateDateTime)
+                if (offlineItem.UpdateDateTime.ToUniversalTime() > onlineItem.UpdateDateTime.ToUniversalTime())
                 {
                     await UpdateDebtOnlineAsync(offlineItem);
                 }
-                else if (offlineItem.UpdateDateTime < onlineItem.UpdateDateTime)
+                else if (offlineItem.UpdateDateTime.ToUniversalTime() < onlineItem.UpdateDateTime.ToUniversalTime())
                 {
                     await UpdateDebtAsync(onlineItem);
                 }
@@ -162,11 +163,12 @@ public async Task SynchronizeDebtsAsync()
         }
         catch (Exception ex)
         {
-            Debug.WriteLine("Sync exception" + ex.Message);
+            Debug.WriteLine("Debts Sync exception" + ex.Message);
         }
     }
     public async Task<bool> AddDebtAsync(DebtModel debt)
     {
+        debt.UpdateDateTime = DateTime.UtcNow;
         try
         {
             using (db = await OpenDB())
@@ -201,9 +203,11 @@ public async Task<bool> AddDebtAsync(DebtModel debt)
     }
     public async Task<bool> UpdateDebtAsync(DebtModel debt)
     {
+        debt.UpdateDateTime = DateTime.UtcNow;
+
         try
         {
-            using(db = await OpenDB())
+            using (db = await OpenDB())
             {
                 if (await AllDebts.UpdateAsync(debt))
                 {
@@ -236,10 +240,11 @@ public async Task<bool> UpdateDebtAsync(DebtModel debt)
     }
     public async Task<bool> DeleteDebtAsync(DebtModel debt)
     {
+        debt.UpdateDateTime = DateTime.UtcNow;
         debt.IsDeleted = true;
         try
         {
-            using(db = await OpenDB())
+            using (db = await OpenDB())
             {
                 if (await AllDebts.UpdateAsync(debt))
                 {
@@ -284,13 +289,11 @@ async Task DeleteDebtOnlineAsync(DebtModel debtItem)
     {
         await AllDebtsOnline.ReplaceOneAsync(debt => debt.Id == debtItem.Id, debtItem);
     }
-    public Task DropDebtCollection()
-    {
-        throw new NotImplementedException();
-    }
-
-    public Task<bool> SynchronizeDebtAsync(string userEmail, string userPassword)
+    public async Task DropDebtCollection()
     {
-        throw new NotImplementedException();
+        await OpenDB();
+        await db.DropCollectionAsync(DebtsCollectionName);
+        db.Dispose();
+        Debug.WriteLine("debts Collection dropped!");
     }
 }