Add activity logging across app

agil3st · agil3st · commit 9cd13dd279ce · 2025-11-15T22:24:11.000+07:00
diff --git a/lib/core/database/pockaw_database.dart b/lib/core/database/pockaw_database.dart
@@ -175,6 +175,7 @@ class AppDatabase extends _$AppDatabase {
   Future<void> _deleteAllUsers() => delete(users).go();
   Future<void> _deleteAllWallets() => delete(wallets).go();
   Future<void> _deleteAllCategories() => delete(categories).go();
+  Future<void> _deleteAllUserActivities() => delete(userActivities).go();
 
   /// Clears all data from all tables in the correct order to respect foreign key constraints.
   Future<void> clearAllTables() async {
@@ -188,6 +189,7 @@ class AppDatabase extends _$AppDatabase {
       await _deleteAllUsers(); // Users table has no incoming FKs from other tables
       await _deleteAllWallets();
       await _deleteAllCategories();
+      await _deleteAllUserActivities();
     });
     Log.i('All database tables cleared.', label: 'database');
   }
diff --git a/lib/features/authentication/presentation/riverpod/auth_provider.dart b/lib/features/authentication/presentation/riverpod/auth_provider.dart
@@ -152,6 +152,10 @@ class AuthNotifier extends Notifier<UserModel> {
               .read(activeWalletProvider.notifier)
               .setActiveWalletByID(wallet.id);
         }
+
+        ref
+            .read(userActivityServiceProvider)
+            .logActivity(action: UserActivityAction.signIn);
       } else {
         await _setSession();
         final currencyNotifier = ref.read(currenciesStaticProvider.notifier);
@@ -170,12 +174,11 @@ class AuthNotifier extends Notifier<UserModel> {
         int walletID = await db.walletDao.addWallet(wallet);
         Log.d(wallet.toJson(), label: 'selected wallet');
         ref.read(activeWalletProvider.notifier).setActiveWalletByID(walletID);
-      }
 
-      /// log user journey started
-      await ref
-          .read(userActivityServiceProvider)
-          .logActivity(action: UserActivityAction.journeyStarted);
+        ref
+            .read(userActivityServiceProvider)
+            .logActivity(action: UserActivityAction.journeyStarted);
+      }
 
       // Navigate to main screen
       if (context.mounted) {
diff --git a/lib/features/budget/presentation/screens/budget_form_screen.dart b/lib/features/budget/presentation/screens/budget_form_screen.dart
@@ -24,6 +24,8 @@ import 'package:pockaw/features/budget/presentation/riverpod/budget_providers.da
 import 'package:pockaw/features/budget/presentation/riverpod/date_picker_provider.dart'
     as budget_date_provider; // Alias to avoid conflict
 import 'package:pockaw/features/category/data/model/category_model.dart';
+import 'package:pockaw/features/user_activity/data/enum/user_activity_action.dart';
+import 'package:pockaw/features/user_activity/riverpod/user_activity_provider.dart';
 import 'package:pockaw/features/wallet/data/model/wallet_model.dart';
 import 'package:pockaw/features/wallet/riverpod/wallet_providers.dart';
 import 'package:toastification/toastification.dart';
@@ -181,6 +183,16 @@ class BudgetFormScreen extends HookConsumerWidget {
           await budgetDao.addBudget(budgetToSave);
           Toast.show('Budget created!', type: ToastificationType.success);
         }
+
+        ref
+            .read(userActivityServiceProvider)
+            .logActivity(
+              action: isEditing
+                  ? UserActivityAction.budgetUpdated
+                  : UserActivityAction.budgetCreated,
+              subjectId: budgetToSave.id,
+            );
+
         if (context.mounted) context.pop();
       } catch (e) {
         Log.e('Failed to save budget: $e');
@@ -214,6 +226,14 @@ class BudgetFormScreen extends HookConsumerWidget {
                     context.pop(); // close detail screen
 
                     ref.read(budgetDaoProvider).deleteBudget(budgetId!);
+
+                    ref
+                        .read(userActivityServiceProvider)
+                        .logActivity(
+                          action: UserActivityAction.budgetDeleted,
+                          subjectId: budgetId,
+                        );
+
                     Toast.show('Budget deleted!');
                   },
                 ),
