diff --git a/app/apps/worker-service/src/worker/ethereum.worker.ts b/app/apps/worker-service/src/worker/ethereum.worker.ts index d77d31e..67da96a 100644 --- a/app/apps/worker-service/src/worker/ethereum.worker.ts +++ b/app/apps/worker-service/src/worker/ethereum.worker.ts @@ -52,15 +52,18 @@ export class EthereumWorker { '0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef', ], }); - + const emitStart = Date.now(); // handle native transfer await this.emitNativeTransaction(block, false); // handle extracted event for erc20 and nft await this.emitLog(logs, false); + const emitEnd = Date.now(); //only update last sync for confirm await this.saveBlockHistory(blockNumber, false); this.logger.log( - `DETECT Scanning block ${blockNumber} in ${Date.now() - start}ms`, + `DETECT Scanning block ${blockNumber} in ${ + Date.now() - start + }ms and emit ${emitEnd - emitStart}ms`, ); } catch (error) { this.logger.error([ @@ -100,14 +103,17 @@ export class EthereumWorker { '0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef', ], }); + const emitStart = Date.now(); // handle native transfer await this.emitNativeTransaction(block, true); // handle extracted event for erc20 and nft await this.emitLog(logs, true); - + const emitEnd = Date.now(); await this.saveBlockHistory(blockNumber, true); this.logger.log( - `CONFIRM Scanning block ${blockNumber} in ${Date.now() - start}ms`, + `CONFIRM Scanning block ${blockNumber} in ${ + Date.now() - start + }ms and emit ${emitEnd - emitStart}ms`, ); } catch (error) { this.logger.error([ diff --git a/app/apps/worker-service/src/worker/polygon.worker.ts b/app/apps/worker-service/src/worker/polygon.worker.ts index 2d536c2..b34988a 100644 --- a/app/apps/worker-service/src/worker/polygon.worker.ts +++ b/app/apps/worker-service/src/worker/polygon.worker.ts @@ -52,14 +52,18 @@ export class PolygonWorker { ], }); + const emitStart = Date.now(); // handle native transfer await this.emitNativeTransaction(block, false); // handle extracted event for erc20 and nft await this.emitLog(logs, false); + const emitEnd = Date.now(); //only update last sync for confirm await this.saveBlockHistory(blockNumber, false); this.logger.log( - `DETECT Scanning block ${blockNumber} in ${Date.now() - start}ms`, + `DETECT Scanning block ${blockNumber} in ${ + Date.now() - start + }ms with emit ${emitEnd - emitStart}ms`, ); } catch (error) { this.logger.error([ @@ -99,14 +103,17 @@ export class PolygonWorker { '0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef', ], }); + const emitStart = Date.now(); // handle native transfer await this.emitNativeTransaction(block, true); // handle extracted event for erc20 and nft await this.emitLog(logs, true); - + const emitEnd = Date.now(); await this.saveBlockHistory(blockNumber, true); this.logger.log( - `CONFIRM Scanning block ${blockNumber} in ${Date.now() - start}ms`, + `CONFIRM Scanning block ${blockNumber} in ${ + Date.now() - start + }ms with emit ${emitEnd - emitStart}ms`, ); } catch (error) { this.logger.error([