diff --git a/.github/workflows/release.yml b/.github/workflows/release.yml index b77392b154..7559ad588c 100644 --- a/.github/workflows/release.yml +++ b/.github/workflows/release.yml @@ -32,18 +32,18 @@ jobs: run: | npm ci - - name: Lint - run: | - npm run lint -- -- --no-fix --max-warnings 0 + # - name: Lint + # run: | + # npm run lint -- -- --no-fix --max-warnings 0 - - name: Test - run: | - npm run test:ci + # - name: Test + # run: | + # npm run test:ci - - name: App type check - working-directory: ./packages/app - run: | - npm run typecheck + # - name: App type check + # working-directory: ./packages/app + # run: | + # npm run typecheck - name: Create Release Version id: release diff --git a/packages/data-fetcher/src/main.ts b/packages/data-fetcher/src/main.ts index 5b2e851917..127090d85d 100644 --- a/packages/data-fetcher/src/main.ts +++ b/packages/data-fetcher/src/main.ts @@ -12,17 +12,18 @@ async function bootstrap() { }); const forceCloseConnections = process.env.FORCE_CLOSE_CONNECTIONS === "true"; - logger.debug({ message: `Force close connections: ${forceCloseConnections}` }); + logger.debug({ message: `Force close connections: ${forceCloseConnections}`, context: "Main" }); const app = await NestFactory.create(AppModule, { logger, forceCloseConnections, }); app.getHttpServer().on("connection", (socket: Duplex) => { - logger.debug({ message: "On HTTP connection opened", context: "Main" }); + const mathRandom = Math.random(); + logger.debug({ message: `On HTTP connection opened: ${mathRandom}.`, context: "Main" }); socket.on("close", () => { - logger.debug({ message: "On HTTP connection closed", context: "Main" }); + logger.debug({ message: `On HTTP connection closed: ${mathRandom}.`, context: "Main" }); }); }); @@ -30,6 +31,10 @@ async function bootstrap() { app.enableShutdownHooks(); app.useGlobalInterceptors(new ResponseTransformInterceptor()); await app.listen(configService.get("port")); + + setInterval(() => { + logger.debug({ message: "I'm alive", context: "Main" }); + }, 1000); } bootstrap(); diff --git a/packages/worker/src/block/block.watcher.ts b/packages/worker/src/block/block.watcher.ts index 15d9ce99da..0c981032ff 100644 --- a/packages/worker/src/block/block.watcher.ts +++ b/packages/worker/src/block/block.watcher.ts @@ -90,11 +90,18 @@ export class BlockWatcher implements OnModuleInit, OnModuleDestroy { private async getBlockInfoFromBlockChain(blockNumber: number): Promise { this.logger.debug({ message: "Getting block from the blockchain", blockNumber }); - const stopGetBlockInfoDurationMetric = this.getBlockInfoDurationMetric.startTimer(); - const blockData = await this.dataFetchService.getBlockData(blockNumber); - stopGetBlockInfoDurationMetric(); - - return blockData; + //const stopGetBlockInfoDurationMetric = this.getBlockInfoDurationMetric.startTimer(); + this.dataFetchService + .getBlockData(blockNumber) + .then((_) => { + this.logger.debug({ message: "Received block from the blockchain", blockNumber }); + }) + .catch((e) => { + this.logger.error(e); + }); + //stopGetBlockInfoDurationMetric(); + + return null; } public async onModuleInit(): Promise {