Update to 15 mins`

.woodpecker.yaml

@@ -0,0 +1,13 @@
+steps:
+  build-and-push:
+    when:
+      event: [push]
+      branch: [main]
+    image: plugins/docker
+    settings:
+      repo: elisha852/omegabasms
+      tags: latest
+      username:
+        from_secret: DOCKER_USERNAME
+      password:
+        from_secret: DOCKER_PASSWORD

index.js

@@ -267,7 +267,7 @@ async function startClient() {
 }
 
 const http = require('http');
-function renderDashboard() {
+function renderDashboard(clientState) {
   const uptime = Math.floor((Date.now() - startTime) / 1000);
   const h = Math.floor(uptime / 3600);
   const m = Math.floor((uptime % 3600) / 60);
@@ -286,7 +286,7 @@ function renderDashboard() {
       `<tr><td>${name}</td><td>${count}</td></tr>`
     ).join('');
 
-  const connected = client && !restarting;
+  const connected = clientState === 'CONNECTED';
 
   const api = JSON.stringify({
     uptime, uptimeStr, connected,
@@ -376,13 +376,29 @@ poll();
 </html>`;
 }
 
-const server = http.createServer((req, res) => {
+async function getClientState() {
+  if (!client || restarting) return 'DISCONNECTED';
+  try {
+    return await client.getState();
+  } catch {
+    return 'DISCONNECTED';
+  }
+}
+
+const server = http.createServer(async (req, res) => {
   if (req.url === '/liveness') {
+    const state = await getClientState();
+    if (state === 'CONNECTED') {
       res.writeHead(200, { 'Content-Type': 'text/plain' });
       res.end('OK');
+    } else {
+      res.writeHead(503, { 'Content-Type': 'text/plain' });
+      res.end('NOT_CONNECTED');
+    }
     return;
   }
   if (req.url === '/api/stats') {
+    const clientState = await getClientState();
     res.writeHead(200, { 'Content-Type': 'application/json' });
     res.end(JSON.stringify({
       uptime: Math.floor((Date.now() - startTime) / 1000),
@@ -390,7 +406,8 @@ const server = http.createServer((req, res) => {
         const t = Math.floor((Date.now() - startTime) / 1000);
         return Math.floor(t/3600)+'h '+Math.floor((t%3600)/60)+'m '+t%60+'s';
       })(),
-      connected: !!(client && !restarting),
+      connected: clientState === 'CONNECTED',
+      clientState,
       totalForwarded,
       queued: messageQueue.length,
       flushTime: flushTime(),
@@ -399,8 +416,9 @@ const server = http.createServer((req, res) => {
     }));
     return;
   }
+  const clientState = await getClientState();
   res.writeHead(200, { 'Content-Type': 'text/html; charset=utf-8' });
-  res.end(renderDashboard());
+  res.end(renderDashboard(clientState));
 });
 const PORT = process.env.PORT || 3000;
 server.listen(PORT, () => log('INIT', `Dashboard on http://0.0.0.0:${PORT}`));