Add preconfirmation gossip messages

crates/services/p2p/src/codecs/postcard.rs

@@ -158,6 +158,9 @@ impl GossipsubCodec for PostcardCodec {
     fn encode(&self, data: Self::RequestMessage) -> Result<Vec<u8>, io::Error> {
         let encoded_data = match data {
             GossipsubBroadcastRequest::NewTx(tx) => postcard::to_stdvec(&*tx),
+            GossipsubBroadcastRequest::Confirmations(confirmations) => {
+                postcard::to_stdvec(&*confirmations)
+            }
         };
 
         encoded_data.map_err(|e| io::Error::new(io::ErrorKind::Other, e.to_string()))
@@ -170,6 +173,9 @@ impl GossipsubCodec for PostcardCodec {
     ) -> Result<Self::ResponseMessage, io::Error> {
         let decoded_response = match gossipsub_tag {
             GossipTopicTag::NewTx => GossipsubMessage::NewTx(deserialize(encoded_data)?),
+            GossipTopicTag::TxConfirmations => {
+                GossipsubMessage::Confirmations(deserialize(encoded_data)?)
+            }
         };
 
         Ok(decoded_response)

crates/services/p2p/src/gossipsub/config.rs

@@ -1,4 +1,7 @@
-use super::topics::NEW_TX_GOSSIP_TOPIC;
+use super::topics::{
+    NEW_TX_GOSSIP_TOPIC,
+    TX_CONFIRMATIONS_GOSSIP_TOPIC,
+};
 use crate::{
     config::{
         Config,
@@ -49,6 +52,8 @@ const MESH_SIZE: usize = 8;
 // The weight applied to the score for delivering new transactions.
 const NEW_TX_GOSSIP_WEIGHT: f64 = 0.05;
 
+const TX_CONFIRMATIONS_GOSSIP_WEIGHT: f64 = 0.05;
+
 // The threshold for a peer's score to be considered for greylisting.
 // If a peer's score falls below this value, they will be greylisted.
 // Greylisting is a lighter form of banning, where the peer's messages might be ignored or given lower priority,
@@ -222,7 +227,14 @@ fn initialize_gossipsub(gossipsub: &mut gossipsub::Behaviour, p2p_config: &Confi
         .with_peer_score(peer_score_params, peer_score_thresholds)
         .expect("gossipsub initialized with peer score");
 
-    let topics = vec![(NEW_TX_GOSSIP_TOPIC, NEW_TX_GOSSIP_WEIGHT)];
+    // TODO: Make topics configurable.
+    let topics = vec![
+        (NEW_TX_GOSSIP_TOPIC, NEW_TX_GOSSIP_WEIGHT),
+        (
+            TX_CONFIRMATIONS_GOSSIP_TOPIC,
+            TX_CONFIRMATIONS_GOSSIP_WEIGHT,
+        ),
+    ];
 
     // subscribe to gossipsub topics with the network name suffix
     for (topic, weight) in topics {

crates/services/p2p/src/gossipsub/messages.rs

@@ -2,6 +2,7 @@ use std::sync::Arc;
 
 use fuel_core_types::fuel_tx::Transaction;
 
+use fuel_core_types::services::p2p::TxConfirmations;
 use serde::{
     Deserialize,
     Serialize,
@@ -12,6 +13,7 @@ use serde::{
 #[derive(Debug, Clone, Copy, Eq, PartialEq)]
 pub enum GossipTopicTag {
     NewTx,
+    TxConfirmations,
 }
 
 /// Takes `Arc<T>` and wraps it in a matching GossipsubBroadcastRequest
@@ -20,9 +22,11 @@ pub enum GossipTopicTag {
 #[derive(Debug, Clone)]
 pub enum GossipsubBroadcastRequest {
     NewTx(Arc<Transaction>),
+    Confirmations(Arc<TxConfirmations>),
 }
 
 #[derive(Serialize, Deserialize, Debug, Clone)]
 pub enum GossipsubMessage {
     NewTx(Transaction),
+    Confirmations(TxConfirmations),
 }

crates/services/p2p/src/gossipsub/topics.rs

@@ -10,22 +10,27 @@ use super::messages::{
 };
 
 pub const NEW_TX_GOSSIP_TOPIC: &str = "new_tx";
+pub const TX_CONFIRMATIONS_GOSSIP_TOPIC: &str = "tx_confirmations";
 
 /// Holds used Gossipsub Topics
 /// Each field contains TopicHash of existing topics
 /// in order to avoid converting topics to TopicHash on each received message
 #[derive(Debug)]
 pub struct GossipsubTopics {
     new_tx_topic: TopicHash,
+    tx_confirmations_topic: TopicHash,
 }
 
 impl GossipsubTopics {
     pub fn new(network_name: &str) -> Self {
         let new_tx_topic: Sha256Topic =
             Topic::new(format!("{NEW_TX_GOSSIP_TOPIC}/{network_name}"));
+        let tx_confirmations_topic: Sha256Topic =
+            Topic::new(format!("{TX_CONFIRMATIONS_GOSSIP_TOPIC}/{network_name}"));
 
         Self {
             new_tx_topic: new_tx_topic.hash(),
+            tx_confirmations_topic: tx_confirmations_topic.hash(),
         }
     }
 
@@ -36,6 +41,9 @@ impl GossipsubTopics {
     ) -> Option<GossipTopicTag> {
         match incoming_topic {
             hash if hash == &self.new_tx_topic => Some(GossipTopicTag::NewTx),
+            hash if hash == &self.tx_confirmations_topic => {
+                Some(GossipTopicTag::TxConfirmations)
+            }
             _ => None,
         }
     }
@@ -48,6 +56,9 @@ impl GossipsubTopics {
     ) -> TopicHash {
         match outgoing_request {
             GossipsubBroadcastRequest::NewTx(_) => self.new_tx_topic.clone(),
+            GossipsubBroadcastRequest::Confirmations(_) => {
+                self.tx_confirmations_topic.clone()
+            }
         }
     }
 }