Phase 10: Command Scheduler

Added comprehensive command scheduling system: Backend: - New scheduled_commands database table - Scheduler processor runs every minute - Support for three schedule types: interval, hourly, daily - calculateNextRun() function for intelligent scheduling - API endpoints: GET, POST, PUT (toggle), DELETE - Executions automatically created and tracked - Enable/disable schedules without deleting Frontend: - New Scheduler tab in navigation - Create Schedule modal with worker selection - Dynamic schedule input based on type - Schedule list showing status, next/last run times - Enable/Disable toggle for each schedule - Delete schedule functionality - Terminal-themed scheduler UI - Integration with existing worker and execution systems Schedule Types: - Interval: Every X minutes (e.g., 30 for every 30 min) - Hourly: Every X hours (e.g., 2 for every 2 hours) - Daily: At specific time (e.g., 03:00 for 3 AM daily) Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
Phase 9: Execution Diff View
2026-01-07 23:13:27 -05:00 · 2026-01-07 23:08:55 -05:00 · 2026-01-07 23:06:43 -05:00 · 2026-01-07 23:03:45 -05:00 · 2026-01-07 22:55:13 -05:00 · 2026-01-07 22:52:51 -05:00
8 changed files with 2254 additions and 2379 deletions
--- a/Claude.md
+++ b/Claude.md
--- a/README.md
+++ b/README.md
@@ -2,24 +2,6 @@

 A distributed workflow orchestration platform for managing and executing complex multi-step operations across server clusters through a retro terminal-themed web interface.

