Implement gas price updater for service

CHANGELOG.md

@@ -6,6 +6,10 @@ and this project adheres to [Semantic Versioning](http://semver.org/).
 
 ## [Unreleased]
 
+### Added
+- [1972](https://github.com/FuelLabs/fuel-core/pull/1972): Implement `AlgorithmUpdater` for `GasPriceService`
+- [#1948](https://github.com/FuelLabs/fuel-core/pull/1948): Add new `AlgorithmV1` and `AlgorithmUpdaterV1` for the gas price. Include tools for analysis
+
 ## [Version 0.30.0]
 
 ### Added
@@ -25,7 +29,6 @@ and this project adheres to [Semantic Versioning](http://semver.org/).
 
 ### Added
 - [#1889](https://github.com/FuelLabs/fuel-core/pull/1889): Add new `FuelGasPriceProvider` that receives the gas price algorithm from a `GasPriceService`
-- [#1948](https://github.com/FuelLabs/fuel-core/pull/1948): Add new `AlgorithmV1` and `AlgorithmUpdaterV1' for the gas price. Include tools for analysis
 
 ### Changed
 - [#1942](https://github.com/FuelLabs/fuel-core/pull/1942): Sequential relayer's commits.

crates/fuel-gas-price-algorithm/src/lib.rs

@@ -46,6 +46,7 @@ pub enum Error {
 /// The DA portion also uses a moving average of the profits over the last `avg_window` blocks
 /// instead of the actual profit. Setting the `avg_window` to 1 will effectively disable the
 /// moving average.
+#[derive(Debug, Clone, PartialEq)]
 pub struct AlgorithmV1 {
     /// The lowest the algorithm allows the gas price to go
     min_da_gas_price: u64,
@@ -140,6 +141,7 @@ impl AlgorithmV1 {
 ///
 /// This projection will inevitably lead to error in the gas price calculation. Special care should be taken
 /// to account for the worst case scenario when calculating the parameters of the algorithm.
+#[derive(Debug, Clone, PartialEq)]
 pub struct AlgorithmUpdaterV1 {
     /// The gas price to cover the execution of the next block
     pub new_exec_price: u64,
@@ -192,7 +194,7 @@ pub struct RecordedBlock {
     pub block_cost: u64,
 }
 
-#[derive(Debug, Clone)]
+#[derive(Debug, Clone, PartialEq)]
 pub struct BlockBytes {
     pub height: u32,
     pub block_bytes: u64,

crates/services/gas_price_service/Cargo.toml

@@ -13,7 +13,9 @@ anyhow = { workspace = true }
 async-trait = { workspace = true }
 fuel-core-services = { workspace = true }
 fuel-core-types = { workspace = true }
+fuel-gas-price-algorithm = { workspace = true }
 futures = { workspace = true }
+thiserror = { workspace = true }
 tokio = { workspace = true }
 tracing = { workspace = true }
 

crates/services/gas_price_service/src/fuel_gas_price_updater.rs

@@ -0,0 +1,132 @@
+use crate::UpdateAlgorithm;
+use fuel_core_types::fuel_types::BlockHeight;
+use fuel_gas_price_algorithm::{
+    AlgorithmUpdaterV1,
+    AlgorithmV1,
+    RecordedBlock,
+};
+
+#[cfg(test)]
+mod tests;
+
+pub struct FuelGasPriceUpdater<L2, Metadata> {
+    inner: AlgorithmUpdaterV1,
+    l2_block_source: L2,
+    metadata_storage: Metadata,
+}
+
+#[derive(Debug, thiserror::Error)]
+pub enum Error {
+    #[error("Failed to find L2 block at height {block_height:?}: {source_error:?}")]
+    CouldNotFetchL2Block {
+        block_height: BlockHeight,
+        source_error: anyhow::Error,
+    },
+    #[error("Failed to find DA records: {0:?}")]
+    CouldNotFetchDARecord(anyhow::Error),
+}
+
+type Result<T> = std::result::Result<T, Error>;
+
+#[derive(Debug, Clone)]
+pub struct BlockInfo {
+    pub height: u32,
+    pub fullness: (u64, u64),
+    pub block_bytes: u64,
+    pub gas_price: u64,
+}
+#[async_trait::async_trait]
+pub trait L2BlockSource: Send + Sync {
+    async fn get_l2_block(&self, height: BlockHeight) -> Result<BlockInfo>;
+}
+
+#[async_trait::async_trait]
+pub trait DARecordSource: Send + Sync {
+    async fn get_da_record(&self) -> Result<Vec<RecordedBlock>>;
+}
+
+#[derive(Debug, Clone)]
+pub enum UpdaterMetadata {
+    V1(AlgorithmUpdaterV1),
+}
+
+impl From<UpdaterMetadata> for AlgorithmUpdaterV1 {
+    fn from(metadata: UpdaterMetadata) -> Self {
+        match metadata {
+            UpdaterMetadata::V1(v1) => v1,
+        }
+    }
+}
+
+impl From<AlgorithmUpdaterV1> for UpdaterMetadata {
+    fn from(v1: AlgorithmUpdaterV1) -> Self {
+        UpdaterMetadata::V1(v1)
+    }
+}
+
+#[async_trait::async_trait]
+pub trait MetadataStorage: Send + Sync {
+    async fn get_metadata(&self) -> Result<Option<UpdaterMetadata>>;
+    async fn set_metadata(&self, metadata: UpdaterMetadata) -> Result<()>;
+}
+
+impl<L2, Metadata> FuelGasPriceUpdater<L2, Metadata>
+where
+    Metadata: MetadataStorage,
+{
+    pub async fn init(
+        init_metadata: UpdaterMetadata,
+        l2_block_source: L2,
+        metadata_storage: Metadata,
+    ) -> Result<Self> {
+        let inner = metadata_storage
+            .get_metadata()
+            .await?
+            .unwrap_or(init_metadata)
+            .into();
+        let updater = Self {
+            inner,
+            l2_block_source,
+            metadata_storage,
+        };
+        Ok(updater)
+    }
+}
+
+#[async_trait::async_trait]
+impl<L2, Metadata> UpdateAlgorithm for FuelGasPriceUpdater<L2, Metadata>
+where
+    L2: L2BlockSource,
+    Metadata: MetadataStorage + Send + Sync,
+{
+    type Algorithm = AlgorithmV1;
+
+    fn start(&self, _for_block: BlockHeight) -> Self::Algorithm {
+        self.inner.algorithm()
+    }
+
+    async fn next(&mut self) -> anyhow::Result<Self::Algorithm> {
+        tokio::select! {
+            l2_block = self.l2_block_source.get_l2_block(self.inner.l2_block_height.into()) => {
+                tracing::info!("Received L2 block: {:?}", l2_block);
+                let l2_block = l2_block?;
+                let BlockInfo {
+                    height,
+                    fullness,
+                    block_bytes,
+                    gas_price,
+                } = l2_block;
+                self.inner.update_l2_block_data(
+                    height,
+                    fullness,
+                    block_bytes,
+                    gas_price,
+                )?;
+                self.metadata_storage
+                    .set_metadata(self.inner.clone().into())
+                    .await?;
+                Ok(self.inner.algorithm())
+            }
+        }
+    }
+}