refactor(snark_pool_candidate): Combine all action types of the snark_pool_candidate module into the parent action type

Author: tizoc

node/src/effects.rs

@@ -21,9 +21,7 @@ use crate::p2p::discovery::{P2pDiscoveryKademliaBootstrapAction, P2pDiscoveryKad
 use crate::p2p::p2p_effects;
 use crate::rpc::rpc_effects;
 use crate::snark::snark_effects;
-use crate::snark_pool::candidate::{
-    SnarkPoolCandidateWorkFetchAllAction, SnarkPoolCandidateWorkVerifyNextAction,
-};
+use crate::snark_pool::candidate::SnarkPoolCandidateAction;
 use crate::snark_pool::{
     snark_pool_effects, SnarkPoolCheckTimeoutsAction, SnarkPoolP2pSendAllAction,
 };
@@ -62,8 +60,8 @@ pub fn effects<S: Service>(store: &mut Store<S>, action: ActionWithMeta) {
 
             p2p_request_best_tip_if_needed(store);
 
-            store.dispatch(SnarkPoolCandidateWorkFetchAllAction {});
-            store.dispatch(SnarkPoolCandidateWorkVerifyNextAction {});
+            store.dispatch(SnarkPoolCandidateAction::WorkFetchAll {});
+            store.dispatch(SnarkPoolCandidateAction::WorkVerifyNext {});
 
             p2p_request_snarks_if_needed(store);
 

node/src/p2p/p2p_effects.rs

@@ -7,10 +7,7 @@ use crate::rpc::{
     RpcP2pConnectionIncomingSuccessAction, RpcP2pConnectionOutgoingErrorAction,
     RpcP2pConnectionOutgoingSuccessAction,
 };
-use crate::snark_pool::candidate::{
-    SnarkPoolCandidateInfoReceivedAction, SnarkPoolCandidatePeerPruneAction,
-    SnarkPoolCandidateWorkReceivedAction,
-};
+use crate::snark_pool::candidate::SnarkPoolCandidateAction;
 use crate::snark_pool::SnarkPoolJobCommitmentAddAction;
 use crate::transition_frontier::sync::ledger::snarked::{
     PeerLedgerQueryError, PeerLedgerQueryResponse,
@@ -262,7 +259,7 @@ pub fn p2p_effects<S: Service>(store: &mut Store<S>, action: P2pActionWithMeta)
                     store.dispatch(action);
                 }
 
-                store.dispatch(SnarkPoolCandidatePeerPruneAction {
+                store.dispatch(SnarkPoolCandidateAction::PeerPrune {
                     peer_id: action.peer_id,
                 });
             }
@@ -356,7 +353,7 @@ pub fn p2p_effects<S: Service>(store: &mut Store<S>, action: P2pActionWithMeta)
                 P2pChannelsSnarkAction::PromiseReceived(_) => {}
                 P2pChannelsSnarkAction::Received(action) => {
                     action.effects(&meta, store);
-                    store.dispatch(SnarkPoolCandidateInfoReceivedAction {
+                    store.dispatch(SnarkPoolCandidateAction::InfoReceived {
                         peer_id: action.peer_id,
                         info: action.snark,
                     });
@@ -366,7 +363,7 @@ pub fn p2p_effects<S: Service>(store: &mut Store<S>, action: P2pActionWithMeta)
                     action.effects(&meta, store);
                 }
                 P2pChannelsSnarkAction::Libp2pReceived(action) => {
-                    store.dispatch(SnarkPoolCandidateWorkReceivedAction {
+                    store.dispatch(SnarkPoolCandidateAction::WorkReceived {
                         peer_id: action.peer_id,
                         work: action.snark,
                     });
@@ -541,7 +538,7 @@ pub fn p2p_effects<S: Service>(store: &mut Store<S>, action: P2pActionWithMeta)
                             });
                         }
                         Some(P2pRpcResponse::Snark(snark)) => {
-                            store.dispatch(SnarkPoolCandidateWorkReceivedAction {
+                            store.dispatch(SnarkPoolCandidateAction::WorkReceived {
                                 peer_id: action.peer_id,
                                 work: snark.clone(),
                             });

node/src/snark/snark_effects.rs

@@ -1,7 +1,5 @@
 use crate::consensus::ConsensusBlockSnarkVerifySuccessAction;
-use crate::snark_pool::candidate::{
-    SnarkPoolCandidateWorkVerifyErrorAction, SnarkPoolCandidateWorkVerifySuccessAction,
-};
+use crate::snark_pool::candidate::SnarkPoolCandidateAction;
 use crate::snark_pool::SnarkPoolWorkAddAction;
 use crate::{Service, Store};
 
@@ -41,7 +39,7 @@ pub fn snark_effects<S: Service>(store: &mut Store<S>, action: SnarkActionWithMe
                 let Some(req) = req else { return };
                 let sender = req.sender().parse().unwrap();
 
-                store.dispatch(SnarkPoolCandidateWorkVerifyErrorAction {
+                store.dispatch(SnarkPoolCandidateAction::WorkVerifyError {
                     peer_id: sender,
                     verify_id: a.req_id,
                 });
@@ -53,7 +51,7 @@ pub fn snark_effects<S: Service>(store: &mut Store<S>, action: SnarkActionWithMe
                 let sender = req.sender().parse().unwrap();
                 let batch = req.batch().to_vec();
 
-                store.dispatch(SnarkPoolCandidateWorkVerifySuccessAction {
+                store.dispatch(SnarkPoolCandidateAction::WorkVerifySuccess {
                     peer_id: sender,
                     verify_id: a.req_id,
                 });