diff --git a/config/event_list.json b/config/event_list.json index b4b9df8..b432937 100644 --- a/config/event_list.json +++ b/config/event_list.json @@ -42,7 +42,7 @@ { "chain": 421614, "address": "0xd46fA2E72BA0F54092D0eF6a6e0D1d5660259C7a", - "event": "Staked", + "event": "Redeem", "abi": "NFT_Redeem", "fromBlock": 3549891, "eventProcesser": "NftStake" diff --git a/src/service/event.batch.service.ts b/src/service/event.batch.service.ts index ba9fc0d..b68698b 100644 --- a/src/service/event.batch.service.ts +++ b/src/service/event.batch.service.ts @@ -62,7 +62,7 @@ export class EventBatchSvr { params.push(_param) } else { let _param = uninParams[uninParams.length - 1] - if (!_param || topicsSet.size > MAX_TOPICS) { + if (!_param || topicsSet.size > 1) { _param = this.buildQueryParams(cfg, toBlock) uninParams.push(_param) topicsSet = new Set() diff --git a/src/utils/block.util.ts b/src/utils/block.util.ts index da0b4cb..e3fadce 100644 --- a/src/utils/block.util.ts +++ b/src/utils/block.util.ts @@ -4,7 +4,7 @@ import logger from "logger/logger"; import { RedisClient } from "redis/RedisClient"; import { utf8ToHex } from "./string.util"; -const MAX_BATCH_AMOUNT = 500 +const MAX_BATCH_AMOUNT = +process.env.MAX_BLOCK_BATCH_AMOUNT const REQUEST_INTERVAL = 0.5 * 1000 export async function divQueryPassBlocks({chainId, rpc, fromBlock, amount}