328 lines
13 KiB
JavaScript
328 lines
13 KiB
JavaScript
import fs from 'fs';
|
|
import http from 'http';
|
|
|
|
const STATUS_PORT = 8082;
|
|
|
|
export function startStatusServer({
|
|
getState,
|
|
WATER_BUTTON_MAC,
|
|
REMOTE_SWITCH_MAC,
|
|
setLight,
|
|
persistedState,
|
|
saveState
|
|
}) {
|
|
async function getButtonOnline() {
|
|
try {
|
|
const ctxGetState = global.__waterBotGetState;
|
|
if (!ctxGetState) return null;
|
|
const online = await ctxGetState(WATER_BUTTON_MAC, 'system', 'online');
|
|
// DB stores booleans as strings 'true'/'false'
|
|
if (online === true || online === 'true') return true;
|
|
if (online === false || online === 'false') return false;
|
|
return null;
|
|
} catch {
|
|
return null;
|
|
}
|
|
}
|
|
|
|
async function getValveOnline() {
|
|
try {
|
|
const ctxGetState = global.__waterBotGetState;
|
|
if (!ctxGetState) return null;
|
|
const online = await ctxGetState(REMOTE_SWITCH_MAC, 'system', 'online');
|
|
if (online === true || online === 'true') return true;
|
|
if (online === false || online === 'false') return false;
|
|
return null;
|
|
} catch {
|
|
return null;
|
|
}
|
|
}
|
|
|
|
function getStatusJSON() {
|
|
const state = getState(WATER_BUTTON_MAC);
|
|
return {
|
|
valveOpen: state.timer !== null || (!state.countMode && state.timer === null),
|
|
timerActive: state.timer !== null,
|
|
countMode: state.countMode,
|
|
countStart: state.countStart || null,
|
|
storedDuration: state.storedDuration,
|
|
timerStartedAt: state.timerStartedAt,
|
|
timerEndsAt: state.timerEndsAt,
|
|
now: Date.now()
|
|
};
|
|
}
|
|
|
|
const statusPageHTML = `<!DOCTYPE html>
|
|
<html lang="en">
|
|
<head>
|
|
<meta charset="UTF-8">
|
|
<meta name="viewport" content="width=device-width, initial-scale=1.0, user-scalable=no">
|
|
<title>Water Timer</title>
|
|
<link rel="stylesheet" href="/style.css">
|
|
</head>
|
|
<body>
|
|
<div class="container">
|
|
<h1>💧 Water Timer</h1>
|
|
|
|
<div class="devices-row">
|
|
<div class="device-status">
|
|
<div class="device-icon-wrap">
|
|
<img src="/taster.png" class="device-icon" alt="Button">
|
|
<span class="device-dot" id="device-dot"></span>
|
|
</div>
|
|
<div class="device-info">
|
|
<span class="device-name">Button</span>
|
|
<span class="device-state" id="device-state">Checking…</span>
|
|
<span class="device-desc">Short press: run timer · Long press: start learn, short press to stop</span>
|
|
</div>
|
|
</div>
|
|
<div class="device-status">
|
|
<div class="device-icon-wrap">
|
|
<img src="/valve.png" class="device-icon" alt="Valve">
|
|
<span class="device-dot" id="valve-dot"></span>
|
|
</div>
|
|
<div class="device-info">
|
|
<span class="device-name">Valve</span>
|
|
<span class="device-state" id="valve-state">Checking…</span>
|
|
<span class="device-desc">⚠️ Connect according to flow direction mark</span>
|
|
</div>
|
|
</div>
|
|
</div>
|
|
|
|
<div class="ring-wrapper">
|
|
<div class="glow" id="glow"></div>
|
|
<svg class="ring-svg" viewBox="0 0 120 120">
|
|
<defs>
|
|
<linearGradient id="grad" x1="0%" y1="0%" x2="100%" y2="100%">
|
|
<stop offset="0%" stop-color="#3b82f6"/>
|
|
<stop offset="100%" stop-color="#06b6d4"/>
|
|
</linearGradient>
|
|
</defs>
|
|
<circle class="ring-bg" cx="60" cy="60" r="52"/>
|
|
<circle class="ring-fg" id="ring" cx="60" cy="60" r="52"
|
|
stroke-dasharray="326.73" stroke-dashoffset="326.73"/>
|
|
</svg>
|
|
<div class="ring-center">
|
|
<div class="countdown idle" id="countdown">—</div>
|
|
<div class="countdown-label" id="label">IDLE</div>
|
|
</div>
|
|
</div>
|
|
|
|
<div class="badge closed" id="badge">
|
|
<span class="dot"></span>
|
|
<span id="badge-text">Loading…</span>
|
|
</div>
|
|
|
|
<div class="controls">
|
|
<div class="run-container">
|
|
<div class="dur-input-group">
|
|
<input type="number" class="dur-input" id="dur-input" min="1" max="300" step="1" value="">
|
|
<span class="dur-unit">sec</span>
|
|
</div>
|
|
<button class="btn primary" id="btn-run" onclick="doRun()">▶ Run</button>
|
|
<button class="btn warning" id="btn-learn" onclick="doLearn()">📐 Learn</button>
|
|
</div>
|
|
<button class="btn success" id="btn-open" onclick="doOpen()">🔓 Open</button>
|
|
<button class="btn danger" id="btn-close" onclick="doClose()">🔒 Close</button>
|
|
</div>
|
|
</div>
|
|
|
|
<script src="/script.js"></script>
|
|
</body>
|
|
</html>`;
|
|
|
|
// Prevent duplicate listeners across hot reloads
|
|
if (global.__waterStatusServer) {
|
|
try { global.__waterStatusServer.close(); } catch (e) { }
|
|
}
|
|
|
|
const srv = http.createServer(async (req, res) => {
|
|
const url = new URL(req.url, `http://${req.headers.host}`);
|
|
|
|
const jsonHeaders = {
|
|
'Content-Type': 'application/json',
|
|
'Cache-Control': 'no-cache',
|
|
'Access-Control-Allow-Origin': '*'
|
|
};
|
|
|
|
if (url.pathname === '/style.css') {
|
|
res.writeHead(200, { 'Content-Type': 'text/css' });
|
|
res.end(fs.readFileSync(new URL('./public/waterButtonStatus/style.css', import.meta.url)));
|
|
return;
|
|
}
|
|
|
|
if (url.pathname === '/script.js') {
|
|
res.writeHead(200, { 'Content-Type': 'application/javascript' });
|
|
res.end(fs.readFileSync(new URL('./public/waterButtonStatus/script.js', import.meta.url)));
|
|
return;
|
|
}
|
|
|
|
if (url.pathname === '/taster.png') {
|
|
res.writeHead(200, { 'Content-Type': 'image/png', 'Cache-Control': 'public, max-age=86400' });
|
|
res.end(fs.readFileSync(new URL('./public/waterButtonStatus/taster.png', import.meta.url)));
|
|
return;
|
|
}
|
|
|
|
if (url.pathname === '/api/button-online') {
|
|
const online = await getButtonOnline();
|
|
res.writeHead(200, jsonHeaders);
|
|
res.end(JSON.stringify({ online }));
|
|
return;
|
|
}
|
|
|
|
if (url.pathname === '/valve.png') {
|
|
res.writeHead(200, { 'Content-Type': 'image/png', 'Cache-Control': 'public, max-age=86400' });
|
|
res.end(fs.readFileSync(new URL('./public/waterButtonStatus/valve.png', import.meta.url)));
|
|
return;
|
|
}
|
|
|
|
if (url.pathname === '/api/valve-online') {
|
|
const online = await getValveOnline();
|
|
res.writeHead(200, jsonHeaders);
|
|
res.end(JSON.stringify({ online }));
|
|
return;
|
|
}
|
|
|
|
if (url.pathname === '/api/status') {
|
|
res.writeHead(200, jsonHeaders);
|
|
res.end(JSON.stringify(getStatusJSON()));
|
|
return;
|
|
}
|
|
|
|
// ── POST command endpoints ──
|
|
if (req.method === 'POST' && url.pathname.startsWith('/api/')) {
|
|
let body = '';
|
|
req.on('data', c => body += c);
|
|
req.on('end', async () => {
|
|
const sendRPC = global.__waterBotRPC;
|
|
const state = getState(WATER_BUTTON_MAC);
|
|
|
|
// ── Learn / Stop-learn: work regardless of device connection ──
|
|
if (url.pathname === '/api/learn') {
|
|
if (state.timer) { clearTimeout(state.timer); state.timer = null; }
|
|
state.timerStartedAt = null;
|
|
state.timerEndsAt = null;
|
|
state.countMode = true;
|
|
state.countStart = Date.now();
|
|
if (sendRPC) {
|
|
try { await setLight(sendRPC, WATER_BUTTON_MAC, false, 0); } catch (e) {
|
|
console.warn('[WaterStatus] learn: setLight failed:', e.message);
|
|
}
|
|
}
|
|
res.writeHead(200, jsonHeaders);
|
|
res.end(JSON.stringify({ ok: true, action: 'learn' }));
|
|
return;
|
|
}
|
|
|
|
if (url.pathname === '/api/stop-learn') {
|
|
if (!state.countMode) {
|
|
res.writeHead(200, jsonHeaders);
|
|
res.end(JSON.stringify({ ok: true, action: 'stop-learn', skipped: true }));
|
|
return;
|
|
}
|
|
const elapsed = Date.now() - (state.countStart || Date.now());
|
|
state.countMode = false;
|
|
state.countStart = 0;
|
|
state.storedDuration = elapsed;
|
|
persistedState[WATER_BUTTON_MAC] = { storedDuration: elapsed };
|
|
saveState(persistedState);
|
|
if (sendRPC) {
|
|
try { await setLight(sendRPC, WATER_BUTTON_MAC, true, 95); } catch (e) {
|
|
console.warn('[WaterStatus] stop-learn: setLight failed:', e.message);
|
|
}
|
|
}
|
|
res.writeHead(200, jsonHeaders);
|
|
res.end(JSON.stringify({ ok: true, action: 'stop-learn', storedDuration: elapsed }));
|
|
return;
|
|
}
|
|
|
|
// ── All other commands require a live device connection ──
|
|
if (!sendRPC) {
|
|
res.writeHead(503, jsonHeaders);
|
|
res.end(JSON.stringify({ ok: false, error: 'Not ready — no device connection' }));
|
|
return;
|
|
}
|
|
|
|
|
|
try {
|
|
if (url.pathname === '/api/run') {
|
|
if (state.timer) { clearTimeout(state.timer); state.timer = null; }
|
|
state.countMode = false;
|
|
await setLight(sendRPC, WATER_BUTTON_MAC, false, 0);
|
|
const duration = state.storedDuration;
|
|
state.timerStartedAt = Date.now();
|
|
state.timerEndsAt = Date.now() + duration;
|
|
state.timer = setTimeout(async () => {
|
|
try {
|
|
const rpc = global.__waterBotRPC;
|
|
if (rpc) await setLight(rpc, WATER_BUTTON_MAC, true, 95);
|
|
state.timer = null;
|
|
state.timerStartedAt = null;
|
|
state.timerEndsAt = null;
|
|
} catch (err) {
|
|
console.error('[WaterStatus] Timer callback error:', err);
|
|
}
|
|
}, duration);
|
|
res.writeHead(200, jsonHeaders);
|
|
res.end(JSON.stringify({ ok: true, action: 'run', duration }));
|
|
|
|
} else if (url.pathname === '/api/open') {
|
|
if (state.timer) { clearTimeout(state.timer); state.timer = null; }
|
|
state.countMode = false;
|
|
state.timerStartedAt = null;
|
|
state.timerEndsAt = null;
|
|
await setLight(sendRPC, WATER_BUTTON_MAC, false, 0);
|
|
res.writeHead(200, jsonHeaders);
|
|
res.end(JSON.stringify({ ok: true, action: 'open' }));
|
|
|
|
} else if (url.pathname === '/api/close') {
|
|
if (state.timer) { clearTimeout(state.timer); state.timer = null; }
|
|
state.countMode = false;
|
|
state.timerStartedAt = null;
|
|
state.timerEndsAt = null;
|
|
await setLight(sendRPC, WATER_BUTTON_MAC, true, 95);
|
|
res.writeHead(200, jsonHeaders);
|
|
res.end(JSON.stringify({ ok: true, action: 'close' }));
|
|
|
|
} else if (url.pathname === '/api/duration') {
|
|
const data = JSON.parse(body || '{}');
|
|
const ms = Math.round((data.seconds || 0) * 1000);
|
|
if (ms <= 0 || ms > 300000) {
|
|
res.writeHead(400, jsonHeaders);
|
|
res.end(JSON.stringify({ ok: false, error: 'Duration must be 1-300s' }));
|
|
return;
|
|
}
|
|
state.storedDuration = ms;
|
|
persistedState[WATER_BUTTON_MAC] = { storedDuration: ms };
|
|
saveState(persistedState);
|
|
res.writeHead(200, jsonHeaders);
|
|
res.end(JSON.stringify({ ok: true, action: 'duration', ms }));
|
|
|
|
} else {
|
|
res.writeHead(404, jsonHeaders);
|
|
res.end(JSON.stringify({ ok: false, error: 'Unknown endpoint' }));
|
|
}
|
|
} catch (err) {
|
|
console.error('[WaterStatus] API error:', err);
|
|
res.writeHead(500, jsonHeaders);
|
|
res.end(JSON.stringify({ ok: false, error: err.message }));
|
|
}
|
|
});
|
|
return;
|
|
}
|
|
|
|
// Serve HTML status page
|
|
res.writeHead(200, {
|
|
'Content-Type': 'text/html',
|
|
'Cache-Control': 'no-cache'
|
|
});
|
|
res.end(statusPageHTML);
|
|
});
|
|
|
|
srv.listen(STATUS_PORT, () => {
|
|
console.log(`[WaterStatus] Status page at http://localhost:${STATUS_PORT}`);
|
|
});
|
|
|
|
global.__waterStatusServer = srv;
|
|
}
|