feat: added performance page

Author: BolverBlitz

api/performance.js

@@ -0,0 +1,24 @@
+const express = require('ultimate-express');
+const { verifyRequest } = require('@middleware/verifyRequest');
+const { limiter } = require('@middleware/limiter');
+const { getPerformanceStats } = require('@lib/sqlite/performanceStats');
+
+const router = new express.Router();
+
+const PluginName = 'Performance';
+const PluginRequirements = [];
+const PluginVersion = '0.0.1';
+
+router.get('/', verifyRequest('app.admin.stats.read'), limiter(1), async (req, res) => {
+    const requestedLimit = Number(req.query?.limit) || 200;
+    const limit = Math.min(Math.max(requestedLimit, 10), 1000);
+    const performanceStats = getPerformanceStats(limit, limit);
+    return res.json({ performanceStats });
+});
+
+module.exports = {
+    router,
+    PluginName,
+    PluginRequirements,
+    PluginVersion,
+};

config/locales/de/AdminPerformance.json

@@ -0,0 +1,33 @@
+{
+  "PageTitle": "Performance",
+  "Subtitle": "HTTP-Request-Dauer, DB-Query-Latenz und ein Sankey der API-Routen.",
+  "Summary": {
+    "Title": "Datenbank-Latenz",
+    "Description": "Tageswerte fuer DB-Queries. Die API-Route-Traffic-Grafik ist getrennt darunter.",
+    "DbMin": "Min",
+    "DbAvg": "Avg",
+    "DbP95": "P95",
+    "DbP99": "P99"
+  },
+  "Pages": {
+    "Title": "Top Seiten",
+    "Description": "Per Route gemessene Page-Load-Zeiten fuer die HTML-Seiten.",
+    "Empty": "Noch keine Seitenaufrufe fuer heute vorhanden."
+  },
+  "Sankey": {
+    "Title": "API-Request-Sankey",
+    "Description": "Breite = Anzahl der Requests pro Route-Pfad. Die Struktur folgt dem /api-Baum.",
+    "Empty": "Noch keine API-Requests fuer heute vorhanden.",
+    "Error": "Performance-Daten konnten nicht geladen werden."
+  },
+  "Table": {
+    "Title": "Top API-Routen",
+    "Description": "Antwortzeiten der API-Routen",
+    "Empty": "Noch keine API-Routen fuer heute vorhanden.",
+    "Route": "Route",
+    "Min": "Min",
+    "Avg": "Avg",
+    "P95": "P95",
+    "P99": "P99"
+  }
+}

config/locales/de/AdminSettings.json

@@ -9,10 +9,17 @@
     "MemRss": "Arbeitsspeicher (Gesamt)",
     "MemHeap": "Heap-Speicher (Nutzung/Gesamt)",
     "MemHeapExternalBuffer": "Speicher für C++ | Buffers",
-    "Storage": "Speicher"
+    "Storage": "Speicher",
+    "DBQueryStats": "DB-Query-Statistik",
+    "PageLoadStats": "Seitenlade-Statistik",
+    "HttpRequestStats": "HTTP-Request-Statistik",
+    "Requests": "Messungen",
+    "Routes": "Routen",
+    "NoPerformanceData": "Noch keine Performance-Daten vorhanden."
   },
   "Logs": {
     "Button": "Logs anzeigen",
+    "PerformanceButton": "Performance",
     "ModalTitle": "Systemlogs",
     "Filters": "Level",
     "Loading": "Lade Logs...",

config/locals_map.js

@@ -68,6 +68,14 @@ module.exports = {
         "Categories",
         "Items"
     ],
+    "/admin/performance": [
+        "Admin",
+        "Error",
+        "Page",
+        "Setup",
+        "Navbar",
+        "AdminPerformance"
+    ],
     "/admin/settings": [
         "Admin",
         "Error",

lib/logger.js

@@ -120,6 +120,7 @@ const rememberLog = (levelnumber, text, timestamp = getTimestamp()) => {
     memoryLogs.push({
         id: ++logSequence,
         timestamp,
+        timestampMs: Date.now(),
         level,
         text: String(text),
     });

lib/sqlite/index.js

@@ -1,6 +1,8 @@
 const path = require('node:path');
 const fs = require('node:fs')
+const { performance } = require('node:perf_hooks');
 const Database = require('better-sqlite3');
+const { installPerformanceStats, stopPerformanceStats, isRecordingEnabled, recordDbQueryDuration } = require('./performanceStats');
 
 if (!fs.existsSync(path.join(__dirname, '..', '..', 'storage'))) {
     fs.mkdirSync(path.join(__dirname, '..', '..', 'storage'), { recursive: true });
@@ -12,26 +14,67 @@ const db = new Database(path.join(__dirname, '..', '..', 'storage', 'application
 
 db.pragma('journal_mode = WAL');
 
+const originalPrepare = db.prepare.bind(db);
+const originalExec = db.exec.bind(db);
+
+db.prepare = function patchedPrepare(sql, ...args) {
+    const statement = originalPrepare(sql, ...args);
+    return new Proxy(statement, {
+        get(target, prop, receiver) {
+            const value = Reflect.get(target, prop, target);
+
+            if (typeof value !== 'function' || !['run', 'get', 'all', 'values'].includes(prop)) {
+                return value;
+            }
+
+            return (...methodArgs) => {
+                const startTime = performance.now();
+                try {
+                    return value.apply(target, methodArgs);
+                } finally {
+                    if (isRecordingEnabled()) {
+                        recordDbQueryDuration(performance.now() - startTime);
+                    }
+                }
+            };
+        }
+    });
+};
+
+db.exec = function patchedExec(sql) {
+    const startTime = performance.now();
+    try {
+        return originalExec(sql);
+    } finally {
+        if (isRecordingEnabled()) {
+            recordDbQueryDuration(performance.now() - startTime);
+        }
+    }
+};
+
+installPerformanceStats(db);
+
 /**
  * Closes the database connection gracefully, ensuring all data is flushed to disk and WAL files are cleaned up.
  */
 function closeDatabases() {
     if (db) {
         try {
+            stopPerformanceStats();
             db.pragma('wal_checkpoint(TRUNCATE)');
             db.unsafeMode(false);
             db.pragma('journal_mode = DELETE'); 
-            process.log.system('WAL successfully merged and deleted.');
+            process.log?.system?.('WAL successfully merged and deleted.');
 
         } catch (err) {
             console.log(err);
-            process.log.error('Error during WAL merge:', err);
+            process.log?.error?.('Error during WAL merge:', err);
         } finally {
             try {
                 db.close();
-                process.log.system('SQLite database closed cleanly');
+                process.log?.system?.('SQLite database closed cleanly');
             } catch (closeErr) {
-                process.log.error('Failed to close DB handle:', closeErr);
+                process.log?.error?.('Failed to close DB handle:', closeErr);
             }
         }
     }
@@ -140,4 +183,4 @@ module.exports = {
     getDBSize,
     vacuumDB,
     closeDatabases
-};
+};