integrates decoding into log extraction

Author: unbound26z

crates/core/src/instruction.rs

@@ -21,8 +21,8 @@
 
 use {
     crate::{
-        error::CarbonResult, filter::Filter, metrics::MetricsCollection, processor::Processor,
-        transaction::TransactionMetadata,
+        deserialize::CarbonDeserialize, error::CarbonResult, filter::Filter,
+        metrics::MetricsCollection, processor::Processor, transaction::TransactionMetadata,
     },
     async_trait::async_trait,
     serde::{Deserialize, Serialize},
@@ -70,14 +70,31 @@ enum LogType {
 }
 
 impl InstructionMetadata {
+    /// Decodes the log events `T` thrown by this instruction.
+    ///
+    /// # Parameters
+    ///
+    /// - `T`: The event type to decode the logs into.
+    ///
+    /// # Returns
+    ///
+    /// All successfull events of the type `T` decoded from the logs of the instruction.
+    pub fn decode_log_events<T: CarbonDeserialize>(&self) -> Vec<T> {
+        self.extract_event_log_data()
+            .into_iter()
+            .map(|log| <T as CarbonDeserialize>::deserialize(&mut &log[8..]))
+            .flatten()
+            .collect()
+    }
+
     /// Extracts the `data` from log messages associated with this instruction.
     ///
     /// This method filters the transaction's log messages to return only those
     /// that correspond to the current instruction, based on its stack height and
     /// absolute path within the instruction stack.
     ///
     /// Returns `Vec<Vec<u8>>` containing the `data` bytes (base64 encoded) from log messages.
-    pub fn extract_event_log_data(&self) -> Vec<Vec<u8>> {
+    fn extract_event_log_data(&self) -> Vec<Vec<u8>> {
         let logs = match &self.transaction_metadata.meta.log_messages {
             Some(logs) => logs,
             None => return Vec::new(),

examples/log-events-example/src/main.rs

@@ -1,7 +1,6 @@
 use {
     async_trait::async_trait,
     carbon_core::{
-        borsh::BorshDeserialize,
         error::CarbonResult,
         instruction::{DecodedInstruction, InstructionMetadata, NestedInstructions},
         metrics::MetricsCollection,
@@ -100,22 +99,10 @@ impl Processor for RaydiumCpmmInstructionProcessor {
         (metadata, _, _, _): Self::InputType,
         _metrics: Arc<MetricsCollection>,
     ) -> CarbonResult<()> {
-        let logs = metadata.extract_event_log_data();
+        let logs = metadata.decode_log_events::<SwapEvent>();
 
         if !logs.is_empty() {
-            println!("Signature: {:?}", metadata.transaction_metadata.signature);
-            println!(
-                "Processing instruction - Index: {}, Stack Height: {}, Path: {:?}",
-                metadata.index, metadata.stack_height, metadata.absolute_path
-            );
-            for log in logs {
-                if log.len() > 8 {
-                    if let Ok(swap_event) = SwapEvent::deserialize(&mut &log[8..]) {
-                        println!("SwapEvent: {:?}", swap_event);
-                    }
-                }
-            }
-            println!("--------------------------------");
+            println!("Swap Events: {:?}", logs);
         }
 
         Ok(())