-> **Security Notice:** This repository is hosted on Gitea and is version-controlled. **Never commit secrets, credentials, passwords, API keys, or any sensitive information to this repo.** All sensitive configuration belongs exclusively in `.env` files which are listed in `.gitignore` and must never be committed. This includes database passwords, worker API keys, webhook secrets, and internal IP details.
-
-**Design System**: [web_template](https://code.lotusguild.org/LotusGuild/web_template) — shared CSS, JS, and layout patterns for all LotusGuild apps
-
-## Styling & Layout
-
-PULSE uses the **LotusGuild Terminal Design System**. For all styling, component, and layout documentation see:
-
- [`web_template/README.md`](https://code.lotusguild.org/LotusGuild/web_template/src/branch/main/README.md) — full component reference, CSS variables, JS API
- [`web_template/base.css`](https://code.lotusguild.org/LotusGuild/web_template/src/branch/main/base.css) — unified CSS (`.lt-*` classes)
- [`web_template/base.js`](https://code.lotusguild.org/LotusGuild/web_template/src/branch/main/base.js) — `window.lt` utilities (toast, modal, WebSocket helpers, fetch)
- [`web_template/aesthetic_diff.md`](https://code.lotusguild.org/LotusGuild/web_template/src/branch/main/aesthetic_diff.md) — cross-app divergence analysis and convergence guide
- [`web_template/node/middleware.js`](https://code.lotusguild.org/LotusGuild/web_template/src/branch/main/node/middleware.js) — Express auth, CSRF, CSP nonce middleware
-
-**Pending convergence items (see aesthetic_diff.md):**
- Extract inline `<style>` from `public/index.html` into `public/style.css` and extend `base.css`
- Use `lt.autoRefresh.start(refreshData, 30000)` instead of raw `setInterval`
-
 ## Overview

 PULSE is a centralized workflow execution system designed to orchestrate operations across distributed infrastructure. It provides a powerful web-based interface with a vintage CRT terminal aesthetic for defining, managing, and executing workflows that can span multiple servers, require human interaction, and perform complex automation tasks at scale.
@@ -323,34 +305,12 @@ MAX_CONCURRENT_TASKS=5              # Max parallel tasks (default: 5)

 PULSE uses MariaDB with the following tables:

-| Table | Purpose |
-|-------|---------|
-| `users` | User accounts synced from Authelia SSO |
-| `workers` | Worker node registry with connection metadata |
-| `workflows` | Workflow definitions stored as JSON |
-| `executions` | Execution history with logs, status, and timestamps |
+- **users**: User accounts from Authelia SSO
+- **workers**: Worker node registry with metadata
+- **workflows**: Workflow definitions (JSON)
+- **executions**: Execution history with logs

-### `executions` Table Key Columns
-
-| Column | Description |
-|--------|-------------|
-| `id` | Auto-increment primary key |
-| `worker_id` | Foreign key to workers |
-| `command` | The command that was executed |
-| `status` | `running`, `completed`, `failed` |
-| `output` | Command output / log (JSON or text) |
-| `created_at` | Execution start timestamp |
-| `completed_at` | Execution end timestamp |
-
-### `workers` Table Key Columns
-
-| Column | Description |
-|--------|-------------|
-| `id` | Auto-increment primary key |
-| `name` | Worker name (from `WORKER_NAME` env) |
-| `last_seen` | Last heartbeat timestamp |
-| `status` | `online`, `offline` |
-| `metadata` | JSON blob of system info |
+See [Claude.md](Claude.md) for complete schema details.

 ## Troubleshooting

--- a/package-lock.json
+++ b/package-lock.json
@@ -9,10 +9,13 @@
      "version": "1.0.0",
      "license": "ISC",
      "dependencies": {
-        "cron-parser": "^5.5.0",
+        "bcryptjs": "^3.0.3",
+        "body-parser": "^2.2.1",
+        "cors": "^2.8.5",
        "dotenv": "^17.2.3",
        "express": "^5.1.0",
-        "express-rate-limit": "^8.3.1",
+        "js-yaml": "^4.1.1",
+        "jsonwebtoken": "^9.0.2",
        "mysql2": "^3.15.3",
        "ws": "^8.18.3"
      }
@@ -30,6 +33,12 @@
        "node": ">= 0.6"
      }
    },
+    "node_modules/argparse": {
+      "version": "2.0.1",
+      "resolved": "https://registry.npmjs.org/argparse/-/argparse-2.0.1.tgz",
+      "integrity": "sha512-8+9WqebbFzpX9OR+Wa6O29asIogeRMzcGtAINdpMHHyAg10f05aSFVBbcEqGf/PXw1EjAZ+q2/bEBg3DvurK3Q==",
+      "license": "Python-2.0"
+    },
    "node_modules/aws-ssl-profiles": {
      "version": "1.1.2",
      "resolved": "https://registry.npmjs.org/aws-ssl-profiles/-/aws-ssl-profiles-1.1.2.tgz",
@@ -39,6 +48,15 @@
        "node": ">= 6.0.0"
      }
    },
+    "node_modules/bcryptjs": {
+      "version": "3.0.3",
+      "resolved": "https://registry.npmjs.org/bcryptjs/-/bcryptjs-3.0.3.tgz",
+      "integrity": "sha512-GlF5wPWnSa/X5LKM1o0wz0suXIINz1iHRLvTS+sLyi7XPbe5ycmYI3DlZqVGZZtDgl4DmasFg7gOB3JYbphV5g==",
+      "license": "BSD-3-Clause",
+      "bin": {
+        "bcrypt": "bin/bcrypt"
+      }
+    },
    "node_modules/body-parser": {
      "version": "2.2.1",
      "resolved": "https://registry.npmjs.org/body-parser/-/body-parser-2.2.1.tgz",
@@ -63,6 +81,12 @@
        "url": "https://opencollective.com/express"
      }
    },
+    "node_modules/buffer-equal-constant-time": {
+      "version": "1.0.1",
+      "resolved": "https://registry.npmjs.org/buffer-equal-constant-time/-/buffer-equal-constant-time-1.0.1.tgz",
+      "integrity": "sha512-zRpUiDwd/xk6ADqPMATG8vc9VPrkck7T07OIx0gnjmJAnHnTVXNQG3vfvWNuiZIkwu9KrKdA1iJKfsfTVxE6NA==",
+      "license": "BSD-3-Clause"
+    },
    "node_modules/bytes": {
      "version": "3.1.2",
      "resolved": "https://registry.npmjs.org/bytes/-/bytes-3.1.2.tgz",
@@ -141,15 +165,17 @@
        "node": ">=6.6.0"
      }
    },
-    "node_modules/cron-parser": {
-      "version": "5.5.0",
-      "resolved": "https://registry.npmjs.org/cron-parser/-/cron-parser-5.5.0.tgz",
-      "integrity": "sha512-oML4lKUXxizYswqmxuOCpgFS8BNUJpIu6k/2HVHyaL8Ynnf3wdf9tkns0yRdJLSIjkJ+b0DXHMZEHGpMwjnPww==",
+    "node_modules/cors": {
+      "version": "2.8.5",
+      "resolved": "https://registry.npmjs.org/cors/-/cors-2.8.5.tgz",
+      "integrity": "sha512-KIHbLJqu73RGr/hnbrO9uBeixNGuvSQjul/jdFvS/KFSIH1hWVd1ng7zOHx+YrEfInLG7q4n6GHQ9cDtxv/P6g==",
+      "license": "MIT",
      "dependencies": {
-        "luxon": "^3.7.1"
+        "object-assign": "^4",
+        "vary": "^1"
      },
      "engines": {
-        "node": ">=18"
+        "node": ">= 0.10"
      }
    },
    "node_modules/debug": {
@@ -213,6 +239,15 @@
        "node": ">= 0.4"
      }
    },
+    "node_modules/ecdsa-sig-formatter": {
+      "version": "1.0.11",
+      "resolved": "https://registry.npmjs.org/ecdsa-sig-formatter/-/ecdsa-sig-formatter-1.0.11.tgz",
+      "integrity": "sha512-nagl3RYrbNv6kQkeJIpt6NJZy8twLB/2vtz6yN9Z4vRKHN4/QZJIEbqohALSgwKdnksuY3k5Addp5lg8sVoVcQ==",
+      "license": "Apache-2.0",
+      "dependencies": {
+        "safe-buffer": "^5.0.1"
+      }
+    },
    "node_modules/ee-first": {
      "version": "1.1.1",
      "resolved": "https://registry.npmjs.org/ee-first/-/ee-first-1.1.1.tgz",
@@ -315,23 +350,6 @@
        "url": "https://opencollective.com/express"
      }
    },
