feat: exclude pending state in broadcast update (toeverything/OctoBas…

…e#546)

y-octo/src/doc/document.rs

@@ -289,7 +289,7 @@ impl Doc {
             }
         }
 
-        store.diff_state_vector(&before_state)
+        store.diff_state_vector(&before_state, false)
     }
 
     pub fn keys(&self) -> Vec<String> {
@@ -356,7 +356,7 @@ impl Doc {
     }
 
     pub fn encode_state_as_update(&self, sv: &StateVector) -> JwstCodecResult<Update> {
-        self.store.read().unwrap().diff_state_vector(sv)
+        self.store.read().unwrap().diff_state_vector(sv, true)
     }
 
     pub fn get_state_vector(&self) -> StateVector {

y-octo/src/doc/publisher.rs

@@ -76,7 +76,7 @@ impl DocPublisher {
                         );
 
                         history.resolve_with_store(&store);
-                        let (binary, history) = match store.diff_state_vector(&last_update) {
+                        let (binary, history) = match store.diff_state_vector(&last_update, false) {
                             Ok(update) => {
                                 drop(store);
 

y-octo/src/doc/store.rs

@@ -728,7 +728,7 @@ impl DocStore {
         diff
     }
 
-    pub fn diff_state_vector(&self, sv: &StateVector) -> JwstCodecResult<Update> {
+    pub fn diff_state_vector(&self, sv: &StateVector, with_pending: bool) -> JwstCodecResult<Update> {
         let update_structs = Self::diff_structs(&self.items, sv)?;
 
         let mut update = Update {
@@ -737,8 +737,10 @@ impl DocStore {
             ..Update::default()
         };
 
-        if let Some(pending) = &self.pending {
-            Update::merge_into(&mut update, [pending.clone()])
+        if with_pending {
+            if let Some(pending) = &self.pending {
+                Update::merge_into(&mut update, [pending.clone()])
+            }
         }
 
         Ok(update)