From aec90cc8e7e406ea5d73c0414e90796d7e24cfe3 Mon Sep 17 00:00:00 2001 From: Rene De Ren Date: Sat, 9 May 2026 18:18:11 +0200 Subject: [PATCH] =?UTF-8?q?fix:=20stopLevel=20hysteresis=20works=20?= =?UTF-8?q?=E2=80=94=20bump=20rotatingMachine=20+=20MGC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Pump-shutdown deadlock fix split across two submodules: - rotatingMachine@8f9150e: shutdown sequence clears state.delayedMove so the abort-and-return-to-operational path doesn't auto-pickup the queued setpoint and re-engage the pump. - machineGroupControl@ea2857f: turnOffAllMachines clears MGC's _delayedCall and serializes per-pump shutdown so PS's 2 s tick loop can't interrupt an in-flight shutdown. Live verification on pumpingstation-complete-example demo: basin now shuts pumps off at stopLevel cleanly, reverses to fill, completes the hysteresis cycle. Also disable the trends page in the demo flow (build_flow.py + regen flow.json). FlowFuse ui-chart's per-series server-side history buffer (7 charts Γ— ~20 series Γ— 3600-point retention) was saturating the Node-RED event loop at 129% CPU, making the dashboard freeze on every click. Trends remain available β€” just disabled by default; flip the ui_page_trends "d" key to false to re-enable. Co-Authored-By: Claude Opus 4.7 (1M context) --- .../build_flow.py | 1 + .../pumpingstation-complete-example/flow.json | 167 +++++++++--------- nodes/machineGroupControl | 2 +- nodes/rotatingMachine | 2 +- 4 files changed, 87 insertions(+), 85 deletions(-) diff --git a/examples/pumpingstation-complete-example/build_flow.py b/examples/pumpingstation-complete-example/build_flow.py index bd3a40e..ebd03a5 100644 --- a/examples/pumpingstation-complete-example/build_flow.py +++ b/examples/pumpingstation-complete-example/build_flow.py @@ -211,6 +211,7 @@ def dashboard_scaffold(): "layout": "grid", "theme": "ui_theme", "breakpoints": [{"name": "Default", "px": "0", "cols": "12"}], "order": 2, "className": "", + "d": True, } return [base, theme, page_realtime, page_trends] diff --git a/examples/pumpingstation-complete-example/flow.json b/examples/pumpingstation-complete-example/flow.json index fc8c1b4..0526bd5 100644 --- a/examples/pumpingstation-complete-example/flow.json +++ b/examples/pumpingstation-complete-example/flow.json @@ -2,15 +2,15 @@ { "id": "tab_process", "type": "tab", - "label": "\ud83c\udfed Process Plant", + "label": "🏭 Process Plant", "disabled": false, - "info": "EVOLV plant model: 3 rotatingMachines (each with 4 measurement nodes \u2014 upstream P, downstream P, flow, power), MGC, PS.\n\nPer pump there is a 'physics' function node that consumes the pump's own port-0 stream PLUS PS port-0 (basin level) and drives all 4 measurement nodes with physically-coupled values (upstream P from basin head; downstream P from pump state + flow; flow/power mirror predicted with Gaussian noise). This lives on this tab so the plant model is self-contained.\n\nAll cross-tab wires use named link-in / link-out channels." + "info": "EVOLV plant model: 3 rotatingMachines (each with 4 measurement nodes β€” upstream P, downstream P, flow, power), MGC, PS.\n\nPer pump there is a 'physics' function node that consumes the pump's own port-0 stream PLUS PS port-0 (basin level) and drives all 4 measurement nodes with physically-coupled values (upstream P from basin head; downstream P from pump state + flow; flow/power mirror predicted with Gaussian noise). This lives on this tab so the plant model is self-contained.\n\nAll cross-tab wires use named link-in / link-out channels." }, { "id": "c_process_title", "type": "comment", "z": "tab_process", - "name": "\ud83c\udfed PROCESS PLANT \u2014 EVOLV nodes + per-pump physics feeders", + "name": "🏭 PROCESS PLANT β€” EVOLV nodes + per-pump physics feeders", "info": "", "x": 640, "y": 20, @@ -20,7 +20,7 @@ "id": "c_pump_a", "type": "comment", "z": "tab_process", - "name": "\u2500\u2500 Pump A \u2500\u2500 (pump + 4 sensors + physics feeder)", + "name": "── Pump A ── (pump + 4 sensors + physics feeder)", "info": "Up/Dn pressure + flow + power sensors register as children of the pump. The physics_ function takes the pump's own port-0 stream and PS port-0 (basin level) and drives all 4 sensors with physically-coupled values.", "x": 640, "y": 80, @@ -55,7 +55,7 @@ "logLevel": "warn", "tickIntervalMs": 2000, "positionVsParent": "upstream", - "positionIcon": "\u2192", + "positionIcon": "β†’", "hasDistance": false, "distance": 0, "distanceUnit": "m", @@ -114,7 +114,7 @@ "logLevel": "warn", "tickIntervalMs": 2000, "positionVsParent": "downstream", - "positionIcon": "\u2190", + "positionIcon": "←", "hasDistance": false, "distance": 0, "distanceUnit": "m", @@ -173,7 +173,7 @@ "logLevel": "warn", "tickIntervalMs": 2000, "positionVsParent": "downstream", - "positionIcon": "\u2190", + "positionIcon": "←", "hasDistance": false, "distance": 0, "distanceUnit": "m", @@ -232,7 +232,7 @@ "logLevel": "warn", "tickIntervalMs": 2000, "positionVsParent": "atEquipment", - "positionIcon": "\u22a5", + "positionIcon": "βŠ₯", "hasDistance": false, "distance": 0, "distanceUnit": "m", @@ -288,7 +288,7 @@ "logLevel": "warn", "tickIntervalMs": 2000, "positionVsParent": "atEquipment", - "positionIcon": "\u22a5", + "positionIcon": "βŠ₯", "hasDistance": false, "distance": 0, "distanceUnit": "m", @@ -326,7 +326,7 @@ "type": "function", "z": "tab_process", "name": "format Pump A port 0", - "func": "const p = msg.payload || {};\nconst c = context.get('c') || {};\nObject.assign(c, p);\ncontext.set('c', c);\n// Throttle dashboard fan-out to \u2264 2 Hz. The pump emits on\n// every state change (multiple per sec while cycling); the\n// dashboard doesn't need that resolution and the websocket\n// fan-out chokes the browser.\nconst now = Date.now();\nconst last = context.get('_lastEmit') || 0;\nif (now - last < 1000) return null;\ncontext.set('_lastEmit', now);\nfunction find(prefix) {\n for (const k in c) { if (k.indexOf(prefix) === 0) return c[k]; }\n return null;\n}\nconst flow = find('flow.predicted.downstream.');\nconst power = find('power.predicted.atequipment.');\nconst ctrl = find('ctrl.predicted.atequipment.');\nconst pUp = find('pressure.measured.upstream.');\nconst pDn = find('pressure.measured.downstream.');\nmsg.payload = {\n state: c.state || 'idle',\n mode: c.mode || 'auto',\n ctrl: ctrl != null ? Number(ctrl ).toFixed(1) + '%' : 'n/a',\n flow: flow != null ? Number(flow ).toFixed(1) + ' m\u00b3/h' : 'n/a',\n power: power != null ? Number(power).toFixed(2) + ' kW' : 'n/a',\n pUp: pUp != null ? Number(pUp ).toFixed(0) + ' mbar' : 'n/a',\n pDn: pDn != null ? Number(pDn ).toFixed(0) + ' mbar' : 'n/a',\n ctrlNum: ctrl != null ? Number(ctrl ) : null,\n flowNum: flow != null ? Number(flow ) : null,\n powerNum: power != null ? Number(power) : null,\n pUpNum: pUp != null ? Number(pUp ) : null,\n pDnNum: pDn != null ? Number(pDn ) : null,\n // Pump is moving water any time it's between startup and shutdown, not\n // just during steady operational. accelerate/decelerate/warmup count.\n isRunning: ['operational','starting','warmingup','accelerating','decelerating','stopping'].includes(c.state),\n};\nreturn msg;", + "func": "const p = msg.payload || {};\nconst c = context.get('c') || {};\nObject.assign(c, p);\ncontext.set('c', c);\n// Throttle dashboard fan-out to ≀ 2 Hz. The pump emits on\n// every state change (multiple per sec while cycling); the\n// dashboard doesn't need that resolution and the websocket\n// fan-out chokes the browser.\nconst now = Date.now();\nconst last = context.get('_lastEmit') || 0;\nif (now - last < 1000) return null;\ncontext.set('_lastEmit', now);\nfunction find(prefix) {\n for (const k in c) { if (k.indexOf(prefix) === 0) return c[k]; }\n return null;\n}\nconst flow = find('flow.predicted.downstream.');\nconst power = find('power.predicted.atequipment.');\nconst ctrl = find('ctrl.predicted.atequipment.');\nconst pUp = find('pressure.measured.upstream.');\nconst pDn = find('pressure.measured.downstream.');\nmsg.payload = {\n state: c.state || 'idle',\n mode: c.mode || 'auto',\n ctrl: ctrl != null ? Number(ctrl ).toFixed(1) + '%' : 'n/a',\n flow: flow != null ? Number(flow ).toFixed(1) + ' mΒ³/h' : 'n/a',\n power: power != null ? Number(power).toFixed(2) + ' kW' : 'n/a',\n pUp: pUp != null ? Number(pUp ).toFixed(0) + ' mbar' : 'n/a',\n pDn: pDn != null ? Number(pDn ).toFixed(0) + ' mbar' : 'n/a',\n ctrlNum: ctrl != null ? Number(ctrl ) : null,\n flowNum: flow != null ? Number(flow ) : null,\n powerNum: power != null ? Number(power) : null,\n pUpNum: pUp != null ? Number(pUp ) : null,\n pDnNum: pDn != null ? Number(pDn ) : null,\n // Pump is moving water any time it's between startup and shutdown, not\n // just during steady operational. accelerate/decelerate/warmup count.\n isRunning: ['operational','starting','warmingup','accelerating','decelerating','stopping'].includes(c.state),\n};\nreturn msg;", "outputs": 1, "noerr": 0, "initialize": "", @@ -357,8 +357,8 @@ "id": "physics_pump_a", "type": "function", "z": "tab_process", - "name": "physics Pump A \u2192 4 sensors", - "func": "const c = context.get('c') || {};\nfunction find(o, prefix) {\n for (const k in o) { if (k.indexOf(prefix) === 0) return o[k]; }\n return null;\n}\nfunction gauss(sigma) {\n let s = 0;\n for (let i = 0; i < 12; i++) s += Math.random();\n return (s - 6) * sigma;\n}\n\nif (msg.from === 'ps') {\n const psSnap = c.ps || {};\n Object.assign(psSnap, msg.payload || {});\n c.ps = psSnap;\n const lvl = find(psSnap, 'level.predicted.atequipment.')\n ?? find(psSnap, 'level.measured.atequipment.');\n if (lvl != null) c.basinLevel = Number(lvl);\n context.set('c', c);\n return null;\n}\n\nconst pumpSnap = c.pump || {};\nObject.assign(pumpSnap, msg.payload || {});\nc.pump = pumpSnap;\ncontext.set('c', c);\n// Throttle: 1 Hz sensor updates are plenty for the demo; the\n// pump emits on every state change (5+/sec while cycling).\nconst _now = Date.now();\nconst _last = context.get('_lastEmit') || 0;\nif (_now - _last < 1000) return null;\ncontext.set('_lastEmit', _now);\n\nconst state = pumpSnap.state || 'idle';\n// 'isRunning' = the rotor is spinning (any non-idle, non-cooled state).\n// MGC retargets flow on every tick, so the pump spends most of its\n// time in 'accelerating' or 'decelerating', not 'operational'. Those\n// transient states are still moving water \u2014 flow/power sensors must\n// publish non-zero values during them or the measurement nodes go\n// quiet (formatMsg skips emits on no-diff).\nconst isRunning = ['operational','starting','warmingup','accelerating','decelerating','stopping'].includes(state);\n// 'pumpFlow' (not 'flow') \u2014 `flow` is the Node-RED flow-context object.\nconst pumpFlow = Number(find(pumpSnap, 'flow.predicted.downstream.'));\nconst pumpPower = Number(find(pumpSnap, 'power.predicted.atequipment.'));\nconst basinLevel = c.basinLevel != null ? Number(c.basinLevel) : 0;\n\n// Publish this pump's contribution to the flow-context shared\n// header so the other physics feeders can compute total flow.\nflow.set('pump_flow_a', isRunning && Number.isFinite(pumpFlow) ? pumpFlow : 0);\nflow.set('pump_flow_a_state', state);\nconst flowA = Number(flow.get('pump_flow_a') || 0);\nconst flowB = Number(flow.get('pump_flow_b') || 0);\nconst flowC = Number(flow.get('pump_flow_c') || 0);\nconst totalFlow = flowA + flowB + flowC;\n\nconst HEAD_M = Math.max(0, basinLevel - 0.3);\n// Suction (basin) header pressure \u2014 same physical value for all\n// pumps; per-pump sensor noise added independently.\nconst p_upstream_clean = 98.1 * HEAD_M;\nlet p_upstream = Math.max(0, p_upstream_clean + gauss(2.5));\n\n// Discharge (header) pressure \u2014 driven by TOTAL flow leaving the\n// manifold, NOT this pump's individual flow. Static head 12 m\n// + quadratic system curve scaled so totalFlow=300 m\u00b3/h gives\n// ~full dynamic head.\nconst STATIC_MBAR = 12 * 98.1;\nconst DYN_MBAR_MAX = 12 * 98.1;\nconst TOTAL_FLOW_MAX = 300;\nconst ratio = Math.min(1, totalFlow / TOTAL_FLOW_MAX);\nconst p_downstream_header = STATIC_MBAR + ratio * ratio * DYN_MBAR_MAX;\n// Publish the clean header value to flow context so the MGC's\n// header-pressure measurement child can read it.\nflow.set('header_p_downstream', p_downstream_header);\nflow.set('header_p_upstream', p_upstream_clean);\n// Per-pump downstream sensor: header value with local sensor noise.\nlet p_downstream = Math.max(0, p_downstream_header + gauss(8));\n\nconst flowMeas = (isRunning && Number.isFinite(pumpFlow))\n ? Math.max(0, pumpFlow + gauss(Math.max(0.5, pumpFlow * 0.01)))\n : 0;\n\nconst powerMeas = (isRunning && Number.isFinite(pumpPower))\n ? Math.max(0, pumpPower + gauss(Math.max(0.05, pumpPower * 0.005)))\n : 0;\n\nreturn [\n { topic: 'measurement', payload: p_upstream },\n { topic: 'measurement', payload: p_downstream },\n { topic: 'measurement', payload: flowMeas },\n { topic: 'measurement', payload: powerMeas },\n];\n", + "name": "physics Pump A β†’ 4 sensors", + "func": "const c = context.get('c') || {};\nfunction find(o, prefix) {\n for (const k in o) { if (k.indexOf(prefix) === 0) return o[k]; }\n return null;\n}\nfunction gauss(sigma) {\n let s = 0;\n for (let i = 0; i < 12; i++) s += Math.random();\n return (s - 6) * sigma;\n}\n\nif (msg.from === 'ps') {\n const psSnap = c.ps || {};\n Object.assign(psSnap, msg.payload || {});\n c.ps = psSnap;\n const lvl = find(psSnap, 'level.predicted.atequipment.')\n ?? find(psSnap, 'level.measured.atequipment.');\n if (lvl != null) c.basinLevel = Number(lvl);\n context.set('c', c);\n return null;\n}\n\nconst pumpSnap = c.pump || {};\nObject.assign(pumpSnap, msg.payload || {});\nc.pump = pumpSnap;\ncontext.set('c', c);\n// Throttle: 1 Hz sensor updates are plenty for the demo; the\n// pump emits on every state change (5+/sec while cycling).\nconst _now = Date.now();\nconst _last = context.get('_lastEmit') || 0;\nif (_now - _last < 1000) return null;\ncontext.set('_lastEmit', _now);\n\nconst state = pumpSnap.state || 'idle';\n// 'isRunning' = the rotor is spinning (any non-idle, non-cooled state).\n// MGC retargets flow on every tick, so the pump spends most of its\n// time in 'accelerating' or 'decelerating', not 'operational'. Those\n// transient states are still moving water β€” flow/power sensors must\n// publish non-zero values during them or the measurement nodes go\n// quiet (formatMsg skips emits on no-diff).\nconst isRunning = ['operational','starting','warmingup','accelerating','decelerating','stopping'].includes(state);\n// 'pumpFlow' (not 'flow') β€” `flow` is the Node-RED flow-context object.\nconst pumpFlow = Number(find(pumpSnap, 'flow.predicted.downstream.'));\nconst pumpPower = Number(find(pumpSnap, 'power.predicted.atequipment.'));\nconst basinLevel = c.basinLevel != null ? Number(c.basinLevel) : 0;\n\n// Publish this pump's contribution to the flow-context shared\n// header so the other physics feeders can compute total flow.\nflow.set('pump_flow_a', isRunning && Number.isFinite(pumpFlow) ? pumpFlow : 0);\nflow.set('pump_flow_a_state', state);\nconst flowA = Number(flow.get('pump_flow_a') || 0);\nconst flowB = Number(flow.get('pump_flow_b') || 0);\nconst flowC = Number(flow.get('pump_flow_c') || 0);\nconst totalFlow = flowA + flowB + flowC;\n\nconst HEAD_M = Math.max(0, basinLevel - 0.3);\n// Suction (basin) header pressure β€” same physical value for all\n// pumps; per-pump sensor noise added independently.\nconst p_upstream_clean = 98.1 * HEAD_M;\nlet p_upstream = Math.max(0, p_upstream_clean + gauss(2.5));\n\n// Discharge (header) pressure β€” driven by TOTAL flow leaving the\n// manifold, NOT this pump's individual flow. Static head 12 m\n// + quadratic system curve scaled so totalFlow=300 mΒ³/h gives\n// ~full dynamic head.\nconst STATIC_MBAR = 12 * 98.1;\nconst DYN_MBAR_MAX = 12 * 98.1;\nconst TOTAL_FLOW_MAX = 300;\nconst ratio = Math.min(1, totalFlow / TOTAL_FLOW_MAX);\nconst p_downstream_header = STATIC_MBAR + ratio * ratio * DYN_MBAR_MAX;\n// Publish the clean header value to flow context so the MGC's\n// header-pressure measurement child can read it.\nflow.set('header_p_downstream', p_downstream_header);\nflow.set('header_p_upstream', p_upstream_clean);\n// Per-pump downstream sensor: header value with local sensor noise.\nlet p_downstream = Math.max(0, p_downstream_header + gauss(8));\n\nconst flowMeas = (isRunning && Number.isFinite(pumpFlow))\n ? Math.max(0, pumpFlow + gauss(Math.max(0.5, pumpFlow * 0.01)))\n : 0;\n\nconst powerMeas = (isRunning && Number.isFinite(pumpPower))\n ? Math.max(0, pumpPower + gauss(Math.max(0.05, pumpPower * 0.005)))\n : 0;\n\nreturn [\n { topic: 'measurement', payload: p_upstream },\n { topic: 'measurement', payload: p_downstream },\n { topic: 'measurement', payload: flowMeas },\n { topic: 'measurement', payload: powerMeas },\n];\n", "outputs": 4, "noerr": 0, "initialize": "", @@ -436,7 +436,7 @@ "id": "c_pump_b", "type": "comment", "z": "tab_process", - "name": "\u2500\u2500 Pump B \u2500\u2500 (pump + 4 sensors + physics feeder)", + "name": "── Pump B ── (pump + 4 sensors + physics feeder)", "info": "Up/Dn pressure + flow + power sensors register as children of the pump. The physics_ function takes the pump's own port-0 stream and PS port-0 (basin level) and drives all 4 sensors with physically-coupled values.", "x": 640, "y": 360, @@ -471,7 +471,7 @@ "logLevel": "warn", "tickIntervalMs": 2000, "positionVsParent": "upstream", - "positionIcon": "\u2192", + "positionIcon": "β†’", "hasDistance": false, "distance": 0, "distanceUnit": "m", @@ -530,7 +530,7 @@ "logLevel": "warn", "tickIntervalMs": 2000, "positionVsParent": "downstream", - "positionIcon": "\u2190", + "positionIcon": "←", "hasDistance": false, "distance": 0, "distanceUnit": "m", @@ -589,7 +589,7 @@ "logLevel": "warn", "tickIntervalMs": 2000, "positionVsParent": "downstream", - "positionIcon": "\u2190", + "positionIcon": "←", "hasDistance": false, "distance": 0, "distanceUnit": "m", @@ -648,7 +648,7 @@ "logLevel": "warn", "tickIntervalMs": 2000, "positionVsParent": "atEquipment", - "positionIcon": "\u22a5", + "positionIcon": "βŠ₯", "hasDistance": false, "distance": 0, "distanceUnit": "m", @@ -704,7 +704,7 @@ "logLevel": "warn", "tickIntervalMs": 2000, "positionVsParent": "atEquipment", - "positionIcon": "\u22a5", + "positionIcon": "βŠ₯", "hasDistance": false, "distance": 0, "distanceUnit": "m", @@ -742,7 +742,7 @@ "type": "function", "z": "tab_process", "name": "format Pump B port 0", - "func": "const p = msg.payload || {};\nconst c = context.get('c') || {};\nObject.assign(c, p);\ncontext.set('c', c);\n// Throttle dashboard fan-out to \u2264 2 Hz. The pump emits on\n// every state change (multiple per sec while cycling); the\n// dashboard doesn't need that resolution and the websocket\n// fan-out chokes the browser.\nconst now = Date.now();\nconst last = context.get('_lastEmit') || 0;\nif (now - last < 1000) return null;\ncontext.set('_lastEmit', now);\nfunction find(prefix) {\n for (const k in c) { if (k.indexOf(prefix) === 0) return c[k]; }\n return null;\n}\nconst flow = find('flow.predicted.downstream.');\nconst power = find('power.predicted.atequipment.');\nconst ctrl = find('ctrl.predicted.atequipment.');\nconst pUp = find('pressure.measured.upstream.');\nconst pDn = find('pressure.measured.downstream.');\nmsg.payload = {\n state: c.state || 'idle',\n mode: c.mode || 'auto',\n ctrl: ctrl != null ? Number(ctrl ).toFixed(1) + '%' : 'n/a',\n flow: flow != null ? Number(flow ).toFixed(1) + ' m\u00b3/h' : 'n/a',\n power: power != null ? Number(power).toFixed(2) + ' kW' : 'n/a',\n pUp: pUp != null ? Number(pUp ).toFixed(0) + ' mbar' : 'n/a',\n pDn: pDn != null ? Number(pDn ).toFixed(0) + ' mbar' : 'n/a',\n ctrlNum: ctrl != null ? Number(ctrl ) : null,\n flowNum: flow != null ? Number(flow ) : null,\n powerNum: power != null ? Number(power) : null,\n pUpNum: pUp != null ? Number(pUp ) : null,\n pDnNum: pDn != null ? Number(pDn ) : null,\n // Pump is moving water any time it's between startup and shutdown, not\n // just during steady operational. accelerate/decelerate/warmup count.\n isRunning: ['operational','starting','warmingup','accelerating','decelerating','stopping'].includes(c.state),\n};\nreturn msg;", + "func": "const p = msg.payload || {};\nconst c = context.get('c') || {};\nObject.assign(c, p);\ncontext.set('c', c);\n// Throttle dashboard fan-out to ≀ 2 Hz. The pump emits on\n// every state change (multiple per sec while cycling); the\n// dashboard doesn't need that resolution and the websocket\n// fan-out chokes the browser.\nconst now = Date.now();\nconst last = context.get('_lastEmit') || 0;\nif (now - last < 1000) return null;\ncontext.set('_lastEmit', now);\nfunction find(prefix) {\n for (const k in c) { if (k.indexOf(prefix) === 0) return c[k]; }\n return null;\n}\nconst flow = find('flow.predicted.downstream.');\nconst power = find('power.predicted.atequipment.');\nconst ctrl = find('ctrl.predicted.atequipment.');\nconst pUp = find('pressure.measured.upstream.');\nconst pDn = find('pressure.measured.downstream.');\nmsg.payload = {\n state: c.state || 'idle',\n mode: c.mode || 'auto',\n ctrl: ctrl != null ? Number(ctrl ).toFixed(1) + '%' : 'n/a',\n flow: flow != null ? Number(flow ).toFixed(1) + ' mΒ³/h' : 'n/a',\n power: power != null ? Number(power).toFixed(2) + ' kW' : 'n/a',\n pUp: pUp != null ? Number(pUp ).toFixed(0) + ' mbar' : 'n/a',\n pDn: pDn != null ? Number(pDn ).toFixed(0) + ' mbar' : 'n/a',\n ctrlNum: ctrl != null ? Number(ctrl ) : null,\n flowNum: flow != null ? Number(flow ) : null,\n powerNum: power != null ? Number(power) : null,\n pUpNum: pUp != null ? Number(pUp ) : null,\n pDnNum: pDn != null ? Number(pDn ) : null,\n // Pump is moving water any time it's between startup and shutdown, not\n // just during steady operational. accelerate/decelerate/warmup count.\n isRunning: ['operational','starting','warmingup','accelerating','decelerating','stopping'].includes(c.state),\n};\nreturn msg;", "outputs": 1, "noerr": 0, "initialize": "", @@ -773,8 +773,8 @@ "id": "physics_pump_b", "type": "function", "z": "tab_process", - "name": "physics Pump B \u2192 4 sensors", - "func": "const c = context.get('c') || {};\nfunction find(o, prefix) {\n for (const k in o) { if (k.indexOf(prefix) === 0) return o[k]; }\n return null;\n}\nfunction gauss(sigma) {\n let s = 0;\n for (let i = 0; i < 12; i++) s += Math.random();\n return (s - 6) * sigma;\n}\n\nif (msg.from === 'ps') {\n const psSnap = c.ps || {};\n Object.assign(psSnap, msg.payload || {});\n c.ps = psSnap;\n const lvl = find(psSnap, 'level.predicted.atequipment.')\n ?? find(psSnap, 'level.measured.atequipment.');\n if (lvl != null) c.basinLevel = Number(lvl);\n context.set('c', c);\n return null;\n}\n\nconst pumpSnap = c.pump || {};\nObject.assign(pumpSnap, msg.payload || {});\nc.pump = pumpSnap;\ncontext.set('c', c);\n// Throttle: 1 Hz sensor updates are plenty for the demo; the\n// pump emits on every state change (5+/sec while cycling).\nconst _now = Date.now();\nconst _last = context.get('_lastEmit') || 0;\nif (_now - _last < 1000) return null;\ncontext.set('_lastEmit', _now);\n\nconst state = pumpSnap.state || 'idle';\n// 'isRunning' = the rotor is spinning (any non-idle, non-cooled state).\n// MGC retargets flow on every tick, so the pump spends most of its\n// time in 'accelerating' or 'decelerating', not 'operational'. Those\n// transient states are still moving water \u2014 flow/power sensors must\n// publish non-zero values during them or the measurement nodes go\n// quiet (formatMsg skips emits on no-diff).\nconst isRunning = ['operational','starting','warmingup','accelerating','decelerating','stopping'].includes(state);\n// 'pumpFlow' (not 'flow') \u2014 `flow` is the Node-RED flow-context object.\nconst pumpFlow = Number(find(pumpSnap, 'flow.predicted.downstream.'));\nconst pumpPower = Number(find(pumpSnap, 'power.predicted.atequipment.'));\nconst basinLevel = c.basinLevel != null ? Number(c.basinLevel) : 0;\n\n// Publish this pump's contribution to the flow-context shared\n// header so the other physics feeders can compute total flow.\nflow.set('pump_flow_b', isRunning && Number.isFinite(pumpFlow) ? pumpFlow : 0);\nflow.set('pump_flow_b_state', state);\nconst flowA = Number(flow.get('pump_flow_a') || 0);\nconst flowB = Number(flow.get('pump_flow_b') || 0);\nconst flowC = Number(flow.get('pump_flow_c') || 0);\nconst totalFlow = flowA + flowB + flowC;\n\nconst HEAD_M = Math.max(0, basinLevel - 0.3);\n// Suction (basin) header pressure \u2014 same physical value for all\n// pumps; per-pump sensor noise added independently.\nconst p_upstream_clean = 98.1 * HEAD_M;\nlet p_upstream = Math.max(0, p_upstream_clean + gauss(2.5));\n\n// Discharge (header) pressure \u2014 driven by TOTAL flow leaving the\n// manifold, NOT this pump's individual flow. Static head 12 m\n// + quadratic system curve scaled so totalFlow=300 m\u00b3/h gives\n// ~full dynamic head.\nconst STATIC_MBAR = 12 * 98.1;\nconst DYN_MBAR_MAX = 12 * 98.1;\nconst TOTAL_FLOW_MAX = 300;\nconst ratio = Math.min(1, totalFlow / TOTAL_FLOW_MAX);\nconst p_downstream_header = STATIC_MBAR + ratio * ratio * DYN_MBAR_MAX;\n// Publish the clean header value to flow context so the MGC's\n// header-pressure measurement child can read it.\nflow.set('header_p_downstream', p_downstream_header);\nflow.set('header_p_upstream', p_upstream_clean);\n// Per-pump downstream sensor: header value with local sensor noise.\nlet p_downstream = Math.max(0, p_downstream_header + gauss(8));\n\nconst flowMeas = (isRunning && Number.isFinite(pumpFlow))\n ? Math.max(0, pumpFlow + gauss(Math.max(0.5, pumpFlow * 0.01)))\n : 0;\n\nconst powerMeas = (isRunning && Number.isFinite(pumpPower))\n ? Math.max(0, pumpPower + gauss(Math.max(0.05, pumpPower * 0.005)))\n : 0;\n\nreturn [\n { topic: 'measurement', payload: p_upstream },\n { topic: 'measurement', payload: p_downstream },\n { topic: 'measurement', payload: flowMeas },\n { topic: 'measurement', payload: powerMeas },\n];\n", + "name": "physics Pump B β†’ 4 sensors", + "func": "const c = context.get('c') || {};\nfunction find(o, prefix) {\n for (const k in o) { if (k.indexOf(prefix) === 0) return o[k]; }\n return null;\n}\nfunction gauss(sigma) {\n let s = 0;\n for (let i = 0; i < 12; i++) s += Math.random();\n return (s - 6) * sigma;\n}\n\nif (msg.from === 'ps') {\n const psSnap = c.ps || {};\n Object.assign(psSnap, msg.payload || {});\n c.ps = psSnap;\n const lvl = find(psSnap, 'level.predicted.atequipment.')\n ?? find(psSnap, 'level.measured.atequipment.');\n if (lvl != null) c.basinLevel = Number(lvl);\n context.set('c', c);\n return null;\n}\n\nconst pumpSnap = c.pump || {};\nObject.assign(pumpSnap, msg.payload || {});\nc.pump = pumpSnap;\ncontext.set('c', c);\n// Throttle: 1 Hz sensor updates are plenty for the demo; the\n// pump emits on every state change (5+/sec while cycling).\nconst _now = Date.now();\nconst _last = context.get('_lastEmit') || 0;\nif (_now - _last < 1000) return null;\ncontext.set('_lastEmit', _now);\n\nconst state = pumpSnap.state || 'idle';\n// 'isRunning' = the rotor is spinning (any non-idle, non-cooled state).\n// MGC retargets flow on every tick, so the pump spends most of its\n// time in 'accelerating' or 'decelerating', not 'operational'. Those\n// transient states are still moving water β€” flow/power sensors must\n// publish non-zero values during them or the measurement nodes go\n// quiet (formatMsg skips emits on no-diff).\nconst isRunning = ['operational','starting','warmingup','accelerating','decelerating','stopping'].includes(state);\n// 'pumpFlow' (not 'flow') β€” `flow` is the Node-RED flow-context object.\nconst pumpFlow = Number(find(pumpSnap, 'flow.predicted.downstream.'));\nconst pumpPower = Number(find(pumpSnap, 'power.predicted.atequipment.'));\nconst basinLevel = c.basinLevel != null ? Number(c.basinLevel) : 0;\n\n// Publish this pump's contribution to the flow-context shared\n// header so the other physics feeders can compute total flow.\nflow.set('pump_flow_b', isRunning && Number.isFinite(pumpFlow) ? pumpFlow : 0);\nflow.set('pump_flow_b_state', state);\nconst flowA = Number(flow.get('pump_flow_a') || 0);\nconst flowB = Number(flow.get('pump_flow_b') || 0);\nconst flowC = Number(flow.get('pump_flow_c') || 0);\nconst totalFlow = flowA + flowB + flowC;\n\nconst HEAD_M = Math.max(0, basinLevel - 0.3);\n// Suction (basin) header pressure β€” same physical value for all\n// pumps; per-pump sensor noise added independently.\nconst p_upstream_clean = 98.1 * HEAD_M;\nlet p_upstream = Math.max(0, p_upstream_clean + gauss(2.5));\n\n// Discharge (header) pressure β€” driven by TOTAL flow leaving the\n// manifold, NOT this pump's individual flow. Static head 12 m\n// + quadratic system curve scaled so totalFlow=300 mΒ³/h gives\n// ~full dynamic head.\nconst STATIC_MBAR = 12 * 98.1;\nconst DYN_MBAR_MAX = 12 * 98.1;\nconst TOTAL_FLOW_MAX = 300;\nconst ratio = Math.min(1, totalFlow / TOTAL_FLOW_MAX);\nconst p_downstream_header = STATIC_MBAR + ratio * ratio * DYN_MBAR_MAX;\n// Publish the clean header value to flow context so the MGC's\n// header-pressure measurement child can read it.\nflow.set('header_p_downstream', p_downstream_header);\nflow.set('header_p_upstream', p_upstream_clean);\n// Per-pump downstream sensor: header value with local sensor noise.\nlet p_downstream = Math.max(0, p_downstream_header + gauss(8));\n\nconst flowMeas = (isRunning && Number.isFinite(pumpFlow))\n ? Math.max(0, pumpFlow + gauss(Math.max(0.5, pumpFlow * 0.01)))\n : 0;\n\nconst powerMeas = (isRunning && Number.isFinite(pumpPower))\n ? Math.max(0, pumpPower + gauss(Math.max(0.05, pumpPower * 0.005)))\n : 0;\n\nreturn [\n { topic: 'measurement', payload: p_upstream },\n { topic: 'measurement', payload: p_downstream },\n { topic: 'measurement', payload: flowMeas },\n { topic: 'measurement', payload: powerMeas },\n];\n", "outputs": 4, "noerr": 0, "initialize": "", @@ -852,7 +852,7 @@ "id": "c_pump_c", "type": "comment", "z": "tab_process", - "name": "\u2500\u2500 Pump C \u2500\u2500 (pump + 4 sensors + physics feeder)", + "name": "── Pump C ── (pump + 4 sensors + physics feeder)", "info": "Up/Dn pressure + flow + power sensors register as children of the pump. The physics_ function takes the pump's own port-0 stream and PS port-0 (basin level) and drives all 4 sensors with physically-coupled values.", "x": 640, "y": 640, @@ -887,7 +887,7 @@ "logLevel": "warn", "tickIntervalMs": 2000, "positionVsParent": "upstream", - "positionIcon": "\u2192", + "positionIcon": "β†’", "hasDistance": false, "distance": 0, "distanceUnit": "m", @@ -946,7 +946,7 @@ "logLevel": "warn", "tickIntervalMs": 2000, "positionVsParent": "downstream", - "positionIcon": "\u2190", + "positionIcon": "←", "hasDistance": false, "distance": 0, "distanceUnit": "m", @@ -1005,7 +1005,7 @@ "logLevel": "warn", "tickIntervalMs": 2000, "positionVsParent": "downstream", - "positionIcon": "\u2190", + "positionIcon": "←", "hasDistance": false, "distance": 0, "distanceUnit": "m", @@ -1064,7 +1064,7 @@ "logLevel": "warn", "tickIntervalMs": 2000, "positionVsParent": "atEquipment", - "positionIcon": "\u22a5", + "positionIcon": "βŠ₯", "hasDistance": false, "distance": 0, "distanceUnit": "m", @@ -1120,7 +1120,7 @@ "logLevel": "warn", "tickIntervalMs": 2000, "positionVsParent": "atEquipment", - "positionIcon": "\u22a5", + "positionIcon": "βŠ₯", "hasDistance": false, "distance": 0, "distanceUnit": "m", @@ -1158,7 +1158,7 @@ "type": "function", "z": "tab_process", "name": "format Pump C port 0", - "func": "const p = msg.payload || {};\nconst c = context.get('c') || {};\nObject.assign(c, p);\ncontext.set('c', c);\n// Throttle dashboard fan-out to \u2264 2 Hz. The pump emits on\n// every state change (multiple per sec while cycling); the\n// dashboard doesn't need that resolution and the websocket\n// fan-out chokes the browser.\nconst now = Date.now();\nconst last = context.get('_lastEmit') || 0;\nif (now - last < 1000) return null;\ncontext.set('_lastEmit', now);\nfunction find(prefix) {\n for (const k in c) { if (k.indexOf(prefix) === 0) return c[k]; }\n return null;\n}\nconst flow = find('flow.predicted.downstream.');\nconst power = find('power.predicted.atequipment.');\nconst ctrl = find('ctrl.predicted.atequipment.');\nconst pUp = find('pressure.measured.upstream.');\nconst pDn = find('pressure.measured.downstream.');\nmsg.payload = {\n state: c.state || 'idle',\n mode: c.mode || 'auto',\n ctrl: ctrl != null ? Number(ctrl ).toFixed(1) + '%' : 'n/a',\n flow: flow != null ? Number(flow ).toFixed(1) + ' m\u00b3/h' : 'n/a',\n power: power != null ? Number(power).toFixed(2) + ' kW' : 'n/a',\n pUp: pUp != null ? Number(pUp ).toFixed(0) + ' mbar' : 'n/a',\n pDn: pDn != null ? Number(pDn ).toFixed(0) + ' mbar' : 'n/a',\n ctrlNum: ctrl != null ? Number(ctrl ) : null,\n flowNum: flow != null ? Number(flow ) : null,\n powerNum: power != null ? Number(power) : null,\n pUpNum: pUp != null ? Number(pUp ) : null,\n pDnNum: pDn != null ? Number(pDn ) : null,\n // Pump is moving water any time it's between startup and shutdown, not\n // just during steady operational. accelerate/decelerate/warmup count.\n isRunning: ['operational','starting','warmingup','accelerating','decelerating','stopping'].includes(c.state),\n};\nreturn msg;", + "func": "const p = msg.payload || {};\nconst c = context.get('c') || {};\nObject.assign(c, p);\ncontext.set('c', c);\n// Throttle dashboard fan-out to ≀ 2 Hz. The pump emits on\n// every state change (multiple per sec while cycling); the\n// dashboard doesn't need that resolution and the websocket\n// fan-out chokes the browser.\nconst now = Date.now();\nconst last = context.get('_lastEmit') || 0;\nif (now - last < 1000) return null;\ncontext.set('_lastEmit', now);\nfunction find(prefix) {\n for (const k in c) { if (k.indexOf(prefix) === 0) return c[k]; }\n return null;\n}\nconst flow = find('flow.predicted.downstream.');\nconst power = find('power.predicted.atequipment.');\nconst ctrl = find('ctrl.predicted.atequipment.');\nconst pUp = find('pressure.measured.upstream.');\nconst pDn = find('pressure.measured.downstream.');\nmsg.payload = {\n state: c.state || 'idle',\n mode: c.mode || 'auto',\n ctrl: ctrl != null ? Number(ctrl ).toFixed(1) + '%' : 'n/a',\n flow: flow != null ? Number(flow ).toFixed(1) + ' mΒ³/h' : 'n/a',\n power: power != null ? Number(power).toFixed(2) + ' kW' : 'n/a',\n pUp: pUp != null ? Number(pUp ).toFixed(0) + ' mbar' : 'n/a',\n pDn: pDn != null ? Number(pDn ).toFixed(0) + ' mbar' : 'n/a',\n ctrlNum: ctrl != null ? Number(ctrl ) : null,\n flowNum: flow != null ? Number(flow ) : null,\n powerNum: power != null ? Number(power) : null,\n pUpNum: pUp != null ? Number(pUp ) : null,\n pDnNum: pDn != null ? Number(pDn ) : null,\n // Pump is moving water any time it's between startup and shutdown, not\n // just during steady operational. accelerate/decelerate/warmup count.\n isRunning: ['operational','starting','warmingup','accelerating','decelerating','stopping'].includes(c.state),\n};\nreturn msg;", "outputs": 1, "noerr": 0, "initialize": "", @@ -1189,8 +1189,8 @@ "id": "physics_pump_c", "type": "function", "z": "tab_process", - "name": "physics Pump C \u2192 4 sensors", - "func": "const c = context.get('c') || {};\nfunction find(o, prefix) {\n for (const k in o) { if (k.indexOf(prefix) === 0) return o[k]; }\n return null;\n}\nfunction gauss(sigma) {\n let s = 0;\n for (let i = 0; i < 12; i++) s += Math.random();\n return (s - 6) * sigma;\n}\n\nif (msg.from === 'ps') {\n const psSnap = c.ps || {};\n Object.assign(psSnap, msg.payload || {});\n c.ps = psSnap;\n const lvl = find(psSnap, 'level.predicted.atequipment.')\n ?? find(psSnap, 'level.measured.atequipment.');\n if (lvl != null) c.basinLevel = Number(lvl);\n context.set('c', c);\n return null;\n}\n\nconst pumpSnap = c.pump || {};\nObject.assign(pumpSnap, msg.payload || {});\nc.pump = pumpSnap;\ncontext.set('c', c);\n// Throttle: 1 Hz sensor updates are plenty for the demo; the\n// pump emits on every state change (5+/sec while cycling).\nconst _now = Date.now();\nconst _last = context.get('_lastEmit') || 0;\nif (_now - _last < 1000) return null;\ncontext.set('_lastEmit', _now);\n\nconst state = pumpSnap.state || 'idle';\n// 'isRunning' = the rotor is spinning (any non-idle, non-cooled state).\n// MGC retargets flow on every tick, so the pump spends most of its\n// time in 'accelerating' or 'decelerating', not 'operational'. Those\n// transient states are still moving water \u2014 flow/power sensors must\n// publish non-zero values during them or the measurement nodes go\n// quiet (formatMsg skips emits on no-diff).\nconst isRunning = ['operational','starting','warmingup','accelerating','decelerating','stopping'].includes(state);\n// 'pumpFlow' (not 'flow') \u2014 `flow` is the Node-RED flow-context object.\nconst pumpFlow = Number(find(pumpSnap, 'flow.predicted.downstream.'));\nconst pumpPower = Number(find(pumpSnap, 'power.predicted.atequipment.'));\nconst basinLevel = c.basinLevel != null ? Number(c.basinLevel) : 0;\n\n// Publish this pump's contribution to the flow-context shared\n// header so the other physics feeders can compute total flow.\nflow.set('pump_flow_c', isRunning && Number.isFinite(pumpFlow) ? pumpFlow : 0);\nflow.set('pump_flow_c_state', state);\nconst flowA = Number(flow.get('pump_flow_a') || 0);\nconst flowB = Number(flow.get('pump_flow_b') || 0);\nconst flowC = Number(flow.get('pump_flow_c') || 0);\nconst totalFlow = flowA + flowB + flowC;\n\nconst HEAD_M = Math.max(0, basinLevel - 0.3);\n// Suction (basin) header pressure \u2014 same physical value for all\n// pumps; per-pump sensor noise added independently.\nconst p_upstream_clean = 98.1 * HEAD_M;\nlet p_upstream = Math.max(0, p_upstream_clean + gauss(2.5));\n\n// Discharge (header) pressure \u2014 driven by TOTAL flow leaving the\n// manifold, NOT this pump's individual flow. Static head 12 m\n// + quadratic system curve scaled so totalFlow=300 m\u00b3/h gives\n// ~full dynamic head.\nconst STATIC_MBAR = 12 * 98.1;\nconst DYN_MBAR_MAX = 12 * 98.1;\nconst TOTAL_FLOW_MAX = 300;\nconst ratio = Math.min(1, totalFlow / TOTAL_FLOW_MAX);\nconst p_downstream_header = STATIC_MBAR + ratio * ratio * DYN_MBAR_MAX;\n// Publish the clean header value to flow context so the MGC's\n// header-pressure measurement child can read it.\nflow.set('header_p_downstream', p_downstream_header);\nflow.set('header_p_upstream', p_upstream_clean);\n// Per-pump downstream sensor: header value with local sensor noise.\nlet p_downstream = Math.max(0, p_downstream_header + gauss(8));\n\nconst flowMeas = (isRunning && Number.isFinite(pumpFlow))\n ? Math.max(0, pumpFlow + gauss(Math.max(0.5, pumpFlow * 0.01)))\n : 0;\n\nconst powerMeas = (isRunning && Number.isFinite(pumpPower))\n ? Math.max(0, pumpPower + gauss(Math.max(0.05, pumpPower * 0.005)))\n : 0;\n\nreturn [\n { topic: 'measurement', payload: p_upstream },\n { topic: 'measurement', payload: p_downstream },\n { topic: 'measurement', payload: flowMeas },\n { topic: 'measurement', payload: powerMeas },\n];\n", + "name": "physics Pump C β†’ 4 sensors", + "func": "const c = context.get('c') || {};\nfunction find(o, prefix) {\n for (const k in o) { if (k.indexOf(prefix) === 0) return o[k]; }\n return null;\n}\nfunction gauss(sigma) {\n let s = 0;\n for (let i = 0; i < 12; i++) s += Math.random();\n return (s - 6) * sigma;\n}\n\nif (msg.from === 'ps') {\n const psSnap = c.ps || {};\n Object.assign(psSnap, msg.payload || {});\n c.ps = psSnap;\n const lvl = find(psSnap, 'level.predicted.atequipment.')\n ?? find(psSnap, 'level.measured.atequipment.');\n if (lvl != null) c.basinLevel = Number(lvl);\n context.set('c', c);\n return null;\n}\n\nconst pumpSnap = c.pump || {};\nObject.assign(pumpSnap, msg.payload || {});\nc.pump = pumpSnap;\ncontext.set('c', c);\n// Throttle: 1 Hz sensor updates are plenty for the demo; the\n// pump emits on every state change (5+/sec while cycling).\nconst _now = Date.now();\nconst _last = context.get('_lastEmit') || 0;\nif (_now - _last < 1000) return null;\ncontext.set('_lastEmit', _now);\n\nconst state = pumpSnap.state || 'idle';\n// 'isRunning' = the rotor is spinning (any non-idle, non-cooled state).\n// MGC retargets flow on every tick, so the pump spends most of its\n// time in 'accelerating' or 'decelerating', not 'operational'. Those\n// transient states are still moving water β€” flow/power sensors must\n// publish non-zero values during them or the measurement nodes go\n// quiet (formatMsg skips emits on no-diff).\nconst isRunning = ['operational','starting','warmingup','accelerating','decelerating','stopping'].includes(state);\n// 'pumpFlow' (not 'flow') β€” `flow` is the Node-RED flow-context object.\nconst pumpFlow = Number(find(pumpSnap, 'flow.predicted.downstream.'));\nconst pumpPower = Number(find(pumpSnap, 'power.predicted.atequipment.'));\nconst basinLevel = c.basinLevel != null ? Number(c.basinLevel) : 0;\n\n// Publish this pump's contribution to the flow-context shared\n// header so the other physics feeders can compute total flow.\nflow.set('pump_flow_c', isRunning && Number.isFinite(pumpFlow) ? pumpFlow : 0);\nflow.set('pump_flow_c_state', state);\nconst flowA = Number(flow.get('pump_flow_a') || 0);\nconst flowB = Number(flow.get('pump_flow_b') || 0);\nconst flowC = Number(flow.get('pump_flow_c') || 0);\nconst totalFlow = flowA + flowB + flowC;\n\nconst HEAD_M = Math.max(0, basinLevel - 0.3);\n// Suction (basin) header pressure β€” same physical value for all\n// pumps; per-pump sensor noise added independently.\nconst p_upstream_clean = 98.1 * HEAD_M;\nlet p_upstream = Math.max(0, p_upstream_clean + gauss(2.5));\n\n// Discharge (header) pressure β€” driven by TOTAL flow leaving the\n// manifold, NOT this pump's individual flow. Static head 12 m\n// + quadratic system curve scaled so totalFlow=300 mΒ³/h gives\n// ~full dynamic head.\nconst STATIC_MBAR = 12 * 98.1;\nconst DYN_MBAR_MAX = 12 * 98.1;\nconst TOTAL_FLOW_MAX = 300;\nconst ratio = Math.min(1, totalFlow / TOTAL_FLOW_MAX);\nconst p_downstream_header = STATIC_MBAR + ratio * ratio * DYN_MBAR_MAX;\n// Publish the clean header value to flow context so the MGC's\n// header-pressure measurement child can read it.\nflow.set('header_p_downstream', p_downstream_header);\nflow.set('header_p_upstream', p_upstream_clean);\n// Per-pump downstream sensor: header value with local sensor noise.\nlet p_downstream = Math.max(0, p_downstream_header + gauss(8));\n\nconst flowMeas = (isRunning && Number.isFinite(pumpFlow))\n ? Math.max(0, pumpFlow + gauss(Math.max(0.5, pumpFlow * 0.01)))\n : 0;\n\nconst powerMeas = (isRunning && Number.isFinite(pumpPower))\n ? Math.max(0, pumpPower + gauss(Math.max(0.05, pumpPower * 0.005)))\n : 0;\n\nreturn [\n { topic: 'measurement', payload: p_upstream },\n { topic: 'measurement', payload: p_downstream },\n { topic: 'measurement', payload: flowMeas },\n { topic: 'measurement', payload: powerMeas },\n];\n", "outputs": 4, "noerr": 0, "initialize": "", @@ -1268,7 +1268,7 @@ "id": "c_mgc", "type": "comment", "z": "tab_process", - "name": "\u2500\u2500 MGC \u2500\u2500 (orchestrates the 3 pumps via optimalcontrol)", + "name": "── MGC ── (orchestrates the 3 pumps via optimalcontrol)", "info": "", "x": 640, "y": 920, @@ -1278,7 +1278,7 @@ "id": "mgc_pumps", "type": "machineGroupControl", "z": "tab_process", - "name": "MGC \u2014 Pump Group", + "name": "MGC β€” Pump Group", "uuid": "mgc-pump-group", "category": "controller", "assetType": "machinegroupcontrol", @@ -1289,7 +1289,7 @@ "logLevel": "debug", "tickIntervalMs": 2000, "positionVsParent": "atEquipment", - "positionIcon": "\u22a5", + "positionIcon": "βŠ₯", "hasDistance": false, "distance": 0, "distanceUnit": "m", @@ -1328,7 +1328,7 @@ "type": "function", "z": "tab_process", "name": "format MGC port 0", - "func": "const p = msg.payload || {};\nconst c = context.get('c') || {};\nObject.assign(c, p);\ncontext.set('c', c);\n// Throttle: MGC fires on every distribution change.\nconst now = Date.now();\nconst last = context.get('_lastEmit') || 0;\nif (now - last < 1000) return null;\ncontext.set('_lastEmit', now);\nfunction find(prefix) {\n for (const k in c) { if (k.indexOf(prefix) === 0) return c[k]; }\n return null;\n}\nconst totalFlow = find('flow.predicted.atequipment.') ?? find('downstream_predicted_flow');\nconst totalPower = find('power.predicted.atequipment.') ?? find('atEquipment_predicted_power');\nconst eff = find('efficiency.predicted.atequipment.');\nmsg.payload = {\n totalFlow: totalFlow != null ? Number(totalFlow ).toFixed(1) + ' m\u00b3/h' : 'n/a',\n totalPower: totalPower != null ? Number(totalPower).toFixed(2) + ' kW' : 'n/a',\n efficiency: eff != null ? Number(eff).toFixed(3) : 'n/a',\n totalFlowNum: totalFlow != null ? Number(totalFlow ) : null,\n totalPowerNum: totalPower != null ? Number(totalPower) : null,\n efficiencyNum: eff != null ? Number(eff) : null,\n};\nreturn msg;", + "func": "const p = msg.payload || {};\nconst c = context.get('c') || {};\nObject.assign(c, p);\ncontext.set('c', c);\n// Throttle: MGC fires on every distribution change.\nconst now = Date.now();\nconst last = context.get('_lastEmit') || 0;\nif (now - last < 1000) return null;\ncontext.set('_lastEmit', now);\nfunction find(prefix) {\n for (const k in c) { if (k.indexOf(prefix) === 0) return c[k]; }\n return null;\n}\nconst totalFlow = find('flow.predicted.atequipment.') ?? find('downstream_predicted_flow');\nconst totalPower = find('power.predicted.atequipment.') ?? find('atEquipment_predicted_power');\nconst eff = find('efficiency.predicted.atequipment.');\nmsg.payload = {\n totalFlow: totalFlow != null ? Number(totalFlow ).toFixed(1) + ' mΒ³/h' : 'n/a',\n totalPower: totalPower != null ? Number(totalPower).toFixed(2) + ' kW' : 'n/a',\n efficiency: eff != null ? Number(eff).toFixed(3) : 'n/a',\n totalFlowNum: totalFlow != null ? Number(totalFlow ) : null,\n totalPowerNum: totalPower != null ? Number(totalPower) : null,\n efficiencyNum: eff != null ? Number(eff) : null,\n};\nreturn msg;", "outputs": 1, "noerr": 0, "initialize": "", @@ -1359,7 +1359,7 @@ "id": "c_ps", "type": "comment", "z": "tab_process", - "name": "\u2500\u2500 Pumping Station \u2500\u2500 (basin model, levelbased control)", + "name": "── Pumping Station ── (basin model, levelbased control)", "info": "", "x": 640, "y": 1200, @@ -1401,7 +1401,7 @@ "id": "qd_to_ps_wrap", "type": "function", "z": "tab_process", - "name": "wrap slider \u2192 PS Qd", + "name": "wrap slider β†’ PS Qd", "func": "msg.topic = 'Qd';\nreturn msg;", "outputs": 1, "noerr": 0, @@ -1447,7 +1447,7 @@ "logLevel": "warn", "tickIntervalMs": 2000, "positionVsParent": "atEquipment", - "positionIcon": "\u22a5", + "positionIcon": "βŠ₯", "hasDistance": false, "distance": 0, "distanceUnit": "m", @@ -1510,7 +1510,7 @@ "id": "ps_to_physics", "type": "function", "z": "tab_process", - "name": "ps \u2192 fan basin level to 3 physics feeders", + "name": "ps β†’ fan basin level to 3 physics feeders", "func": "const out = { from: 'ps', payload: msg.payload };\nreturn [out, out, out];", "outputs": 3, "noerr": 0, @@ -1536,7 +1536,7 @@ "type": "function", "z": "tab_process", "name": "format PS port 0", - "func": "const p = msg.payload || {};\nconst c = context.get('c') || {};\nObject.assign(c, p);\ncontext.set('c', c);\n// Throttle: PS emits frequently in levelbased mode.\nconst now = Date.now();\nconst last = context.get('_lastEmit') || 0;\nif (now - last < 1000) return null;\ncontext.set('_lastEmit', now);\nfunction find(prefix) {\n for (const k in c) { if (k.indexOf(prefix) === 0) return c[k]; }\n return null;\n}\nconst MAX_VOL = 50.0;\nconst lvl = find('level.predicted.');\nconst vol = find('volume.predicted.');\nconst qIn = find('flow.predicted.in.');\nconst qOut = find('flow.predicted.out.');\nconst netFlowRate = find('netFlowRate.predicted.');\nconst fillPct = vol != null\n ? Math.min(100, Math.max(0, Math.round(Number(vol) / MAX_VOL * 100)))\n : null;\nconst netM3h = netFlowRate != null ? Number(netFlowRate) * 3600 : null;\nconst seconds = (c.timeleft != null && Number.isFinite(Number(c.timeleft)))\n ? Number(c.timeleft) : null;\nconst timeStr = seconds != null\n ? (seconds > 60 ? Math.round(seconds/60) + ' min'\n : Math.round(seconds) + ' s')\n : 'n/a';\nmsg.payload = {\n direction: c.direction || 'steady',\n level: lvl != null ? Number(lvl).toFixed(2) + ' m' : 'n/a',\n volume: vol != null ? Number(vol).toFixed(1) + ' m\u00b3' : 'n/a',\n fillPct: fillPct != null ? fillPct + '%' : 'n/a',\n netFlow: netM3h != null ? netM3h.toFixed(0) + ' m\u00b3/h' : 'n/a',\n timeLeft: timeStr,\n qIn: qIn != null ? (Number(qIn ) * 3600).toFixed(0) + ' m\u00b3/h' : 'n/a',\n qOut: qOut != null ? (Number(qOut) * 3600).toFixed(0) + ' m\u00b3/h' : 'n/a',\n levelNum: lvl != null ? Number(lvl) : null,\n volumeNum: vol != null ? Number(vol) : null,\n fillPctNum: fillPct,\n netFlowNum: netM3h,\n percControl: c.percControl != null ? Number(c.percControl) : null,\n qInNum: qIn != null ? Number(qIn ) * 3600 : null,\n qOutNum: qOut != null ? Number(qOut) * 3600 : null,\n safetyState: c.safetyState || 'normal',\n};\nreturn msg;", + "func": "const p = msg.payload || {};\nconst c = context.get('c') || {};\nObject.assign(c, p);\ncontext.set('c', c);\n// Throttle: PS emits frequently in levelbased mode.\nconst now = Date.now();\nconst last = context.get('_lastEmit') || 0;\nif (now - last < 1000) return null;\ncontext.set('_lastEmit', now);\nfunction find(prefix) {\n for (const k in c) { if (k.indexOf(prefix) === 0) return c[k]; }\n return null;\n}\nconst MAX_VOL = 50.0;\nconst lvl = find('level.predicted.');\nconst vol = find('volume.predicted.');\nconst qIn = find('flow.predicted.in.');\nconst qOut = find('flow.predicted.out.');\nconst netFlowRate = find('netFlowRate.predicted.');\nconst fillPct = vol != null\n ? Math.min(100, Math.max(0, Math.round(Number(vol) / MAX_VOL * 100)))\n : null;\nconst netM3h = netFlowRate != null ? Number(netFlowRate) * 3600 : null;\nconst seconds = (c.timeleft != null && Number.isFinite(Number(c.timeleft)))\n ? Number(c.timeleft) : null;\nconst timeStr = seconds != null\n ? (seconds > 60 ? Math.round(seconds/60) + ' min'\n : Math.round(seconds) + ' s')\n : 'n/a';\nmsg.payload = {\n direction: c.direction || 'steady',\n level: lvl != null ? Number(lvl).toFixed(2) + ' m' : 'n/a',\n volume: vol != null ? Number(vol).toFixed(1) + ' mΒ³' : 'n/a',\n fillPct: fillPct != null ? fillPct + '%' : 'n/a',\n netFlow: netM3h != null ? netM3h.toFixed(0) + ' mΒ³/h' : 'n/a',\n timeLeft: timeStr,\n qIn: qIn != null ? (Number(qIn ) * 3600).toFixed(0) + ' mΒ³/h' : 'n/a',\n qOut: qOut != null ? (Number(qOut) * 3600).toFixed(0) + ' mΒ³/h' : 'n/a',\n levelNum: lvl != null ? Number(lvl) : null,\n volumeNum: vol != null ? Number(vol) : null,\n fillPctNum: fillPct,\n netFlowNum: netM3h,\n percControl: c.percControl != null ? Number(c.percControl) : null,\n qInNum: qIn != null ? Number(qIn ) * 3600 : null,\n qOutNum: qOut != null ? Number(qOut) * 3600 : null,\n safetyState: c.safetyState || 'normal',\n};\nreturn msg;", "outputs": 1, "noerr": 0, "initialize": "", @@ -1567,7 +1567,7 @@ "id": "c_mode_bcast", "type": "comment", "z": "tab_process", - "name": "\u2500\u2500 Mode broadcast \u2500\u2500", + "name": "── Mode broadcast ──", "info": "", "x": 640, "y": 1420, @@ -1593,7 +1593,7 @@ "id": "fanout_mode", "type": "function", "z": "tab_process", - "name": "fan setMode \u2192 3 pumps", + "name": "fan setMode β†’ 3 pumps", "func": "msg.topic = 'setMode';\nreturn [msg, msg, msg];", "outputs": 3, "noerr": 0, @@ -1618,7 +1618,7 @@ "id": "c_station_cmds", "type": "comment", "z": "tab_process", - "name": "\u2500\u2500 Station-wide commands \u2500\u2500", + "name": "── Station-wide commands ──", "info": "", "x": 640, "y": 1620, @@ -1644,7 +1644,7 @@ "id": "fan_station_start", "type": "function", "z": "tab_process", - "name": "fan startup \u2192 3 pumps", + "name": "fan startup β†’ 3 pumps", "func": "return [msg, msg, msg];", "outputs": 3, "noerr": 0, @@ -1685,7 +1685,7 @@ "id": "fan_station_stop", "type": "function", "z": "tab_process", - "name": "fan shutdown \u2192 3 pumps", + "name": "fan shutdown β†’ 3 pumps", "func": "return [msg, msg, msg];", "outputs": 3, "noerr": 0, @@ -1726,7 +1726,7 @@ "id": "fan_station_estop", "type": "function", "z": "tab_process", - "name": "fan emergency stop \u2192 3 pumps", + "name": "fan emergency stop β†’ 3 pumps", "func": "return [msg, msg, msg];", "outputs": 3, "noerr": 0, @@ -1751,7 +1751,7 @@ "id": "c_setup_at_mgc", "type": "comment", "z": "tab_process", - "name": "\u2500\u2500 Setup feeders \u2500\u2500", + "name": "── Setup feeders ──", "info": "", "x": 640, "y": 1900, @@ -1792,9 +1792,9 @@ { "id": "tab_ui", "type": "tab", - "label": "\ud83d\udcca Dashboard UI", + "label": "πŸ“Š Dashboard UI", "disabled": false, - "info": "All FlowFuse ui-* widgets. Two pages:\n /dashboard/realtime \u2014 gauges + per-pump status (no time history)\n /dashboard/trends \u2014 line charts, 1 hour rolling window\n\nAll inputs leave via link-out; all process state arrives via link-in." + "info": "All FlowFuse ui-* widgets. Two pages:\n /dashboard/realtime β€” gauges + per-pump status (no time history)\n /dashboard/trends β€” line charts, 1 hour rolling window\n\nAll inputs leave via link-out; all process state arrives via link-in." }, { "id": "ui_base", @@ -1853,7 +1853,7 @@ { "id": "ui_page_trends", "type": "ui-page", - "name": "Trends \u2014 1 hour", + "name": "Trends β€” 1 hour", "ui": "ui_base", "path": "/trends", "icon": "show_chart", @@ -1867,7 +1867,8 @@ } ], "order": 2, - "className": "" + "className": "", + "d": true }, { "id": "ui_grp_inflow", @@ -1984,7 +1985,7 @@ { "id": "ui_grp_tr_demand", "type": "ui-group", - "name": "Process demand \u2014 PS percControl (1h)", + "name": "Process demand β€” PS percControl (1h)", "page": "ui_page_trends", "width": "12", "height": "1", @@ -1998,7 +1999,7 @@ { "id": "ui_grp_tr_dq", "type": "ui-group", - "name": "\u0394Q = inflow \u2212 outflow (m\u00b3/h, +fill / \u2212drain)", + "name": "Ξ”Q = inflow βˆ’ outflow (mΒ³/h, +fill / βˆ’drain)", "page": "ui_page_trends", "width": "12", "height": "1", @@ -2069,7 +2070,7 @@ "id": "c_ui_title", "type": "comment", "z": "tab_ui", - "name": "\ud83d\udcca DASHBOARD UI \u2014 only ui-* widgets here", + "name": "πŸ“Š DASHBOARD UI β€” only ui-* widgets here", "info": "", "x": 640, "y": 20, @@ -2079,7 +2080,7 @@ "id": "c_ui_inflow", "type": "comment", "z": "tab_ui", - "name": "\u2500\u2500 Operator inflow input \u2500\u2500", + "name": "── Operator inflow input ──", "info": "", "x": 640, "y": 80, @@ -2091,7 +2092,7 @@ "z": "tab_ui", "group": "ui_grp_inflow", "name": "Inflow baseline", - "label": "Inflow baseline (m\u00b3/h) \u2014 scenarios modulate around this value", + "label": "Inflow baseline (mΒ³/h) β€” scenarios modulate around this value", "tooltip": "", "order": 1, "width": "0", @@ -2357,7 +2358,7 @@ "type": "function", "z": "tab_ui", "name": "dispatch inflow", - "func": "const p = msg.payload || {};\nconst ts = Date.now();\nreturn [\n { payload: (p.scenario || 'constant').toUpperCase() },\n { payload: p.q_h != null ? Number(p.q_h).toFixed(1) + ' m\u00b3/h' : 'n/a' },\n p.q_h != null ? { topic: 'Inflow', payload: Number(p.q_h), timestamp: ts } : null,\n];", + "func": "const p = msg.payload || {};\nconst ts = Date.now();\nreturn [\n { payload: (p.scenario || 'constant').toUpperCase() },\n { payload: p.q_h != null ? Number(p.q_h).toFixed(1) + ' mΒ³/h' : 'n/a' },\n p.q_h != null ? { topic: 'Inflow', payload: Number(p.q_h), timestamp: ts } : null,\n];", "outputs": 3, "noerr": 0, "initialize": "", @@ -2421,7 +2422,7 @@ "id": "c_ui_station", "type": "comment", "z": "tab_ui", - "name": "\u2500\u2500 Mode + Station-wide buttons \u2500\u2500", + "name": "── Mode + Station-wide buttons ──", "info": "", "x": 640, "y": 380, @@ -2433,7 +2434,7 @@ "z": "tab_ui", "group": "ui_grp_station", "name": "Station mode", - "label": "Station mode (Auto = level-based \u00b7 Manual = slider Qd)", + "label": "Station mode (Auto = level-based Β· Manual = slider Qd)", "tooltip": "", "order": 1, "width": "0", @@ -2480,7 +2481,7 @@ "z": "tab_ui", "group": "ui_grp_station", "name": "Manual Qd", - "label": "Manual Qd (m\u00b3/h, manual mode only)", + "label": "Manual Qd (mΒ³/h, manual mode only)", "tooltip": "", "order": 1, "width": "0", @@ -2707,7 +2708,7 @@ "id": "c_ui_basin", "type": "comment", "z": "tab_ui", - "name": "\u2500\u2500 Basin realtime (gauges + text) \u2500\u2500", + "name": "── Basin realtime (gauges + text) ──", "info": "", "x": 640, "y": 700, @@ -2734,7 +2735,7 @@ "type": "function", "z": "tab_ui", "name": "dispatch PS", - "func": "const p = msg.payload || {};\nconst ts = Date.now();\n// \u0394Q = inflow \u2212 outflow in m\u00b3/h (positive = filling).\nconst dQ = (p.qInNum != null && p.qOutNum != null)\n ? p.qInNum - p.qOutNum : null;\n// Demand text formatting.\nconst demandStr = p.percControl != null\n ? Number(p.percControl).toFixed(0) + '%' : 'n/a';\nreturn [\n { payload: String(p.direction || 'steady') },\n { payload: String(p.level || 'n/a') },\n { payload: String(p.volume || 'n/a') },\n { payload: String(p.fillPct || 'n/a') },\n { payload: String(p.netFlow || 'n/a') },\n { payload: String(p.timeLeft || 'n/a') },\n { payload: String(p.qIn || 'n/a') },\n { payload: String(p.qOut || 'n/a') },\n { payload: String(p.safetyState || 'normal') },\n { payload: demandStr },\n p.levelNum != null ? { payload: p.levelNum } : null,\n p.fillPctNum != null ? { payload: p.fillPctNum } : null,\n p.percControl != null ? { payload: p.percControl } : null,\n p.levelNum != null ? { topic: 'Basin level', payload: p.levelNum, timestamp: ts } : null,\n p.fillPctNum != null ? { topic: 'Fill %', payload: p.fillPctNum, timestamp: ts } : null,\n p.qOutNum != null ? { topic: 'Outflow', payload: p.qOutNum, timestamp: ts } : null,\n p.percControl != null ? { topic: 'PS demand', payload: p.percControl, timestamp: ts } : null,\n dQ != null ? { topic: '\u0394Q', payload: dQ, timestamp: ts } : null,\n];", + "func": "const p = msg.payload || {};\nconst ts = Date.now();\n// Ξ”Q = inflow βˆ’ outflow in mΒ³/h (positive = filling).\nconst dQ = (p.qInNum != null && p.qOutNum != null)\n ? p.qInNum - p.qOutNum : null;\n// Demand text formatting.\nconst demandStr = p.percControl != null\n ? Number(p.percControl).toFixed(0) + '%' : 'n/a';\nreturn [\n { payload: String(p.direction || 'steady') },\n { payload: String(p.level || 'n/a') },\n { payload: String(p.volume || 'n/a') },\n { payload: String(p.fillPct || 'n/a') },\n { payload: String(p.netFlow || 'n/a') },\n { payload: String(p.timeLeft || 'n/a') },\n { payload: String(p.qIn || 'n/a') },\n { payload: String(p.qOut || 'n/a') },\n { payload: String(p.safetyState || 'normal') },\n { payload: demandStr },\n p.levelNum != null ? { payload: p.levelNum } : null,\n p.fillPctNum != null ? { payload: p.fillPctNum } : null,\n p.percControl != null ? { payload: p.percControl } : null,\n p.levelNum != null ? { topic: 'Basin level', payload: p.levelNum, timestamp: ts } : null,\n p.fillPctNum != null ? { topic: 'Fill %', payload: p.fillPctNum, timestamp: ts } : null,\n p.qOutNum != null ? { topic: 'Outflow', payload: p.qOutNum, timestamp: ts } : null,\n p.percControl != null ? { topic: 'PS demand', payload: p.percControl, timestamp: ts } : null,\n dQ != null ? { topic: 'Ξ”Q', payload: dQ, timestamp: ts } : null,\n];", "outputs": 18, "noerr": 0, "initialize": "", @@ -3144,7 +3145,7 @@ "id": "c_ui_mgc", "type": "comment", "z": "tab_ui", - "name": "\u2500\u2500 MGC realtime \u2500\u2500", + "name": "── MGC realtime ──", "info": "", "x": 640, "y": 1080, @@ -3266,9 +3267,9 @@ "gtype": "gauge-34", "gstyle": "Rounded", "title": "Total flow", - "units": "m\u00b3/h", + "units": "mΒ³/h", "prefix": "", - "suffix": " m\u00b3/h", + "suffix": " mΒ³/h", "min": 0, "max": 600, "segments": [ @@ -3347,7 +3348,7 @@ "id": "c_ui_pump_a", "type": "comment", "z": "tab_ui", - "name": "\u2500\u2500 Pump A \u2500\u2500", + "name": "── Pump A ──", "info": "", "x": 640, "y": 1340, @@ -3720,7 +3721,7 @@ "id": "c_ui_pump_b", "type": "comment", "z": "tab_ui", - "name": "\u2500\u2500 Pump B \u2500\u2500", + "name": "── Pump B ──", "info": "", "x": 640, "y": 1820, @@ -4093,7 +4094,7 @@ "id": "c_ui_pump_c", "type": "comment", "z": "tab_ui", - "name": "\u2500\u2500 Pump C \u2500\u2500", + "name": "── Pump C ──", "info": "", "x": 640, "y": 2300, @@ -4466,7 +4467,7 @@ "id": "c_ui_trends", "type": "comment", "z": "tab_ui", - "name": "\u2500\u2500 Trend charts (1h rolling) \u2500\u2500", + "name": "── Trend charts (1h rolling) ──", "info": "", "x": 640, "y": 2840, @@ -4601,8 +4602,8 @@ "type": "ui-chart", "z": "tab_ui", "group": "ui_grp_tr_dq", - "name": "\u0394Q \u2014 inflow \u2212 outflow", - "label": "\u0394Q", + "name": "Ξ”Q β€” inflow βˆ’ outflow", + "label": "Ξ”Q", "order": 1, "chartType": "line", "interpolation": "linear", @@ -4616,7 +4617,7 @@ "xAxisFormatType": "auto", "xmin": "", "xmax": "", - "yAxisLabel": "m\u00b3/h", + "yAxisLabel": "mΒ³/h", "yAxisProperty": "payload", "yAxisPropertyType": "msg", "ymin": "", @@ -4740,7 +4741,7 @@ "xAxisFormatType": "auto", "xmin": "", "xmax": "", - "yAxisLabel": "m\u00b3/h", + "yAxisLabel": "mΒ³/h", "yAxisProperty": "payload", "yAxisPropertyType": "msg", "ymin": "", @@ -4909,15 +4910,15 @@ { "id": "tab_drivers", "type": "tab", - "label": "\ud83c\udf9b\ufe0f Demo Drivers", + "label": "πŸŽ›οΈ Demo Drivers", "disabled": false, - "info": "Inflow generator. The operator picks a SCENARIO (Constant / Sine / Diurnal / Storm) on the dashboard and sets a BASELINE m\u00b3/h value. Every second this generator emits q_in to the PS based on the active scenario + baseline.\n\nOutflow is implicit: the pumps drain the basin via MGC." + "info": "Inflow generator. The operator picks a SCENARIO (Constant / Sine / Diurnal / Storm) on the dashboard and sets a BASELINE mΒ³/h value. Every second this generator emits q_in to the PS based on the active scenario + baseline.\n\nOutflow is implicit: the pumps drain the basin via MGC." }, { "id": "c_drv_title", "type": "comment", "z": "tab_drivers", - "name": "\ud83c\udf9b\ufe0f DEMO DRIVERS \u2014 operator-driven inflow generator", + "name": "πŸŽ›οΈ DEMO DRIVERS β€” operator-driven inflow generator", "info": "", "x": 640, "y": 20, @@ -5039,15 +5040,15 @@ { "id": "tab_setup", "type": "tab", - "label": "\u2699\ufe0f Setup & Init", + "label": "βš™οΈ Setup & Init", "disabled": false, - "info": "One-shot deploy-time injects:\n \u2022 MGC scaling = normalized + mode = optimalcontrol\n \u2022 all pumps mode = auto\n \u2022 initial inflow baseline + scenario\n\nDisable this tab in production." + "info": "One-shot deploy-time injects:\n β€’ MGC scaling = normalized + mode = optimalcontrol\n β€’ all pumps mode = auto\n β€’ initial inflow baseline + scenario\n\nDisable this tab in production." }, { "id": "c_setup_title", "type": "comment", "z": "tab_setup", - "name": "\u2699\ufe0f SETUP & INIT \u2014 one-shot deploy-time injects", + "name": "βš™οΈ SETUP & INIT β€” one-shot deploy-time injects", "info": "", "x": 640, "y": 20, @@ -5176,7 +5177,7 @@ "id": "setup_inflow_baseline", "type": "inject", "z": "tab_setup", - "name": "inflow baseline = 25 m\u00b3/h (nominal)", + "name": "inflow baseline = 25 mΒ³/h (nominal)", "props": [ { "p": "topic", @@ -5307,7 +5308,7 @@ { "id": "tab_telemetry", "type": "tab", - "label": "\ud83d\udcc8 Telemetry", + "label": "πŸ“ˆ Telemetry", "disabled": false, "info": "InfluxDB writer: every EVOLV node's port-1 telemetry is fanned in via the evt:tlm link channel, converted to line protocol, and POSTed to InfluxDB v2 (org=evolv, bucket=telemetry).\n\nPattern adapted from docker/demo-flow.json." }, @@ -5315,7 +5316,7 @@ "id": "c_tlm_title", "type": "comment", "z": "tab_telemetry", - "name": "\ud83d\udcc8 TELEMETRY \u2014 InfluxDB writer", + "name": "πŸ“ˆ TELEMETRY β€” InfluxDB writer", "info": "", "x": 640, "y": 20, @@ -5357,7 +5358,7 @@ "id": "fn_tlm_to_lp", "type": "function", "z": "tab_telemetry", - "name": "\u2192 InfluxDB line protocol", + "name": "β†’ InfluxDB line protocol", "func": "const p = msg.payload;\nif (!p || !p.measurement || !p.fields) return null;\nconst esc = (s) => String(s)\n .replace(/,/g, '\\\\,').replace(/ /g, '\\\\ ').replace(/=/g, '\\\\=');\nconst tags = Object.entries(p.tags || {})\n .filter(([k, v]) => v !== undefined && v !== null && v !== '')\n .map(([k, v]) => `${esc(k)}=${esc(v)}`).join(',');\nconst fieldPairs = Object.entries(p.fields)\n .filter(([k, v]) => v !== undefined && v !== null)\n .map(([k, v]) => {\n if (typeof v === 'number' && Number.isFinite(v)) return `${esc(k)}=${v}`;\n if (typeof v === 'boolean') return `${esc(k)}=${v}`;\n return `${esc(k)}=\"${String(v).replace(/\"/g, '\\\\\"')}\"`;\n });\nif (fieldPairs.length === 0) return null;\nconst ts = Date.now() * 1000000;\nmsg.payload = `${esc(p.measurement)}${tags ? ',' + tags : ''} `\n + `${fieldPairs.join(',')} ${ts}`;\n// Hint the join node to fire on size or timeout.\nmsg.topic = 'tlm';\nreturn msg;", "outputs": 1, "noerr": 0, @@ -5446,7 +5447,7 @@ "type": "function", "z": "tab_telemetry", "name": "Count writes", - "func": "const lines = Number(msg.lineCount) || 0;\nconst writes = (global.get('influx_writes') || 0) + 1;\nconst totalLines = (global.get('influx_lines') || 0) + lines;\nglobal.set('influx_writes', writes);\nglobal.set('influx_lines', totalLines);\nconst errors = global.get('influx_errors') || 0;\nif (msg.statusCode && msg.statusCode >= 400) {\n global.set('influx_errors', errors + 1);\n node.status({fill:'red', shape:'ring',\n text:`ERR ${errors+1}: ${msg.statusCode}`});\n} else {\n node.status({fill:'green', shape:'dot',\n text:`${writes} POSTs \u00b7 ${totalLines} lines (${errors} err)`});\n}\nreturn null;", + "func": "const lines = Number(msg.lineCount) || 0;\nconst writes = (global.get('influx_writes') || 0) + 1;\nconst totalLines = (global.get('influx_lines') || 0) + lines;\nglobal.set('influx_writes', writes);\nglobal.set('influx_lines', totalLines);\nconst errors = global.get('influx_errors') || 0;\nif (msg.statusCode && msg.statusCode >= 400) {\n global.set('influx_errors', errors + 1);\n node.status({fill:'red', shape:'ring',\n text:`ERR ${errors+1}: ${msg.statusCode}`});\n} else {\n node.status({fill:'green', shape:'dot',\n text:`${writes} POSTs Β· ${totalLines} lines (${errors} err)`});\n}\nreturn null;", "outputs": 1, "noerr": 0, "initialize": "", diff --git a/nodes/machineGroupControl b/nodes/machineGroupControl index 2651aaf..ea2857f 160000 --- a/nodes/machineGroupControl +++ b/nodes/machineGroupControl @@ -1 +1 @@ -Subproject commit 2651aaf409503d50bea3e471635307c5aa7a5847 +Subproject commit ea2857fb25429936bc5775096f1ed84cd736baba diff --git a/nodes/rotatingMachine b/nodes/rotatingMachine index 5a8113a..8f9150e 160000 --- a/nodes/rotatingMachine +++ b/nodes/rotatingMachine @@ -1 +1 @@ -Subproject commit 5a8113a9d1680a8751b4f81937bd938ea5692a15 +Subproject commit 8f9150e1601d68c01a0c76d697e72e3fe0063833