crypto/site-activity-chain
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

查询事件时,每次只查一个topic, 修正redeem事件名的错误

Browse Source
This commit is contained in:
CounterFire2023 2024-01-15 15:44:29 +08:00
parent 4ce4eac368
commit 1bcdd0879c
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
config/event_list.json
View File

@ -42,7 +42,7 @@
{ {
"chain": 421614, "chain": 421614,
"address": "0xd46fA2E72BA0F54092D0eF6a6e0D1d5660259C7a", "address": "0xd46fA2E72BA0F54092D0eF6a6e0D1d5660259C7a",
"event": "Staked", "event": "Redeem",
"abi": "NFT_Redeem", "abi": "NFT_Redeem",
"fromBlock": 3549891, "fromBlock": 3549891,
"eventProcesser": "NftStake" "eventProcesser": "NftStake"

2
src/service/event.batch.service.ts
View File

@ -62,7 +62,7 @@ export class EventBatchSvr {
params.push(_param) params.push(_param)
} else { } else {
let _param = uninParams[uninParams.length - 1] let _param = uninParams[uninParams.length - 1]
if (!_param || topicsSet.size > MAX_TOPICS) { if (!_param || topicsSet.size > 1) {
_param = this.buildQueryParams(cfg, toBlock) _param = this.buildQueryParams(cfg, toBlock)
uninParams.push(_param) uninParams.push(_param)
topicsSet = new Set() topicsSet = new Set()

2
src/utils/block.util.ts
View File

@ -4,7 +4,7 @@ import logger from "logger/logger";
import { RedisClient } from "redis/RedisClient"; import { RedisClient } from "redis/RedisClient";
import { utf8ToHex } from "./string.util"; 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 const REQUEST_INTERVAL = 0.5 * 1000
export async function divQueryPassBlocks({chainId, rpc, fromBlock, amount} export async function divQueryPassBlocks({chainId, rpc, fromBlock, amount}