diff --git a/side-node/src/node.rs b/side-node/src/node.rs index c3bd046..fab29c3 100644 --- a/side-node/src/node.rs +++ b/side-node/src/node.rs @@ -2,7 +2,7 @@ use bft_json_crdt::json_crdt::{BaseCrdt, SignedOp}; use fastcrypto::ed25519::Ed25519KeyPair; use tokio::sync::mpsc; -use crate::crdt::TransactionList; +use crate::{crdt::TransactionList, utils}; pub(crate) struct SideNode { crdt: BaseCrdt, @@ -31,9 +31,13 @@ impl SideNode { println!("Starting node..."); loop { - match self.stdin_receiver.try_recv() { + match self.stdin_receiver.recv() { Ok(stdin) => { println!("Received stdin input: {:?}", stdin); + let transaction = utils::fake_transaction(stdin); + let json = serde_json::to_value(transaction).unwrap(); + let signed_op = self._add_transaction_local(json); + self.send_to_network(signed_op); } Err(_) => {} } @@ -46,6 +50,10 @@ impl SideNode { } } + fn send_to_network(&self, signed_op: SignedOp) { + println!("sending to network: {:?}", signed_op); + } + fn handle_incoming(&mut self, incoming: &SignedOp) { println!("WINNNINGINGINGINGINGIGNIGN"); self.crdt.apply(incoming.clone());