Merge pull request #1130 from 0xMimir/feat/graphql-current-snark-worker

Added 'currentSnarkWorker' graphql endpoint

Author: adonagy

node/native/src/graphql/mod.rs

@@ -6,6 +6,8 @@ use mina_p2p_messages::v2::{
     conv, LedgerHash, MinaBaseSignedCommandStableV2, MinaBaseUserCommandStableV2,
     MinaBaseZkappCommandTStableV1WireStableV1, TokenIdKeyHash, TransactionHash,
 };
+use mina_signer::CompressedPubKey;
+use node::rpc::RpcSnarkerConfig;
 use node::{
     account::AccountPublicKey,
     ledger::read::LedgerStatus,
@@ -26,7 +28,7 @@ use openmina_core::{
     NetworkConfig,
 };
 use openmina_node_common::rpc::RpcSender;
-use snark::GraphQLPendingSnarkWork;
+use snark::{GraphQLPendingSnarkWork, GraphQLSnarkWorker};
 use std::str::FromStr;
 use tokio::sync::OnceCell;
 use transaction::GraphQLTransactionStatus;
@@ -41,6 +43,9 @@ pub mod transaction;
 pub mod user_command;
 pub mod zkapp;
 
+/// Base58 encoded public key
+pub type GraphQLPublicKey = String;
+
 #[derive(Debug, thiserror::Error)]
 pub enum Error {
     #[error("Conversion error: {0}")]
@@ -534,6 +539,34 @@ impl Query {
         let res = BuildEnv::get().git.commit_hash;
         Ok(res)
     }
+
+    async fn current_snark_worker(
+        &self,
+        context: &Context,
+    ) -> juniper::FieldResult<Option<GraphQLSnarkWorker>> {
+        let config: Option<RpcSnarkerConfig> = context
+            .rpc_sender
+            .oneshot_request(RpcRequest::SnarkerConfig)
+            .await
+            .ok_or(Error::StateMachineEmptyResponse)?;
+
+        let Some(config) = config else {
+            return Ok(None);
+        };
+
+        let account = context
+            .load_account(AccountId {
+                public_key: CompressedPubKey::try_from(&config.public_key)?,
+                token_id: TokenIdKeyHash::default().into(),
+            })
+            .await;
+
+        Ok(Some(GraphQLSnarkWorker {
+            key: config.public_key.to_string(),
+            account,
+            fee: config.fee.to_string(),
+        }))
+    }
 }
 
 async fn inject_tx<R>(

node/native/src/graphql/snark.rs

@@ -1,12 +1,12 @@
-use juniper::GraphQLObject;
+use juniper::{graphql_object, GraphQLObject};
 use ledger::scan_state::scan_state::{AvailableJobMessage, ParallelScanAvailableJob};
 use mina_p2p_messages::v2::{
     MinaBaseFeeExcessStableV1, MinaStateBlockchainStateValueStableV2SignedAmount,
     TransactionSnarkScanStateTransactionWithWitnessStableV2, TransactionSnarkStableV2,
 };
 use node::snark_pool::JobState;
 
-use super::ConversionError;
+use super::{account::GraphQLAccount, Context, ConversionError, GraphQLPublicKey};
 
 #[derive(GraphQLObject, Debug)]
 #[graphql(description = "A Mina block")]
@@ -149,3 +149,25 @@ impl TryFrom<TransactionSnarkStableV2> for GraphQLWorkDescription {
         })
     }
 }
+
+pub(crate) struct GraphQLSnarkWorker {
+    pub key: GraphQLPublicKey,
+    pub account: Option<GraphQLAccount>,
+    pub fee: String,
+}
+
+#[graphql_object(context = Context)]
+#[graphql(description = "A snark worker")]
+impl GraphQLSnarkWorker {
+    pub fn key(&self) -> String {
+        self.key.to_string()
+    }
+
+    pub fn fee(&self) -> String {
+        self.fee.to_string()
+    }
+
+    pub fn account(&self) -> Option<GraphQLAccount> {
+        self.account.clone()
+    }
+}