Skip to content

Commit

Permalink
wip
Browse files Browse the repository at this point in the history
  • Loading branch information
nopestack committed Nov 27, 2023
1 parent 56af06a commit 840bcaf
Show file tree
Hide file tree
Showing 3 changed files with 0 additions and 9 deletions.
1 change: 0 additions & 1 deletion crates/node/src/consensus/consensus_module.rs
Original file line number Diff line number Diff line change
Expand Up @@ -292,7 +292,6 @@ impl ConsensusModule {
)))?
.0;

dbg!("made it here");
self.check_vote_is_valid(&quorum_id, &vote).await?;

match self.votes_pool.entry(quorum_id.clone()) {
Expand Down
1 change: 0 additions & 1 deletion crates/node/src/network/handler.rs
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,6 @@ impl Handler<EventMessage> for NetworkModule {
.await?;
}
Event::NewTxnForwarded(node_id, txn) => {
println!("sending out transaction from {}", &node_id);
info!("Broadcasting transaction to known peers from {node_id}");
self.broadcast_forwarded_transaction(node_id, txn).await?;
}
Expand Down
7 changes: 0 additions & 7 deletions crates/node/src/network/network_event_handler.rs
Original file line number Diff line number Diff line change
Expand Up @@ -123,19 +123,12 @@ impl dyswarm::server::Handler<NetworkEvent> for DyswarmHandler {
}
}
NetworkEvent::NewTxnForwarded(node_id, txn) => {
println!("{} received txn {}", &self.node_id, txn.id(),);
let evt = Event::NewTxnForwarded(node_id, txn);
if let Err(err) = self.send_event_to_runtime(evt).await {
telemetry::error!("{}", err);
}
}
NetworkEvent::TransactionVoteCreated(vote) => {
println!(
"{} received vote on {} from {}",
&self.node_id,
vote.txn.id(),
vote.farmer_id,
);
let evt = Event::TransactionVoteCreated(vote);
if let Err(err) = self.send_event_to_runtime(evt).await {
telemetry::error!("{}", err);
Expand Down

0 comments on commit 840bcaf

Please sign in to comment.