Added snark pool endpoint

Author: 0xMimir

core/src/snark/snark.rs

@@ -77,6 +77,16 @@ impl From<TransactionSnarkWorkTStableV2> for Snark {
     }
 }
 
+impl From<Snark> for TransactionSnarkWorkTStableV2 {
+    fn from(value: Snark) -> Self {
+        Self {
+            fee: value.fee,
+            proofs: value.proofs.as_ref().clone(),
+            prover: value.snarker,
+        }
+    }
+}
+
 impl From<NetworkPoolSnarkPoolDiffVersionedStableV2AddSolvedWork1> for Snark {
     fn from(value: NetworkPoolSnarkPoolDiffVersionedStableV2AddSolvedWork1) -> Self {
         Self {

node/common/src/service/rpc/mod.rs

@@ -272,6 +272,10 @@ impl node::rpc_effectful::RpcService for NodeService {
     );
     rpc_service_impl!(respond_snark_pool_get, RpcSnarkPoolGetResponse);
     rpc_service_impl!(respond_snark_pool_job_get, RpcSnarkPoolJobGetResponse);
+    rpc_service_impl!(
+        respond_snark_pool_completed_jobs_get,
+        RpcSnarkPoolCompletedJobsResponse
+    );
     rpc_service_impl!(respond_snarker_job_commit, RpcSnarkerJobCommitResponse);
     rpc_service_impl!(
         respond_snarker_job_spec,

node/native/src/graphql/mod.rs

@@ -1,4 +1,4 @@
-use block::{GraphQLBlock, GraphQLUserCommands};
+use block::{GraphQLBlock, GraphQLSnarkJob, GraphQLUserCommands};
 use juniper::{graphql_value, EmptySubscription, FieldError, GraphQLEnum, RootNode};
 use ledger::Account;
 use mina_p2p_messages::v2::{
@@ -405,6 +405,19 @@ impl Query {
             just_emitted_a_proof: false,
         })?)
     }
+
+    async fn snark_pool(context: &Context) -> juniper::FieldResult<Vec<GraphQLSnarkJob>> {
+        let jobs: RpcSnarkPoolCompletedJobsResponse = context
+            .0
+            .oneshot_request(RpcRequest::SnarkPoolCompletedJobsGet)
+            .await
+            .ok_or(Error::StateMachineEmptyResponse)?;
+
+        Ok(jobs
+            .iter()
+            .map(GraphQLSnarkJob::from)
+            .collect())
+    }
 }
 
 async fn inject_tx<R>(

node/src/action_kind.rs

@@ -503,6 +503,7 @@ pub enum ActionKind {
     RpcScanStateSummaryGetSuccess,
     RpcScanStateSummaryLedgerGetInit,
     RpcSnarkPoolAvailableJobsGet,
+    RpcSnarkPoolCompletedJobsGet,
     RpcSnarkPoolJobGet,
     RpcSnarkerConfigGet,
     RpcSnarkerJobCommit,
@@ -542,6 +543,7 @@ pub enum ActionKind {
     RpcEffectfulReadinessCheck,
     RpcEffectfulScanStateSummaryGetSuccess,
     RpcEffectfulSnarkPoolAvailableJobsGet,
+    RpcEffectfulSnarkPoolCompletedJobsGet,
     RpcEffectfulSnarkPoolJobGet,
     RpcEffectfulSnarkerConfigGet,
     RpcEffectfulSnarkerJobCommit,
@@ -724,7 +726,7 @@ pub enum ActionKind {
 }
 
 impl ActionKind {
-    pub const COUNT: u16 = 614;
+    pub const COUNT: u16 = 616;
 }
 
 impl std::fmt::Display for ActionKind {
@@ -1070,6 +1072,7 @@ impl ActionKindGet for RpcAction {
             Self::ScanStateSummaryGetSuccess { .. } => ActionKind::RpcScanStateSummaryGetSuccess,
             Self::SnarkPoolAvailableJobsGet { .. } => ActionKind::RpcSnarkPoolAvailableJobsGet,
             Self::SnarkPoolJobGet { .. } => ActionKind::RpcSnarkPoolJobGet,
+            Self::SnarkPoolCompletedJobsGet { .. } => ActionKind::RpcSnarkPoolCompletedJobsGet,
             Self::SnarkerConfigGet { .. } => ActionKind::RpcSnarkerConfigGet,
             Self::SnarkerJobCommit { .. } => ActionKind::RpcSnarkerJobCommit,
             Self::SnarkerJobSpec { .. } => ActionKind::RpcSnarkerJobSpec,
@@ -1135,6 +1138,9 @@ impl ActionKindGet for RpcEffectfulAction {
                 ActionKind::RpcEffectfulSnarkPoolAvailableJobsGet
             }
             Self::SnarkPoolJobGet { .. } => ActionKind::RpcEffectfulSnarkPoolJobGet,
+            Self::SnarkPoolCompletedJobsGet { .. } => {
+                ActionKind::RpcEffectfulSnarkPoolCompletedJobsGet
+            }
             Self::SnarkerConfigGet { .. } => ActionKind::RpcEffectfulSnarkerConfigGet,
             Self::SnarkerJobCommit { .. } => ActionKind::RpcEffectfulSnarkerJobCommit,
             Self::SnarkerJobSpec { .. } => ActionKind::RpcEffectfulSnarkerJobSpec,

node/src/event_source/event.rs

@@ -51,6 +51,7 @@ impl std::fmt::Display for Event {
                     RpcRequest::SnarkPoolJobGet { job_id } => {
                         write!(f, "SnarkPoolJobGet, {job_id}")
                     }
+                    RpcRequest::SnarkPoolCompletedJobsGet => write!(f, "SnarkPoolCompletedJobsGet"),
                     RpcRequest::SnarkerConfig => write!(f, "SnarkerConfig"),
                     RpcRequest::SnarkerJobCommit { job_id } => {
                         write!(f, "SnarkerJobCommit, {job_id}")

node/src/event_source/event_source_effects.rs

@@ -340,6 +340,9 @@ pub fn event_source_effects<S: Service>(store: &mut Store<S>, action: EventSourc
                 RpcRequest::SnarkPoolJobGet { job_id } => {
                     store.dispatch(RpcAction::SnarkPoolJobGet { rpc_id, job_id });
                 }
+                RpcRequest::SnarkPoolCompletedJobsGet => {
+                    store.dispatch(RpcAction::SnarkPoolCompletedJobsGet { rpc_id });
+                }
                 RpcRequest::SnarkerConfig => {
                     store.dispatch(RpcAction::SnarkerConfigGet { rpc_id });
                 }

node/src/rpc/mod.rs

@@ -14,6 +14,7 @@ use mina_p2p_messages::v2::{
     MinaBaseTransactionStatusStableV2, MinaBaseUserCommandStableV2,
     MinaBaseZkappCommandTStableV1WireStableV1, MinaTransactionTransactionStableV2,
     SnarkWorkerWorkerRpcsVersionedGetWorkV2TResponse, StateHash, TransactionHash,
+    TransactionSnarkWorkTStableV2,
 };
 use openmina_core::block::{AppliedBlock, ArcBlockWithHash};
 use openmina_core::consensus::ConsensusConstants;
@@ -72,6 +73,7 @@ pub enum RpcRequest {
     ScanStateSummaryGet(RpcScanStateSummaryGetQuery),
     SnarkPoolGet,
     SnarkPoolJobGet { job_id: SnarkJobId },
+    SnarkPoolCompletedJobsGet,
     SnarkerConfig,
     SnarkerJobCommit { job_id: SnarkJobId },
     SnarkerJobSpec { job_id: SnarkJobId },
@@ -362,6 +364,7 @@ pub type RpcPeersGetResponse = Vec<RpcPeerInfo>;
 pub type RpcP2pConnectionOutgoingResponse = Result<(), String>;
 pub type RpcScanStateSummaryGetResponse = Result<RpcScanStateSummary, String>;
 pub type RpcSnarkPoolGetResponse = Vec<RpcSnarkPoolJobSummary>;
+pub type RpcSnarkPoolCompletedJobsResponse = Vec<TransactionSnarkWorkTStableV2>;
 pub type RpcSnarkPoolJobGetResponse = Option<RpcSnarkPoolJobFull>;
 pub type RpcSnarkerConfigGetResponse = Option<RpcSnarkerConfig>;
 pub type RpcTransactionPoolResponse = Vec<ValidCommandWithHash>;

node/src/rpc/rpc_actions.rs

@@ -115,7 +115,9 @@ pub enum RpcAction {
         job_id: SnarkWorkId,
         rpc_id: RpcId,
     },
-
+    SnarkPoolCompletedJobsGet {
+        rpc_id: RpcId,
+    },
     SnarkerConfigGet {
         rpc_id: RpcId,
     },
@@ -306,6 +308,7 @@ impl redux::EnablingCondition<crate::State> for RpcAction {
                 .is_some_and(|v| v.status.is_pending()),
             RpcAction::SnarkPoolAvailableJobsGet { .. } => true,
             RpcAction::SnarkPoolJobGet { .. } => true,
+            RpcAction::SnarkPoolCompletedJobsGet { .. } => true,
             RpcAction::SnarkerConfigGet { .. } => true,
             RpcAction::SnarkerJobCommit { .. } => true,
             RpcAction::SnarkerJobSpec { .. } => true,

node/src/rpc/rpc_reducer.rs

@@ -1,6 +1,6 @@
 use ledger::scan_state::transaction_logic::valid;
 use mina_p2p_messages::v2::{
-    MinaBaseSignedCommandStableV2, MinaBaseZkappCommandTStableV1WireStableV1, NonZeroCurvePoint,
+    MinaBaseSignedCommandStableV2, MinaBaseZkappCommandTStableV1WireStableV1, NonZeroCurvePoint, TransactionSnarkWorkTStableV2,
 };
 use openmina_core::{
     block::AppliedBlock,
@@ -331,6 +331,20 @@ impl RpcState {
                     job_id: job_id.clone(),
                 });
             }
+            RpcAction::SnarkPoolCompletedJobsGet { rpc_id } => {
+                let (dispatcher, state) = state_context.into_dispatcher_and_state();
+
+                let jobs = state
+                    .snark_pool
+                    .completed_snarks_iter()
+                    .map(|s| TransactionSnarkWorkTStableV2::from(s.clone()))
+                    .collect::<Vec<_>>();
+
+                dispatcher.push(RpcEffectfulAction::SnarkPoolCompletedJobsGet {
+                    rpc_id: *rpc_id,
+                    jobs,
+                });
+            }
             RpcAction::SnarkerConfigGet { rpc_id } => {
                 let (dispatcher, state) = state_context.into_dispatcher_and_state();
 

node/src/rpc_effectful/rpc_effectful_action.rs

@@ -4,9 +4,9 @@ use crate::{
     rpc::{
         discovery::RpcDiscoveryRoutingTable, AccountQuery, ActionStatsQuery, RpcBestChainResponse,
         RpcGenesisBlockResponse, RpcGetBlockResponse, RpcPeerInfo, RpcPooledUserCommandsResponse,
-        RpcPooledZkappCommandsResponse, RpcScanStateSummaryScanStateJob, RpcSnarkerConfig,
-        RpcTransactionInjectFailure, RpcTransactionInjectRejected, RpcTransactionInjectSuccess,
-        SyncStatsQuery,
+        RpcPooledZkappCommandsResponse, RpcScanStateSummaryScanStateJob,
+        RpcSnarkPoolCompletedJobsResponse, RpcSnarkerConfig, RpcTransactionInjectFailure,
+        RpcTransactionInjectRejected, RpcTransactionInjectSuccess, SyncStatsQuery,
     },
 };
 use ledger::{
@@ -80,6 +80,10 @@ pub enum RpcEffectfulAction {
         job_id: SnarkWorkId,
         rpc_id: RpcId,
     },
+    SnarkPoolCompletedJobsGet {
+        rpc_id: RpcId,
+        jobs: RpcSnarkPoolCompletedJobsResponse,
+    },
     SnarkerConfigGet {
         rpc_id: RpcId,
         config: Option<RpcSnarkerConfig>,