diff --git a/lib/features/category/presentation/riverpod/category_form_service.dart b/lib/features/category/presentation/riverpod/category_form_service.dart
@@ -9,6 +9,8 @@ import 'package:pockaw/core/utils/logger.dart';
 import 'package:pockaw/features/category/data/model/category_model.dart';
 import 'package:pockaw/features/category/presentation/riverpod/category_actions_provider.dart';
 import 'package:pockaw/features/category/presentation/riverpod/category_providers.dart';
+import 'package:pockaw/features/user_activity/data/enum/user_activity_action.dart';
+import 'package:pockaw/features/user_activity/riverpod/user_activity_provider.dart';
 import 'package:toastification/toastification.dart';
 
 class CategoryFormService {
@@ -49,17 +51,27 @@ class CategoryFormService {
       ); // Use upsert for create/update
 
       Log.d(row, label: 'row affected');
+
+      ref
+          .read(userActivityServiceProvider)
+          .logActivity(
+            action: categoryModel.id == null
+                ? UserActivityAction.categoryCreated
+                : UserActivityAction.categoryUpdated,
+            subjectId: categoryModel.id,
+          );
+
       // Clear the selected parent state after saving
       ref.read(selectedParentCategoryProvider.notifier).clear();
       if (!context.mounted) return;
       context.pop(); // Go back after successful save
     } catch (e) {
       // Handle database save errors
       if (!context.mounted) return;
-      toastification.show(
-        context: context, // optional if you use ToastificationWrapper
-        title: Text('Failed to save category: $e'),
-        autoCloseDuration: const Duration(seconds: 5),
+
+      Toast.show(
+        'Failed to save category',
+        type: ToastificationType.error,
       );
     }
   }
@@ -80,5 +92,12 @@ class CategoryFormService {
 
     // Then delete the main category
     actions.delete(categoryModel.id ?? 0);
+
+    ref
+        .read(userActivityServiceProvider)
+        .logActivity(
+          action: UserActivityAction.categoryDeleted,
+          subjectId: categoryModel.id,
+        );
   }
 }
diff --git a/lib/features/goal/presentation/services/goal_form_service.dart b/lib/features/goal/presentation/services/goal_form_service.dart
@@ -8,6 +8,8 @@ import 'package:pockaw/features/goal/data/model/checklist_item_model.dart';
 import 'package:pockaw/features/goal/data/model/goal_model.dart';
 import 'package:pockaw/features/goal/presentation/riverpod/checklist_actions_provider.dart';
 import 'package:pockaw/features/goal/presentation/riverpod/goals_actions_provider.dart';
+import 'package:pockaw/features/user_activity/data/enum/user_activity_action.dart';
+import 'package:pockaw/features/user_activity/riverpod/user_activity_provider.dart';
 
 class GoalFormService {
   Future<void> save(
@@ -53,6 +55,15 @@ class GoalFormService {
       );
     }
 
+    ref
+        .read(userActivityServiceProvider)
+        .logActivity(
+          action: isEditing
+              ? UserActivityAction.goalUpdated
+              : UserActivityAction.goalCreated,
+          subjectId: goal.id,
+        );
+
     if (!context.mounted) return;
     context.pop();
   }
diff --git a/lib/features/settings/presentation/screens/personal_details_screen.dart b/lib/features/settings/presentation/screens/personal_details_screen.dart
@@ -13,6 +13,8 @@ import 'package:pockaw/core/constants/app_colors.dart';
 import 'package:pockaw/core/constants/app_spacing.dart';
 import 'package:pockaw/core/services/image_service/image_service.dart';
 import 'package:pockaw/features/authentication/presentation/riverpod/auth_provider.dart';
