/*! hero-gradient.js: set window.SMEIRD before load (broker/creds/topics/coords/timers); requires mqtt.min.js global `mqtt` and hero-gradient.css; URL params hero_override=STATE (30m) & hero_debug=1. */ (function () { var win = window; var doc = document; if (!doc || typeof mqtt === 'undefined') return; var topics = { outside_temp: 'sensors/outside/temperature_c', wind_speed: 'sensors/wind/speed_kmh', barometer: 'sensors/weather/pressure_hpa', dew_point: 'sensors/outside/dewpoint_c', wind_chill: 'sensors/outside/windchill_c', rain_today: 'sensors/rain/today_mm', wind_gust: 'sensors/wind/gust_kmh', wind_dir: 'sensors/wind/dir_deg' }; var defaults = { brokerUrl: 'wss://mqtt.example.com:8083/mqtt', clientId: 'smeird-hero-' + Math.random().toString(16).slice(2), username: null, password: null, loopTopic: 'weather/loop', topics: topics, siteLat: 51.8117, siteLon: -0.2939, staleAfterMs: 600000, minDwellMs: 300000, evalIntervalMs: 60000 }; var user = win.SMEIRD || {}; var SMEIRD = win.SMEIRD = Object.assign({}, defaults, user); SMEIRD.topics = Object.assign({}, topics, user.topics || {}); var required = ['outside_temp', 'wind_speed', 'barometer', 'dew_point', 'wind_gust', 'rain_today']; var ranges = { outside_temp: [-60, 60], dew_point: [-60, 60], wind_speed: [0, 200], wind_gust: [0, 250], barometer: [800, 1100], wind_chill: [-80, 60], rain_today: [0, 2000] }; var severity = { stale: 9, storm: 8, 'heavy-rain': 7, rain: 6, snow: 5, fog: 4, windy: 3, hot: 2, cold: 2, 'clear-night': 1, overcast: 1 }; var vals = {}; var lastMsg = 0; var rainHist = []; var pressureHist = []; var currentState = null; var currentCause = null; var lastChange = 0; var overrideState = null; var overrideUntil = 0; var params = new URLSearchParams(win.location.search); var debugMode = params.get('hero_debug') === '1'; var panel = null; if (params.get('hero_override')) { setOverride(params.get('hero_override'), Date.now() + 1800000); } else { readOverride(); } if (debugMode) { panel = createPanel(); } var client = mqtt.connect(SMEIRD.brokerUrl, { clientId: SMEIRD.clientId, username: SMEIRD.username || undefined, password: SMEIRD.password || undefined, reconnectPeriod: 5000 }); client.on('connect', function () { if (SMEIRD.loopTopic) { client.subscribe(SMEIRD.loopTopic); } Object.keys(SMEIRD.topics).forEach(function (key) { if (SMEIRD.topics[key]) { client.subscribe(SMEIRD.topics[key]); } }); }); client.on('message', function (topic, payload) { if (SMEIRD.loopTopic && topic === SMEIRD.loopTopic) { if (applyLoopPayload(payload)) { lastMsg = Date.now(); if (debugMode) updatePanel(); evaluate(); } return; } var key = getKey(topic); if (!key) return; var val = parseNumber(key, payload); if (val === null) return; vals[key] = val; lastMsg = Date.now(); if (debugMode) updatePanel(); evaluate(); }); setInterval(evaluate, SMEIRD.evalIntervalMs); evaluate(); function getKey(topic) { for (var k in SMEIRD.topics) { if (SMEIRD.topics[k] === topic) return k; } return null; } function parseNumber(key, payload) { var str; if (payload instanceof Uint8Array) { if (typeof TextDecoder !== 'undefined') { str = new TextDecoder().decode(payload); } else { str = String.fromCharCode.apply(null, payload); } } else { str = String(payload); } var num = parseFloat(str); if (!isFinite(num)) return null; var range = ranges[key]; if (range) { if (num < range[0]) num = range[0]; if (num > range[1]) num = range[1]; } return num; } function decodePayload(payload) { if (payload == null) return ''; if (typeof payload === 'string') return payload; if (payload instanceof Uint8Array) { if (typeof TextDecoder !== 'undefined') { try { return new TextDecoder().decode(payload); } catch (err) {} } var out = ''; for (var i = 0; i < payload.length; i++) { out += String.fromCharCode(payload[i]); } return out; } if (typeof payload === 'object' && payload !== null) { if (typeof payload.buffer !== 'undefined' && typeof TextDecoder !== 'undefined') { try { return new TextDecoder().decode(new Uint8Array(payload.buffer)); } catch (err) {} } if (typeof payload.toString === 'function' && payload.toString !== Object.prototype.toString) { return payload.toString(); } } return String(payload || ''); } function coerceNumber(raw) { if (raw === null || raw === undefined) return null; if (typeof raw === 'number') { return isFinite(raw) ? raw : null; } var num = parseFloat(String(raw)); return isFinite(num) ? num : null; } function applyRange(key, num) { var range = ranges[key]; if (range) { if (num < range[0]) num = range[0]; if (num > range[1]) num = range[1]; } return num; } function applyValue(key, raw, transform) { var num = coerceNumber(raw); if (num === null) return false; if (typeof transform === 'function') { num = transform(num); if (num === null || num === undefined) return false; } if (!isFinite(num)) return false; num = applyRange(key, num); vals[key] = num; return true; } function assignFromCandidates(key, candidates) { if (!candidates || !candidates.length) return false; for (var i = 0; i < candidates.length; i++) { var candidate = candidates[i]; if (!candidate) continue; var value = candidate[0]; if (value === undefined || value === null) continue; var transform = candidate.length > 1 ? candidate[1] : null; if (applyValue(key, value, transform)) { return true; } } return false; } function normaliseDirection(value) { var num = coerceNumber(value); if (num === null) return null; num = num % 360; if (num < 0) num += 360; return num; } function applyLoopPayload(payload) { var text = decodePayload(payload); if (!text) return false; var data; try { data = JSON.parse(text); } catch (err) { console.warn('hero gradient: failed to parse loop payload', err); return false; } if (!data || typeof data !== 'object') return false; var appliedAny = false; function use(key, candidates) { if (assignFromCandidates(key, candidates)) { appliedAny = true; } } use('outside_temp', [ [data.outTemp_C], [data.temperature_C], [data.outTemp], [data.temperature], [data.outTemp_F, function (v) { return (v - 32) / 1.8; }], [data.temperature_F, function (v) { return (v - 32) / 1.8; }] ]); use('dew_point', [ [data.dewpoint_C], [data.dewPoint_C], [data.dewpoint], [data.dewPoint], [data.dewpoint_F, function (v) { return (v - 32) / 1.8; }] ]); use('wind_speed', [ [data.windSpeed_kph], [data.wind_speed_kph], [data.windSpeed], [data.windSpd], [data.windSpeed_mps, function (v) { return v * 3.6; }], [data.windSpeed_ms, function (v) { return v * 3.6; }], [data.windSpeed_mph, function (v) { return v * 1.60934; }], [data.windSpeed_kn, function (v) { return v * 1.852; }] ]); use('wind_gust', [ [data.windGust_kph], [data.wind_gust_kph], [data.windGust], [data.windGust_mps, function (v) { return v * 3.6; }], [data.windGust_ms, function (v) { return v * 3.6; }], [data.windGust_mph, function (v) { return v * 1.60934; }], [data.windGust_kn, function (v) { return v * 1.852; }] ]); var dir = normaliseDirection(data.windDir || data.windDirection || data.windBearing || data.windDeg || data.wind_direction); if (dir !== null) { vals.wind_dir = dir; appliedAny = true; } use('wind_chill', [ [data.windchill_C], [data.windChill_C], [data.windchill], [data.windChill], [data.windchill_F, function (v) { return (v - 32) / 1.8; }] ]); use('barometer', [ [data.pressure_mbar], [data.barometer_hpa], [data.barometer], [data.pressure_hpa], [data.pressure], [data.barometer_inhg, function (v) { return v * 33.8639; }], [data.pressure_inhg, function (v) { return v * 33.8639; }] ]); use('rain_today', [ [data.dayRain_mm], [data.rainDay_mm], [data.rainToday_mm], [data.dayRain_cm, function (v) { return v * 10; }], [data.rainDay_cm, function (v) { return v * 10; }], [data.dayRain_in, function (v) { return v * 25.4; }], [data.rainDay_in, function (v) { return v * 25.4; }] ]); return appliedAny; } function maintainHistory(now) { if (typeof vals.rain_today === 'number') { rainHist.push({ ts: now, value: vals.rain_today }); } if (typeof vals.barometer === 'number') { pressureHist.push({ ts: now, value: vals.barometer }); } var rainCut = now - 900000; while (rainHist.length && rainHist[0].ts < rainCut) rainHist.shift(); var pressureCut = now - 3600000; while (pressureHist.length && pressureHist[0].ts < pressureCut) pressureHist.shift(); } function rainDelta(ms, now) { if (!rainHist.length) return 0; var latest = rainHist[rainHist.length - 1]; var base = rainHist[0]; for (var i = rainHist.length - 1; i >= 0; i--) { if (now - rainHist[i].ts <= ms) base = rainHist[i]; } var delta = latest.value - base.value; return delta > 0 ? delta : 0; } function pressureDrop(ms, now) { if (!pressureHist.length) return 0; var latest = pressureHist[pressureHist.length - 1]; var ref = pressureHist[0]; for (var i = pressureHist.length - 1; i >= 0; i--) { if (now - pressureHist[i].ts >= ms) { ref = pressureHist[i]; break; } } var drop = ref.value - latest.value; return drop > 0 ? drop : 0; } function evaluate() { var now = Date.now(); if (overrideState && now > overrideUntil) clearOverride(); var night = sunElevation(now, SMEIRD.siteLat, SMEIRD.siteLon) < -6; var missing = []; for (var m = 0; m < required.length; m++) { if (!(required[m] in vals)) missing.push(required[m]); } var hasAnyData = lastMsg > 0 || Object.keys(vals).length > 0; if (!hasAnyData) { var pendingTarget = overrideState || (currentState || 'stale'); var pendingCause = overrideState ? 'override-pending-data' : 'missing-data'; var pendingInfo = { state: pendingTarget, cause: pendingCause, isNight: night, lastChangeTs: lastChange, rain15: 0, pressureDrop: 0, values: Object.assign({}, vals), missing: missing.slice() }; if (pendingTarget !== currentState) { currentState = pendingTarget; lastChange = now; currentCause = pendingCause; pendingInfo.lastChangeTs = now; applyState(pendingTarget, pendingCause, pendingInfo); } win.__smeirdHeroState = pendingInfo; if (debugMode) updatePanel(); return; } maintainHistory(now); var v = vals; var rain15 = rainDelta(900000, now); var drop60 = pressureDrop(3600000, now); var result = computeState(now, rain15, drop60, night); var target = result.state; var cause = result.cause; if (overrideState) { target = overrideState; cause = 'override'; } if (target !== currentState) { var allowHysteresis = !overrideState && !debugMode && currentState && currentState !== 'stale' && currentCause !== 'missing-data' && currentCause !== 'override-pending-data' && currentCause !== 'override'; if (allowHysteresis) { if (currentState && now - lastChange < SMEIRD.minDwellMs && severity[target] <= severity[currentState]) { target = currentState; cause = 'dwell'; } else if (currentState === 'windy' && target !== 'windy' && severity[target] < severity[currentState] && ((v.wind_speed || 0) >= 25 || (v.wind_gust || 0) >= 35)) { target = currentState; cause = 'windy-hold'; } else if (currentState === 'hot' && target !== 'hot' && severity[target] < severity[currentState] && (v.outside_temp || 0) >= 26) { target = currentState; cause = 'hot-hold'; } else if (currentState === 'cold' && target !== 'cold' && severity[target] < severity[currentState] && !((v.outside_temp || 0) > 3 && (v.wind_chill === undefined || v.wind_chill > 1))) { target = currentState; cause = 'cold-hold'; } } } var info = { state: target, cause: cause, isNight: night, lastChangeTs: lastChange, rain15: rain15, pressureDrop: drop60, values: Object.assign({}, v), missing: missing.slice() }; if (target !== currentState) { currentState = target; lastChange = now; currentCause = cause; info.lastChangeTs = now; applyState(target, cause, info); } win.__smeirdHeroState = info; if (debugMode) updatePanel(); } function computeState(now, rain15, drop60, night) { var v = vals; var outsideTemp = typeof v.outside_temp === 'number' ? v.outside_temp : null; var dewPoint = typeof v.dew_point === 'number' ? v.dew_point : null; var windSpeed = typeof v.wind_speed === 'number' ? v.wind_speed : null; var windGust = typeof v.wind_gust === 'number' ? v.wind_gust : null; var windChill = typeof v.wind_chill === 'number' ? v.wind_chill : null; if (!lastMsg || now - lastMsg > SMEIRD.staleAfterMs) { return { state: 'stale', cause: 'stale' }; } if ((windGust !== null && windGust >= 50) || drop60 >= 2) { return { state: 'storm', cause: 'gust/pressure' }; } if (rain15 >= 0.5) { return { state: 'heavy-rain', cause: 'rain15=' + rain15.toFixed(2) }; } if (rain15 > 0) { return { state: 'rain', cause: 'rain15=' + rain15.toFixed(2) }; } if (((outsideTemp !== null && outsideTemp <= 0 && rain15 > 0) || (windChill !== null && windChill <= -1))) { return { state: 'snow', cause: 'temp/windchill' }; } if (outsideTemp !== null && dewPoint !== null && Math.abs(outsideTemp - dewPoint) <= 1.5 && (windSpeed || 0) < 3) { return { state: 'fog', cause: 'dewpoint proximity' }; } if ((windSpeed !== null && windSpeed >= 30) || (windGust !== null && windGust >= 40)) { return { state: 'windy', cause: 'wind' }; } if (outsideTemp !== null && outsideTemp >= 28) { return { state: 'hot', cause: 'temp' }; } if ((outsideTemp !== null && outsideTemp <= 2) || (windChill !== null && windChill <= 0)) { return { state: 'cold', cause: 'temp' }; } if (night && rain15 === 0 && drop60 < 2 && (windGust === null || windGust < 50)) { return { state: 'clear-night', cause: 'night' }; } return { state: 'overcast', cause: 'default' }; } function applyState(state, cause, info) { if (doc.body) doc.body.setAttribute('data-weather', state); console.info('hero state %s (%s)', state, cause, info); } function setOverride(state, expiry) { if (!severity.hasOwnProperty(state)) return; overrideState = state; overrideUntil = expiry; try { localStorage.setItem('smeirdHeroOverride', JSON.stringify({ state: state, expires: expiry })); } catch (e) {} } function clearOverride() { overrideState = null; overrideUntil = 0; try { localStorage.removeItem('smeirdHeroOverride'); } catch (e) {} } function readOverride() { try { var raw = localStorage.getItem('smeirdHeroOverride'); if (!raw) return; var data = JSON.parse(raw); if (data && data.state && data.expires > Date.now()) { overrideState = data.state; overrideUntil = data.expires; } else { localStorage.removeItem('smeirdHeroOverride'); } } catch (e) {} } function sunElevation(ms, lat, lon) { var rad = Math.PI / 180; var d = (ms - Date.UTC(2000, 0, 1, 12)) / 86400000; var g = 357.529 + 0.98560028 * d; var q = 280.459 + 0.98564736 * d; var gR = g * rad; var L = (q + 1.915 * Math.sin(gR) + 0.02 * Math.sin(2 * gR)) % 360; if (L < 0) L += 360; var Lr = L * rad; var e = (23.439 - 0.00000036 * d) * rad; var RA = Math.atan2(Math.cos(e) * Math.sin(Lr), Math.cos(Lr)); var RAdeg = (RA / rad + 360) % 360; var eq = q % 360 - RAdeg; if (eq > 180) eq -= 360; if (eq < -180) eq += 360; var eqMin = 4 * eq; var date = new Date(ms); var utcMin = date.getUTCHours() * 60 + date.getUTCMinutes() + date.getUTCSeconds() / 60; var tst = (utcMin + eqMin + lon * 4 + 1440) % 1440; var ha = tst / 4 - 180; var haR = ha * rad; var latR = lat * rad; var dec = Math.asin(Math.sin(e) * Math.sin(Lr)); var elev = Math.asin(Math.sin(latR) * Math.sin(dec) + Math.cos(latR) * Math.cos(dec) * Math.cos(haR)); return elev / rad; } function createPanel() { var wrap = doc.createElement('div'); wrap.style.cssText = 'position:fixed;bottom:1rem;right:1rem;z-index:9999;background:rgba(0,0,0,.78);color:#fff;padding:.75rem;border-radius:8px;font:12px/1.4 sans-serif;max-width:260px;'; wrap.innerHTML = 'Hero Debug

'; doc.body.appendChild(wrap); var buttons = wrap.querySelector('.hero-debug-buttons'); ['storm', 'heavy-rain', 'rain', 'snow', 'fog', 'windy', 'hot', 'cold'].forEach(function (s) { var b = doc.createElement('button'); b.type = 'button'; b.textContent = s; b.style.cssText = 'margin:0 .25rem .25rem 0;padding:.25rem .5rem;font-size:11px;'; b.addEventListener('click', function () { simulate(s); }); buttons.appendChild(b); }); var clearBtn = doc.createElement('button'); clearBtn.type = 'button'; clearBtn.textContent = 'clear override'; clearBtn.style.cssText = 'margin:.25rem 0 0;padding:.25rem .5rem;font-size:11px;'; clearBtn.addEventListener('click', function () { clearOverride(); evaluate(); }); buttons.appendChild(clearBtn); return wrap; } function simulate(state) { required.forEach(function (key) { if (!(key in vals)) { vals[key] = key === 'outside_temp' ? 10 : key === 'barometer' ? 1013 : 0; } }); if (!('dew_point' in vals)) vals.dew_point = vals.outside_temp - 2; if (!('wind_chill' in vals)) vals.wind_chill = vals.outside_temp; if (!('wind_gust' in vals)) vals.wind_gust = vals.wind_speed; var now = Date.now(); lastMsg = now; switch (state) { case 'storm': vals.wind_gust = 60; vals.wind_speed = 35; pressureHist.push({ ts: now - 3600000, value: (vals.barometer || 1010) + 3 }); break; case 'heavy-rain': rainHist.push({ ts: now - 900000, value: vals.rain_today || 0 }); vals.rain_today = (vals.rain_today || 0) + 1; break; case 'rain': rainHist.push({ ts: now - 900000, value: vals.rain_today || 0 }); vals.rain_today = (vals.rain_today || 0) + 0.2; break; case 'snow': vals.outside_temp = -1; vals.wind_chill = -2; break; case 'fog': vals.dew_point = vals.outside_temp; vals.wind_speed = 1; break; case 'windy': vals.wind_speed = 32; vals.wind_gust = 45; break; case 'hot': vals.outside_temp = 30; break; case 'cold': vals.outside_temp = 0; vals.wind_chill = -1; break; } evaluate(); } function updatePanel() { if (!panel) return; var target = panel.querySelector('.hero-debug-values'); var info = win.__smeirdHeroState || {}; var lines = [ 'state: ' + (info.state || 'n/a'), 'cause: ' + (info.cause || 'n/a'), 'night: ' + (info.isNight ? 'yes' : 'no') ]; if (info.missing && info.missing.length) { lines.push('missing: ' + info.missing.join(', ')); } if (overrideState) { lines.push('override: ' + overrideState + ' (until ' + new Date(overrideUntil).toLocaleTimeString() + ')'); } Object.keys(vals).forEach(function (k) { lines.push(k + ': ' + vals[k]); }); target.innerHTML = '

' + lines.join('\n') + '

'; } })();

Barometric Pressure over time