dave/bft-crdt-experiment
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Renaming keys to bft_crdt_keys

Browse Source
This commit is contained in:
Dave Hrycyszyn
2024-06-18 16:34:03 +01:00
parent f5da5af0b9
commit ae8a70e249
1 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
side-node/src/lib.rs
View File

@@ -39,8 +39,8 @@ pub async fn run() {
async fn setup(name: &String) -> SideNode { async fn setup(name: &String) -> SideNode {
// First, load up the keys and create a bft-crdt // First, load up the keys and create a bft-crdt
let side_dir = utils::home(name); let side_dir = utils::home(name);
let keys = keys::load_from_file(side_dir); let bft_crdt_keys = keys::load_from_file(side_dir);
let crdt = BaseCrdt::<TransactionList>::new(&keys); let crdt = BaseCrdt::<TransactionList>::new(&bft_crdt_keys);
// Channels for internal communication, and a tokio task for stdin input // Channels for internal communication, and a tokio task for stdin input
let (incoming_sender, incoming_receiver) = mpsc::channel::<SignedOp>(32); let (incoming_sender, incoming_receiver) = mpsc::channel::<SignedOp>(32);
@@ -51,7 +51,13 @@ async fn setup(name: &String) -> SideNode {
// Finally, create the node and return it // Finally, create the node and return it
let handle = WebSocketClient::new(incoming_sender).await; let handle = WebSocketClient::new(incoming_sender).await;
let node = SideNode::new(crdt, keys, incoming_receiver, stdin_receiver, handle); let node = SideNode::new(
crdt,
bft_crdt_keys,
incoming_receiver,
stdin_receiver,
handle,
);
println!("Node setup complete."); println!("Node setup complete.");
node node
} }