Latest gas price endpoint

CHANGELOG.md

@@ -10,6 +10,7 @@ Description of the upcoming release here.
 
 ### Changed
 
+- [#1649](https://github.com/FuelLabs/fuel-core/pull/1649): Add api endpoint for getting latest gas price
 - [#1600](https://github.com/FuelLabs/fuel-core/pull/1640): Upgrade to fuel-vm 0.45.0
 - [#1633](https://github.com/FuelLabs/fuel-core/pull/1633): Notify services about importing of the genesis block.
 - [#1625](https://github.com/FuelLabs/fuel-core/pull/1625): Making relayer independent from the executor and preparation for the force transaction inclusion.

crates/client/assets/schema.sdl

@@ -518,6 +518,11 @@ type InputMessage {
 }
 
 
+type LatestGasPrice {
+	gasPrice: U64!
+	blockHeight: U32!
+}
+
 type LightOperation {
 	base: U64!
 	unitsPerGas: U64!
@@ -806,6 +811,7 @@ type Query {
 	contractBalance(contract: ContractId!, asset: AssetId!): ContractBalance!
 	contractBalances(filter: ContractBalanceFilterInput!, first: Int, after: String, last: Int, before: String): ContractBalanceConnection!
 	nodeInfo: NodeInfo!
+	latestGasPrice: LatestGasPrice!
 	message(nonce: Nonce!): Message
 	messages(owner: Address, first: Int, after: String, last: Int, before: String): MessageConnection!
 	messageProof(transactionId: TransactionId!, nonce: Nonce!, commitBlockId: BlockId, commitBlockHeight: U32): MessageProof

crates/client/src/client.rs

@@ -12,6 +12,7 @@ use crate::client::{
         TransactionId,
     },
     types::{
+        gas_price::LatestGasPrice,
         message::MessageStatus,
         primitives::{
             Address,
@@ -348,6 +349,11 @@ impl FuelClient {
         self.query(query).await.map(|r| r.node_info.into())
     }
 
+    pub async fn latest_gas_price(&self) -> io::Result<LatestGasPrice> {
+        let query = schema::gas_price::QueryLatestGasPrice::build(());
+        self.query(query).await.map(|r| r.latest_gas_price.into())
+    }
+
     pub async fn connected_peers_info(&self) -> io::Result<Vec<PeerInfo>> {
         let query = schema::node_info::QueryPeersInfo::build(());
         self.query(query)

crates/client/src/client/schema.rs

@@ -33,6 +33,8 @@ pub mod coins;
 pub mod contract;
 pub mod message;
 pub mod node_info;
+
+pub mod gas_price;
 pub mod primitives;
 pub mod tx;
 

crates/client/src/client/schema/gas_price.rs

@@ -0,0 +1,30 @@
+use crate::client::schema::{
+    schema,
+    U32,
+    U64,
+};
+
+#[derive(cynic::QueryFragment, Debug)]
+#[cynic(schema_path = "./assets/schema.sdl")]
+pub struct LatestGasPrice {
+    pub gas_price: U64,
+    pub block_height: U32,
+}
+
+#[derive(cynic::QueryFragment, Debug)]
+#[cynic(schema_path = "./assets/schema.sdl", graphql_type = "Query")]
+pub struct QueryLatestGasPrice {
+    pub latest_gas_price: LatestGasPrice,
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[test]
+    fn latest_gas_price_query_gql_output() {
+        use cynic::QueryBuilder;
+        let operation = QueryLatestGasPrice::build(());
+        insta::assert_snapshot!(operation.query)
+    }
+}

crates/client/src/client/schema/snapshots/fuel_core_client__client__schema__gas_price__tests__latest_gas_price_query_gql_output.snap

@@ -0,0 +1,12 @@
+---
+source: crates/client/src/client/schema/gas_price.rs
+expression: operation.query
+---
+query {
+  latestGasPrice {
+    gasPrice
+    blockHeight
+  }
+}
+
+

crates/client/src/client/types.rs

@@ -4,6 +4,8 @@ pub mod chain_info;
 pub mod coins;
 pub mod contract;
 pub mod gas_costs;
+
+pub mod gas_price;
 pub mod merkle_proof;
 pub mod message;
 pub mod node_info;

crates/client/src/client/types/gas_price.rs

@@ -0,0 +1,16 @@
+use crate::client::schema;
+
+pub struct LatestGasPrice {
+    pub gas_price: u64,
+    pub block_height: u32,
+}
+
+// GraphQL Translation
+impl From<schema::gas_price::LatestGasPrice> for LatestGasPrice {
+    fn from(value: schema::gas_price::LatestGasPrice) -> Self {
+        Self {
+            gas_price: value.gas_price.into(),
+            block_height: value.block_height.into(),
+        }
+    }
+}

crates/fuel-core/src/schema.rs

@@ -28,6 +28,8 @@ pub mod dap;
 pub mod health;
 pub mod message;
 pub mod node_info;
+
+pub mod gas_price;
 pub mod scalars;
 pub mod tx;
 
@@ -43,6 +45,7 @@ pub struct Query(
     contract::ContractQuery,
     contract::ContractBalanceQuery,
     node_info::NodeQuery,
+    gas_price::LatestGasPriceQuery,
     message::MessageQuery,
 );
 

crates/fuel-core/src/schema/gas_price.rs

@@ -0,0 +1,54 @@
+use super::scalars::{
+    U32,
+    U64,
+};
+use crate::{
+    fuel_core_graphql_api::{
+        database::ReadView,
+        Config as GraphQLConfig,
+    },
+    query::BlockQueryData,
+};
+use async_graphql::{
+    Context,
+    Object,
+};
+use fuel_core_types::blockchain::block::Block;
+
+pub struct LatestGasPrice {
+    pub gas_price: U64,
+    pub block_height: U32,
+}
+
+#[Object]
+impl LatestGasPrice {
+    async fn gas_price(&self) -> U64 {
+        self.gas_price
+    }
+
+    async fn block_height(&self) -> U32 {
+        self.block_height
+    }
+}
+
+#[derive(Default)]
+pub struct LatestGasPriceQuery {}
+
+#[Object]
+impl LatestGasPriceQuery {
+    async fn latest_gas_price(
+        &self,
+        ctx: &Context<'_>,
+    ) -> async_graphql::Result<LatestGasPrice> {
+        let config = ctx.data_unchecked::<GraphQLConfig>();
+
+        let query: &ReadView = ctx.data_unchecked();
+        let latest_block: Block<_> = query.latest_block()?;
+        let block_height = u32::from(*latest_block.header().height());
+
+        Ok(LatestGasPrice {
+            gas_price: config.min_gas_price.into(),
+            block_height: block_height.into(),
+        })
+    }
+}

tests/tests/gas_price.rs

@@ -0,0 +1,18 @@
+use fuel_core::service::{
+    Config,
+    FuelService,
+};
+use fuel_core_client::client::{
+    types::gas_price::LatestGasPrice,
+    FuelClient,
+};
+
+#[tokio::test]
+async fn latest_gas_price() {
+    let node_config = Config::local_node();
+    let srv = FuelService::new_node(node_config.clone()).await.unwrap();
+    let client = FuelClient::from(srv.bound_address);
+
+    let LatestGasPrice { gas_price, .. } = client.latest_gas_price().await.unwrap();
+    assert_eq!(gas_price, node_config.txpool.min_gas_price);
+}

tests/tests/lib.rs

@@ -11,6 +11,8 @@ mod dap;
 mod debugger;
 mod deployment;
 mod fee_collection_contract;
+
+mod gas_price;
 mod health;
 mod helpers;
 mod messages;