PE-4994: Prompt Users to Create a Snapshot

lib/app_shell.dart

@@ -1,6 +1,9 @@
+import 'package:ardrive/blocs/prompt_to_snapshot/prompt_to_snapshot_bloc.dart';
+import 'package:ardrive/blocs/prompt_to_snapshot/prompt_to_snapshot_event.dart';
 import 'package:ardrive/components/profile_card.dart';
 import 'package:ardrive/components/side_bar.dart';
 import 'package:ardrive/gift/reedem_button.dart';
+import 'package:ardrive/models/daos/drive_dao/drive_dao.dart';
 import 'package:ardrive/pages/drive_detail/components/hover_widget.dart';
 import 'package:ardrive/utils/logger.dart';
 import 'package:ardrive/utils/size_constants.dart';
@@ -60,9 +63,38 @@ class AppShellState extends State<AppShell> {
 
   @override
   Widget build(BuildContext context) => BlocBuilder<DrivesCubit, DrivesState>(
-        builder: (context, _) {
+        builder: (context, drivesState) {
           Widget buildPage(scaffold) => Material(
-                child: BlocBuilder<SyncCubit, SyncState>(
+                child: BlocConsumer<SyncCubit, SyncState>(
+                  listener: (context, syncState) async {
+                    if (drivesState is DrivesLoadSuccess) {
+                      if (syncState is! SyncInProgress) {
+                        final profileState = context.read<ProfileCubit>().state;
+
+                        final promptToSnapshotBloc =
+                            context.read<PromptToSnapshotBloc>();
+                        final driveDao = context.read<DriveDao>();
+                        final selectedDriveId = drivesState.selectedDriveId;
+
+                        final selectedDrive = selectedDriveId == null
+                            ? null
+                            : await driveDao
+                                .driveById(driveId: selectedDriveId)
+                                .getSingleOrNull();
+
+                        final hasWritePermissions =
+                            profileState is ProfileLoggedIn &&
+                                selectedDrive?.ownerAddress ==
+                                    profileState.walletAddress;
+
+                        if (hasWritePermissions) {
+                          promptToSnapshotBloc.add(SelectedDrive(
+                            driveId: drivesState.selectedDriveId,
+                          ));
+                        }
+                      }
+                    }
+                  },
                   builder: (context, syncState) => syncState is SyncInProgress
                       ? Stack(
                           children: [

lib/blocs/drives/drives_cubit.dart

@@ -2,10 +2,13 @@ import 'dart:async';
 
 import 'package:ardrive/authentication/ardrive_auth.dart';
 import 'package:ardrive/blocs/blocs.dart';
+import 'package:ardrive/blocs/prompt_to_snapshot/prompt_to_snapshot_bloc.dart';
+import 'package:ardrive/blocs/prompt_to_snapshot/prompt_to_snapshot_event.dart';
 import 'package:ardrive/core/activity_tracker.dart';
 import 'package:ardrive/models/models.dart';
 import 'package:ardrive/utils/user_utils.dart';
 import 'package:ardrive_utils/ardrive_utils.dart';
+import 'package:collection/collection.dart';
 import 'package:drift/drift.dart';
 import 'package:equatable/equatable.dart';
 import 'package:flutter_bloc/flutter_bloc.dart';
@@ -17,6 +20,7 @@ part 'drives_state.dart';
 /// It works even if the user profile is unavailable.
 class DrivesCubit extends Cubit<DrivesState> {
   final ProfileCubit _profileCubit;
+  final PromptToSnapshotBloc _promptToSnapshotBloc;
   final DriveDao _driveDao;
   final ArDriveAuth _auth;
 
@@ -26,9 +30,11 @@ class DrivesCubit extends Cubit<DrivesState> {
     required ArDriveAuth auth,
     this.initialSelectedDriveId,
     required ProfileCubit profileCubit,
+    required PromptToSnapshotBloc promptToSnapshotBloc,
     required DriveDao driveDao,
     required ActivityTracker activityTracker,
   })  : _profileCubit = profileCubit,
+        _promptToSnapshotBloc = promptToSnapshotBloc,
         _driveDao = driveDao,
         _auth = auth,
         super(DrivesLoadInProgress()) {
@@ -52,7 +58,7 @@ class DrivesCubit extends Cubit<DrivesState> {
     ).listen((drives) async {
       final state = this.state;
 
-      final profile = _profileCubit.state;
+      final profileState = _profileCubit.state;
 
       String? selectedDriveId;
 
@@ -64,22 +70,34 @@ class DrivesCubit extends Cubit<DrivesState> {
       }
 
       final walletAddress =
-          profile is ProfileLoggedIn ? profile.walletAddress : null;
+          profileState is ProfileLoggedIn ? profileState.walletAddress : null;
 
       final ghostFolders = await _driveDao.ghostFolders().get();
 
       final sharedDrives =
           drives.where((d) => !isDriveOwner(auth, d.ownerAddress)).toList();
 
+      final userDrives = drives
+          .where((d) => profileState is ProfileLoggedIn
+              ? d.ownerAddress == walletAddress
+              : false)
+          .toList();
+
+      final selectedDrive =
+          drives.firstWhereOrNull((d) => d.id == selectedDriveId);
+
+      final hasWritePermission = profileState is ProfileLoggedIn &&
+          selectedDrive?.ownerAddress == profileState.walletAddress;
+
+      if (hasWritePermission) {
+        _promptToSnapshotBloc.add(SelectedDrive(driveId: selectedDriveId));
+      }
+
       emit(
         DrivesLoadSuccess(
           selectedDriveId: selectedDriveId,
           // If the user is not logged in, all drives are considered shared ones.
-          userDrives: drives
-              .where((d) => profile is ProfileLoggedIn
-                  ? d.ownerAddress == walletAddress
-                  : false)
-              .toList(),
+          userDrives: userDrives,
           sharedDrives: sharedDrives,
           drivesWithAlerts: ghostFolders.map((e) => e.driveId).toList(),
           canCreateNewDrive: _profileCubit.state is ProfileLoggedIn,
@@ -89,16 +107,43 @@ class DrivesCubit extends Cubit<DrivesState> {
   }
 
   void selectDrive(String driveId) {
-    final canCreateNewDrive = _profileCubit.state is ProfileLoggedIn;
-    final state = this.state is DrivesLoadSuccess
-        ? (this.state as DrivesLoadSuccess).copyWith(selectedDriveId: driveId)
-        : DrivesLoadedWithNoDrivesFound(canCreateNewDrive: canCreateNewDrive);
+    final profileIsLoggedIn = _profileCubit.state is ProfileLoggedIn;
+    final canCreateNewDrive = profileIsLoggedIn;
+    final DrivesState state;
+    if (this.state is DrivesLoadSuccess) {
+      state = (this.state as DrivesLoadSuccess).copyWith(
+        selectedDriveId: driveId,
+      );
+
+      if (profileIsLoggedIn) {
+        final profileStateAsLoggedIn = _profileCubit.state as ProfileLoggedIn;
+
+        _driveDao
+            .driveById(driveId: driveId)
+            .getSingleOrNull()
+            .then((maybeDrive) {
+          final hasWritePermission =
+              maybeDrive?.ownerAddress == profileStateAsLoggedIn.walletAddress;
+
+          if (hasWritePermission) {
+            _promptToSnapshotBloc.add(SelectedDrive(driveId: driveId));
+          }
+        });
+      }
+    } else {
+      state = DrivesLoadedWithNoDrivesFound(
+        canCreateNewDrive: canCreateNewDrive,
+      );
+      _promptToSnapshotBloc.add(const SelectedDrive(driveId: null));
+    }
     emit(state);
   }
 
   void cleanDrives() {
     initialSelectedDriveId = null;
 
+    _promptToSnapshotBloc.add(const SelectedDrive(driveId: null));
+
     final state = DrivesLoadSuccess(
         selectedDriveId: null,
         userDrives: const [],
@@ -110,21 +155,44 @@ class DrivesCubit extends Cubit<DrivesState> {
   }
 
   void _resetDriveSelection(DriveID detachedDriveId) {
-    final canCreateNewDrive = _profileCubit.state is ProfileLoggedIn;
+    final profileIsLoggedIn = _profileCubit.state is ProfileLoggedIn;
+    final canCreateNewDrive = profileIsLoggedIn;
     if (state is DrivesLoadSuccess) {
       final state = this.state as DrivesLoadSuccess;
       state.userDrives.removeWhere((drive) => drive.id == detachedDriveId);
       state.sharedDrives.removeWhere((drive) => drive.id == detachedDriveId);
-      final firstOrNullDrive = state.userDrives.isNotEmpty
+      final firstOrNullDriveId = state.userDrives.isNotEmpty
           ? state.userDrives.first.id
           : state.sharedDrives.isNotEmpty
               ? state.sharedDrives.first.id
               : null;
-      if (firstOrNullDrive != null) {
-        emit(state.copyWith(selectedDriveId: firstOrNullDrive));
+      if (firstOrNullDriveId != null) {
+        if (profileIsLoggedIn && state.selectedDriveId != null) {
+          final profileStateAsLoggedIn = _profileCubit.state as ProfileLoggedIn;
+
+          _driveDao
+              .driveById(driveId: firstOrNullDriveId)
+              .getSingleOrNull()
+              .then((maybeDrive) {
+            final hasWritePermission = maybeDrive?.ownerAddress ==
+                profileStateAsLoggedIn.walletAddress;
+
+            if (hasWritePermission) {
+              _promptToSnapshotBloc.add(SelectedDrive(
+                driveId: firstOrNullDriveId,
+              ));
+            } else {
+              _promptToSnapshotBloc.add(const SelectedDrive(driveId: null));
+            }
+          });
+        }
+
+        emit(state.copyWith(selectedDriveId: firstOrNullDriveId));
         return;
       }
     }
+
+    _promptToSnapshotBloc.add(const SelectedDrive(driveId: null));
     emit(DrivesLoadedWithNoDrivesFound(canCreateNewDrive: canCreateNewDrive));
   }
 

lib/blocs/feedback_survey/feedback_survey_cubit.dart

@@ -12,7 +12,6 @@ class FeedbackSurveyCubit extends Cubit<FeedbackSurveyState> {
 
   FeedbackSurveyCubit(
     FeedbackSurveyState initialState, {
-
     /// takes a KeyValueStore for testing purposes
     KeyValueStore? store,
   }) : super(initialState) {