add implementations for pre conf task (#2780)

## Linked Issues/PRs
<!-- List of related issues/PRs -->
part of #2739

## Description
<!-- List of detailed changes -->
Introduced some working and some dummy implementations. 

We still need to implement the P2P broadcast trait and the delegate key
generator stuff. We don't know what kind of keys we are going to use, so
that needs to be decided on.

## Checklist
- [x] New behavior is reflected in tests

### Before requesting review
- [x] I have reviewed the code myself
- [x] I have created follow-up issues caused by this PR and linked them
here
#2782
#2783

---------

Co-authored-by: Green Baneling <[email protected]>

Author: MitchTurner

.changes/added/2780.md

@@ -0,0 +1 @@
+Add implementations for the pre-confirmation signing task

Cargo.lock

@@ -89,6 +89,8 @@ mockall = { workspace = true }
 proptest = { workspace = true }
 test-case = { workspace = true }
 test-strategy = { workspace = true }
+tokio-test = "0.4.4"
+tracing-subscriber = { workspace = true }
 
 [features]
 default = ["rocksdb"]

crates/fuel-core/Cargo.toml

@@ -3,6 +3,9 @@
 #![deny(unused_crate_dependencies)]
 #![deny(warnings)]
 
+#[cfg(test)]
+use tracing_subscriber as _;
+
 use crate::service::genesis::NotifyCancel;
 use tokio_util::sync::CancellationToken;
 

crates/fuel-core/src/lib.rs

@@ -1,17 +1,5 @@
-use crate::{
-    database::{
-        database_description::relayer::Relayer,
-        Database,
-    },
-    fuel_core_graphql_api::ports::GasPriceEstimate,
-    service::{
-        sub_services::{
-            BlockProducerService,
-            TxPoolSharedState,
-        },
-        vm_pool::MemoryPool,
-    },
-};
+use std::sync::Arc;
+
 use fuel_core_consensus_module::{
     block_verifier::Verifier,
     RelayerConsensusConfig,
@@ -53,7 +41,21 @@ use fuel_core_types::{
 };
 //#[cfg(not(feature = "parallel-executor"))]
 use fuel_core_upgradable_executor::executor::Executor;
-use std::sync::Arc;
+
+use crate::{
+    database::{
+        database_description::relayer::Relayer,
+        Database,
+    },
+    fuel_core_graphql_api::ports::GasPriceEstimate,
+    service::{
+        sub_services::{
+            BlockProducerService,
+            TxPoolSharedState,
+        },
+        vm_pool::MemoryPool,
+    },
+};
 
 pub mod block_importer;
 pub mod chain_state_info_provider;
@@ -100,9 +102,10 @@ impl StaticGasPrice {
 mod universal_gas_price_provider_tests {
     #![allow(non_snake_case)]
 
-    use super::*;
     use proptest::proptest;
 
+    use super::*;
+
     fn _worst_case__correctly_calculates_value(
         gas_price: u64,
         starting_height: u32,

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

@@ -47,6 +47,8 @@ use tokio_stream::{
     StreamExt,
 };
 
+pub mod pre_confirmation_signature;
+
 impl PoAAdapter {
     pub fn new(shared_state: Option<SharedState>) -> Self {
         Self { shared_state }

crates/fuel-core/src/service/adapters/consensus_module/poa.rs

@@ -0,0 +1,13 @@
+use fuel_core_types::{
+    fuel_tx::TxId,
+    services::p2p::PreconfirmationStatus,
+};
+
+pub mod broadcast;
+pub mod key_generator;
+pub mod parent_signature;
+pub mod signing_key;
+pub mod trigger;
+pub mod tx_receiver;
+
+pub type Preconfirmations = Vec<(TxId, PreconfirmationStatus)>;

crates/fuel-core/src/service/adapters/consensus_module/poa/pre_confirmation_signature.rs

@@ -0,0 +1,33 @@
+use crate::service::adapters::consensus_module::poa::pre_confirmation_signature::{
+    parent_signature::FuelParentSignature,
+    signing_key::DummyKey,
+    Preconfirmations,
+};
+use fuel_core_poa::pre_confirmation_signature_service::{
+    broadcast::Broadcast,
+    error::Result as PoAResult,
+    Signed,
+};
+
+/// TODO: Implement `Broadcast` properly: <https://github.com/FuelLabs/fuel-core/issues/2783>
+pub struct P2PBroadcast;
+
+impl Broadcast for P2PBroadcast {
+    type PreConfirmations = Preconfirmations;
+    type ParentSignature = FuelParentSignature<DummyKey>;
+    type DelegateKey = DummyKey;
+
+    async fn broadcast_txs(
+        &mut self,
+        _txs: Signed<Self::DelegateKey, Self::PreConfirmations>,
+    ) -> PoAResult<()> {
+        todo!()
+    }
+
+    async fn broadcast_delegate_key(
+        &mut self,
+        _delegate_key: Self::ParentSignature,
+    ) -> PoAResult<()> {
+        todo!()
+    }
+}

crates/fuel-core/src/service/adapters/consensus_module/poa/pre_confirmation_signature/broadcast.rs

@@ -0,0 +1,17 @@
+use crate::service::adapters::consensus_module::poa::pre_confirmation_signature::{
+    signing_key::DummyKey,
+};
+use fuel_core_poa::pre_confirmation_signature_service::{
+    error::Result as PoAResult,
+    key_generator::KeyGenerator,
+};
+
+pub struct DelegateKeyGenerator;
+
+impl KeyGenerator for DelegateKeyGenerator {
+    type Key = DummyKey;
+
+    async fn generate(&mut self) -> PoAResult<Self::Key> {
+        todo!()
+    }
+}

crates/fuel-core/src/service/adapters/consensus_module/poa/pre_confirmation_signature/key_generator.rs

@@ -0,0 +1,52 @@
+use fuel_core_poa::pre_confirmation_signature_service::{
+    error::{
+        Error as PoaError,
+        Result as PoAResult,
+    },
+    parent_signature::ParentSignature,
+};
+use fuel_core_types::{
+    fuel_crypto,
+    signer::SignMode,
+};
+
+pub struct FuelParentSigner<T> {
+    mode: SignMode,
+    _phantom: std::marker::PhantomData<T>,
+}
+
+pub struct FuelParentSignature<T> {
+    signature: fuel_core_types::fuel_vm::Signature,
+    _phantom: std::marker::PhantomData<T>,
+}
+
+impl<T> FuelParentSignature<T> {
+    pub fn signature(&self) -> fuel_core_types::fuel_vm::Signature {
+        self.signature
+    }
+}
+
+impl<T> From<fuel_core_types::fuel_vm::Signature> for FuelParentSignature<T> {
+    fn from(signature: fuel_core_types::fuel_vm::Signature) -> Self {
+        Self {
+            signature,
+            _phantom: std::marker::PhantomData,
+        }
+    }
+}
+
+impl<T> ParentSignature<T> for FuelParentSigner<T>
+where
+    T: Send + Sync,
+    T: Into<fuel_crypto::Message>,
+{
+    type SignedData = FuelParentSignature<T>;
+
+    async fn sign(&self, data: T) -> PoAResult<Self::SignedData> {
+        let message = data.into();
+        let signature = self.mode.sign_message(message).await.map_err(|e| {
+            PoaError::ParentSignature(format!("Failed to sign message: {}", e))
+        })?;
+        Ok(signature.into())
+    }
+}