feat: return all reminders

appflowy-integrate/src/collab_builder.rs

@@ -55,24 +55,25 @@ pub struct AppFlowyCollabBuilder {
   network_reachability: CollabNetworkReachability,
   workspace_id: RwLock<Option<String>>,
   cloud_storage: RwLock<Arc<dyn CollabStorageProvider>>,
-  snapshot_persistence: Option<Arc<dyn SnapshotPersistence>>,
+  snapshot_persistence: Mutex<Option<Arc<dyn SnapshotPersistence>>>,
   device_id: Mutex<String>,
 }
 
 impl AppFlowyCollabBuilder {
-  pub fn new<T: CollabStorageProvider>(
-    cloud_storage: T,
-    snapshot_persistence: Option<Arc<dyn SnapshotPersistence>>,
-  ) -> Self {
+  pub fn new<T: CollabStorageProvider>(cloud_storage: T) -> Self {
     Self {
       network_reachability: CollabNetworkReachability::new(),
       workspace_id: Default::default(),
       cloud_storage: RwLock::new(Arc::new(cloud_storage)),
-      snapshot_persistence,
+      snapshot_persistence: Default::default(),
       device_id: Default::default(),
     }
   }
 
+  pub fn set_snapshot_persistence(&self, snapshot_persistence: Arc<dyn SnapshotPersistence>) {
+    *self.snapshot_persistence.lock() = Some(snapshot_persistence);
+  }
+
   pub fn initialize(&self, workspace_id: String) {
     *self.workspace_id.write() = Some(workspace_id);
   }
@@ -104,13 +105,13 @@ impl AppFlowyCollabBuilder {
     object_id: &str,
     object_type: CollabType,
     raw_data: CollabRawData,
-    db: Weak<RocksCollabDB>,
+    collab_db: Weak<RocksCollabDB>,
   ) -> Result<Arc<MutexCollab>, Error> {
     self.build_with_config(
       uid,
       object_id,
       object_type,
-      db,
+      collab_db,
       raw_data,
       &CollabPersistenceConfig::default(),
     )
@@ -196,7 +197,7 @@ impl AppFlowyCollabBuilder {
       CollabStorageType::Local => {},
     }
 
-    if let Some(snapshot_persistence) = &self.snapshot_persistence {
+    if let Some(snapshot_persistence) = self.snapshot_persistence.lock().as_ref() {
       if config.enable_snapshot {
         let collab_object = CollabObject::new(uid, object_id.to_string(), object_type)
           .with_device_id(self.device_id.lock().clone());

collab-plugins/src/cloud_storage/remote_collab.rs

@@ -598,6 +598,7 @@ pub enum CollabType {
   WorkspaceDatabase = 2,
   Folder = 3,
   DatabaseRow = 4,
+  UserAwareness = 5,
 }
 
 impl CollabType {
@@ -614,6 +615,7 @@ impl Display for CollabType {
       Self::WorkspaceDatabase => f.write_str("WorkspaceDatabase"),
       Self::DatabaseRow => f.write_str("DatabaseRow"),
       Self::Folder => f.write_str("Folder"),
+      Self::UserAwareness => f.write_str("UserAwareness"),
     }
   }
 }

collab-user/src/user_awareness.rs

@@ -201,6 +201,11 @@ impl UserAwareness {
     self.reminders.add(reminder);
   }
 
+  /// Returns all reminders in the `UserAwareness` object.
+  pub fn get_all_reminders(&self) -> Vec<Reminder> {
+    self.reminders.get_all_reminders()
+  }
+
   /// Removes an existing reminder from the `UserAwareness` object.
   ///
   /// # Arguments