From e0c991d0f94f6971a37e8302c5d578efa1c70401 Mon Sep 17 00:00:00 2001
From: Dave Hrycyszyn <futurechimp@users.noreply.github.com>
Date: Tue, 11 Jun 2024 17:06:49 +0100
Subject: [PATCH] Getting ready for network broadcast

---
 side-node/src/node.rs | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

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<TransactionList>,
@@ -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());