fix: race indexing condition

kuco23 · kuco23 · commit c97d4a65adcd · 2025-09-29T10:26:23.000+02:00
diff --git a/packages/fasset-indexer-core/src/indexer/reindexing/indexer-parallel-race-population.ts b/packages/fasset-indexer-core/src/indexer/reindexing/indexer-parallel-race-population.ts
@@ -40,7 +40,7 @@ export class EventIndexerParallelRacePopulation {
       await this.backIndexer.runHistoric(firstUnhandledBlockBack, endblock - 1)
     }
     firstUnhandledBlockBack = await this.backIndexer.firstUnhandledBlock()
-    if (firstUnhandledBlockBack == firstUnhandledBlockFront) {
+    if (firstUnhandledBlockBack >= firstUnhandledBlockFront) {
       await setVar(this.frontIndexer.context.orm.em.fork(), this.updateSynced, 'true')
       return this.indexer
     }

Original file line number	Diff line number	Diff line change
`@@ -40,7 +40,7 @@ export class EventIndexerParallelRacePopulation {`
`40`	`40`	`await this.backIndexer.runHistoric(firstUnhandledBlockBack, endblock - 1)`
`41`	`41`	`}`
`42`	`42`	`firstUnhandledBlockBack = await this.backIndexer.firstUnhandledBlock()`
`43`		`- if (firstUnhandledBlockBack == firstUnhandledBlockFront) {`
	`43`	`+ if (firstUnhandledBlockBack >= firstUnhandledBlockFront) {`
`44`	`44`	`await setVar(this.frontIndexer.context.orm.em.fork(), this.updateSynced, 'true')`
`45`	`45`	`return this.indexer`
`46`	`46`	`}`