From 4155335bb5052a4a4054e5df9b86e5581f35b1e0 Mon Sep 17 00:00:00 2001
From: Ben <wilsob12@gmail.com>
Date: Sun, 7 Jun 2026 23:18:00 -0400
Subject: [PATCH] Limit background services by process role

---
 src/services/notification.service.ts    | 6 +++++-
 src/services/stratum-v1-jobs.service.ts | 4 +++-
 src/services/telegram.service.ts        | 7 +++++++
 3 files changed, 15 insertions(+), 2 deletions(-)

diff --git a/src/services/notification.service.ts b/src/services/notification.service.ts
index f643426..4b1355b 100644
--- a/src/services/notification.service.ts
+++ b/src/services/notification.service.ts
@@ -14,6 +14,10 @@ export class NotificationService implements OnModuleInit {
     ) { }
 
     async onModuleInit(): Promise<void> {
+        if (process.env.MASTER !== 'true') {
+            return;
+        }
+
         await this.discordService.notifyRestarted();
     }
 
@@ -21,4 +25,4 @@ export class NotificationService implements OnModuleInit {
         await this.discordService.notifySubscribersBlockFound(height, block, message);
         await this.telegramService.notifySubscribersBlockFound(address, height, block, message);
     }
-}
\ No newline at end of file
+}
diff --git a/src/services/stratum-v1-jobs.service.ts b/src/services/stratum-v1-jobs.service.ts
index ca35c82..83d89cd 100644
--- a/src/services/stratum-v1-jobs.service.ts
+++ b/src/services/stratum-v1-jobs.service.ts
@@ -154,7 +154,9 @@ export class StratumV1JobsService {
             shareReplay({ refCount: true, bufferSize: 1 })
         )
 
-        this.newMiningJob$.subscribe();
+        if (process.env.API_ONLY !== 'true') {
+            this.newMiningJob$.subscribe();
+        }
     }
 
     private calculateNetworkDifficulty(nBits: number) {
diff --git a/src/services/telegram.service.ts b/src/services/telegram.service.ts
index 499a630..2bdf78b 100644
--- a/src/services/telegram.service.ts
+++ b/src/services/telegram.service.ts
@@ -18,6 +18,10 @@ export class TelegramService implements OnModuleInit {
         private readonly configService: ConfigService,
         private readonly telegramSubscriptionsService: TelegramSubscriptionsService
     ) {
+        if (process.env.MASTER !== 'true') {
+            return;
+        }
+
         const token: string | null = this.configService.get('TELEGRAM_BOT_TOKEN');
         if (token == null || token.length < 1) {
             return;
@@ -32,6 +36,9 @@ export class TelegramService implements OnModuleInit {
     }
 
     async onModuleInit(): Promise<void> {
+        if (process.env.MASTER !== 'true') {
+            return;
+        }
 
         if (this.bot == null) {
             return;