From 1bcdd0879c4e2952a94eb098700f66ffac38d832 Mon Sep 17 00:00:00 2001
From: CounterFire2023 <136581895+CounterFire2023@users.noreply.github.com>
Date: Mon, 15 Jan 2024 15:44:29 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9F=A5=E8=AF=A2=E4=BA=8B=E4=BB=B6=E6=97=B6,?=
 =?UTF-8?q?=E6=AF=8F=E6=AC=A1=E5=8F=AA=E6=9F=A5=E4=B8=80=E4=B8=AAtopic,=20?=
 =?UTF-8?q?=E4=BF=AE=E6=AD=A3redeem=E4=BA=8B=E4=BB=B6=E5=90=8D=E7=9A=84?=
 =?UTF-8?q?=E9=94=99=E8=AF=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 config/event_list.json             | 2 +-
 src/service/event.batch.service.ts | 2 +-
 src/utils/block.util.ts            | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

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}