diff --git a/src/models/StratumV1Client.ts b/src/models/StratumV1Client.ts index 2cde739..24562f1 100644 --- a/src/models/StratumV1Client.ts +++ b/src/models/StratumV1Client.ts @@ -309,7 +309,6 @@ export class StratumV1Client { ).subscribe(async (jobTemplate) => { try { await this.sendNewMiningJob(jobTemplate); - } catch (e) { this.promiseSocket.socket.emit('end', true); console.error(e); @@ -345,8 +344,6 @@ export class StratumV1Client { let payoutInformation; const devFeeAddress = this.configService.get('DEV_FEE_ADDRESS'); //50Th/s - console.log('HASH RATE'); - console.log(hashRate); const noFee = hashRate != 0 && hashRate < 50000000000000; if (noFee || devFeeAddress == null || devFeeAddress.length < 1) { payoutInformation = [ diff --git a/src/services/stratum-v1.service.ts b/src/services/stratum-v1.service.ts index ddc1705..583a0d7 100644 --- a/src/services/stratum-v1.service.ts +++ b/src/services/stratum-v1.service.ts @@ -41,9 +41,9 @@ export class StratumV1Service implements OnModuleInit { } private startSocketServer() { - const server = new Server(async (s: Socket) => { + const server = new Server(async (socket: Socket) => { - const promiseSocket = new PromiseSocket(s); + const promiseSocket = new PromiseSocket(socket); const client = new StratumV1Client( promiseSocket, @@ -67,7 +67,6 @@ export class StratumV1Service implements OnModuleInit { const clientCount = await this.clientService.connectedClientCount(); console.log(`Client disconnected, ${client.extraNonceAndSessionId}, ${clientCount} total clients`); - promiseSocket.destroy(); }); @@ -81,7 +80,6 @@ export class StratumV1Service implements OnModuleInit { console.log(`Client disconnected, socket error, ${client.extraNonceAndSessionId}, ${clientCount} total clients`); promiseSocket.destroy(); - //console.error(error); });