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

Moved stdin onto root

Browse Source
This commit is contained in:
Dave
2025-06-12 16:27:41 -04:00
parent b933f8d6fc
commit 0126614dd3
3 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
crdt-node/src/bft_crdt/mod.rs
View File

@@ -6,7 +6,6 @@ use bft_json_crdt::{
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
pub mod keys; pub mod keys;
pub mod stdin;
pub mod websocket; pub mod websocket;
#[add_crdt_fields] #[add_crdt_fields]

3
crdt-node/src/lib.rs
View File

@@ -9,6 +9,7 @@ pub mod bft_crdt;
pub(crate) mod cli; pub(crate) mod cli;
pub(crate) mod init; pub(crate) mod init;
pub mod node; pub mod node;
mod stdin;
pub mod utils; pub mod utils;
#[tokio::main] #[tokio::main]
@@ -42,7 +43,7 @@ async fn setup(name: &String) -> SideNode {
let (incoming_sender, incoming_receiver) = mpsc::channel::<SignedOp>(32); let (incoming_sender, incoming_receiver) = mpsc::channel::<SignedOp>(32);
let (stdin_sender, stdin_receiver) = std::sync::mpsc::channel(); let (stdin_sender, stdin_receiver) = std::sync::mpsc::channel();
task::spawn(async move { task::spawn(async move {
bft_crdt::stdin::input(stdin_sender); stdin::input(stdin_sender);
}); });
// Wire the websocket client to the incoming channel // Wire the websocket client to the incoming channel

0
crdt-node/src/bft_crdt/stdin.rs → crdt-node/src/stdin.rs
View File