From 88ae09d9f5a256090cfe33e27a9c05758cc8b183 Mon Sep 17 00:00:00 2001 From: Theo Butler Date: Fri, 18 Oct 2024 06:06:06 -0400 Subject: [PATCH] fix: ignore records before start timestamp --- src/bin/main.rs | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/bin/main.rs b/src/bin/main.rs index ecc57fc..7df0ba1 100644 --- a/src/bin/main.rs +++ b/src/bin/main.rs @@ -119,6 +119,9 @@ async fn run() -> anyhow::Result<()> { receiver, fees_grt, } => { + if aggregation_timestamp < start_timestamp { + continue; + } let key = IndexerFeesKey { signer, receiver }; let agg = aggregations.entry(aggregation_timestamp).or_default(); *agg.indexer_fees.entry(key).or_default() += fees_grt;