From fb8715c23d2e9568cdbeb439a119568f760ef827 Mon Sep 17 00:00:00 2001
From: Benjamin Wilson <admin@opensourceminer.com>
Date: Sat, 7 Sep 2024 23:56:09 -0400
Subject: [PATCH] multi port

---
 .env.example                       |  2 +-
 src/services/stratum-v1.service.ts | 13 ++++++++-----
 2 files changed, 9 insertions(+), 6 deletions(-)

diff --git a/.env.example b/.env.example
index 0c1ae87..c5b8633 100644
--- a/.env.example
+++ b/.env.example
@@ -15,7 +15,7 @@ BITCOIN_RPC_TIMEOUT=10000
 # BITCOIN_ZMQ_HOST="tcp://192.168.1.100:3000"
 
 API_PORT=3334
-STRATUM_PORT=3333
+STRATUM_PORTS=3333,3332,3331,3330
 
 #optional telegram bot
 #TELEGRAM_BOT_TOKEN=
diff --git a/src/services/stratum-v1.service.ts b/src/services/stratum-v1.service.ts
index 59fb2d4..68269f2 100644
--- a/src/services/stratum-v1.service.ts
+++ b/src/services/stratum-v1.service.ts
@@ -33,12 +33,15 @@ export class StratumV1Service implements OnModuleInit {
       if (process.env.NODE_APP_INSTANCE == '0') {
         await this.clientService.deleteAll();
       }
-      this.startSocketServer();
-
+      setTimeout(() => {
+        process.env.STRATUM_PORTS.split(',').forEach(port =>{
+          this.startSocketServer(parseInt(port));
+        });
+      }, 1000 * 10)
 
   }
 
-  private startSocketServer() {
+  private startSocketServer(port: number) {
     const server = new Server(async (socket: Socket) => {
 
       //10 min
@@ -78,8 +81,8 @@ export class StratumV1Service implements OnModuleInit {
 
     });
 
-    server.listen(process.env.STRATUM_PORT, () => {
-      console.log(`Stratum server is listening on port ${process.env.STRATUM_PORT}`);
+    server.listen(port, () => {
+      console.log(`Stratum server is listening on port ${port}`);
     });
 
   }