feat: add macOS build, Docker image, and CI workflows

macOS (.dmg): - Add mac build config to apps/desktop/package.json (x64 + arm64 DMGs) - .github/workflows/build-mac.yml — builds on macos-latest, uploads to release Docker (headless scheduler + web remote): - docker/server.js — Node.js entry point using homebridge-plugin lib; REST API + WebSocket, serves mobile web UI on PORT (default 3456) - docker/package.json — production deps (adm-zip, axios, sql.js, ws, xml2js, xmlbuilder2) - Dockerfile — node:20-alpine image; VOLUME /data for persistent config - .github/workflows/build-docker.yml — builds linux/amd64+arm64, pushes to ghcr.io/k0rb3nd4ll4s/dibby-wemo-manager Usage: docker run -d --network host -v /opt/wemo:/data \ ghcr.io/k0rb3nd4ll4s/dibby-wemo-manager:latest Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
2026-03-29 16:27:03 -04:00
parent 58f2724d17
commit 3480c75f4c
6 changed files with 373 additions and 0 deletions
@@ -0,0 +1,218 @@
+'use strict';
+
+/**
+ * Dibby Wemo Manager — Docker entry point
+ *
+ * Runs the DWM scheduler + REST/WebSocket API server without Electron.
+ * Configure via environment variables:
+ *   DATA_DIR  — path to persistent data directory  (default: /data)
+ *   PORT      — HTTP port                          (default: 3456)
+ */
+
+const http = require('http');
+const path = require('path');
+const fs   = require('fs');
+const os   = require('os');
+
+const DwmStore     = require('./lib/store');
+const DwmScheduler = require('./lib/scheduler');
+const wemo         = require('./lib/wemo-client');
+
+const DATA_DIR = process.env.DATA_DIR || '/data';
+const PORT     = parseInt(process.env.PORT || '3456', 10);
+const WEB_DIR  = path.join(__dirname, 'web');
+
+// ── Bootstrap ─────────────────────────────────────────────────────────────────
+
+const store     = new DwmStore(DATA_DIR);
+const scheduler = new DwmScheduler({ store, wemoClient: wemo, log: console });
+
+let _wss = null;
+
+function broadcast(type, data) {
+  if (!_wss) return;
+  const msg = JSON.stringify({ type, data });
+  for (const client of _wss.clients) {
+    if (client.readyState === 1 /* OPEN */) client.send(msg);
+  }
+}
+
+// ── Helpers ───────────────────────────────────────────────────────────────────
+
+function getLocalIP() {
+  for (const iface of Object.values(os.networkInterfaces())) {
+    for (const addr of iface) {
+      if (addr.family === 'IPv4' && !addr.internal) return addr.address;
+    }
+  }
+  return 'localhost';
+}
+
+function json(res, data, status = 200) {
+  const body = JSON.stringify(data);
+  res.writeHead(status, {
+    'Content-Type': 'application/json',
+    'Access-Control-Allow-Origin': '*',
+  });
+  res.end(body);
+}
+
+function jsonErr(res, msg, status = 500) {
+  json(res, { error: msg }, status);
+}
+
+// ── Request router ────────────────────────────────────────────────────────────
+
+async function handleRequest(req, res) {
+  const url    = req.url.split('?')[0];
+  const method = req.method.toUpperCase();
+
+  if (method === 'OPTIONS') {
+    res.writeHead(204, {
+      'Access-Control-Allow-Origin':  '*',
+      'Access-Control-Allow-Methods': 'GET,POST,PUT,DELETE',
+      'Access-Control-Allow-Headers': 'Content-Type',
+    });
+    res.end();
+    return;
+  }
+
+  const body = await new Promise((resolve) => {
+    if (method !== 'POST' && method !== 'PUT') return resolve({});
+    let raw = '';
+    req.on('data', (c) => { raw += c; });
+    req.on('end', () => { try { resolve(JSON.parse(raw)); } catch { resolve({}); } });
+  });
+
+  try {
+    // ── Devices ────────────────────────────────────────────────────────────
+
+    if (url === '/api/devices' && method === 'GET') {
+      return json(res, store.getDevices());
+    }
+
+    if (url === '/api/devices/discover' && method === 'POST') {
+      const saved  = store.getDevices();
+      const manual = saved.map((d) => ({ host: d.host, port: d.port }));
+      const devs   = await wemo.discoverDevices(8000, manual);
+      store.saveDevices(devs);
+      return json(res, devs);
+    }
+
+    const stateMatch = url.match(/^\/api\/devices\/([^/]+)\/(\d+)\/state$/);
+    if (stateMatch) {
+      const [, host, port] = stateMatch;
+      if (method === 'GET') {
+        const on = await wemo.getBinaryState(host, Number(port));
+        return json(res, { on });
+      }
+      if (method === 'POST') {
+        await wemo.setBinaryState(host, Number(port), !!body.on);
+        return json(res, { ok: true });
+      }
+    }
+
+    // ── DWM Rules ──────────────────────────────────────────────────────────
+
+    if (url === '/api/dwm-rules') {
+      if (method === 'GET')  return json(res, store.getDwmRules());
+      if (method === 'POST') {
+        const rule = store.createDwmRule(body);
+        scheduler.reload();
+        return json(res, rule, 201);
+      }
+    }
+
+    const ruleMatch = url.match(/^\/api\/dwm-rules\/(.+)$/);
+    if (ruleMatch) {
+      const id = ruleMatch[1];
+      if (method === 'PUT') {
+        const updated = store.updateDwmRule(id, body);
+        scheduler.reload();
+        return json(res, updated);
+      }
+      if (method === 'DELETE') {
+        store.deleteDwmRule(id);
+        scheduler.reload();
+        return json(res, { ok: true });
+      }
+    }
+
+    // ── Wemo Device Rules ──────────────────────────────────────────────────
+
+    const wemoRulesMatch = url.match(/^\/api\/devices\/([^/]+)\/(\d+)\/rules$/);
+    if (wemoRulesMatch && method === 'GET') {
+      const [, host, port] = wemoRulesMatch;
+      return json(res, await wemo.getRules(host, Number(port)));
+    }
+
+    const wemoRuleMatch = url.match(/^\/api\/devices\/([^/]+)\/(\d+)\/rules\/(\d+)$/);
+    if (wemoRuleMatch && method === 'PUT') {
+      const [, host, port, ruleId] = wemoRuleMatch;
+      await wemo.updateRule(host, Number(port), Number(ruleId), body);
+      return json(res, { ok: true });
+    }
+
+    // ── Scheduler ──────────────────────────────────────────────────────────
+
+    if (url === '/api/scheduler/status' && method === 'GET') {
+      return json(res, scheduler.getStatus());
+    }
+
+    // ── Static assets ──────────────────────────────────────────────────────
+
+    if (url === '/icon.png' && method === 'GET') {
+      const file = path.join(__dirname, 'icon.png');
+      fs.readFile(file, (e, data) => {
+        if (e) { res.writeHead(404); res.end(); return; }
+        res.writeHead(200, { 'Content-Type': 'image/png' });
+        res.end(data);
+      });
+      return;
+    }
+
+    // Fallback → serve mobile web UI
+    const file = path.join(WEB_DIR, 'index.html');
+    fs.readFile(file, (e, data) => {
+      if (e) { res.writeHead(404); res.end('Web UI not found'); return; }
+      res.writeHead(200, { 'Content-Type': 'text/html' });
+      res.end(data);
+    });
+
+  } catch (e) {
+    jsonErr(res, e.message);
+  }
+}
+
+// ── Start ─────────────────────────────────────────────────────────────────────
+
+async function main() {
+  // Ensure data directory exists
+  fs.mkdirSync(DATA_DIR, { recursive: true });
+
+  await scheduler.start();
+  console.log(`[DWM] Scheduler started — data: ${DATA_DIR}`);
+
+  const server = http.createServer(handleRequest);
+
+  let WebSocketServer;
+  try { WebSocketServer = require('ws').WebSocketServer || require('ws').Server; } catch {}
+
+  if (WebSocketServer) {
+    _wss = new WebSocketServer({ server });
+    _wss.on('connection', (ws) => {
+      ws.send(JSON.stringify({ type: 'scheduler-status', data: scheduler.getStatus() }));
+    });
+    scheduler.onFire   = (event)  => broadcast('scheduler-fired',  event);
+    scheduler.onStatus = (status) => broadcast('scheduler-status', status);
+  }
+
+  server.listen(PORT, '0.0.0.0', () => {
+    console.log(`[DWM] Web Remote: http://${getLocalIP()}:${PORT}`);
+  });
+
+  process.on('SIGTERM', () => { server.close(); process.exit(0); });
+  process.on('SIGINT',  () => { server.close(); process.exit(0); });
+}
+
+main().catch((e) => { console.error('[DWM] Fatal:', e); process.exit(1); });