[graphql/rpc] Protocol config impl (MystenLabs#13402)

crates/sui-graphql-rpc/schema/draft_schema.graphql

@@ -421,15 +421,22 @@ type Epoch {
 
 type ProtocolConfigs {
   protocolVersion: Int!
-  configs: [ProtocolConfig]
-  config(key: String!): ProtocolConfig
+  featureFlags: [ProtocolConfigFeatureFlag]
+  configs: [ProtocolConfigAttr]
+  config(key: String!): ProtocolConfigAttr
+  featureFlag(key: String!): ProtocolConfigFeatureFlag
 }
 
-type ProtocolConfig {
+type ProtocolConfigAttr {
   key: String!
   value: String!
 }
 
+type ProtocolConfigFeatureFlag {
+  key: String!
+  value: Boolean!
+}
+
 type SystemParameters {
   durationMs: BigInt
   stakeSubsidyStartEpoch: Int

crates/sui-graphql-rpc/src/server/data_provider.rs

@@ -9,6 +9,9 @@ use crate::types::base64::Base64;
 use crate::types::big_int::BigInt;
 use crate::types::object::ObjectFilter;
 use crate::types::object::ObjectKind;
+use crate::types::protocol_config::ProtocolConfigAttr;
+use crate::types::protocol_config::ProtocolConfigFeatureFlag;
+use crate::types::protocol_config::ProtocolConfigs;
 use crate::types::transaction_block::TransactionBlock;
 use crate::types::{object::Object, sui_address::SuiAddress};
 use async_graphql::connection::{Connection, Edge};
@@ -172,6 +175,41 @@ pub(crate) async fn fetch_chain_id(cl: &SuiClient) -> Result<String> {
     Ok(cl.read_api().get_chain_identifier().await?)
 }
 
+pub(crate) async fn fetch_protocol_config(
+    cl: &SuiClient,
+    version: Option<u64>,
+) -> Result<ProtocolConfigs> {
+    let cfg = cl
+        .read_api()
+        .get_protocol_config(version.map(|x| x.into()))
+        .await?;
+
+    Ok(ProtocolConfigs {
+        configs: cfg
+            .attributes
+            .into_iter()
+            .map(|(k, v)| ProtocolConfigAttr {
+                key: k,
+                // TODO:  what to return when value is None? nothing?
+                // TODO: do we want to return type info separately?
+                value: match v {
+                    Some(q) => format!("{:?}", q),
+                    None => "".to_string(),
+                },
+            })
+            .collect(),
+        feature_flags: cfg
+            .feature_flags
+            .into_iter()
+            .map(|x| ProtocolConfigFeatureFlag {
+                key: x.0,
+                value: x.1,
+            })
+            .collect(),
+        protocol_version: cfg.protocol_version.as_u64(),
+    })
+}
+
 fn convert_bal(b: sui_json_rpc_types::Balance) -> Balance {
     Balance {
         coin_object_count: b.coin_object_count as u64,

crates/sui-graphql-rpc/src/types/display.rs

@@ -0,0 +1,10 @@
+// Copyright (c) Mysten Labs, Inc.
+// SPDX-License-Identifier: Apache-2.0
+
+use async_graphql::*;
+
+#[derive(Clone, Debug, PartialEq, Eq, SimpleObject)]
+pub(crate) struct DisplayEntry {
+    pub key: String,
+    pub value: String,
+}

crates/sui-graphql-rpc/src/types/gas.rs

@@ -0,0 +1,29 @@
+// Copyright (c) Mysten Labs, Inc.
+// SPDX-License-Identifier: Apache-2.0
+
+use crate::types::object::Object;
+use async_graphql::*;
+
+use super::{address::Address, big_int::BigInt};
+
+#[derive(Clone, Debug, PartialEq, Eq, SimpleObject)]
+pub(crate) struct GasInput {
+    pub gas_sponsor: Option<Address>,
+    pub gas_payment: Option<Vec<Object>>,
+    pub gas_price: Option<BigInt>,
+    pub gas_budget: Option<BigInt>,
+}
+
+#[derive(Clone, Debug, PartialEq, Eq, SimpleObject)]
+pub(crate) struct GasCostSummary {
+    pub computation_cost: Option<BigInt>,
+    pub storage_cost: Option<BigInt>,
+    pub storage_rebate: Option<BigInt>,
+    pub non_refundable_storage_fee: Option<BigInt>,
+}
+
+#[derive(Clone, Debug, PartialEq, Eq, SimpleObject)]
+pub(crate) struct GasEffects {
+    pub gas_object: Option<Object>,
+    pub gas_summary: Option<GasCostSummary>,
+}

crates/sui-graphql-rpc/src/types/mod.rs

@@ -7,9 +7,12 @@ pub(crate) mod base64;
 pub(crate) mod big_int;
 pub(crate) mod coin;
 pub(crate) mod date_time;
+pub(crate) mod display;
+pub(crate) mod gas;
 pub(crate) mod name_service;
 pub(crate) mod object;
 pub(crate) mod owner;
+pub(crate) mod protocol_config;
 pub(crate) mod query;
 pub(crate) mod stake;
 pub(crate) mod sui_address;

crates/sui-graphql-rpc/src/types/object.rs

@@ -17,6 +17,7 @@ use crate::{
     types::base64::Base64,
 };
 
+#[derive(Clone, Eq, PartialEq, Debug)]
 pub(crate) struct Object {
     pub address: SuiAddress,
     pub version: u64,

crates/sui-graphql-rpc/src/types/protocol_config.rs

@@ -0,0 +1,83 @@
+// Copyright (c) Mysten Labs, Inc.
+// SPDX-License-Identifier: Apache-2.0
+
+use async_graphql::*;
+
+use crate::server::data_provider::fetch_protocol_config;
+
+#[derive(Clone, Debug, PartialEq, Eq, SimpleObject)]
+pub(crate) struct ProtocolConfigAttr {
+    pub key: String,
+    pub value: String,
+}
+
+#[derive(Clone, Debug, PartialEq, Eq, SimpleObject)]
+pub(crate) struct ProtocolConfigFeatureFlag {
+    pub key: String,
+    pub value: bool,
+}
+
+#[derive(Clone, Debug, PartialEq, Eq)]
+pub(crate) struct ProtocolConfigs {
+    pub configs: Vec<ProtocolConfigAttr>,
+    pub feature_flags: Vec<ProtocolConfigFeatureFlag>,
+    pub protocol_version: u64,
+}
+
+#[allow(unreachable_code)]
+#[allow(unused_variables)]
+#[Object]
+impl ProtocolConfigs {
+    async fn configs(&self, ctx: &Context<'_>) -> Result<Option<Vec<ProtocolConfigAttr>>> {
+        Ok(Some(
+            fetch_protocol_config(ctx.data_unchecked::<sui_sdk::SuiClient>(), None)
+                .await?
+                .configs,
+        ))
+    }
+
+    async fn feature_flags(
+        &self,
+        ctx: &Context<'_>,
+    ) -> Result<Option<Vec<ProtocolConfigFeatureFlag>>> {
+        Ok(Some(
+            fetch_protocol_config(ctx.data_unchecked::<sui_sdk::SuiClient>(), None)
+                .await?
+                .feature_flags,
+        ))
+    }
+
+    async fn protocol_version(&self, ctx: &Context<'_>) -> Result<u64> {
+        Ok(
+            fetch_protocol_config(ctx.data_unchecked::<sui_sdk::SuiClient>(), None)
+                .await?
+                .protocol_version,
+        )
+    }
+
+    async fn config(&self, ctx: &Context<'_>, key: String) -> Result<Option<ProtocolConfigAttr>> {
+        match self
+            .configs(ctx)
+            .await?
+            .map(|configs| configs.into_iter().find(|config| config.key == key))
+        {
+            Some(config) => Ok(config),
+            None => Ok(None),
+        }
+    }
+
+    async fn feature_flag(
+        &self,
+        ctx: &Context<'_>,
+        key: String,
+    ) -> Result<Option<ProtocolConfigFeatureFlag>> {
+        match self
+            .feature_flags(ctx)
+            .await?
+            .map(|flags| flags.into_iter().find(|config| config.key == key))
+        {
+            Some(config) => Ok(config),
+            None => Ok(None),
+        }
+    }
+}

crates/sui-graphql-rpc/src/types/query.rs

@@ -3,7 +3,10 @@
 
 use async_graphql::*;
 
-use super::{address::Address, object::Object, owner::ObjectOwner, sui_address::SuiAddress};
+use super::{
+    address::Address, object::Object, owner::ObjectOwner, protocol_config::ProtocolConfigs,
+    sui_address::SuiAddress,
+};
 use crate::server::data_provider::fetch_chain_id;
 
 pub(crate) struct Query;
@@ -38,4 +41,13 @@ impl Query {
     async fn address(&self, address: SuiAddress) -> Option<Address> {
         Some(Address { address })
     }
+
+    async fn protocol_config(
+        &self,
+        ctx: &Context<'_>,
+        protocol_version: Option<u64>,
+    ) -> Result<ProtocolConfigs> {
+        let cl = ctx.data_unchecked::<sui_sdk::SuiClient>();
+        crate::server::data_provider::fetch_protocol_config(cl, protocol_version).await
+    }
 }

crates/sui-graphql-rpc/tests/snapshots/snapshot_tests__test__schema_sdl_export.snap

@@ -155,11 +155,30 @@ type PageInfo {
 	endCursor: String
 }
 
+type ProtocolConfigAttr {
+	key: String!
+	value: String!
+}
+
+type ProtocolConfigFeatureFlag {
+	key: String!
+	value: Boolean!
+}
+
+type ProtocolConfigs {
+	configs: [ProtocolConfigAttr!]
+	featureFlags: [ProtocolConfigFeatureFlag!]
+	protocolVersion: Int!
+	config(key: String!): ProtocolConfigAttr
+	featureFlag(key: String!): ProtocolConfigFeatureFlag
+}
+
 type Query {
 	chainIdentifier: String!
 	owner(address: SuiAddress!): ObjectOwner
 	object(address: SuiAddress!, version: Int): Object
 	address(address: SuiAddress!): Address
+	protocolConfig(protocolVersion: Int): ProtocolConfigs!
 }
 
 type StakeConnection {