diff --git a/side-node/src/websocket/mod.rs b/side-node/src/websocket/mod.rs index 54348c2..53e7e20 100644 --- a/side-node/src/websocket/mod.rs +++ b/side-node/src/websocket/mod.rs @@ -32,10 +32,11 @@ pub(crate) async fn start() -> Result<(), websockets::WebSocketError> { println!("Sending: {}", json); ws.send_text(json.clone()).await?; - // TODO: bft_crdt.apply() changes in here when we receive socket input from other nodes - let msg = ws.receive().await?; println!("Received: {:?}", msg); + // TODO: bft_crdt.apply() changes in here when we receive socket input from other nodes + bft_crdt.apply(msg); + println!("New crdt state is: {}", bft_crdt.doc.view()) } }