feat: implement node disabling and stopping logic in queue processors

- Added logic to disable nodes without active inbounds in StartAllNodesByProfileQueueProcessor.
- Integrated StopNodeQueueService to handle stopping of nodes in both StartAllNodesByProfileQueueProcessor and StartNodeQueueProcessor.

Author: kastov

src/queue/start-all-nodes-by-profile/start-all-nodes-by-profile.processor.ts

@@ -13,6 +13,7 @@ import { NodesEntity, NodesRepository } from '@modules/nodes';
 
 import { StartAllNodesQueueService } from '@queue/start-all-nodes';
 import { StartNodeQueueService } from '@queue/start-node';
+import { StopNodeQueueService } from '@queue/stop-node';
 
 import { StartAllNodesByProfileJobNames } from './enums';
 import { QueueNames } from '../queue.enum';
@@ -34,6 +35,7 @@ export class StartAllNodesByProfileQueueProcessor extends WorkerHost {
         private readonly nodesRepository: NodesRepository,
         private readonly axios: AxiosService,
         private readonly startNodeQueueService: StartNodeQueueService,
+        private readonly stopNodeQueueService: StopNodeQueueService,
         private readonly startAllNodesQueueService: StartAllNodesQueueService,
         private readonly queryBus: QueryBus,
     ) {
@@ -69,6 +71,32 @@ export class StartAllNodesByProfileQueueProcessor extends WorkerHost {
             const activeNodeTags = new Map<string, string[]>();
 
             for (const node of nodes) {
+                if (node.activeInbounds.length === 0) {
+                    this.logger.warn(
+                        `No active inbounds found for node ${node.uuid} with profile ${payload.profileUuid}, disabling and clearing profile from node...`,
+                    );
+
+                    await this.nodesRepository.update({
+                        uuid: node.uuid,
+                        isDisabled: true,
+                        activeConfigProfileUuid: null,
+                        isConnecting: false,
+                        isXrayRunning: false,
+                        isNodeOnline: false,
+                        isConnected: false,
+                        lastStatusMessage: null,
+                        lastStatusChange: new Date(),
+                        usersOnline: 0,
+                    });
+
+                    await this.stopNodeQueueService.stopNode({
+                        nodeUuid: node.uuid,
+                        isNeedToBeDeleted: false,
+                    });
+
+                    continue;
+                }
+
                 await this.nodesRepository.update({
                     uuid: node.uuid,
                     isConnecting: true,

src/queue/start-node/start-node.processor.ts

@@ -13,6 +13,8 @@ import { NodeEvent } from '@integration-modules/notifications/interfaces';
 import { GetPreparedConfigWithUsersQuery } from '@modules/users/queries/get-prepared-config-with-users';
 import { NodesRepository } from '@modules/nodes';
 
+import { StopNodeQueueService } from '@queue/stop-node';
+
 import { StartNodeJobNames } from './enums';
 import { QueueNames } from '../queue.enum';
 
@@ -25,6 +27,7 @@ export class StartNodeQueueProcessor extends WorkerHost {
     constructor(
         private readonly axios: AxiosService,
         private readonly nodesRepository: NodesRepository,
+        private readonly stopNodeQueueService: StopNodeQueueService,
         private readonly queryBus: QueryBus,
         private readonly eventEmitter: EventEmitter2,
     ) {
@@ -47,7 +50,28 @@ export class StartNodeQueueProcessor extends WorkerHost {
             }
 
             if (!nodeEntity.activeConfigProfileUuid || !nodeEntity.activeInbounds) {
-                this.logger.error(`Node ${nodeUuid} has no active config profile or inbounds`);
+                this.logger.warn(
+                    `Node ${nodeUuid} has no active config profile or inbounds, disabling and clearing profile from node...`,
+                );
+
+                await this.nodesRepository.update({
+                    uuid: nodeEntity.uuid,
+                    isDisabled: true,
+                    activeConfigProfileUuid: null,
+                    isConnecting: false,
+                    isXrayRunning: false,
+                    isNodeOnline: false,
+                    isConnected: false,
+                    lastStatusMessage: null,
+                    lastStatusChange: new Date(),
+                    usersOnline: 0,
+                });
+
+                await this.stopNodeQueueService.stopNode({
+                    nodeUuid: nodeEntity.uuid,
+                    isNeedToBeDeleted: false,
+                });
+
                 return;
             }