Merge pull request #1124 from 0xMimir/feat/graphql-genesis-block

Added graphql genesis block endpoint

Author: adonagy

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

@@ -9,12 +9,12 @@ pub mod transition_frontier;
 
 use node::rpc::{
     RpcBestChainResponse, RpcBlockProducerStatsGetResponse, RpcConsensusConstantsGetResponse,
-    RpcDiscoveryBoostrapStatsResponse, RpcDiscoveryRoutingTableResponse, RpcGetBlockResponse,
-    RpcHealthCheckResponse, RpcHeartbeatGetResponse, RpcLedgerAccountsResponse,
-    RpcLedgerSlimAccountsResponse, RpcMessageProgressResponse, RpcPeersGetResponse,
-    RpcPooledUserCommandsResponse, RpcPooledZkappCommandsResponse, RpcReadinessCheckResponse,
-    RpcRequest, RpcStateGetError, RpcStatusGetResponse, RpcTransactionInjectResponse,
-    RpcTransactionPoolResponse, RpcTransactionStatusGetResponse,
+    RpcDiscoveryBoostrapStatsResponse, RpcDiscoveryRoutingTableResponse, RpcGenesisBlockResponse,
+    RpcGetBlockResponse, RpcHealthCheckResponse, RpcHeartbeatGetResponse,
+    RpcLedgerAccountsResponse, RpcLedgerSlimAccountsResponse, RpcMessageProgressResponse,
+    RpcPeersGetResponse, RpcPooledUserCommandsResponse, RpcPooledZkappCommandsResponse,
+    RpcReadinessCheckResponse, RpcRequest, RpcStateGetError, RpcStatusGetResponse,
+    RpcTransactionInjectResponse, RpcTransactionPoolResponse, RpcTransactionStatusGetResponse,
     RpcTransitionFrontierUserCommandsResponse,
 };
 use serde::{Deserialize, Serialize};
@@ -315,6 +315,7 @@ impl node::rpc_effectful::RpcService for NodeService {
         respond_pooled_zkapp_commands,
         RpcPooledZkappCommandsResponse
     );
+    rpc_service_impl!(respond_genesis_block, RpcGenesisBlockResponse);
 }
 
 #[cfg(test)]

node/native/src/graphql/mod.rs

@@ -8,10 +8,10 @@ use mina_p2p_messages::v2::{
 use node::{
     account::AccountPublicKey,
     rpc::{
-        AccountQuery, GetBlockQuery, PooledCommandsQuery, RpcGetBlockResponse,
-        RpcPooledUserCommandsResponse, RpcPooledZkappCommandsResponse, RpcRequest,
-        RpcSyncStatsGetResponse, RpcTransactionInjectResponse, RpcTransactionStatusGetResponse,
-        SyncStatsQuery,
+        AccountQuery, GetBlockQuery, PooledCommandsQuery, RpcGenesisBlockResponse,
+        RpcGetBlockResponse, RpcPooledUserCommandsResponse, RpcPooledZkappCommandsResponse,
+        RpcRequest, RpcSyncStatsGetResponse, RpcTransactionInjectResponse,
+        RpcTransactionStatusGetResponse, SyncStatsQuery,
     },
     stats::sync::SyncKind,
 };
@@ -391,6 +391,20 @@ impl Query {
             .map(GraphQLZkapp::try_from)
             .collect::<Result<Vec<_>, _>>()?)
     }
