From 06375151c8d0e928614c9ba3681ae7224a78d014 Mon Sep 17 00:00:00 2001
From: Ben Wilson <ben@registrationmax.com>
Date: Sun, 6 Aug 2023 00:08:09 -0400
Subject: [PATCH] don't attempt to destroy socket on end event

---
 src/models/StratumV1Client.ts      | 3 ---
 src/services/stratum-v1.service.ts | 6 ++----
 2 files changed, 2 insertions(+), 7 deletions(-)

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);
 
       });