+import 'package:pockaw/features/user_activity/data/enum/user_activity_action.dart';
+import 'package:pockaw/features/user_activity/riverpod/user_activity_provider.dart';
 import 'package:toastification/toastification.dart';
 
 class PersonalDetailsScreen extends HookConsumerWidget {
@@ -142,6 +144,10 @@ class PersonalDetailsScreen extends HookConsumerWidget {
                 type: ToastificationType.success,
               );
 
+              ref
+                  .read(userActivityServiceProvider)
+                  .logActivity(action: UserActivityAction.profileUpdated);
+
               if (context.mounted) context.pop();
             },
           ).floatingBottomContained,
diff --git a/lib/features/splash/presentation/screens/splash_screen.dart b/lib/features/splash/presentation/screens/splash_screen.dart
@@ -51,10 +51,12 @@ class SplashScreen extends HookConsumerWidget {
         final auth = ref.read(authStateProvider.notifier);
         final user = await auth.getSession();
         if (context.mounted) {
-          // Ensure context is still valid
           if (user == null) {
             GoRouter.of(rootNavKey.currentContext!).go(Routes.onboarding);
           } else {
+            ref
+                .read(userActivityServiceProvider)
+                .logActivity(action: UserActivityAction.signInWithSession);
             GoRouter.of(rootNavKey.currentContext!).go(Routes.main);
           }
         }
diff --git a/lib/features/transaction/presentation/riverpod/transaction_form_state.dart b/lib/features/transaction/presentation/riverpod/transaction_form_state.dart
@@ -16,6 +16,8 @@ import 'package:pockaw/core/services/image_service/riverpod/image_notifier.dart'
 import 'package:pockaw/core/utils/logger.dart';
 import 'package:pockaw/features/category/data/model/category_model.dart';
 import 'package:pockaw/features/transaction/data/model/transaction_model.dart';
+import 'package:pockaw/features/user_activity/data/enum/user_activity_action.dart';
+import 'package:pockaw/features/user_activity/riverpod/user_activity_provider.dart';
 import 'package:pockaw/features/wallet/riverpod/wallet_providers.dart';
 import 'package:toastification/toastification.dart';
 
@@ -135,6 +137,15 @@ class TransactionFormState {
         await _adjustWalletBalance(ref, initialTransaction, transactionToSave);
       }
 
+      ref
+          .read(userActivityServiceProvider)
+          .logActivity(
+            action: isEditing
+                ? UserActivityAction.transactionUpdated
+                : UserActivityAction.transactionCreated,
+            subjectId: savedTransactionId,
+          );
+
       if (context.mounted) {
         context.pop();
       }
@@ -178,6 +189,13 @@ class TransactionFormState {
             initialTransaction!.id!,
           );
 
+          ref
+              .read(userActivityServiceProvider)
+              .logActivity(
+                action: UserActivityAction.transactionDeleted,
+                subjectId: id,
+              );
+
           Log.d(id, label: 'deleted transaction id');
         },
       ),