+
+    async fn genesis_block(context: &Context) -> juniper::FieldResult<GraphQLBlock> {
+        let block = context
+            .0
+            .oneshot_request::<RpcGenesisBlockResponse>(RpcRequest::GenesisBlockGet)
+            .await
+            .ok_or(Error::StateMachineEmptyResponse)?
+            .ok_or(Error::StateMachineEmptyResponse)?;
+
+        Ok(GraphQLBlock::try_from(AppliedBlock {
+            block,
+            just_emitted_a_proof: false,
+        })?)
+    }
 }
 
 async fn inject_tx<R>(

node/src/action_kind.rs

@@ -476,6 +476,7 @@ pub enum ActionKind {
     RpcDiscoveryBoostrapStats,
     RpcDiscoveryRoutingTable,
     RpcFinish,
+    RpcGenesisBlock,
     RpcGlobalStateGet,
     RpcHealthCheck,
     RpcHeartbeatGet,
@@ -524,6 +525,7 @@ pub enum ActionKind {
     RpcEffectfulConsensusConstantsGet,
     RpcEffectfulDiscoveryBoostrapStats,
     RpcEffectfulDiscoveryRoutingTable,
+    RpcEffectfulGenesisBlock,
     RpcEffectfulGlobalStateGet,
     RpcEffectfulHealthCheck,
     RpcEffectfulHeartbeatGet,
@@ -722,7 +724,7 @@ pub enum ActionKind {
 }
 
 impl ActionKind {
-    pub const COUNT: u16 = 612;
+    pub const COUNT: u16 = 614;
 }
 
 impl std::fmt::Display for ActionKind {
@@ -1094,6 +1096,7 @@ impl ActionKindGet for RpcAction {
             Self::BlockGet { .. } => ActionKind::RpcBlockGet,
             Self::PooledUserCommands { .. } => ActionKind::RpcPooledUserCommands,
             Self::PooledZkappCommands { .. } => ActionKind::RpcPooledZkappCommands,
+            Self::GenesisBlock { .. } => ActionKind::RpcGenesisBlock,
             Self::Finish { .. } => ActionKind::RpcFinish,
         }
     }
@@ -1162,6 +1165,7 @@ impl ActionKindGet for RpcEffectfulAction {
             Self::BlockGet { .. } => ActionKind::RpcEffectfulBlockGet,
             Self::PooledUserCommands { .. } => ActionKind::RpcEffectfulPooledUserCommands,
             Self::PooledZkappCommands { .. } => ActionKind::RpcEffectfulPooledZkappCommands,
+            Self::GenesisBlock { .. } => ActionKind::RpcEffectfulGenesisBlock,
         }
     }
 }

node/src/event_source/event.rs

@@ -75,6 +75,7 @@ impl std::fmt::Display for Event {
                     RpcRequest::GetBlock(..) => write!(f, "GetBlock"),
                     RpcRequest::PooledUserCommands(..) => write!(f, "PooledUserCommands"),
                     RpcRequest::PooledZkappCommands(..) => write!(f, "PooledZkappCommands"),
+                    RpcRequest::GenesisBlockGet => write!(f, "GenesisBlock"),
                 }
             }
             Self::ExternalSnarkWorker(event) => {

node/src/event_source/event_source_effects.rs

@@ -397,6 +397,9 @@ pub fn event_source_effects<S: Service>(store: &mut Store<S>, action: EventSourc
                 RpcRequest::PooledZkappCommands(query) => {
                     store.dispatch(RpcAction::PooledZkappCommands { rpc_id, query });
                 }
+                RpcRequest::GenesisBlockGet => {
+                    store.dispatch(RpcAction::GenesisBlock { rpc_id });
+                }
             },
             Event::ExternalSnarkWorker(e) => match e {
                 ExternalSnarkWorkerEvent::Started => {

node/src/rpc/mod.rs

@@ -15,7 +15,7 @@ use mina_p2p_messages::v2::{
     MinaBaseZkappCommandTStableV1WireStableV1, MinaTransactionTransactionStableV2,
     SnarkWorkerWorkerRpcsVersionedGetWorkV2TResponse, StateHash, TransactionHash,
 };
-use openmina_core::block::AppliedBlock;
+use openmina_core::block::{AppliedBlock, ArcBlockWithHash};
 use openmina_core::consensus::ConsensusConstants;
 use openmina_node_account::AccountPublicKey;
 use p2p::bootstrap::P2pNetworkKadBootstrapStats;
@@ -90,6 +90,7 @@ pub enum RpcRequest {
     GetBlock(GetBlockQuery),
     PooledUserCommands(PooledUserCommandsQuery),
     PooledZkappCommands(PooledZkappsCommandsQuery),
+    GenesisBlockGet,
 }
 
 pub type MaxLength = u32;
@@ -372,6 +373,7 @@ pub type RpcConsensusConstantsGetResponse = ConsensusConstants;
 pub type RpcTransactionStatusGetResponse = TransactionStatus;
 pub type RpcPooledUserCommandsResponse = Vec<MinaBaseSignedCommandStableV2>;
 pub type RpcPooledZkappCommandsResponse = Vec<MinaBaseZkappCommandTStableV1WireStableV1>;
+pub type RpcGenesisBlockResponse = Option<ArcBlockWithHash>;
 
 #[derive(Serialize, Deserialize, Debug, Clone, strum_macros::Display)]
 #[strum(serialize_all = "SCREAMING_SNAKE_CASE")]

node/src/rpc/rpc_actions.rs

@@ -219,6 +219,9 @@ pub enum RpcAction {
         rpc_id: RpcId,
         query: PooledZkappsCommandsQuery,
     },
+    GenesisBlock {
+        rpc_id: RpcId,
+    },
 
     Finish {
         rpc_id: RpcId,
@@ -317,6 +320,7 @@ impl redux::EnablingCondition<crate::State> for RpcAction {
             RpcAction::TransactionStatusGet { .. } => true,
             RpcAction::PooledUserCommands { .. } => true,
             RpcAction::PooledZkappCommands { .. } => true,
+            RpcAction::GenesisBlock { .. } => true,
             RpcAction::LedgerAccountsGetInit { .. } => {
                 state.transition_frontier.best_tip().is_some()
             }

node/src/rpc/rpc_reducer.rs

@@ -696,6 +696,14 @@ impl RpcState {
                     user_commands: user_commands.into_iter().map(|(_, tx)| tx).collect(),
                 });
             }
+            RpcAction::GenesisBlock { rpc_id } => {
+                let (dispatcher, state) = state_context.into_dispatcher_and_state();
+                let genesis_block = state.genesis_block();
+                dispatcher.push(RpcEffectfulAction::GenesisBlock {
+                    rpc_id: *rpc_id,
+                    genesis_block,
+                });
+            }
             RpcAction::PooledZkappCommands { rpc_id, query } => {
                 let (dispatcher, state) = state_context.into_dispatcher_and_state();
 

node/src/rpc_effectful/rpc_effectful_action.rs

@@ -3,7 +3,7 @@ use crate::{
     p2p::connection::P2pConnectionResponse,
     rpc::{
         discovery::RpcDiscoveryRoutingTable, AccountQuery, ActionStatsQuery, RpcBestChainResponse,
-        RpcGetBlockResponse, RpcPeerInfo, RpcPooledUserCommandsResponse,
+        RpcGenesisBlockResponse, RpcGetBlockResponse, RpcPeerInfo, RpcPooledUserCommandsResponse,
         RpcPooledZkappCommandsResponse, RpcScanStateSummaryScanStateJob, RpcSnarkerConfig,
         RpcTransactionInjectFailure, RpcTransactionInjectRejected, RpcTransactionInjectSuccess,
         SyncStatsQuery,
@@ -160,6 +160,10 @@ pub enum RpcEffectfulAction {
         rpc_id: RpcId,
         zkapp_commands: RpcPooledZkappCommandsResponse,
     },
+    GenesisBlock {
+        rpc_id: RpcId,
+        genesis_block: RpcGenesisBlockResponse,
+    },
 }
 
 impl redux::EnablingCondition<crate::State> for RpcEffectfulAction {

node/src/rpc_effectful/rpc_effectful_effects.rs

@@ -799,6 +799,15 @@ pub fn rpc_effects<S: Service>(store: &mut Store<S>, action: ActionWithMeta<RpcE
                 meta.time()
             )
         }
+        RpcEffectfulAction::GenesisBlock {
+            rpc_id,
+            genesis_block,
+        } => {
+            respond_or_log!(
+                store.service().respond_genesis_block(rpc_id, genesis_block),
+                meta.time()
+            )
+        }
     }
 }