Feature/expose invalid transactions

src/mapper/babbage.rs

@@ -8,6 +8,8 @@ use pallas::ledger::primitives::babbage::{
 
 use pallas::crypto::hash::Hash;
 
+use std::ops::Deref;
+
 use crate::model::{BlockRecord, Era, TransactionRecord};
 use crate::utils::time::TimeProvider;
 use crate::{
@@ -142,15 +144,27 @@ impl EventWriter {
                 false => None,
             },
             transactions: None,
+            invalid_transactions: None
         };
 
         if self.config.include_block_details {
             record.transactions = Some(self.collect_babbage_tx_records(source)?);
         }
 
+        if self.config.include_invalid_transaction_details {
+            record.invalid_transactions = self.collect_invalid_tx_indices(source);
+        }
+
         Ok(record)
     }
 
+    pub fn collect_invalid_tx_indices(
+        &self,
+        block: &MintedBlock,
+    ) -> Option<Vec<u32>> {
+        block.invalid_transactions.as_ref().map(|im| im.deref().to_vec())
+    }
+
     pub fn collect_babbage_tx_records(
         &self,
         block: &MintedBlock,

src/mapper/byron.rs

@@ -175,6 +175,7 @@ impl EventWriter {
                 false => None,
             },
             transactions: None,
+            invalid_transactions: None
         };
 
         if self.config.include_block_details {
@@ -235,6 +236,7 @@ impl EventWriter {
                 false => None,
             },
             transactions: None,
+            invalid_transactions: None
         })
     }
 

src/mapper/map.rs

@@ -495,6 +495,7 @@ impl EventWriter {
                 false => None,
             },
             transactions: None,
+            invalid_transactions: None
         };
 
         if self.config.include_block_details {

src/mapper/prelude.rs

@@ -25,6 +25,9 @@ pub struct Config {
     #[serde(default)]
     pub include_transaction_end_events: bool,
 
+    #[serde(default)]
+    pub include_invalid_transaction_details: bool,
+
     #[serde(default)]
     pub include_block_details: bool,
 

src/model.rs

@@ -275,6 +275,7 @@ pub struct BlockRecord {
     pub previous_hash: String,
     pub cbor_hex: Option<String>,
     pub transactions: Option<Vec<TransactionRecord>>,
+    pub invalid_transactions: Option<Vec<u32>>
 }
 
 impl From<BlockRecord> for EventData {