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

fix bug

Browse Source
This commit is contained in:
CounterFire2023 2024-01-16 10:28:17 +08:00
parent eda5df70c0
commit 9fe1ea98d6
4 changed files with 11 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/chain/chain.api.ts
View File

@ -6,8 +6,14 @@ const AbortController = globalThis.AbortController
const request = async (url: string, options: any) => { const request = async (url: string, options: any) => {
const controller = new AbortController() const controller = new AbortController()
const timeout = setTimeout(() => controller.abort(), 30000) const timeout = setTimeout(() => controller.abort(), 30000)
const res = await fetch(url, { ...options, signal: controller.signal }) let res;
clearTimeout(timeout) try {
res = await fetch(url, { ...options, signal: controller.signal })
clearTimeout(timeout)
} catch (err) {
clearTimeout(timeout)
throw err;
}
return res return res
} }

3
src/models/NftHolder.ts
View File

@ -30,7 +30,8 @@ export class NftHolderClass extends BaseModule {
const tokenId = event.decodedData.tokenId; const tokenId = event.decodedData.tokenId;
const blockNumer = event.blockNumber; const blockNumer = event.blockNumber;
const burn = event.decodedData.to === ZERO_ADDRESS const burn = event.decodedData.to === ZERO_ADDRESS
const user = (burn ? event.decodedData.from : event.decodedData.to).toLowerCase() let user = (burn ? event.decodedData.from : event.decodedData.to).toLowerCase()
user = user.toLowerCase()
let record = await NftHolder.findOne({ address, chain, tokenId }) let record = await NftHolder.findOne({ address, chain, tokenId })
if (!record) { if (!record) {
record = new NftHolder({ address, chain, tokenId, blockNumber: blockNumer, user, burn }) record = new NftHolder({ address, chain, tokenId, blockNumber: blockNumer, user, burn })

6
src/service/block.sync.service.ts
View File

@ -28,7 +28,6 @@ export class BlockSyncSvr {
} }
async execute() { async execute() {
// try {
let currentBlock = await retryEthBlockNumber(this.rpc) let currentBlock = await retryEthBlockNumber(this.rpc)
let blockStr = await new RedisClient().get(this.redisKey) let blockStr = await new RedisClient().get(this.redisKey)
if (blockStr) { if (blockStr) {
@ -45,9 +44,6 @@ export class BlockSyncSvr {
amount: this.batchCount amount: this.batchCount
}) })
await this.processBlockDatas(blocks) await this.processBlockDatas(blocks)
// } catch (err) {
// console.log(err)
// }
} }
async processBlockDatas(iterator: any) { async processBlockDatas(iterator: any) {
@ -82,4 +78,4 @@ export class BlockSyncSvr {
} }
return count return count
} }
} }

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

@ -41,7 +41,6 @@ export class EventBatchSvr {
async execute() { async execute() {
// try {
let currentBlock = await retryEthBlockNumber(this.rpc) let currentBlock = await retryEthBlockNumber(this.rpc)
let toBlock = parseInt(currentBlock.result, 16) let toBlock = parseInt(currentBlock.result, 16)
let blockStr = await new RedisClient().get(this.redisKey) let blockStr = await new RedisClient().get(this.redisKey)
@ -110,11 +109,6 @@ export class EventBatchSvr {
await new RedisClient().set(redisKey, cfg.fromBlock + '') await new RedisClient().set(redisKey, cfg.fromBlock + '')
} }
await new RedisClient().set(this.redisKey, nextBlock + '') await new RedisClient().set(this.redisKey, nextBlock + '')
// } catch (err) {
// logger.error('sync events error: ', err.message || err)
// throw err
// }
} }
buildRedisKey(cfg: IEventCfg) { buildRedisKey(cfg: IEventCfg) {