fix: Evaluate Tx records for metadata filters (#406)

txpipe · Sep 3, 2022 · 525f3d3 · 525f3d3
1 parent 4de19ee
commit 525f3d3
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/src/filters/selection.rs b/src/filters/selection.rs
@@ -6,7 +6,10 @@ use serde::Deserialize;
 use serde_json::Value as JsonValue;
 
 use crate::{
-    model::{Event, EventData, MetadataRecord, MetadatumRendition, MintRecord, OutputAssetRecord, TxOutputRecord},
+    model::{
+        Event, EventData, MetadataRecord, MetadatumRendition, MintRecord, OutputAssetRecord,
+        TransactionRecord, TxOutputRecord,
+    },
     pipelining::{new_inter_stage_channel, FilterProvider, PartialBootstrapResult, StageReceiver},
 };
 
@@ -51,9 +54,7 @@ fn policy_matches(event: &Event, policy: &str) -> bool {
 #[inline]
 fn address_matches(event: &Event, address: &str) -> bool {
     match &event.data {
-        EventData::TxOutput(TxOutputRecord { address: x, .. }) => {
-            relaxed_str_matches(x, address)
-        },
+        EventData::TxOutput(TxOutputRecord { address: x, .. }) => relaxed_str_matches(x, address),
         _ => false,
     }
 }
@@ -70,6 +71,9 @@ fn asset_matches(event: &Event, asset: &str) -> bool {
 #[inline]
 fn metadata_label_matches(event: &Event, label: &str) -> bool {
     match &event.data {
+        EventData::Transaction(TransactionRecord {
+            metadata: Some(x), ..
+        }) => x.iter().any(|r| relaxed_str_matches(&r.label, label)),
         EventData::Metadata(MetadataRecord { label: x, .. }) => relaxed_str_matches(x, label),
         _ => false,
     }