Yehowshua/ZIm
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Broadcast operations when synchronizing with the server

Browse source
This commit is contained in:
Antonio Scandurra 2023-07-25 10:05:59 +02:00
parent 9358958b1f
commit 31f84cef14
2 changed files with 6 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

6
crates/crdb/src/crdb.rs
View file

@ -257,7 +257,7 @@ impl<E: Executor, N: ClientNetwork> Checkout<E, N> {
.expect("network is infallible");
for operation in operations {
this.network_room
.broadcast(MessageEnvelope::Operation(operation.clone()).to_bytes());
.broadcast(MessageEnvelope::Operation(operation).to_bytes());
}
}
}
@ -303,6 +303,10 @@ impl<E: Executor, N: ClientNetwork> Checkout<E, N> {
operations: chunk.to_vec(),
})
.await?;
for operation in chunk {
self.network_room
.broadcast(MessageEnvelope::Operation(operation.clone()).to_bytes());
}
}
Ok(())

2
crates/crdb/src/messages.rs
View file

@ -90,7 +90,7 @@ impl Into<RequestEnvelope> for SyncRepo {
}
}
#[derive(Clone, Serialize, Deserialize)]
#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct SyncRepoResponse {
pub operations: Vec<Operation>,
pub max_operation_ids: BTreeMap<ReplicaId, OperationCount>,