feat: integrate shared user notification

Author: LucasXu0

frontend/appflowy_flutter/lib/features/share_tab/logic/share_tab_bloc.dart

@@ -1,11 +1,15 @@
+import 'package:appflowy/core/notification/folder_notification.dart';
 import 'package:appflowy/features/share_tab/data/models/models.dart';
 import 'package:appflowy/features/share_tab/data/repositories/share_with_user_repository.dart';
 import 'package:appflowy/features/share_tab/logic/share_tab_event.dart';
 import 'package:appflowy/features/share_tab/logic/share_tab_state.dart';
+import 'package:appflowy/features/util/extensions.dart';
 import 'package:appflowy/plugins/document/presentation/editor_plugins/copy_and_paste/clipboard_service.dart';
 import 'package:appflowy/plugins/shared/share/constants.dart';
 import 'package:appflowy/shared/feature_flags.dart';
 import 'package:appflowy/startup/startup.dart';
+import 'package:appflowy_backend/log.dart';
+import 'package:appflowy_backend/protobuf/flowy-folder/protobuf.dart';
 import 'package:appflowy_result/appflowy_result.dart';
 import 'package:bloc/bloc.dart';
 
@@ -28,12 +32,22 @@ class ShareTabBloc extends Bloc<ShareTabEvent, ShareTabState> {
     on<ShareTabEventSearchAvailableUsers>(_onSearchAvailableUsers);
     on<ShareTabEventConvertToMember>(_onTurnIntoMember);
     on<ShareTabEventClearState>(_onClearState);
+    on<ShareTabEventUpdateSharedUsers>(_onUpdateSharedUsers);
   }
 
   final ShareWithUserRepository repository;
   final String workspaceId;
   final String pageId;
 
+  // Used to listen for shared view updates.
+  late final FolderNotificationListener _folderNotificationListener;
+
+  @override
+  Future<void> close() async {
+    await _folderNotificationListener.stop();
+    await super.close();
+  }
+
   Future<void> _onInitial(
     ShareTabEventInitialize event,
     Emitter<ShareTabState> emit,
@@ -49,6 +63,8 @@ class ShareTabBloc extends Bloc<ShareTabEvent, ShareTabState> {
       return;
     }
 
+    _initFolderNotificationListener();
+
     final result = await repository.getCurrentUserProfile();
     final currentUser = result.fold(
       (user) => user,
@@ -343,4 +359,41 @@ class ShareTabBloc extends Bloc<ShareTabEvent, ShareTabState> {
       ),
     );
   }
+
+  void _onUpdateSharedUsers(
+    ShareTabEventUpdateSharedUsers event,
+    Emitter<ShareTabState> emit,
+  ) {
+    emit(
+      state.copyWith(
+        users: event.users,
+      ),
+    );
+  }
+
+  void _initFolderNotificationListener() {
+    _folderNotificationListener = FolderNotificationListener(
+      objectId: pageId,
+      handler: (notification, result) {
+        if (notification == FolderNotification.DidUpdateSharedUsers) {
+          final response = result.fold(
+            (payload) {
+              final repeatedSharedUsers =
+                  RepeatedSharedUserPB.fromBuffer(payload);
+              return repeatedSharedUsers;
+            },
+            (error) => null,
+          );
+          Log.debug('update shared users: $response');
+          if (response != null) {
+            add(
+              ShareTabEvent.updateSharedUsers(
+                users: response.sharedUsers,
+              ),
+            );
+          }
+        }
+      },
+    );
+  }
 }

frontend/appflowy_flutter/lib/features/share_tab/logic/share_tab_event.dart

@@ -50,6 +50,11 @@ sealed class ShareTabEvent {
       ShareTabEventConvertToMember(email: email);
 
   factory ShareTabEvent.clearState() => const ShareTabEventClearState();
+
+  factory ShareTabEvent.updateSharedUsers({
+    required SharedUsers users,
+  }) =>
+      ShareTabEventUpdateSharedUsers(users: users);
 }
 
 /// Initializes the share tab bloc.
@@ -132,3 +137,11 @@ class ShareTabEventConvertToMember extends ShareTabEvent {
 class ShareTabEventClearState extends ShareTabEvent {
   const ShareTabEventClearState();
 }
+
+class ShareTabEventUpdateSharedUsers extends ShareTabEvent {
+  const ShareTabEventUpdateSharedUsers({
+    required this.users,
+  });
+
+  final SharedUsers users;
+}

frontend/rust-lib/flowy-folder/src/manager.rs

@@ -1396,7 +1396,6 @@ impl FolderManager {
       .share_page_with_user(&workspace_id, params)
       .await?;
 
-    // If successful, refresh the shared page details from cloud and update local database
     let cloud_workspace_id = workspace_id;
     let cloud_page_id = view_id;
     let user = self.user.clone();