From 2b61afbafe9fc17af11a920428bb2da968e18f38 Mon Sep 17 00:00:00 2001 From: gozzy Date: Wed, 22 Mar 2023 20:50:13 +0000 Subject: [PATCH] improve rpc rate-limit conditions --- services/events.js | 6 +++--- services/registry/index.js | 5 ++--- 2 files changed, 5 insertions(+), 6 deletions(-) diff --git a/services/events.js b/services/events.js index 7fee968..b76880e 100644 --- a/services/events.js +++ b/services/events.js @@ -280,8 +280,8 @@ class EventService { } catch (e) { if (shouldRetry) { i = i + 1 - // maximum 10 second buffer for rate-limiting - await sleep(2000 * i) + // maximum 5 second buffer for rate-limiting + await sleep(1000 * i) events = await this.getEventsPartFromRpc( { @@ -317,6 +317,7 @@ class EventService { (e, i) => new Promise(async (resolve) => { try { + sleep(20 * i) const { events } = await this.getEventsPartFromRpc({ ...e }, true) resolve(events) } catch (e) { @@ -369,7 +370,6 @@ class EventService { } } await this.updateEventProgress(progressIndex / batchCount, type) - await sleep(200) } events = flattenNArray(events) diff --git a/services/registry/index.js b/services/registry/index.js index c20a744..9a372be 100644 --- a/services/registry/index.js +++ b/services/registry/index.js @@ -37,7 +37,7 @@ class RelayerRegister { resolve(registeredEventsPart) } catch (error) { if (shouldRetry) { - sleep(1000) + sleep(500) const events = this.fetchEvents({ fromBlock, toBlock }) @@ -61,8 +61,7 @@ class RelayerRegister { const promises = new Array(chunkCount).fill('').map( (_, i) => new Promise((resolve) => { - sleep(300) - + sleep(20 * i) const batch = this.fetchEvents( { fromBlock: i * blockDenom + fromBlock,