chore: enhance node health checks in processors

Author: kastov

package-lock.json

@@ -77,7 +77,7 @@
     "@prisma/adapter-pg": "6.19.0",
     "@prisma/client": "6.19.0",
     "@remnawave/hashed-set": "^0.0.4",
-    "@remnawave/node-contract": "0.6.0",
+    "@remnawave/node-contract": "0.6.1",
     "@remnawave/xtls-sdk": "^0.7.0",
     "@scalar/nestjs-api-reference": "^1.0.8",
     "@simplewebauthn/server": "^13.2.2",

package.json

@@ -54,6 +54,7 @@ export class AxiosService {
                 ca: jwt.caCert,
                 checkServerIdentity: () => undefined,
                 rejectUnauthorized: true,
+                keepAlive: true,
             });
 
             this.axiosInstance.defaults.httpsAgent = httpsAgent;

src/common/axios/axios.service.ts

@@ -152,6 +152,49 @@ export class StartAllNodesByProfileQueueProcessor extends WorkerHost {
                     throw new Error('Failed to get active node inbounds tags');
                 }
 
+                const xrayStatusResponse = await this.axios.getNodeHealth(node.address, node.port);
+
+                if (!xrayStatusResponse.isOk || !xrayStatusResponse.response) {
+                    await this.commandBus.execute(
+                        new UpdateNodeCommand({
+                            uuid: node.uuid,
+                            lastStatusMessage: xrayStatusResponse.message ?? null,
+                            lastStatusChange: new Date(),
+                            isConnected: false,
+                            isConnecting: false,
+                            usersOnline: 0,
+                        }),
+                    );
+
+                    this.logger.error(
+                        `Pre-check failed. Node: ${node.uuid} – ${node.address}:${node.port}, error: ${xrayStatusResponse.message}`,
+                    );
+
+                    return;
+                }
+
+                if (
+                    xrayStatusResponse.response.nodeVersion === null ||
+                    xrayStatusResponse.response.nodeVersion === undefined
+                ) {
+                    await this.commandBus.execute(
+                        new UpdateNodeCommand({
+                            uuid: node.uuid,
+                            lastStatusMessage:
+                                'Unknown node version. Please upgrade Remnawave Node to the latest version.',
+                            lastStatusChange: new Date(),
+                            isConnected: false,
+                            isConnecting: false,
+                            usersOnline: 0,
+                        }),
+                    );
+
+                    this.logger.error(
+                        `Node ${node.uuid} – unknown node version. Please upgrade Remnawave Node to the latest version.`,
+                    );
+                    return;
+                }
+
                 const filteredInboundsHashes = config.response.hashesPayload.inbounds.filter(
                     (inbound) => activeNodeInboundsTags.has(inbound.tag),
                 );

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

@@ -91,7 +91,7 @@ export class StartNodeProcessor extends WorkerHost {
                 nodeEntity.port,
             );
 
-            if (!xrayStatusResponse.isOk) {
+            if (!xrayStatusResponse.isOk || !xrayStatusResponse.response) {
                 await this.commandBus.execute(
                     new UpdateNodeCommand({
                         uuid: nodeEntity.uuid,
@@ -110,6 +110,28 @@ export class StartNodeProcessor extends WorkerHost {
                 return;
             }
 
+            if (
+                xrayStatusResponse.response.nodeVersion === null ||
+                xrayStatusResponse.response.nodeVersion === undefined
+            ) {
+                await this.commandBus.execute(
+                    new UpdateNodeCommand({
+                        uuid: nodeEntity.uuid,
+                        lastStatusMessage:
+                            'Unknown node version. Please upgrade Remnawave Node to the latest version.',
+                        lastStatusChange: new Date(),
+                        isConnected: false,
+                        isConnecting: false,
+                        usersOnline: 0,
+                    }),
+                );
+
+                this.logger.error(
+                    `Node ${nodeEntity.uuid} – unknown node version. Please upgrade Remnawave Node to the latest version.`,
+                );
+                return;
+            }
+
             const startTime = getTime();
             const config = await this.queryBus.execute(
                 new GetPreparedConfigWithUsersQuery(