fix oracle interval index

DeFiCh · Dec 16, 2024 · de33a9b · de33a9b
1 parent 29246ff
commit de33a9b
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/lib/ain-ocean/src/indexer/oracle.rs b/lib/ain-ocean/src/indexer/oracle.rs
@@ -581,16 +581,14 @@ pub fn index_interval_mapper(
         .next()
         .transpose()?;
 
-    let Some(previous) = previous else {
+    if previous.is_none() || block.median_time - aggregated.block.median_time > interval as i64 {
         return start_new_bucket(services, block, token, currency, aggregated, interval);
     };
 
-    if block.median_time - aggregated.block.median_time > interval as i64 {
-        return start_new_bucket(services, block, token, currency, aggregated, interval);
+    if let Some(previous) = previous {
+        forward_aggregate(services, previous, aggregated)?;
     };
 
-    forward_aggregate(services, previous, aggregated)?;
-
     Ok(())
 }