From ec29788a488983e2986c5149a6a7c4167738b6c0 Mon Sep 17 00:00:00 2001
From: Ben Wilson <ben@registrationmax.com>
Date: Wed, 28 Jun 2023 17:51:22 -0400
Subject: [PATCH] changed it back to callback based

---
 src/models/StratumV1Client.ts | 13 +++++--------
 1 file changed, 5 insertions(+), 8 deletions(-)

diff --git a/src/models/StratumV1Client.ts b/src/models/StratumV1Client.ts
index 4c99fbb..45b5749 100644
--- a/src/models/StratumV1Client.ts
+++ b/src/models/StratumV1Client.ts
@@ -4,7 +4,6 @@ import { validate, ValidatorOptions } from 'class-validator';
 import * as crypto from 'crypto';
 import { Socket } from 'net';
 import { combineLatest, firstValueFrom, interval, startWith } from 'rxjs';
-import { promisify } from 'util';
 
 import { ClientStatisticsService } from '../ORM/client-statistics/client-statistics.service';
 import { ClientEntity } from '../ORM/client/client.entity';
@@ -246,7 +245,7 @@ export class StratumV1Client extends EasyUnsubscribe {
 
                 lastIntervalCount = interValCount;
 
-                await this.sendNewMiningJob(blockTemplate, clearJobs);
+                this.sendNewMiningJob(blockTemplate, clearJobs);
 
                 await this.checkDifficulty();
 
@@ -256,7 +255,7 @@ export class StratumV1Client extends EasyUnsubscribe {
         }
     }
 
-    private async sendNewMiningJob(blockTemplate: IBlockTemplate, clearJobs: boolean) {
+    private sendNewMiningJob(blockTemplate: IBlockTemplate, clearJobs: boolean) {
 
         // const payoutInformation = [
         //     { address: 'bc1q99n3pu025yyu0jlywpmwzalyhm36tg5u37w20d', percent: 1.8 },
@@ -273,8 +272,7 @@ export class StratumV1Client extends EasyUnsubscribe {
 
         const data = job.response + '\n';
 
-        const writeAsync = promisify(this.socket.write).bind(this.socket);
-        await writeAsync(data);
+        this.socket.write(data);
 
         console.log(`Sent new job to ${this.extraNonce}. (clearJobs: ${clearJobs})`)
 
@@ -337,12 +335,11 @@ export class StratumV1Client extends EasyUnsubscribe {
                 params: [targetDiff]
             }) + '\n';
 
-            const writeAsync = promisify(this.socket.write).bind(this.socket);
-            await writeAsync(data);
+            this.socket.write(data);
 
             // we need to clear the jobs so that the difficulty set takes effect. Otherwise the different miner implementations can cause issues
             const { blockTemplate } = await firstValueFrom(this.blockTemplateService.currentBlockTemplate$);
-            await this.sendNewMiningJob(blockTemplate, true);
+            this.sendNewMiningJob(blockTemplate, true);