From 4928f34dafa660204b5b06d57a4094318b0d1a64 Mon Sep 17 00:00:00 2001 From: Benjamin Wilson Date: Mon, 16 Sep 2024 19:39:56 -0400 Subject: [PATCH] debug --- src/ORM/rpc-block/rpc-block.service.ts | 2 +- src/models/StratumV1Client.ts | 2 +- src/services/bitcoin-rpc.service.ts | 7 ++++++- src/services/stratum-v1.service.ts | 2 +- 4 files changed, 9 insertions(+), 4 deletions(-) diff --git a/src/ORM/rpc-block/rpc-block.service.ts b/src/ORM/rpc-block/rpc-block.service.ts index 65d8d4a..1bc3c9c 100644 --- a/src/ORM/rpc-block/rpc-block.service.ts +++ b/src/ORM/rpc-block/rpc-block.service.ts @@ -19,7 +19,7 @@ export class RpcBlockService { } public saveBlock(blockHeight: number, data: string) { - return this.rpcBlockRepository.update(blockHeight, { data }) + return this.rpcBlockRepository.update(blockHeight, { data }); } public async deleteOldBlocks() { diff --git a/src/models/StratumV1Client.ts b/src/models/StratumV1Client.ts index e90f9ac..26b97ad 100644 --- a/src/models/StratumV1Client.ts +++ b/src/models/StratumV1Client.ts @@ -143,7 +143,7 @@ export class StratumV1Client { this.sessionStart = new Date(); this.statistics = new StratumV1ClientStatistics(this.clientStatisticsService); this.extraNonceAndSessionId = this.getRandomHexString(); - console.log(`New client ID: : ${this.extraNonceAndSessionId}, ${this.socket.remoteAddress}:${this.socket.remotePort}`); + //console.log(`New client ID: : ${this.extraNonceAndSessionId}, ${this.socket.remoteAddress}:${this.socket.remotePort}`); } this.clientSubscription = subscriptionMessage; diff --git a/src/services/bitcoin-rpc.service.ts b/src/services/bitcoin-rpc.service.ts index c5efa62..95b9cfa 100644 --- a/src/services/bitcoin-rpc.service.ts +++ b/src/services/bitcoin-rpc.service.ts @@ -134,7 +134,12 @@ export class BitcoinRpcService implements OnModuleInit { try{ console.log(`Saving block ${blockHeight}`); - await this.rpcBlockService.saveBlock(blockHeight, JSON.stringify(blockTemplate)); + const result = await this.rpcBlockService.saveBlock(blockHeight, JSON.stringify(blockTemplate)); + if(result.affected < 1){ + console.error('Block was not saved'); + }else { + console.log('block saved'); + } }catch(e){ console.error('Error saving block', e); diff --git a/src/services/stratum-v1.service.ts b/src/services/stratum-v1.service.ts index 1d9fc25..aae82c2 100644 --- a/src/services/stratum-v1.service.ts +++ b/src/services/stratum-v1.service.ts @@ -64,7 +64,7 @@ export class StratumV1Service implements OnModuleInit { if (client.extraNonceAndSessionId != null) { // Handle socket disconnection await client.destroy(); - console.log(`Client ${client.extraNonceAndSessionId} disconnected, hadError?:${hadError}`); + //console.log(`Client ${client.extraNonceAndSessionId} disconnected, hadError?:${hadError}`); } });