Status management by a service. Displays the ping of the bot and the API.

2026-03-21 09:48:56 +01:00 · 2025-10-29 08:43:47 +01:00
parent 1689a34d75
commit dd8fc81097
6 changed files with 146 additions and 77 deletions
--- a/src/services/status.service.ts
+++ b/src/services/status.service.ts
@@ -0,0 +1,112 @@
+import ping from "ping";
+import * as cron from 'cron';
+
+export class StatusService {
+
+    public hosts : Host[] = [
+        {
+            'host': 'https://protojx.com',
+            'name': 'Protojx Website 🌐',
+            alive: false,
+            type: 'website'
+        },
+        {
+            'host': 'https://manager.protojx.com',
+            'name': 'Espace Client 💻',
+            alive: false,
+            type: 'website'
+        },
+        {
+            host: '5.178.99.4',
+            name: 'RYZEN 01 🖥️',
+            alive: false,
+            type: 'ping'
+        },
+        {
+            host: '5.167.99.6',
+            name: 'RYZEN 02 🖥️',
+            alive: false,
+            type: 'ping'
+        },
+        {
+            host: '5.178.99.5',
+            name: 'RYZEN 03 🖥️',
+            alive: false,
+            type: 'ping'
+        },
+        {
+            host: '5.178.99.177',
+            name: 'XEON 01 (2697A V4) 🖥️',
+            alive: false,
+            type: 'ping'
+        },
+        {
+            host: '5.178.99.248',
+            name: 'XEON 02 (2687W V4) 🖥️',
+            alive: false,
+            type: 'ping'
+        },
+        {
+            host: '5.178.99.53',
+            name: 'RYZEN-GAME 01 👾',
+            alive: false,
+            type: 'ping'
+        },
+        {
+            host: '5.178.99.63',
+            name: 'XEON-GAME 01 👾',
+            alive: false,
+            type: 'ping'
+        }
+    ]
+    
+    constructor() {
+        const cronJob = new cron.CronJob('*/2 * * * *', async () => {
+            try {
+                await this.fetch();
+                console.log('Status check completed at:', new Date().toISOString());
+            } catch (error) {
+                console.error('Error during status check:', error);
+            }
+        });
+        cronJob.start();
+        console.log('Status monitoring started - checking every 2 minutes');
+    }
+
+    async fetch(max = 1): Promise<Host[]> {
+        
+        const hosts = this.hosts.filter((value, index) => index < max * 10 && index >= (max - 1) * 10);
+        async function fetchAlive(host: Host) {
+            if(host.type === 'ping'){
+                let res = await ping.promise.probe(host.host, {timeout: 5});
+                host.alive = res.alive;
+            }else if(host.type === 'website'){
+                try {
+                    const response = await fetch(host.host, { method: 'HEAD', signal: AbortSignal.timeout(3000) });
+                    host.alive = response.ok;
+                } catch (error) {
+                    host.alive = false; 
+                }
+            }
+            return host;
+        }
+
+        const fetchPromises = hosts.map(host => fetchAlive(host));
+        const updatedHosts = await Promise.all(fetchPromises);
+
+        updatedHosts.forEach((updatedHost, index) => {
+            const originalIndex = (max - 1) * 10 + index;
+            if (originalIndex < this.hosts.length) {
+                this.hosts[originalIndex] = updatedHost;
+            }
+        });
+
+        if(this.hosts.length > max * 10) {
+            await this.fetch(max + 1);
+        }
+
+        return this.hosts;
+    }
+}
+
+export default new StatusService();