Add preconfirmation signature verification to tx status manager

.changes/added/2856.md

@@ -0,0 +1 @@
+Add generic logic for managing the signatures and delegate keys for pre-confirmations signatures

bin/fuel-core/src/cli/run.rs

@@ -714,6 +714,8 @@ impl Command {
                 max_tx_update_subscriptions: tx_number_active_subscriptions,
                 subscription_ttl,
                 status_cache_ttl: status_cache_ttl.into(),
+                // TODO: Where can I get this value?
+                protocol_public_key: Default::default(),
             },
         };
         Ok(config)

crates/fuel-core/src/service/sub_services.rs

@@ -41,6 +41,15 @@ use crate::service::adapters::consensus_module::poa::pre_confirmation_signature:
     tx_receiver::PreconfirmationsReceiver,
 };
 
+use super::{
+    adapters::{
+        FuelBlockSigner,
+        P2PAdapter,
+        TxStatusManagerAdapter,
+    },
+    genesis::create_genesis_block,
+    DbType,
+};
 use crate::{
     combined_database::CombinedDatabase,
     database::Database,
@@ -76,16 +85,6 @@ use crate::{
     },
 };
 
-use super::{
-    adapters::{
-        FuelBlockSigner,
-        P2PAdapter,
-        TxStatusManagerAdapter,
-    },
-    genesis::create_genesis_block,
-    DbType,
-};
-
 pub type PoAService = fuel_core_poa::Service<
     TxPoolAdapter,
     BlockProducerAdapter,

crates/services/tx_status_manager/Cargo.toml

@@ -13,9 +13,10 @@ anyhow = { workspace = true }
 async-trait = { workspace = true }
 derive_more = { workspace = true }
 fuel-core-services = { workspace = true }
-fuel-core-types = { workspace = true, features = ["std"] }
+fuel-core-types = { workspace = true, features = ["std", "serde"] }
 futures = { workspace = true }
 parking_lot = { workspace = true }
+postcard = { workspace = true }
 tokio = { workspace = true }
 tokio-stream = { workspace = true }
 tracing = { workspace = true }
@@ -30,6 +31,7 @@ test-case = { workspace = true }
 test-strategy = { workspace = true }
 tokio = { workspace = true, features = ["test-util", "macros"] }
 tracing = { workspace = true }
+tracing-subscriber = { workspace = true }
 
 [features]
 test-helpers = ["fuel-core-types/test-helpers"]

crates/services/tx_status_manager/src/config.rs

@@ -1,3 +1,4 @@
+use fuel_core_types::fuel_crypto::PublicKey;
 use std::time::Duration;
 
 #[derive(Clone, Debug)]
@@ -8,6 +9,8 @@ pub struct Config {
     pub subscription_ttl: Duration,
     /// Maximum time to keep the status in the cache of the manager.
     pub status_cache_ttl: Duration,
+    /// Protocol Signing Key, i.e. the block signer's public key
+    pub protocol_public_key: PublicKey,
 }
 
 #[cfg(feature = "test-helpers")]
@@ -17,6 +20,7 @@ impl Default for Config {
             max_tx_update_subscriptions: 1000,
             subscription_ttl: Duration::from_secs(60 * 10),
             status_cache_ttl: Duration::from_secs(5),
+            protocol_public_key: PublicKey::default(),
         }
     }
 }

crates/services/tx_status_manager/src/lib.rs

@@ -9,7 +9,7 @@ pub mod config;
 mod error;
 mod manager;
 pub mod ports;
-mod service;
+pub mod service;
 mod subscriptions;
 mod tx_status_stream;
 mod update_sender;