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 { + 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 { + if (process.env.MASTER !== 'true') { + return; + } if (this.bot == null) { return;