From b8e9d714294333771a3cc08c7c7ae78e9248f48f Mon Sep 17 00:00:00 2001 From: Dave Hrycyszyn Date: Wed, 5 Jun 2024 19:52:37 +0100 Subject: [PATCH] Renamed ListExample --- side-node/src/list_transaction_crdt.rs | 8 ++++---- side-node/src/websocket/mod.rs | 4 ++-- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/side-node/src/list_transaction_crdt.rs b/side-node/src/list_transaction_crdt.rs index 5fb27fa..6b3941a 100644 --- a/side-node/src/list_transaction_crdt.rs +++ b/side-node/src/list_transaction_crdt.rs @@ -12,7 +12,7 @@ use websockets::WebSocket; #[add_crdt_fields] #[derive(Clone, CrdtNode, Serialize, Deserialize)] -pub(crate) struct ListExample { +pub(crate) struct CrdtList { pub(crate) list: ListCrdt, // switch to Transaction as soon as char is working } @@ -25,15 +25,15 @@ pub(crate) struct Transaction { amount: f64, } -pub(crate) fn new() -> (BaseCrdt, Ed25519KeyPair) { +pub(crate) fn new() -> (BaseCrdt, Ed25519KeyPair) { let keys = make_keypair(); - let bft_crdt = BaseCrdt::::new(&keys); + let bft_crdt = BaseCrdt::::new(&keys); (bft_crdt, keys) } pub(crate) async fn send( count: u32, - bft_crdt: &mut BaseCrdt, + bft_crdt: &mut BaseCrdt, ws: &mut WebSocket, keys: &Ed25519KeyPair, ) -> Result<(), websockets::WebSocketError> { diff --git a/side-node/src/websocket/mod.rs b/side-node/src/websocket/mod.rs index 0e9b6d9..34c2e87 100644 --- a/side-node/src/websocket/mod.rs +++ b/side-node/src/websocket/mod.rs @@ -1,4 +1,4 @@ -use crate::list_transaction_crdt::{self, ListExample}; +use crate::list_transaction_crdt::{self, CrdtList}; use bft_json_crdt::json_crdt::SignedOp; use bft_json_crdt::json_crdt::{BaseCrdt, CrdtNode}; use bft_json_crdt::keypair::Ed25519KeyPair; @@ -8,7 +8,7 @@ use websockets::WebSocket; /// Starts a websocket and periodically sends a BFT-CRDT message to the websocket server pub(crate) async fn start( keys: Ed25519KeyPair, - bft_crdt: &mut BaseCrdt, + bft_crdt: &mut BaseCrdt, ) -> Result<(), websockets::WebSocketError> { println!("connecting to websocket at ws://127.0.0.1:8080/"); let mut ws = WebSocket::connect("ws://127.0.0.1:8080/").await?;