fix: collab origin issue (AppFlowy-IO#402)

* fix: collab origin issue

* chore: fix lint

* chore: upgrade collab

---------

Co-authored-by: nathan <nathan@appflowy.io>

Cargo.toml

@@ -177,10 +177,10 @@ inherits = "release"
 debug = true
 
 [patch.crates-io]
-collab = { git = "https://github.com/AppFlowy-IO/AppFlowy-Collab", rev = "ba46c5e9e39049c4fedd6f3d67410368874b324f" }
-collab-entity = { git = "https://github.com/AppFlowy-IO/AppFlowy-Collab", rev = "ba46c5e9e39049c4fedd6f3d67410368874b324f" }
-collab-folder = { git = "https://github.com/AppFlowy-IO/AppFlowy-Collab", rev = "ba46c5e9e39049c4fedd6f3d67410368874b324f" }
-collab-document = { git = "https://github.com/AppFlowy-IO/AppFlowy-Collab", rev = "ba46c5e9e39049c4fedd6f3d67410368874b324f" }
+collab = { git = "https://github.com/AppFlowy-IO/AppFlowy-Collab", rev = "0970b2e1440134af7c83bb8fc80cac5d2dedebb7" }
+collab-entity = { git = "https://github.com/AppFlowy-IO/AppFlowy-Collab", rev = "0970b2e1440134af7c83bb8fc80cac5d2dedebb7" }
+collab-folder = { git = "https://github.com/AppFlowy-IO/AppFlowy-Collab", rev = "0970b2e1440134af7c83bb8fc80cac5d2dedebb7" }
+collab-document = { git = "https://github.com/AppFlowy-IO/AppFlowy-Collab", rev = "0970b2e1440134af7c83bb8fc80cac5d2dedebb7" }
 
 [features]
 custom_env= []

libs/client-api/src/collab_sync/sync_control.rs

@@ -337,8 +337,9 @@ where
     let is_valid = sink.validate_response(&msg).await;
     // If there's no payload or the payload is empty, return.
     if is_valid && !msg.payload().is_empty() {
+      let msg_origin = msg.origin();
       ObserveCollab::<Sink, Stream>::process_payload(
-        origin,
+        msg_origin,
         msg.payload(),
         &object.object_id,
         collab,

libs/realtime-entity/src/collab_msg.rs

@@ -397,7 +397,7 @@ pub struct UpdateSync {
   ///    ...
   ///   }
   /// ```
-  ///  
+  ///
   pub payload: Bytes,
 }
 
@@ -866,6 +866,15 @@ impl ServerCollabMessage {
       ServerCollabMessage::ServerBroadcast(msg) => msg.payload.len(),
     }
   }
+
+  pub fn origin(&self) -> &CollabOrigin {
+    match self {
+      ServerCollabMessage::ClientAck(value) => &value.origin,
+      ServerCollabMessage::ServerInitSync(value) => &value.origin,
+      ServerCollabMessage::AwarenessSync(value) => &value.origin,
+      ServerCollabMessage::ServerBroadcast(value) => &value.origin,
+    }
+  }
 }
 
 impl Display for ServerCollabMessage {

libs/workspace-template/src/lib.rs

@@ -115,6 +115,7 @@ impl WorkspaceTemplateBuilder {
         favorites: Default::default(),
         recent: Default::default(),
         trash: Default::default(),
+        private: Default::default(),
       };
 
       let collab = Arc::new(MutexCollab::new(