-    "node_modules/express-rate-limit": {
-      "version": "8.3.1",
-      "resolved": "https://registry.npmjs.org/express-rate-limit/-/express-rate-limit-8.3.1.tgz",
-      "integrity": "sha512-D1dKN+cmyPWuvB+G2SREQDzPY1agpBIcTa9sJxOPMCNeH3gwzhqJRDWCXW3gg0y//+LQ/8j52JbMROWyrKdMdw==",
-      "dependencies": {
-        "ip-address": "10.1.0"
-      },
-      "engines": {
-        "node": ">= 16"
-      },
-      "funding": {
-        "url": "https://github.com/sponsors/express-rate-limit"
-      },
-      "peerDependencies": {
-        "express": ">= 4.11"
-      }
-    },
    "node_modules/finalhandler": {
      "version": "2.1.0",
      "resolved": "https://registry.npmjs.org/finalhandler/-/finalhandler-2.1.0.tgz",
@@ -500,14 +518,6 @@
      "integrity": "sha512-k/vGaX4/Yla3WzyMCvTQOXYeIHvqOKtnqBduzTHpzpQZzAskKMhZ2K+EnBiSM9zGSoIFeMpXKxa4dYeZIQqewQ==",
      "license": "ISC"
    },
-    "node_modules/ip-address": {
-      "version": "10.1.0",
-      "resolved": "https://registry.npmjs.org/ip-address/-/ip-address-10.1.0.tgz",
-      "integrity": "sha512-XXADHxXmvT9+CRxhXg56LJovE+bmWnEWB78LB83VZTprKTmaC5QfruXocxzTZ2Kl0DNwKuBdlIhjL8LeY8Sf8Q==",
-      "engines": {
-        "node": ">= 12"
-      }
-    },
    "node_modules/ipaddr.js": {
      "version": "1.9.1",
      "resolved": "https://registry.npmjs.org/ipaddr.js/-/ipaddr.js-1.9.1.tgz",
@@ -529,6 +539,103 @@
      "integrity": "sha512-Ks/IoX00TtClbGQr4TWXemAnktAQvYB7HzcCxDGqEZU6oCmb2INHuOoKxbtR+HFkmYWBKv/dOZtGRiAjDhj92g==",
      "license": "MIT"
    },
+    "node_modules/js-yaml": {
+      "version": "4.1.1",
+      "resolved": "https://registry.npmjs.org/js-yaml/-/js-yaml-4.1.1.tgz",
+      "integrity": "sha512-qQKT4zQxXl8lLwBtHMWwaTcGfFOZviOJet3Oy/xmGk2gZH677CJM9EvtfdSkgWcATZhj/55JZ0rmy3myCT5lsA==",
+      "license": "MIT",
+      "dependencies": {
+        "argparse": "^2.0.1"
+      },
+      "bin": {
+        "js-yaml": "bin/js-yaml.js"
+      }
+    },
+    "node_modules/jsonwebtoken": {
+      "version": "9.0.2",
+      "resolved": "https://registry.npmjs.org/jsonwebtoken/-/jsonwebtoken-9.0.2.tgz",
+      "integrity": "sha512-PRp66vJ865SSqOlgqS8hujT5U4AOgMfhrwYIuIhfKaoSCZcirrmASQr8CX7cUg+RMih+hgznrjp99o+W4pJLHQ==",
+      "license": "MIT",
+      "dependencies": {
+        "jws": "^3.2.2",
+        "lodash.includes": "^4.3.0",
+        "lodash.isboolean": "^3.0.3",
+        "lodash.isinteger": "^4.0.4",
+        "lodash.isnumber": "^3.0.3",
+        "lodash.isplainobject": "^4.0.6",
+        "lodash.isstring": "^4.0.1",
+        "lodash.once": "^4.0.0",
+        "ms": "^2.1.1",
+        "semver": "^7.5.4"
+      },
+      "engines": {
+        "node": ">=12",
+        "npm": ">=6"
+      }
+    },
+    "node_modules/jwa": {
+      "version": "1.4.2",
+      "resolved": "https://registry.npmjs.org/jwa/-/jwa-1.4.2.tgz",
+      "integrity": "sha512-eeH5JO+21J78qMvTIDdBXidBd6nG2kZjg5Ohz/1fpa28Z4CcsWUzJ1ZZyFq/3z3N17aZy+ZuBoHljASbL1WfOw==",
+      "license": "MIT",
+      "dependencies": {
+        "buffer-equal-constant-time": "^1.0.1",
+        "ecdsa-sig-formatter": "1.0.11",
+        "safe-buffer": "^5.0.1"
+      }
+    },
+    "node_modules/jws": {
+      "version": "3.2.2",
+      "resolved": "https://registry.npmjs.org/jws/-/jws-3.2.2.tgz",
+      "integrity": "sha512-YHlZCB6lMTllWDtSPHz/ZXTsi8S00usEV6v1tjq8tOUZzw7DpSDWVXjXDre6ed1w/pd495ODpHZYSdkRTsa0HA==",
+      "license": "MIT",
+      "dependencies": {
+        "jwa": "^1.4.1",
+        "safe-buffer": "^5.0.1"
+      }
+    },
+    "node_modules/lodash.includes": {
+      "version": "4.3.0",
+      "resolved": "https://registry.npmjs.org/lodash.includes/-/lodash.includes-4.3.0.tgz",
+      "integrity": "sha512-W3Bx6mdkRTGtlJISOvVD/lbqjTlPPUDTMnlXZFnVwi9NKJ6tiAk6LVdlhZMm17VZisqhKcgzpO5Wz91PCt5b0w==",
+      "license": "MIT"
+    },
+    "node_modules/lodash.isboolean": {
+      "version": "3.0.3",
+      "resolved": "https://registry.npmjs.org/lodash.isboolean/-/lodash.isboolean-3.0.3.tgz",
+      "integrity": "sha512-Bz5mupy2SVbPHURB98VAcw+aHh4vRV5IPNhILUCsOzRmsTmSQ17jIuqopAentWoehktxGd9e/hbIXq980/1QJg==",
+      "license": "MIT"
+    },
+    "node_modules/lodash.isinteger": {
+      "version": "4.0.4",
+      "resolved": "https://registry.npmjs.org/lodash.isinteger/-/lodash.isinteger-4.0.4.tgz",
+      "integrity": "sha512-DBwtEWN2caHQ9/imiNeEA5ys1JoRtRfY3d7V9wkqtbycnAmTvRRmbHKDV4a0EYc678/dia0jrte4tjYwVBaZUA==",
+      "license": "MIT"
+    },
+    "node_modules/lodash.isnumber": {
+      "version": "3.0.3",
+      "resolved": "https://registry.npmjs.org/lodash.isnumber/-/lodash.isnumber-3.0.3.tgz",
+      "integrity": "sha512-QYqzpfwO3/CWf3XP+Z+tkQsfaLL/EnUlXWVkIk5FUPc4sBdTehEqZONuyRt2P67PXAk+NXmTBcc97zw9t1FQrw==",
+      "license": "MIT"
+    },
+    "node_modules/lodash.isplainobject": {
+      "version": "4.0.6",
+      "resolved": "https://registry.npmjs.org/lodash.isplainobject/-/lodash.isplainobject-4.0.6.tgz",
+      "integrity": "sha512-oSXzaWypCMHkPC3NvBEaPHf0KsA5mvPrOPgQWDsbg8n7orZ290M0BmC/jgRZ4vcJ6DTAhjrsSYgdsW/F+MFOBA==",
+      "license": "MIT"
+    },
+    "node_modules/lodash.isstring": {
+      "version": "4.0.1",
+      "resolved": "https://registry.npmjs.org/lodash.isstring/-/lodash.isstring-4.0.1.tgz",
+      "integrity": "sha512-0wJxfxH1wgO3GrbuP+dTTk7op+6L41QCXbGINEmD+ny/G/eCqGzxyCsh7159S+mgDDcoarnBw6PC1PS5+wUGgw==",
+      "license": "MIT"
+    },
+    "node_modules/lodash.once": {
+      "version": "4.1.1",
+      "resolved": "https://registry.npmjs.org/lodash.once/-/lodash.once-4.1.1.tgz",
+      "integrity": "sha512-Sb487aTOCr9drQVL8pIxOzVhafOjZN9UU54hiN8PU3uAiSV7lx1yYNpbNmex2PK6dSJoNTSJUUswT651yww3Mg==",
+      "license": "MIT"
+    },
    "node_modules/long": {
      "version": "5.3.2",
      "resolved": "https://registry.npmjs.org/long/-/long-5.3.2.tgz",
@@ -559,14 +666,6 @@
        "url": "https://github.com/sponsors/wellwelwel"
      }
    },