diff --git a/lib/features/user_activity/data/enum/user_activity_action.dart b/lib/features/user_activity/data/enum/user_activity_action.dart
@@ -5,6 +5,7 @@
 enum UserActivityAction {
   // Authentication
   signIn,
+  signInWithSession,
   signOut,
 
   // Onboarding / journey
@@ -47,12 +48,14 @@ enum UserActivityAction {
   goalUpdated,
   goalDeleted,
 
+  walletSelected,
   walletCreated,
   walletUpdated,
   walletDeleted,
 
   categoryCreated,
   categoryUpdated,
+  categoryDeleted,
 
   // Media
   imageUploaded,
diff --git a/lib/features/wallet/riverpod/wallet_providers.dart b/lib/features/wallet/riverpod/wallet_providers.dart
@@ -1,6 +1,8 @@
 import 'package:flutter_riverpod/flutter_riverpod.dart';
 import 'package:pockaw/core/database/database_provider.dart';
 import 'package:pockaw/core/utils/logger.dart';
+import 'package:pockaw/features/user_activity/data/enum/user_activity_action.dart';
+import 'package:pockaw/features/user_activity/riverpod/user_activity_provider.dart';
 import 'package:pockaw/features/wallet/data/model/wallet_model.dart';
 // import 'package:pockaw/features/wallet/data/repositories/wallet_repo.dart'; // No longer needed for hardcoded list
 
@@ -55,32 +57,65 @@ class ActiveWalletNotifier extends AsyncNotifier<WalletModel?> {
       state = AsyncValue.data(
         wallets.firstWhere((wallet) => wallet.id == walletID),
       );
+
+      ref
+          .read(userActivityServiceProvider)
+          .logActivity(
+            action: UserActivityAction.walletSelected,
+            subjectId: walletID,
+          );
     }
   }
 
+  /// create new wallet and set as active wallet
+  Future<void> createNewActiveWallet(WalletModel newWallet) async {
+    final db = ref.read(databaseProvider);
+    Log.d(newWallet.toJson(), label: 'new wallet');
+    int id = await db.walletDao.addWallet(newWallet);
+    Log.d(id, label: 'new wallet');
+
+    ref
+        .read(userActivityServiceProvider)
+        .logActivity(
+          action: UserActivityAction.walletCreated,
+          subjectId: id,
+        );
+  }
+
   void updateActiveWallet(WalletModel? newWalletData) {
     final currentActiveWallet = state.asData?.value;
     final currentActiveWalletId = currentActiveWallet?.id;
+    UserActivityAction action = UserActivityAction.walletSelected;
 
     if (newWalletData != null && newWalletData.id == currentActiveWalletId) {
       Log.d(
         'Updating active wallet ID ${newWalletData.id} with new data: ${newWalletData.toJson()}',
         label: 'ActiveWalletNotifier',
       );
       state = AsyncValue.data(newWalletData);
+      action = UserActivityAction.walletUpdated;
     } else if (newWalletData != null && currentActiveWalletId == null) {
       Log.d(
         'Setting active wallet (was null) to ID ${newWalletData.id} via updateActiveWallet: ${newWalletData.toJson()}',
         label: 'ActiveWalletNotifier',
       );
       state = AsyncValue.data(newWalletData);
+      action = UserActivityAction.walletSelected;
     } else if (newWalletData == null && currentActiveWalletId != null) {
       Log.d(
         'Clearing active wallet (was ID $currentActiveWalletId) via updateActiveWallet.',
         label: 'ActiveWalletNotifier',
       );
       state = const AsyncValue.data(null);
+      action = UserActivityAction.walletDeleted;
     }
+
+    ref
+        .read(userActivityServiceProvider)
+        .logActivity(
+          action: action,
+          subjectId: newWalletData?.id,
+        );
   }
 
   Future<void> refreshActiveWallet() async {
diff --git a/lib/features/wallet/screens/wallet_form_bottom_sheet.dart b/lib/features/wallet/screens/wallet_form_bottom_sheet.dart
@@ -114,9 +114,9 @@ class WalletFormBottomSheet extends HookConsumerWidget {
                         .read(activeWalletProvider.notifier)
                         .updateActiveWallet(newWallet);
                   } else {
-                    Log.d(newWallet.toJson(), label: 'new wallet');
-                    int id = await db.walletDao.addWallet(newWallet);
-                    Log.d(id, label: 'new wallet');
+                    ref
+                        .read(activeWalletProvider.notifier)
+                        .createNewActiveWallet(newWallet);
                   }
 
                   onSave?.call(

Original file line number	Diff line number	Diff line change
`@@ -51,10 +51,12 @@ class SplashScreen extends HookConsumerWidget {`
`51`	`51`	`final auth = ref.read(authStateProvider.notifier);`
`52`	`52`	`final user = await auth.getSession();`
`53`	`53`	`if (context.mounted) {`
`54`		`- // Ensure context is still valid`
`55`	`54`	`if (user == null) {`
`56`	`55`	`GoRouter.of(rootNavKey.currentContext!).go(Routes.onboarding);`
`57`	`56`	`} else {`
	`57`	`+ ref`
	`58`	`+ .read(userActivityServiceProvider)`
	`59`	`+ .logActivity(action: UserActivityAction.signInWithSession);`
`58`	`60`	`GoRouter.of(rootNavKey.currentContext!).go(Routes.main);`
`59`	`61`	`}`
`60`	`62`	`}`