chore: return is local when observer (#443)

* chore: return local when observe

* chore: lint

Author: appflowy

collab/build.rs

@@ -21,24 +21,15 @@ fn main() -> Result<(), Box<dyn std::error::Error>> {
     println!("cargo:rerun-if-changed={}", proto_file);
   }
 
+  let out_dir = std::env::var("OUT_DIR")?;
   prost_build::Config::new()
-    .out_dir("src/entity/proto/")
+    .out_dir(out_dir)
     .compile_protos(&proto_files, &["proto/entity/"])?;
 
-  // Run rustfmt on the generated files.
-  let files = std::fs::read_dir("src/entity/proto/")?
-    .filter_map(Result::ok)
-    .filter(|entry| {
-      entry
-        .path()
-        .extension()
-        .map(|ext| ext == "rs")
-        .unwrap_or(false)
-    })
-    .map(|entry| entry.path().display().to_string());
-
-  for file in files {
-    Command::new("rustfmt").arg(file).status()?;
-  }
+  // Optional: keep generated sources formatted when building locally.
+  // Ignore errors to avoid failing builds when `rustfmt` isn't available.
+  let _ = Command::new("rustfmt")
+    .arg(format!("{}/collab.rs", std::env::var("OUT_DIR")?))
+    .status();
   Ok(())
 }

collab/src/database/database.rs

@@ -1857,7 +1857,11 @@ impl DatabaseBody {
     let views: MapRef = root.get_or_init(&mut txn, VIEWS); // { DATABASE: { FIELDS: {:}, VIEWS: {:} } }
     let metas: MapRef = root.get_or_init(&mut txn, DATABASE_METAS); // { DATABASE: { FIELDS: {:},  VIEWS: {:}, METAS: {:} } }
 
-    let fields = FieldMap::new(fields, Some(context.notifier.field_change_tx.clone()));
+    let fields = FieldMap::new(
+      origin.clone(),
+      fields,
+      Some(context.notifier.field_change_tx.clone()),
+    );
     let views = DatabaseViews::new(origin, views, Some(context.notifier.view_change_tx.clone()));
     let block = Block::new(
       database_id,
@@ -1938,7 +1942,11 @@ impl DatabaseBody {
     let views: MapRef = root.get_with_txn(&txn, VIEWS)?; // { DATABASE: { FIELDS: {:}, VIEWS: {:} } }
     let metas: MapRef = root.get_with_txn(&txn, DATABASE_METAS)?; // { DATABASE: { FIELDS: {:},  VIEWS: {:}, METAS: {:} } }
 
-    let fields = FieldMap::new(fields, notifier.as_ref().map(|n| n.field_change_tx.clone()));
+    let fields = FieldMap::new(
+      origin.clone(),
+      fields,
+      notifier.as_ref().map(|n| n.field_change_tx.clone()),
+    );
     let views = DatabaseViews::new(
       origin,
       views,

collab/src/database/fields/field_map.rs

@@ -1,3 +1,4 @@
+use crate::core::origin::CollabOrigin;
 use crate::preclude::{Map, MapExt, MapRef, ReadTxn, Subscription, TransactionMut};
 
 use crate::database::database::timestamp;
@@ -15,8 +16,12 @@ pub struct FieldMap {
 }
 
 impl FieldMap {
-  pub fn new(mut container: MapRef, field_change_tx: Option<FieldChangeSender>) -> Self {
-    let subscription = field_change_tx.map(|tx| subscribe_field_change(&mut container, tx));
+  pub fn new(
+    origin: CollabOrigin,
+    mut container: MapRef,
+    field_change_tx: Option<FieldChangeSender>,
+  ) -> Self {
+    let subscription = field_change_tx.map(|tx| subscribe_field_change(origin, &mut container, tx));
     Self {
       container,
       subscription,