first commit

app/checkRunner.js

@@ -0,0 +1,47 @@
+const { spawn } = require("child_process");
+const path = require("path");
+const dockerApi = require("./dockerApi");
+
+const CHECKS_DIR = path.join(__dirname, "checks");
+
+async function runCheck(check) {
+  const start = Date.now();
+
+  if (check.type === "docker_container") {
+    const result = await dockerApi.isContainerRunning(check.target);
+    return {
+      status: result ? "OK" : "FAIL",
+      message: `Container ${check.target} running: ${result}`,
+      duration: Date.now() - start
+    };
+  }
+
+  if (check.type === "docker_network") {
+    const [network, container] = check.target.split(",");
+    const result = await dockerApi.networkContainsContainer(network, container);
+    return {
+      status: result ? "OK" : "FAIL",
+      message: `Container ${container} in network ${network}: ${result}`,
+      duration: Date.now() - start
+    };
+  }
+
+  if (check.type === "script") {
+    return new Promise((resolve) => {
+      const scriptPath = path.join(CHECKS_DIR, check.script_name);
+      const child = spawn("sh", [scriptPath], {
+        timeout: check.timeout_seconds * 1000
+      });
+
+      child.on("close", (code) => {
+        resolve({
+          status: code === 0 ? "OK" : "FAIL",
+          message: `Exit code: ${code}`,
+          duration: Date.now() - start
+        });
+      });
+    });
+  }
+}
+
+module.exports = runCheck;

app/checks/check_http_google.sh

@@ -0,0 +1,3 @@
+#!/bin/sh
+wget -q --spider https://google.com
+exit $?

app/db.js

@@ -0,0 +1,9 @@
+const { Pool } = require("pg");
+
+module.exports = new Pool({
+  host: process.env.DB_HOST,
+  user: process.env.DB_USER,
+  password: process.env.DB_PASSWORD,
+  database: process.env.DB_NAME,
+  port: process.env.DB_PORT
+});

app/dockerApi.js

@@ -0,0 +1,48 @@
+const http = require("http");
+
+function dockerRequest(path) {
+  return new Promise((resolve, reject) => {
+    const options = {
+      socketPath: "/var/run/docker.sock",
+      path,
+      method: "GET"
+    };
+
+    const req = http.request(options, (res) => {
+      let data = "";
+      res.on("data", chunk => data += chunk);
+      res.on("end", () => {
+        try {
+          resolve(JSON.parse(data));
+        } catch {
+          resolve(data);
+        }
+      });
+    });
+
+    req.on("error", reject);
+    req.end();
+  });
+}
+
+async function isContainerRunning(name) {
+  try {
+    const data = await dockerRequest(`/containers/${name}/json`);
+    return data.State?.Running === true;
+  } catch {
+    return false;
+  }
+}
+
+async function networkContainsContainer(networkName, containerName) {
+  try {
+    const data = await dockerRequest(`/networks/${networkName}`);
+    if (!data.Containers) return false;
+    return Object.values(data.Containers)
+      .some(c => c.Name === containerName);
+  } catch {
+    return false;
+  }
+}
+
+module.exports = { isContainerRunning, networkContainsContainer };

app/init.sh

@@ -0,0 +1,2 @@
+chmod +x checks/*.sh
+docker compose up --build

app/package.json

@@ -0,0 +1,11 @@
+{
+  "name": "docker-info-dashboard",
+  "version": "2.0.0",
+  "main": "server.js",
+  "dependencies": {
+    "ejs": "^3.1.9",
+    "express": "^4.18.2",
+    "node-cron": "^3.0.3",
+    "pg": "^8.11.3"
+  }
+}

app/public/style.css

@@ -0,0 +1,5 @@
+body { font-family: Arial; }
+table { border-collapse: collapse; width: 80%; }
+th, td { border: 1px solid #ccc; padding: 8px; }
+.ok { color: green; font-weight: bold; }
+.fail { color: red; font-weight: bold; }

app/scheduler.js

@@ -0,0 +1,26 @@
+const cron = require("node-cron");
+const pool = require("./db");
+const runCheck = require("./checkRunner");
+
+async function scheduleChecks() {
+  const { rows } = await pool.query("SELECT * FROM checks WHERE active = true");
+
+  rows.forEach(check => {
+    cron.schedule(`*/${check.schedule_seconds} * * * * *`, async () => {
+      const result = await runCheck(check);
+
+      await pool.query(
+        `INSERT INTO results (check_id, status, message, duration_ms)
+         VALUES ($1,$2,$3,$4)`,
+        [check.id, result.status, result.message, result.duration]
+      );
+
+      await pool.query(
+        `UPDATE checks SET last_run = NOW(), last_status = $1 WHERE id = $2`,
+        [result.status, check.id]
+      );
+    });
+  });
+}
+
+module.exports = scheduleChecks;

app/server.js

@@ -0,0 +1,17 @@
+const express = require("express");
+const pool = require("./db");
+const scheduleChecks = require("./scheduler");
+
+const app = express();
+app.set("view engine", "ejs");
+app.use(express.static("public"));
+
+app.get("/", async (req, res) => {
+  const { rows } = await pool.query("SELECT * FROM checks ORDER BY id");
+  res.render("index", { checks: rows });
+});
+
+app.listen(3000, async () => {
+  console.log("Server läuft auf Port 3000");
+  await scheduleChecks();
+});

app/views/index.ejs

@@ -0,0 +1,30 @@
+<!DOCTYPE html>
+<html>
+<head>
+  <title>Docker Info Dashboard</title>
+  <link rel="stylesheet" href="/style.css">
+</head>
+<body>
+<h1>System Status</h1>
+<table>
+<tr>
+<th>ID</th>
+<th>Name</th>
+<th>Status</th>
+<th>Last Run</th>
+</tr>
+
+<% checks.forEach(c => { %>
+<tr>
+<td><%= c.id %></td>
+<td><%= c.name %></td>
+<td class="<%= c.last_status === 'OK' ? 'ok' : 'fail' %>">
+<%= c.last_status || 'N/A' %>
+</td>
+<td><%= c.last_run || 'N/A' %></td>
+</tr>
+<% }) %>
+
+</table>
+</body>
+</html>