Skip to content

Commit a17ed0c

Browse files
committed
fix(p2p): Adjust callbacks formatting and deduplicate name
1 parent ddc6414 commit a17ed0c

File tree

1 file changed

+10
-7
lines changed

1 file changed

+10
-7
lines changed

node/src/state.rs

Lines changed: 10 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -513,7 +513,10 @@ impl P2p {
513513
P2pCallbacks {
514514
on_p2p_channels_transaction_libp2p_received: Some(redux::callback!(
515515
on_p2p_channels_transaction_libp2p_received(transaction: Box<MinaBaseUserCommandStableV2>) -> crate::Action{
516-
TransactionPoolAction::StartVerify { commands: std::iter::once(*transaction).collect(), from_rpc: None }
516+
TransactionPoolAction::StartVerify {
517+
commands: std::iter::once(*transaction).collect(),
518+
from_rpc: None
519+
}
517520
}
518521
)),
519522
on_p2p_channels_snark_job_commitment_received: Some(redux::callback!(
@@ -527,7 +530,7 @@ impl P2p {
527530
}
528531
)),
529532
on_p2p_channels_snark_libp2p_received: Some(redux::callback!(
530-
on_p2p_channels_snark_received((peer_id: PeerId, snark: Box<Snark>)) -> crate::Action{
533+
on_p2p_channels_snark_libp2p_received((peer_id: PeerId, snark: Box<Snark>)) -> crate::Action{
531534
SnarkPoolCandidateAction::WorkReceived { peer_id, work: *snark }
532535
}
533536
)),
@@ -573,12 +576,12 @@ impl P2p {
573576
)),
574577
on_p2p_peer_best_tip_update: Some(redux::callback!(
575578
on_p2p_peer_best_tip_update(best_tip: BlockWithHash<Arc<MinaBlockBlockStableV2>>) -> crate::Action{
576-
ConsensusAction::P2pBestTipUpdate{best_tip}
579+
ConsensusAction::P2pBestTipUpdate { best_tip }
577580
}
578581
)),
579582
on_p2p_channels_rpc_ready: Some(redux::callback!(
580583
on_p2p_channels_rpc_ready(peer_id: PeerId) -> crate::Action{
581-
P2pCallbacksAction::P2pChannelsRpcReady {peer_id}
584+
P2pCallbacksAction::P2pChannelsRpcReady { peer_id }
582585
}
583586
)),
584587
on_p2p_channels_rpc_timeout: Some(redux::callback!(
@@ -588,17 +591,17 @@ impl P2p {
588591
)),
589592
on_p2p_channels_rpc_response_received: Some(redux::callback!(
590593
on_p2p_channels_rpc_response_received((peer_id: PeerId, id: P2pRpcId, response: Option<Box<P2pRpcResponse>>)) -> crate::Action{
591-
P2pCallbacksAction::P2pChannelsRpcResponseReceived {peer_id, id, response}
594+
P2pCallbacksAction::P2pChannelsRpcResponseReceived { peer_id, id, response }
592595
}
593596
)),
594597
on_p2p_channels_rpc_request_received: Some(redux::callback!(
595598
on_p2p_channels_rpc_request_received((peer_id: PeerId, id: P2pRpcId, request: Box<P2pRpcRequest>)) -> crate::Action{
596-
P2pCallbacksAction::P2pChannelsRpcRequestReceived {peer_id, id, request}
599+
P2pCallbacksAction::P2pChannelsRpcRequestReceived { peer_id, id, request }
597600
}
598601
)),
599602
on_p2p_channels_streaming_rpc_response_received: Some(redux::callback!(
600603
on_p2p_channels_streaming_rpc_response_received((peer_id: PeerId, id: P2pRpcId, response: Option<P2pStreamingRpcResponseFull>)) -> crate::Action{
601-
P2pCallbacksAction::P2pChannelsStreamingRpcResponseReceived {peer_id, id, response}
604+
P2pCallbacksAction::P2pChannelsStreamingRpcResponseReceived { peer_id, id, response }
602605
}
603606
)),
604607
on_p2p_channels_streaming_rpc_timeout: Some(redux::callback!(

0 commit comments

Comments
 (0)