fixes

Author: Zoran Cvetkov

graph/src/blockchain/block_stream.rs

@@ -413,7 +413,7 @@ impl<C: Blockchain> TriggersAdapterWrapper<C> {
         from: BlockNumber,
         to: BlockNumber,
         filter: &Arc<TriggerFilterWrapper<C>>,
-        entities: BTreeMap<BlockNumber, Entity>,
+        entities: BTreeMap<BlockNumber, Vec<Entity>>,
     ) -> Result<(Vec<BlockWithTriggers<C>>, BlockNumber), Error> {
         let logger2 = logger.cheap_clone();
         let adapter = self.adapter.clone();
@@ -427,7 +427,7 @@ impl<C: Blockchain> TriggersAdapterWrapper<C> {
                 match entities.get(&key) {
                     Some(e) => {
                         let trigger_data =
-                            vec![Self::create_subgraph_trigger_from_entity(first_filter, e)];
+                            Self::create_subgraph_trigger_from_entity(first_filter, e);
                         Some(BlockWithTriggers::new_with_subgraph_triggers(
                             block,
                             trigger_data,
@@ -445,13 +445,16 @@ impl<C: Blockchain> TriggersAdapterWrapper<C> {
 
     fn create_subgraph_trigger_from_entity(
         filter: &SubgraphFilter,
-        entity: &Entity,
-    ) -> subgraph::TriggerData {
-        subgraph::TriggerData {
-            source: filter.subgraph.clone(),
-            entity: entity.clone(),
-            entity_type: filter.entities.first().unwrap().clone(),
-        }
+        entity: &Vec<Entity>,
+    ) -> Vec<subgraph::TriggerData> {
+        entity
+            .iter()
+            .map(|e| subgraph::TriggerData {
+                source: filter.subgraph.clone(),
+                entity: e.clone(),
+                entity_type: filter.entities.first().unwrap().clone(),
+            })
+            .collect()
     }
 }