From 14f6d5802f013b7e713f0a8f17abf2c050da0928 Mon Sep 17 00:00:00 2001
From: Ben Wilson <ben@registrationmax.com>
Date: Mon, 7 Aug 2023 22:38:19 -0400
Subject: [PATCH] defer some db operations

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

diff --git a/src/models/StratumV1Client.ts b/src/models/StratumV1Client.ts
index 0aab5c8..cdf96a4 100644
--- a/src/models/StratumV1Client.ts
+++ b/src/models/StratumV1Client.ts
@@ -359,12 +359,16 @@ export class StratumV1Client {
 
     private async sendNewMiningJob(jobTemplate: IJobTemplate) {
 
-        this.hashRate = await this.clientStatisticsService.getHashRateForSession(this.clientAuthorization.address, this.clientAuthorization.worker, this.extraNonceAndSessionId);
+
 
         let payoutInformation;
         const devFeeAddress = this.configService.get('DEV_FEE_ADDRESS');
         //50Th/s
-        this.noFee = this.hashRate != 0 && this.hashRate < 50000000000000;
+        this.noFee = false;
+        if (this.entity) {
+            this.hashRate = await this.clientStatisticsService.getHashRateForSession(this.clientAuthorization.address, this.clientAuthorization.worker, this.extraNonceAndSessionId);
+            this.noFee = this.hashRate != 0 && this.hashRate < 50000000000000;
+        }
         if (this.noFee || devFeeAddress == null || devFeeAddress.length < 1) {
             payoutInformation = [
                 { address: this.clientAuthorization.address, percent: 100 }
@@ -576,7 +580,7 @@ export class StratumV1Client {
 
                 return true;
             } else {
-                console.error('Error: Cannot write to closed or ended socket.');
+                console.error(`Error: Cannot write to closed or ended socket. ${this.extraNonceAndSessionId}`);
                 this.destroy();
                 return false;
             }
@@ -585,7 +589,7 @@ export class StratumV1Client {
             if (!this.socket.destroyed && !this.socket.writableEnded) {
                 await this.socket.end();
             }
-            console.error('Error occurred while writing to socket:', error);
+            console.error(`Error occurred while writing to socket: ${this.extraNonceAndSessionId}`, error);
             return false;
         }
     }