-    "node_modules/luxon": {
-      "version": "3.7.2",
-      "resolved": "https://registry.npmjs.org/luxon/-/luxon-3.7.2.tgz",
-      "integrity": "sha512-vtEhXh/gNjI9Yg1u4jX/0YVPMvxzHuGgCm6tC5kZyb08yjGWGnqAjGJvcXbqQR2P3MyMEFnRbpcdFS6PBcLqew==",
-      "engines": {
-        "node": ">=12"
-      }
-    },
    "node_modules/math-intrinsics": {
      "version": "1.1.0",
      "resolved": "https://registry.npmjs.org/math-intrinsics/-/math-intrinsics-1.1.0.tgz",
@@ -669,6 +768,15 @@
        "node": ">= 0.6"
      }
    },
+    "node_modules/object-assign": {
+      "version": "4.1.1",
+      "resolved": "https://registry.npmjs.org/object-assign/-/object-assign-4.1.1.tgz",
+      "integrity": "sha512-rJgTQnkUnH1sFw8yT6VSU3zD3sWmu6sZhIseY8VX+GRu3P6F7Fu+JNDoXfklElbLJSnc3FUQHVe4cU5hj+BcUg==",
+      "license": "MIT",
+      "engines": {
+        "node": ">=0.10.0"
+      }
+    },
    "node_modules/object-inspect": {
      "version": "1.13.4",
      "resolved": "https://registry.npmjs.org/object-inspect/-/object-inspect-1.13.4.tgz",
@@ -789,12 +897,44 @@
        "node": ">= 18"
      }
    },
+    "node_modules/safe-buffer": {
+      "version": "5.2.1",
+      "resolved": "https://registry.npmjs.org/safe-buffer/-/safe-buffer-5.2.1.tgz",
+      "integrity": "sha512-rp3So07KcdmmKbGvgaNxQSJr7bGVSVk5S9Eq1F+ppbRo70+YeaDxkw5Dd8NPN+GD6bjnYm2VuPuCXmpuYvmCXQ==",
+      "funding": [
+        {
+          "type": "github",
+          "url": "https://github.com/sponsors/feross"
+        },
+        {
+          "type": "patreon",
+          "url": "https://www.patreon.com/feross"
+        },
+        {
+          "type": "consulting",
+          "url": "https://feross.org/support"
+        }
+      ],
+      "license": "MIT"
+    },
    "node_modules/safer-buffer": {
      "version": "2.1.2",
      "resolved": "https://registry.npmjs.org/safer-buffer/-/safer-buffer-2.1.2.tgz",
      "integrity": "sha512-YZo3K82SD7Riyi0E1EQPojLz7kpepnSQI9IyPbHHg1XXXevb5dJI7tpyN2ADxGcQbHG7vcyRHk0cbwqcQriUtg==",
      "license": "MIT"
    },
