Skip to content

Commit ed71a78

Browse files
authored
Improve stability of Block Handlers (#738)
* Remove db_write_timestamp * Prevent OOM for big ranges of onBlock handler * Update tests * Improve rollback logic for onBlock handlers * Fix block handler for multichain * Fix nextItemIsNone check * Fix tests
1 parent 4ac325a commit ed71a78

File tree

22 files changed

+779
-608
lines changed

22 files changed

+779
-608
lines changed

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

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -58,6 +58,18 @@ let getOrderedNextItem = (fetchStates: ChainMap.t<FetchState.t>): option<
5858
})
5959
}
6060

61+
let hasUnorderedNextItem = (fetchStates: ChainMap.t<FetchState.t>) => {
62+
fetchStates
63+
->ChainMap.values
64+
->Js.Array2.some(fetchState => {
65+
fetchState->FetchState.isActivelyIndexing &&
66+
switch fetchState->FetchState.getEarliestEvent {
67+
| Item(_) => true
68+
| NoItem(_) => false
69+
}
70+
})
71+
}
72+
6173
let popOrderedBatchItems = (
6274
~maxBatchSize,
6375
~fetchStates: ChainMap.t<FetchState.t>,

0 commit comments

Comments
 (0)