fix filtered injective modules to return completely empty data when e…

…vent/trx list is empty

injective-common/derived-substreams-example.yaml

@@ -7,7 +7,7 @@ package:
 network: injective-mainnet
 
 imports:
-  injective: ./injective-common-v0.2.0.spkg
+  injective: ./injective-common-v0.2.1.spkg
 
 modules:
   - name: my_events

injective-common/src/lib.rs

@@ -182,6 +182,9 @@ fn filtered_events(query: String, events: EventList) -> Result<EventList, Error>
         })
         .collect();
 
+    if filtered.len() == 0 {
+        return Ok(EventList::default());
+    }
     Ok(EventList {
         events: filtered,
         clock: events.clock,
@@ -216,6 +219,9 @@ fn filtered_event_groups(query: String, events: EventList) -> Result<EventList,
         })
         .collect();
 
+    if filtered.len() == 0 {
+        return Ok(EventList::default());
+    }
     Ok(EventList {
         events: filtered,
         clock: events.clock,
@@ -256,6 +262,9 @@ fn filtered_trx_by_events(query: String, trxs: TransactionList) -> Result<Transa
         .filter(|t| matching_trx_hashes.contains_key(t.hash.as_str()))
         .collect();
 
+    if transactions.len() == 0 {
+        return Ok(TransactionList::default());
+    }
     Ok(TransactionList {
         transactions: transactions,
         clock: trxs.clock,
@@ -282,6 +291,9 @@ fn filtered_events_by_attribute_value(query: String, events: EventList) -> Resul
         })
         .collect();
 
+    if filtered.len() == 0 {
+        return Ok(EventList::default());
+    }
     Ok(EventList {
         events: filtered,
         clock: events.clock,
@@ -317,6 +329,9 @@ fn filtered_event_groups_by_attribute_value(query: String, events: EventList) ->
         })
         .collect();
 
+    if filtered.len() == 0 {
+        return Ok(EventList::default());
+    }
     Ok(EventList {
         events: filtered,
         clock: events.clock,
@@ -350,6 +365,9 @@ fn filtered_trx_by_events_attribute_value(query: String, events: EventList, trxs
         .filter(|t| matching_trx_hashes.contains_key(t.hash.as_str()))
         .collect();
 
+    if transactions.len() == 0 {
+        return Ok(TransactionList::default());
+    }
     Ok(TransactionList {
         transactions: transactions,
         clock: trxs.clock,

injective-common/substreams.yaml

@@ -2,7 +2,7 @@
 specVersion: v0.1.0
 package:
   name: injective_common
-  version: v0.2.0
+  version: v0.2.1
   url: https://github.com/streamingfast/substreams-foundational-modules/injective-common
   doc: |
     common Injective substreams modules to extract events and transactions with indexing
@@ -168,4 +168,4 @@ params:
   filtered_trx_by_events: "type:wasm"
   filtered_events_by_attribute_value: "type:wasm && attr:_contract_address:inj1v77y5ttah96dc9qkcpc88ad7rce8n88e99t3m5"
   filtered_event_groups_by_attribute_value: "type:wasm && attr:_contract_address:inj1v77y5ttah96dc9qkcpc88ad7rce8n88e99t3m5"
-  filtered_trx_by_events_attribute_value: "type:wasm && attr:_contract_address:inj1v77y5ttah96dc9qkcpc88ad7rce8n88e99t3m5"
+  filtered_trx_by_events_attribute_value: "type:wasm && attr:_contract_address:inj1v77y5ttah96dc9qkcpc88ad7rce8n88e99t3m5"