@@ -339,6 +352,40 @@ evtSource.onerror = () => { setTimeout(() => location.reload(), 5000); };
// Resume audio on first interaction
document.addEventListener('click', () => { if (audioCtx.state === 'suspended') audioCtx.resume(); }, { once: true });
+// === ROOM SENSORS (7pm - 8am only) ===
+const sensorEl = document.getElementById('room-sensors');
+
+function isNightTime() {
+ const h = new Date().getHours();
+ return h >= 19 || h < 8;
+}
+
+async function updateSensors() {
+ if (!isNightTime()) { sensorEl.style.display = 'none'; return; }
+ sensorEl.style.display = '';
+ try {
+ const r = await fetch('/api/sensors/bed1');
+ const d = await r.json();
+ const tempF = parseFloat(d.temperature);
+ const tempC = ((tempF - 32) * 5/9).toFixed(1);
+ document.getElementById('s-temp').textContent = Math.round(tempF) + '°';
+ document.getElementById('s-temp').title = tempC + '°C';
+
+ const hum = parseFloat(d.humidity);
+ const humEl = document.getElementById('s-hum');
+ humEl.textContent = Math.round(hum) + '%';
+ humEl.className = 'sensor-val' + (hum < 30 || hum > 65 ? ' warn' : '');
+
+ const co2 = parseInt(d.co2);
+ const co2El = document.getElementById('s-co2');
+ co2El.textContent = co2;
+ co2El.className = 'sensor-val' + (co2 > 1500 ? ' crit' : co2 > 1000 ? ' warn' : '');
+ } catch(e) { console.error('Sensor fetch failed:', e); }
+}
+
+updateSensors();
+setInterval(updateSensors, 30000);
+
// === PULSE-OX CAMERA (7pm - 8am only) ===
const camImg = document.getElementById('pulse-cam');
const camWrap = document.getElementById('cam-wrap');
diff --git a/server.js b/server.js
index 0ea89e3..7e3131d 100644
--- a/server.js
+++ b/server.js
@@ -58,6 +58,43 @@ app.post('/api/alerts', (req, res) => {
res.status(201).json(alert);
});
+// Bedroom 1 sensors proxy from HA
+const SENSOR_ENTITIES = {
+ temperature: 'sensor.bed1_temperature',
+ humidity: 'sensor.bed1_humidity',
+ co2: 'sensor.athom_co2_sensor_b34780_co2'
+};
+
+let sensorCache = { data: null, ts: 0 };
+
+app.get('/api/sensors/bed1', async (req, res) => {
+ // Cache for 15s to avoid hammering HA
+ if (sensorCache.data && Date.now() - sensorCache.ts < 15000) {
+ return res.json(sensorCache.data);
+ }
+ try {
+ const results = {};
+ for (const [key, entity] of Object.entries(SENSOR_ENTITIES)) {
+ const data = await new Promise((resolve, reject) => {
+ const r = http.get(`${HA_URL}/api/states/${entity}`, {
+ headers: { 'Authorization': `Bearer ${HA_TOKEN}` }
+ }, (haRes) => {
+ let body = '';
+ haRes.on('data', c => body += c);
+ haRes.on('end', () => { try { resolve(JSON.parse(body)); } catch(e) { reject(e); } });
+ });
+ r.on('error', reject);
+ r.setTimeout(3000, () => { r.destroy(); reject(new Error('timeout')); });
+ });
+ results[key] = data.state;
+ }
+ sensorCache = { data: results, ts: Date.now() };
+ res.json(results);
+ } catch(e) {
+ res.status(502).json({ error: 'HA unavailable' });
+ }
+});
+
// Camera proxy - snapshot from HA
app.get('/api/cam/pulse-ox', (req, res) => {
const haReq = http.get(`${HA_URL}/api/camera_proxy/camera.pulse_ox_live_view`, {