commits go through the replica

1 files changed, 4 insertions, 13 deletions

diff --git a/src/state/mod.rs b/src/state/mod.rs
index efa4953..cf64dc3 100644
--- a/src/state/mod.rs
+++ b/src/state/mod.rs
@@ -413,7 +413,7 @@ impl AppState {
         .expect("document write task panicked")
     }
 
-    /// Mutates the document on the blocking pool as one Automerge change, then
+    /// Mutates the document on the blocking pool as one change, then
     /// publishes it. Write and notification run in the same blocking task, so a
     /// cancelled request can't leave a committed write unannounced.
     pub(crate) async fn mutate_doc<T, E>(
@@ -431,19 +431,10 @@ impl AppState {
                 let mut replica = state.doc.blocking_write();
                 let result = f(&mut replica.doc);
                 match &result {
-                    // One API write = one Automerge change.
-                    Ok(_) => {
-                        // Stamped with our clock (milliseconds), so receivers can tell
-                        // how long the change took to reach them (`swarm::stats`).
-                        replica.doc.commit_with(
-                            automerge::transaction::CommitOptions::default()
-                                .with_time(state.clock.now_millis().as_u64() as i64),
-                        );
-                    }
+                    // One API write = one change.
+                    Ok(_) => replica.commit(state.clock.now_millis()),
                     // Discard partial ops (e.g. old value deleted, new one not written).
-                    Err(_) => {
-                        replica.doc.rollback();
-                    }
+                    Err(_) => replica.rollback(),
                 }
                 replica.refresh_heads();
                 result