fix(publisher): Include transaction_ids in blocks

benches/nats-publisher/src/main.rs

@@ -47,7 +47,8 @@ async fn main() -> anyhow::Result<()> {
             for height in 0..*last_height {
                 let height = height.into();
                 let block = block_helper.find_by_height(height);
-                let block = Block::new(&block, Consensus::default());
+                let block =
+                    Block::new(&block, Consensus::default(), Vec::new());
 
                 block_helper.publish(&block).await?;
                 // for (index, tx) in block.transactions().iter().enumerate() {
@@ -65,7 +66,7 @@ async fn main() -> anyhow::Result<()> {
     while let Ok(result) = subscription.recv().await {
         let result = &**result;
         let block = &result.sealed_block.entity;
-        let block = Block::new(block, Consensus::default());
+        let block = Block::new(block, Consensus::default(), Vec::new());
 
         block_helper.publish(&block).await?;
         // for (index, tx) in block.transactions().iter().enumerate() {

crates/fuel-streams-core/src/blocks/mod.rs

@@ -42,7 +42,7 @@ mod tests {
             header: header.clone(),
             height: 42,
             id: Default::default(),
-            transactions: vec![], // Always empty for now
+            transaction_ids: vec![],
             version: BlockVersion::V1,
         };
 
@@ -76,7 +76,7 @@ mod tests {
             },
             "height": 42,
             "id": "0000000000000000000000000000000000000000000000000000000000000000",
-            "transactions": [],
+            "transactionIds": [],
             "version": "V1"
         });
 

crates/fuel-streams-core/src/blocks/types.rs

@@ -8,14 +8,15 @@ pub struct Block {
     pub header: BlockHeader,
     pub height: u32,
     pub id: FuelCoreBlockId,
-    pub transactions: Vec<Transaction>,
+    pub transaction_ids: Vec<Bytes32>,
     pub version: BlockVersion,
 }
 
 impl Block {
     pub fn new(
         block: &fuel_core_types::blockchain::block::Block,
         consensus: Consensus,
+        transaction_ids: Vec<Bytes32>,
     ) -> Self {
         let header: BlockHeader = block.header().into();
         let height = header.height;
@@ -32,7 +33,7 @@ impl Block {
             header,
             height,
             id,
-            transactions: Vec::new(),
+            transaction_ids,
             version,
         }
     }
@@ -187,6 +188,6 @@ impl MockBlock {
             .collect::<Vec<_>>();
         *block.transactions_mut() = txs;
 
-        Block::new(&block, Consensus::default())
+        Block::new(&block, Consensus::default(), Vec::new())
     }
 }

crates/fuel-streams-publisher/src/publisher/mod.rs

@@ -212,6 +212,11 @@ impl Publisher {
         let block_producer = Arc::new(block_producer.clone());
         let block_height = block.header().consensus().height;
         let txs = block.transactions();
+        let transaction_ids = txs
+            .iter()
+            .map(|tx| tx.id(&chain_id).into())
+            .collect::<Vec<Bytes32>>();
+
         let consensus: Consensus =
             self.fuel_core.get_consensus(&block_height)?.into();
 
@@ -239,6 +244,7 @@ impl Publisher {
             block,
             block_stream,
             opts,
+            transaction_ids,
         )))
         .collect::<FuturesUnordered<_>>();
 

crates/fuel-streams-publisher/src/publisher/payloads/blocks.rs

@@ -9,12 +9,13 @@ pub fn publish_task(
     block: &FuelCoreBlock<FuelCoreTransaction>,
     stream: Arc<Stream<Block>>,
     opts: &Arc<PublishOpts>,
+    transaction_ids: Vec<Bytes32>,
 ) -> JoinHandle<anyhow::Result<()>> {
     let block_height = (*opts.block_height).clone();
     let block_producer = (*opts.block_producer).clone();
     let consensus = (*opts.consensus).clone();
 
-    let block = Block::new(block, consensus);
+    let block = Block::new(block, consensus, transaction_ids);
     let packet = PublishPacket::new(
         block,
         BlocksSubject {