From a4c2e715b8ea24518720c97d329ebf2ae3ac10ae Mon Sep 17 00:00:00 2001 From: Alexander Filippov Date: Wed, 10 Jul 2024 19:03:24 +0300 Subject: [PATCH] Fix sync --- zp-relayer/pool/BasePool.ts | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/zp-relayer/pool/BasePool.ts b/zp-relayer/pool/BasePool.ts index 58ce807..fe7eb79 100644 --- a/zp-relayer/pool/BasePool.ts +++ b/zp-relayer/pool/BasePool.ts @@ -188,9 +188,10 @@ export abstract class BasePool { async syncStateFromIndexer(indexerUrl: string) { let txs = [] - let commitIndex = this.state.getNextIndex() / OUTPLUSONE + let offset = this.state.getNextIndex() + let commitIndex = offset / OUTPLUSONE do { - txs = await this.fetchTransactionsFromIndexer(indexerUrl, this.state.getNextIndex(), 200) + txs = await this.fetchTransactionsFromIndexer(indexerUrl, offset, 200) for (const tx of txs) { const outCommit = hexToNumberString('0x' + tx.commitment) this.optimisticState.addCommitment(commitIndex, Helpers.strToNum(outCommit)) @@ -199,6 +200,7 @@ export abstract class BasePool { } commitIndex++ } + offset = this.optimisticState.getNextIndex() } while (txs.length !== 0) }