WIP

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())
     }
 }