Skip to content

Commit cd389f9

Browse files
Zoran Cvetkovincrypto32
authored andcommitted
simplify
1 parent 3453551 commit cd389f9

File tree

1 file changed

+9
-24
lines changed

1 file changed

+9
-24
lines changed

graph/src/blockchain/block_stream.rs

Lines changed: 9 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -351,18 +351,6 @@ impl<C: Blockchain> TriggersAdapterWrapper<C> {
351351
) -> Result<(Vec<BlockWithTriggers<C>>, BlockNumber), Error> {
352352
if !filter.subgraph_filter.is_empty() {
353353
// TODO: handle empty range, or empty entity set bellow
354-
if to <= from {
355-
let entities = BTreeMap::<BlockNumber, Entity>::new();
356-
return self
357-
.subgraph_triggers(
358-
Logger::root(slog::Discard, o!()),
359-
from,
360-
to,
361-
filter,
362-
entities,
363-
)
364-
.await;
365-
}
366354

367355
if let Some(SubgraphFilter {
368356
subgraph: dh,
@@ -380,23 +368,20 @@ impl<C: Blockchain> TriggersAdapterWrapper<C> {
380368
let t: u32 = to as u32;
381369
let br: Range<u32> = f..t;
382370
let entities = store.get_range(&et, br)?;
383-
if !entities.is_empty() {
384-
return self
385-
.subgraph_triggers(
386-
Logger::root(slog::Discard, o!()),
387-
from,
388-
to,
389-
filter,
390-
entities,
391-
)
392-
.await;
393-
}
371+
return self
372+
.subgraph_triggers(
373+
Logger::root(slog::Discard, o!()),
374+
from,
375+
to,
376+
filter,
377+
entities,
378+
)
379+
.await;
394380
}
395381
}
396382
}
397383
}
398384
}
399-
400385
self.adapter
401386
.scan_triggers(from, to, &filter.chain_filter)
402387
.await

0 commit comments

Comments
 (0)