nerdminer stuff

src/models/StratumV1Client.ts

@@ -90,7 +90,7 @@ export class StratumV1Client extends EasyUnsubscribe {
             parsedMessage = JSON.parse(message);
         } catch (e) {
             console.log("Invalid JSON");
-            this.promiseSocket.end();
+            await this.promiseSocket.end();
             return;
         }
 
@@ -282,7 +282,7 @@ export class StratumV1Client extends EasyUnsubscribe {
 
                 await this.checkDifficulty();
 
-                // await this.watchdog();
+                await this.watchdog();
             })
 
         }
@@ -295,10 +295,10 @@ export class StratumV1Client extends EasyUnsubscribe {
         }
         const now = Date.now();
         const diffSeconds = (now - time.getTime()) / 1000;
-        // two minutes
-        if (diffSeconds > 120) {
+        // five minutes
+        if (diffSeconds > 60 * 5) {
             console.log('Watchdog ending session');
-            this.promiseSocket.end();
+            await this.promiseSocket.end();
         }
     }
 

src/models/StratumV1ClientStatistics.ts

@@ -3,7 +3,7 @@ import { ClientEntity } from '../ORM/client/client.entity';
 
 const CACHE_SIZE = 30;
 const TARGET_SUBMISSION_PER_SECOND = 10;
-const MIN_DIFF = 1e-9;
+const MIN_DIFF = 0.000001;
 export class StratumV1ClientStatistics {
 
     private submissionCacheStart: Date;