From 7d46abd9dc86d3021fc333bcd1fc742457deb5b5 Mon Sep 17 00:00:00 2001 From: MuRong Date: Wed, 26 Feb 2025 17:40:33 +0800 Subject: [PATCH 1/5] feat(reku): add debug logs --- .../src/event/crosschecker/autochecker.ts | 33 ++++++++++++------- 1 file changed, 21 insertions(+), 12 deletions(-) diff --git a/packages/reku/src/event/crosschecker/autochecker.ts b/packages/reku/src/event/crosschecker/autochecker.ts index e953cb0..a530ec1 100644 --- a/packages/reku/src/event/crosschecker/autochecker.ts +++ b/packages/reku/src/event/crosschecker/autochecker.ts @@ -92,6 +92,7 @@ export class AutoCrossChecker extends BaseCrossChecker { const waitNextCrosscheck = async (): Promise => { latestBlockNum = await timeoutWithRetry(() => { + // console.log(this.provider, this.provider.provider) if (!this.provider || !this.provider.provider) throw new Error('provider not ready') return this.provider.provider?.getBlockNumber() @@ -142,20 +143,28 @@ export class AutoCrossChecker extends BaseCrossChecker { debug('crosscheck running') // TODO: replace polling with schedule cron - await polling(async () => { - const wait = await waitOrUpdateToBlock() - debug('polling interval: %d, wait: %s, from block: %d, to block: %d', pollingInterval, wait, ccrOptions.fromBlock, ccrOptions.toBlock) - if (wait) { - await this.crossCheckRange(ccrOptions) - // only update options after cc succ - await updateCCROptions(ccrOptions) + polling(async () => { + try { + debug('start polling') + const wait = await waitOrUpdateToBlock() + debug('polling interval: %d, wait: %s, from block: %d, to block: %d', pollingInterval, wait, ccrOptions.fromBlock, ccrOptions.toBlock) + if (wait) { + await this.crossCheckRange(ccrOptions) + // only update options after cc succ + await updateCCROptions(ccrOptions) + } + else { + debug('Because the latest block %d is too old, skip this cross check', latestBlockNum) + } + debug('end condition') + const end = endingCondition() + debug('polling ending condition: %s', end) + return end } - else { - debug('Because the latest block %d is too old, skip this cross check', latestBlockNum) + catch (error) { + debug('polling error', error) + return false } - const end = endingCondition() - debug('polling ending condition: %s', end) - return end }, pollingInterval) } From 3db6c9d797262ab4e4289fd06729f45596431940 Mon Sep 17 00:00:00 2001 From: MuRong Date: Wed, 26 Feb 2025 17:41:06 +0800 Subject: [PATCH 2/5] chore: release v0.3.6 --- packages/reku/package.json | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/packages/reku/package.json b/packages/reku/package.json index d8e9ca2..bdf09d2 100644 --- a/packages/reku/package.json +++ b/packages/reku/package.json @@ -1,7 +1,7 @@ { "name": "@ora-io/reku", "type": "module", - "version": "0.3.5", + "version": "0.3.6", "packageManager": "pnpm@8.10.5", "description": "", "author": "Norman (nom4dv3), MuRong", From ce8d741b744a3709687f623404205bee7c82cf99 Mon Sep 17 00:00:00 2001 From: MuRong Date: Wed, 26 Feb 2025 18:17:33 +0800 Subject: [PATCH 3/5] fix(reku): polling --- packages/reku/src/event/crosschecker/autochecker.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/packages/reku/src/event/crosschecker/autochecker.ts b/packages/reku/src/event/crosschecker/autochecker.ts index a530ec1..541a363 100644 --- a/packages/reku/src/event/crosschecker/autochecker.ts +++ b/packages/reku/src/event/crosschecker/autochecker.ts @@ -143,7 +143,7 @@ export class AutoCrossChecker extends BaseCrossChecker { debug('crosscheck running') // TODO: replace polling with schedule cron - polling(async () => { + await polling(async () => { try { debug('start polling') const wait = await waitOrUpdateToBlock() From 91a1491dff63436c5e84cd76bbbbad124af1fdfc Mon Sep 17 00:00:00 2001 From: MuRong Date: Wed, 26 Feb 2025 18:18:03 +0800 Subject: [PATCH 4/5] chore: release v0.3.7 --- packages/reku/package.json | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/packages/reku/package.json b/packages/reku/package.json index bdf09d2..10ade28 100644 --- a/packages/reku/package.json +++ b/packages/reku/package.json @@ -1,7 +1,7 @@ { "name": "@ora-io/reku", "type": "module", - "version": "0.3.6", + "version": "0.3.7", "packageManager": "pnpm@8.10.5", "description": "", "author": "Norman (nom4dv3), MuRong", From a012db666e0d8e5a2434a3ff97d9fe6083340589 Mon Sep 17 00:00:00 2001 From: MuRong Date: Wed, 26 Feb 2025 18:31:12 +0800 Subject: [PATCH 5/5] chore: release v0.3.5 --- package.json | 2 +- packages/orap/package.json | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/package.json b/package.json index 9db6342..f57a702 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "ora-stack", - "version": "0.3.4", + "version": "0.3.5", "private": true, "packageManager": "pnpm@9.7.0", "description": "", diff --git a/packages/orap/package.json b/packages/orap/package.json index 229f912..d6e58f9 100644 --- a/packages/orap/package.json +++ b/packages/orap/package.json @@ -1,7 +1,7 @@ { "name": "@ora-io/orap", "type": "module", - "version": "0.3.4", + "version": "0.3.5", "packageManager": "pnpm@8.10.5", "description": "", "author": "Norman (nom4dv3), MuRong",