Skip to content

Commit ac600cf

Browse files
committed
Improve rollback logic for onBlock handlers
1 parent c8d2650 commit ac600cf

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

codegenerator/cli/npm/envio/src/FetchState.res

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1165,6 +1165,7 @@ let rollbackPartition = (
11651165
| {selection: {dependsOnAddresses: false}} =>
11661166
Some({
11671167
...p,
1168+
// FIXME: Should rollback latestFetchedBlock???
11681169
status: {
11691170
fetchingStateId: None,
11701171
},
@@ -1232,7 +1233,10 @@ let rollback = (fetchState: t, ~firstChangeEvent) => {
12321233
p->rollbackPartition(~firstChangeEvent, ~addressesToRemove)
12331234
)
12341235

1235-
fetchState->updateInternal(
1236+
{
1237+
...fetchState,
1238+
latestOnBlockBlockNumber: firstChangeEvent.blockNumber - 1, // TODO: This is not tested
1239+
}->updateInternal(
12361240
~partitions,
12371241
~indexingContracts,
12381242
~mutItems=fetchState.queue->pruneQueueFromFirstChangeEvent(~firstChangeEvent),

0 commit comments

Comments
 (0)