+    "node_modules/semver": {
+      "version": "7.7.3",
+      "resolved": "https://registry.npmjs.org/semver/-/semver-7.7.3.tgz",
+      "integrity": "sha512-SdsKMrI9TdgjdweUSR9MweHA4EJ8YxHn8DFaDisvhVlUOe4BF1tLD7GAj0lIqWVl+dPb/rExr0Btby5loQm20Q==",
+      "license": "ISC",
+      "bin": {
+        "semver": "bin/semver.js"
+      },
+      "engines": {
+        "node": ">=10"
+      }
+    },
    "node_modules/send": {
      "version": "1.2.0",
      "resolved": "https://registry.npmjs.org/send/-/send-1.2.0.tgz",
--- a/package.json
+++ b/package.json
@@ -10,10 +10,13 @@
  "license": "ISC",
  "description": "",
  "dependencies": {
-    "cron-parser": "^5.5.0",
+    "bcryptjs": "^3.0.3",
+    "body-parser": "^2.2.1",
+    "cors": "^2.8.5",
    "dotenv": "^17.2.3",
    "express": "^5.1.0",
-    "express-rate-limit": "^8.3.1",
+    "js-yaml": "^4.1.1",
+    "jsonwebtoken": "^9.0.2",
    "mysql2": "^3.15.3",
    "ws": "^8.18.3"
  }
--- a/public/base.js
+++ b/public/base.js
@@ -1 +0,0 @@
-/root/code/web_template/base.js
--- a/public/index.html
+++ b/public/index.html
--- a/server.js
+++ b/server.js
--- a/worker/worker.js
+++ b/worker/worker.js
@@ -1,257 +0,0 @@
-const axios = require('axios');
-const WebSocket = require('ws');
-const { exec } = require('child_process');
-const { promisify } = require('util');
-const os = require('os');
-const crypto = require('crypto');
-require('dotenv').config();
-
-const execAsync = promisify(exec);
-
-class PulseWorker {
-  constructor() {
-    this.workerId = crypto.randomUUID();
-    this.workerName = process.env.WORKER_NAME || os.hostname();
-    this.serverUrl = process.env.PULSE_SERVER || 'http://localhost:8080';
-    this.wsUrl = process.env.PULSE_WS || 'ws://localhost:8080';
-    this.apiKey = process.env.WORKER_API_KEY;
-    this.heartbeatInterval = parseInt(process.env.HEARTBEAT_INTERVAL || '30') * 1000;
-    this.maxConcurrentTasks = parseInt(process.env.MAX_CONCURRENT_TASKS || '5');
-    this.activeTasks = 0;
-    this.ws = null;
-    this.heartbeatTimer = null;
-  }
-
-  async start() {
-    console.log(`[PULSE Worker] Starting worker: ${this.workerName}`);
-    console.log(`[PULSE Worker] Worker ID: ${this.workerId}`);
-    console.log(`[PULSE Worker] Server: ${this.serverUrl}`);
-
-    // Send initial heartbeat
-    await this.sendHeartbeat();
-
-    // Start heartbeat timer
-    this.startHeartbeat();
-
-    // Connect to WebSocket for real-time commands
-    this.connectWebSocket();
-
-    console.log(`[PULSE Worker] Worker started successfully`);
-  }
-
-  startHeartbeat() {
-    this.heartbeatTimer = setInterval(async () => {
-      try {
-        await this.sendHeartbeat();
-      } catch (error) {
-        console.error('[PULSE Worker] Heartbeat failed:', error.message);
-      }
-    }, this.heartbeatInterval);
-  }
-
-  async sendHeartbeat() {
-    const metadata = {
-      hostname: os.hostname(),
-      platform: os.platform(),
-      arch: os.arch(),
-      cpus: os.cpus().length,
-      totalMem: os.totalmem(),
-      freeMem: os.freemem(),
-      uptime: os.uptime(),
-      loadavg: os.loadavg(),
-      activeTasks: this.activeTasks,
-      maxConcurrentTasks: this.maxConcurrentTasks
-    };
-
-    try {
-      const response = await axios.post(
-        `${this.serverUrl}/api/workers/heartbeat`,
-        {
-          worker_id: this.workerId,
-          name: this.workerName,
-          metadata: metadata
-        },
-        {
-          headers: {
-            'X-API-Key': this.apiKey,
-            'Content-Type': 'application/json'
-          }
-        }
-      );
-
-      console.log(`[PULSE Worker] Heartbeat sent - Status: online`);
-      return response.data;
-    } catch (error) {
-      console.error('[PULSE Worker] Heartbeat error:', error.message);
-      throw error;
-    }
-  }
-
-  connectWebSocket() {
-    console.log(`[PULSE Worker] Connecting to WebSocket...`);
-    
-    this.ws = new WebSocket(this.wsUrl);
-
-    this.ws.on('open', () => {
-      console.log('[PULSE Worker] WebSocket connected');
-      // Identify this worker
-      this.ws.send(JSON.stringify({
-        type: 'worker_connect',
-        worker_id: this.workerId,
-        worker_name: this.workerName
-      }));
-    });
-
-    this.ws.on('message', async (data) => {
-      try {
-        const message = JSON.parse(data.toString());
-        await this.handleMessage(message);
-      } catch (error) {
-        console.error('[PULSE Worker] Message handling error:', error);
-      }
-    });
-
-    this.ws.on('close', () => {
-      console.log('[PULSE Worker] WebSocket disconnected, reconnecting...');
-      setTimeout(() => this.connectWebSocket(), 5000);
-    });
-
-    this.ws.on('error', (error) => {
-      console.error('[PULSE Worker] WebSocket error:', error.message);
-    });
-  }
-
-  async handleMessage(message) {
-    console.log(`[PULSE Worker] Received message:`, message.type);
-
-    switch (message.type) {
-      case 'execute_command':
-        await this.executeCommand(message);
-        break;
-      case 'execute_workflow':
-        await this.executeWorkflow(message);
-        break;
-      case 'ping':
-        this.sendPong();
-        break;
-      default:
-        console.log(`[PULSE Worker] Unknown message type: ${message.type}`);
-    }
-  }
-
-  async executeCommand(message) {
-    const { command, execution_id, command_id, timeout = 300000 } = message;
-
-    if (this.activeTasks >= this.maxConcurrentTasks) {
-      console.log(`[PULSE Worker] Max concurrent tasks reached, rejecting command`);
-      return;
-    }
-
-    this.activeTasks++;
-    console.log(`[PULSE Worker] Executing command (active tasks: ${this.activeTasks})`);
-
-    try {
-      const startTime = Date.now();
-      const { stdout, stderr } = await execAsync(command, {
-        timeout: timeout,
-        maxBuffer: 10 * 1024 * 1024 // 10MB buffer
-      });
-      const duration = Date.now() - startTime;
-
-      const result = {
-        type: 'command_result',
-        execution_id,
-        worker_id: this.workerId,
-        command_id,
-        success: true,
-        stdout: stdout,
-        stderr: stderr,
-        duration: duration,
-        timestamp: new Date().toISOString()
-      };
-
-      this.sendResult(result);
-      console.log(`[PULSE Worker] Command completed in ${duration}ms`);
-    } catch (error) {
-      const result = {
-        type: 'command_result',
-        execution_id,
-        worker_id: this.workerId,
-        command_id,
-        success: false,
-        error: error.message,
-        stdout: error.stdout || '',
-        stderr: error.stderr || '',
-        timestamp: new Date().toISOString()
-      };
-
-      this.sendResult(result);
-      console.error(`[PULSE Worker] Command failed:`, error.message);
-    } finally {
-      this.activeTasks--;
-    }
-  }
-
-  async executeWorkflow(message) {
-    const { workflow, execution_id } = message;
-    
-    console.log(`[PULSE Worker] Executing workflow: ${workflow.name}`);
-    
-    // Workflow execution will be implemented in phase 2
-    // For now, just acknowledge receipt
-    this.sendResult({
-      type: 'workflow_result',
-      execution_id,
-      worker_id: this.workerId,
-      success: true,
-      message: 'Workflow execution not yet implemented',
-      timestamp: new Date().toISOString()
-    });
-  }
-
-  sendResult(result) {
-    if (this.ws && this.ws.readyState === WebSocket.OPEN) {
-      this.ws.send(JSON.stringify(result));
-    }
-  }
-
-  sendPong() {
-    if (this.ws && this.ws.readyState === WebSocket.OPEN) {
-      this.ws.send(JSON.stringify({ type: 'pong', worker_id: this.workerId }));
-    }
-  }
-
-  async stop() {
-    console.log('[PULSE Worker] Shutting down...');
-    
-    if (this.heartbeatTimer) {
-      clearInterval(this.heartbeatTimer);
-    }
-
-    if (this.ws) {
-      this.ws.close();
-    }
-
-    console.log('[PULSE Worker] Shutdown complete');
-  }
-}
-
-// Start worker
-const worker = new PulseWorker();
-
-// Handle graceful shutdown
-process.on('SIGTERM', async () => {
-  await worker.stop();
-  process.exit(0);
-});
-
-process.on('SIGINT', async () => {
-  await worker.stop();
-  process.exit(0);
-});
-
-// Start the worker
-worker.start().catch((error) => {
-  console.error('[PULSE Worker] Fatal error:', error);
-  process.exit(1);
-});
Author	SHA1	Message	Date
Jared Vititoe	56f8047322	Phase 10: Command Scheduler Added comprehensive command scheduling system: Backend: - New scheduled_commands database table - Scheduler processor runs every minute - Support for three schedule types: interval, hourly, daily - calculateNextRun() function for intelligent scheduling - API endpoints: GET, POST, PUT (toggle), DELETE - Executions automatically created and tracked - Enable/disable schedules without deleting Frontend: - New Scheduler tab in navigation - Create Schedule modal with worker selection - Dynamic schedule input based on type - Schedule list showing status, next/last run times - Enable/Disable toggle for each schedule - Delete schedule functionality - Terminal-themed scheduler UI - Integration with existing worker and execution systems Schedule Types: - Interval: Every X minutes (e.g., 30 for every 30 min) - Hourly: Every X hours (e.g., 2 for every 2 hours) - Daily: At specific time (e.g., 03:00 for 3 AM daily) Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>	2026-01-07 23:13:27 -05:00
Jared Vititoe	bf908568e3	Phase 9: Execution Diff View Added powerful execution comparison and diff view: - Compare Mode toggle button in executions tab - Multi-select up to 5 executions for comparison - Visual selection indicators with checkmarks - Comparison modal with summary table (status, duration, timestamps) - Side-by-side output view for all selected executions - Line-by-line diff analysis for 2-execution comparisons - Highlights identical vs. different lines - Shows identical/different line counts - Color-coded diff (green for exec 1, amber for exec 2) - Perfect for comparing same command across workers - Terminal-themed comparison UI Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>	2026-01-07 23:08:55 -05:00
Jared Vititoe	ffa124ed9d	Phase 8: Execution Search & Filtering Added comprehensive search and filtering for execution history: - Search bar to filter by command text, execution ID, or workflow name - Status filter dropdown (All, Running, Completed, Failed, Waiting) - Real-time client-side filtering as user types - Filter statistics showing X of Y executions - Clear Filters button to reset all filters - Extracts command text from logs for quick command searches - Maintains all executions in memory for instant filtering - Terminal-themed filter UI matching existing aesthetic Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>	2026-01-07 23:06:43 -05:00
Jared Vititoe	84edea8027	Phase 7: Multi-Worker Command Execution Added ability to execute commands on multiple workers simultaneously: - Added execution mode selector (Single/Multiple Workers) - Multi-worker mode with checkbox list for worker selection - Helper buttons: Select All, Online Only, Clear All - Sequential execution across selected workers - Results summary showing success/fail count per worker - Updated command history to track multi-worker executions - Terminal beep feedback based on overall success/failure - Maintained backward compatibility with single worker mode Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>	2026-01-07 23:03:45 -05:00
Jared Vititoe	095bfb65ab	Fix clearCompletedExecutions for new pagination API format Changes: - Handle new pagination response format (data.executions vs data) - Request up to 1000 executions to ensure all are checked - Track successful deletions count - Use terminal notification instead of alert - Better error handling for individual delete failures Fixes regression from Phase 5 pagination changes. Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>	2026-01-07 22:55:13 -05:00
Jared Vititoe	c619add705	Phase 6: Terminal aesthetic refinements and notifications Changes: - Added blinking terminal cursor animation - Smooth hover effects for execution/worker/workflow items - Hover animation: background highlight + border expand + slide - Loading pulse animation for loading states - Slide-in animation for log entries - Terminal beep sound using Web Audio API (different tones for success/error) - Real-time terminal notifications for command completion - Toast-style notifications with green glow effects - Auto-dismiss after 3 seconds with fade-out - Visual and audio feedback for user actions Sound features: - 800Hz tone for success (higher pitch) - 200Hz tone for errors (lower pitch) - 440Hz tone for info (standard A note) - 100ms duration, exponential fade-out - Graceful fallback if Web Audio API not supported Notification features: - Fixed position top-right - Terminal-themed styling with glow - Color-coded: green for success, red for errors - Icons: ✓ success, ✗ error, ℹ info - Smooth animations (slide-in, fade-out) Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>	2026-01-07 22:52:51 -05:00
Jared Vititoe	e6a6b7e359	Phase 5: Auto-cleanup and pagination for executions Changes: Server-side: - Added automatic cleanup of old executions (runs daily) - Configurable retention period via EXECUTION_RETENTION_DAYS env var (default: 30 days) - Cleanup runs on server startup and every 24 hours - Only cleans completed/failed executions, keeps running ones - Added pagination support to /api/executions endpoint - Returns total count, limit, offset, and hasMore flag Client-side: - Implemented "Load More" button for execution pagination - Loads 50 executions at a time - Appends additional executions when "Load More" clicked - Shows total execution count info - Backward compatible with old API format Benefits: - Automatic database maintenance - Prevents execution table from growing indefinitely - Better performance with large execution histories - User can browse all executions via pagination - Configurable retention policy per deployment Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>	2026-01-07 22:50:39 -05:00
Jared Vititoe	d25ba27f24	Phase 4: Execution detail enhancements with re-run and download Changes: - Added "Re-run Command" button to execution details modal - Added "Download Logs" button to export execution data as JSON - Re-run automatically switches to Quick Command tab and pre-fills form - Download includes all execution metadata and logs - Buttons only show for applicable execution types - Terminal-themed button styling Features: - Re-run: Quickly repeat a previous command on same worker - Download: Export execution logs for auditing/debugging - JSON format includes: execution_id, status, timestamps, logs - Filename includes execution ID and date for easy organization Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>	2026-01-07 22:49:20 -05:00
Jared Vititoe	76b0a6d0d3	Phase 3: Quick command enhancements with templates and history Changes: - Added command templates modal with 12 common system commands - Added command history tracking (stored in localStorage) - History saves last 50 commands with timestamp and worker name - Template categories: system info, disk/memory, network, Docker, logs - Click templates to auto-fill command field - Click history items to reuse previous commands - Terminal-themed modals with green/amber styling - History persists across browser sessions Templates included: - System: uname, uptime, CPU info, processes - Resources: df -h, free -h, memory usage - Network: ip addr, active connections - Docker: container list - Logs: syslog tail, who is logged in, last logins Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>	2026-01-07 22:45:40 -05:00
Jared Vititoe	adbbec2631	Phase 2: Enhanced worker status display with metadata Changes: - Show worker system metrics in dashboard and worker list - Display CPU cores, memory usage, load average, uptime - Added formatBytes() to display memory in human-readable format - Added formatUptime() to show uptime as days/hours/minutes - Added getTimeAgo() to show relative last-seen time - Improved worker list with detailed metadata panel - Show active tasks vs max concurrent tasks - Terminal-themed styling for metadata display - Amber labels for metadata fields Benefits: - See worker health at a glance - Monitor resource usage (CPU, RAM, load) - Track worker activity (active tasks) - Better operational visibility Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>	2026-01-07 22:43:13 -05:00
Jared Vititoe	8b8d2c6312	Phase 1: Improve log display formatting Changes: - Added formatLogEntry() function to parse and format log entries - Replaced raw JSON display with readable formatted logs - Added specific formatting for command_sent and command_result logs - Show timestamp, status, duration, stdout/stderr in organized layout - Color-coded success (green) and failure (red) states - Added scrollable output sections with max-height - Syntax highlighting for command code blocks - Terminal-themed styling with green/amber colors Benefits: - Much easier to read execution logs - Clear visual distinction between sent/result logs - Professional terminal aesthetic maintained - Better UX for debugging command execution Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>	2026-01-07 22:41:29 -05:00
Jared Vititoe	1f5c84f327	Add execution cleanup functionality Changes: - Added DELETE /api/executions/:id endpoint - Added "Clear Completed" button to Executions tab - Deletes all completed and failed executions - Broadcasts execution_deleted event to update all clients - Shows count of deleted executions Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>	2026-01-07 22:36:51 -05:00
Jared Vititoe	e03f8d6287	Fix worker ID mapping - use database ID for command routing Problem: - Workers generate random UUID on startup (runtime ID) - Database stores workers with persistent IDs (database ID) - UI sends commands using database ID - Server couldn't find worker connection (stored by runtime ID) - Result: 400 Bad Request "Worker not connected" Solution: - When worker connects, look up database ID by worker name - Store WebSocket connection in Map using BOTH IDs: * Runtime ID (from worker_connect message) * Database ID (from database lookup by name) - Commands from UI use database ID → finds correct WebSocket - Cleanup both IDs when worker disconnects Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>	2026-01-07 22:29:23 -05:00
Jared Vititoe	2097b73404	Fix worker command execution and execution status updates Changes: - Removed duplicate /api/executions/:id endpoint that didn't parse logs - Added workers Map to track worker_id -> WebSocket connection - Store worker connections when they send worker_connect message - Send commands to specific worker instead of broadcasting to all clients - Clean up workers Map when worker disconnects - Update execution status to completed/failed when command results arrive - Add proper error handling when worker is not connected Fixes: - execution.logs.forEach is not a function (logs now properly parsed) - Commands stuck in "running" status (now update to completed/failed) - Commands not reaching workers (now sent to specific worker WebSocket) Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>	2026-01-07 22:23:02 -05:00
Jared Vititoe	6d15e4d240	Remove database migrations after direct schema fixes Changes: - Removed all migration code from server.js - Database schema fixed directly via MySQL: * Dropped users.role column (SSO only) * Dropped users.password column (SSO only) * Added executions.started_by column * Added workflows.created_by column * All tables now match expected schema - Server startup will be faster without migrations Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>	2026-01-07 22:11:07 -05:00
Jared Vititoe	7896b40d91	Remove password column from users table Changes: - Drop password column from users table (SSO authentication only) - PULSE uses Authelia SSO, not password-based authentication - Fixes 500 error: Field 'password' doesn't have a default value Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>	2026-01-07 22:01:58 -05:00
Jared Vititoe	e2dc371bfe	Add last_login column to users table migration Changes: - Add last_login TIMESTAMP column to existing users table - Complete the users table migration with all required columns - Fixes 500 error: Unknown column 'last_login' in 'INSERT INTO' Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>	2026-01-07 20:33:04 -05:00
Jared Vititoe	df0184facf	Add migration to update users table schema Changes: - Add display_name, email, and groups columns to existing users table - Handle MariaDB lack of IF NOT EXISTS in ALTER TABLE - Gracefully skip columns that already exist - Fixes 500 error when authenticating users Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>	2026-01-07 20:28:47 -05:00
Jared Vititoe	a8be111e04	Allow NULL workflow_id in executions table for quick commands Changes: - Modified executions table schema to allow NULL workflow_id - Removed foreign key constraint that prevented NULL values - Added migration to update existing table structure - Quick commands can now be stored without a workflow reference Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>	2026-01-07 20:27:02 -05:00
Jared Vititoe	b3806545bd	Fix quick command executions not appearing in execution tab Changes: - Create execution record in database when quick command is sent - Store initial log entry with command details - Broadcast execution_started event to update UI - Display quick commands as "[Quick Command]" in execution list - Fix worker communication to properly track all executions Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>	2026-01-07 20:24:11 -05:00
Jared Vititoe	2767087e27	Updated websocket handler	2026-01-07 20:20:18 -05:00
Jared Vititoe	a1cf8ac90b	updates aesthetic	2026-01-07 20:12:16 -05:00
Jared Vititoe	9e842624e1	Claude md file	2026-01-07 19:57:16 -05:00