diff --git a/src/service/block.sync.service.ts b/src/service/block.sync.service.ts index c2e503f..3223946 100644 --- a/src/service/block.sync.service.ts +++ b/src/service/block.sync.service.ts @@ -28,7 +28,7 @@ export class BlockSyncSvr { } async execute() { - try { + // try { let currentBlock = await retryEthBlockNumber(this.rpc) let blockStr = await new RedisClient().get(this.redisKey) if (blockStr) { @@ -45,9 +45,9 @@ export class BlockSyncSvr { amount: this.batchCount }) await this.processBlockDatas(blocks) - } catch (err) { - console.log(err) - } + // } catch (err) { + // console.log(err) + // } } async processBlockDatas(iterator: any) { diff --git a/src/service/event.batch.service.ts b/src/service/event.batch.service.ts index af7faec..f31e57e 100644 --- a/src/service/event.batch.service.ts +++ b/src/service/event.batch.service.ts @@ -41,7 +41,7 @@ export class EventBatchSvr { async execute() { - try { + // try { let currentBlock = await retryEthBlockNumber(this.rpc) let toBlock = parseInt(currentBlock.result, 16) let blockStr = await new RedisClient().get(this.redisKey) @@ -111,9 +111,10 @@ export class EventBatchSvr { } await new RedisClient().set(this.redisKey, nextBlock + '') - } catch (err) { - console.log(err) - } + // } catch (err) { + // logger.error('sync events error: ', err.message || err) + // throw err + // } } buildRedisKey(cfg: IEventCfg) {