46dd2ca37a
Replaces manual base config construction with shared buildConfig() method. Node now only specifies domain-specific config sections. Part of #1: Extract base config schema Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
285 lines
9.7 KiB
JavaScript
285 lines
9.7 KiB
JavaScript
/**
|
|
* node class.js
|
|
*
|
|
* Encapsulates all node logic in a reusable class. In future updates we can split this into multiple generic classes and use the config to specifiy which ones to use.
|
|
* This allows us to keep the Node-RED node clean and focused on wiring up the UI and event handlers.
|
|
*/
|
|
const { outputUtils, configManager } = require('generalFunctions');
|
|
const Specific = require("./specificClass");
|
|
|
|
class nodeClass {
|
|
/**
|
|
* Create a Node.
|
|
* @param {object} uiConfig - Node-RED node configuration.
|
|
* @param {object} RED - Node-RED runtime API.
|
|
*/
|
|
constructor(uiConfig, RED, nodeInstance, nameOfNode) {
|
|
|
|
// Preserve RED reference for HTTP endpoints if needed
|
|
this.node = nodeInstance; // This is the Node-RED node instance, we can use this to send messages and update status
|
|
this.RED = RED; // This is the Node-RED runtime API, we can use this to create endpoints if needed
|
|
this.name = nameOfNode; // This is the name of the node, it should match the file name and the node type in Node-RED
|
|
this.source = null; // Will hold the specific class instance
|
|
this.config = null; // Will hold the merged configuration
|
|
|
|
// Load default & UI config
|
|
this._loadConfig(uiConfig,this.node);
|
|
|
|
// Instantiate core class
|
|
this._setupSpecificClass(uiConfig);
|
|
|
|
// Wire up event and lifecycle handlers
|
|
this._bindEvents();
|
|
this._registerChild();
|
|
this._startTickLoop();
|
|
this._attachInputHandler();
|
|
this._attachCloseHandler();
|
|
}
|
|
|
|
/**
|
|
* Load and merge default config with user-defined settings.
|
|
* @param {object} uiConfig - Raw config from Node-RED UI.
|
|
*/
|
|
_loadConfig(uiConfig,node) {
|
|
const cfgMgr = new configManager();
|
|
|
|
// Build config: base sections + rotatingMachine-specific domain config
|
|
this.config = cfgMgr.buildConfig(this.name, uiConfig, node.id, {
|
|
flowNumber: uiConfig.flowNumber
|
|
});
|
|
|
|
// Utility for formatting outputs
|
|
this._output = new outputUtils();
|
|
}
|
|
|
|
/**
|
|
* Instantiate the core Measurement logic and store as source.
|
|
*/
|
|
_setupSpecificClass(uiConfig) {
|
|
const machineConfig = this.config;
|
|
|
|
console.log(`----------------> Loaded movementMode in nodeClass: ${uiConfig.movementMode}`);
|
|
|
|
// need extra state for this
|
|
const stateConfig = {
|
|
general: {
|
|
logging: {
|
|
enabled: machineConfig.eneableLog,
|
|
logLevel: machineConfig.logLevel
|
|
}
|
|
},
|
|
movement: {
|
|
speed: Number(uiConfig.speed),
|
|
mode: uiConfig.movementMode
|
|
},
|
|
time: {
|
|
starting: Number(uiConfig.startup),
|
|
warmingup: Number(uiConfig.warmup),
|
|
stopping: Number(uiConfig.shutdown),
|
|
coolingdown: Number(uiConfig.cooldown)
|
|
}
|
|
};
|
|
|
|
this.source = new Specific(machineConfig, stateConfig);
|
|
|
|
//store in node
|
|
this.node.source = this.source; // Store the source in the node instance for easy access
|
|
|
|
}
|
|
|
|
/**
|
|
* Bind events to Node-RED status updates. Using internal emitter. --> REMOVE LATER WE NEED ONLY COMPLETE CHILDS AND THEN CHECK FOR UPDATES
|
|
*/
|
|
_bindEvents() {
|
|
|
|
}
|
|
|
|
_updateNodeStatus() {
|
|
const m = this.source;
|
|
try {
|
|
const mode = m.currentMode;
|
|
const state = m.state.getCurrentState();
|
|
const flow = Math.round(m.measurements.type("flow").variant("predicted").position('downstream').getCurrentValue('m3/h'));
|
|
const power = Math.round(m.measurements.type("power").variant("predicted").position('atequipment').getCurrentValue('kW'));
|
|
let symbolState;
|
|
switch(state){
|
|
case "off":
|
|
symbolState = "⬛";
|
|
break;
|
|
case "idle":
|
|
symbolState = "⏸️";
|
|
break;
|
|
case "operational":
|
|
symbolState = "⏵️";
|
|
break;
|
|
case "starting":
|
|
symbolState = "⏯️";
|
|
break;
|
|
case "warmingup":
|
|
symbolState = "🔄";
|
|
break;
|
|
case "accelerating":
|
|
symbolState = "⏩";
|
|
break;
|
|
case "stopping":
|
|
symbolState = "⏹️";
|
|
break;
|
|
case "coolingdown":
|
|
symbolState = "❄️";
|
|
break;
|
|
case "decelerating":
|
|
symbolState = "⏪";
|
|
break;
|
|
case "maintenance":
|
|
symbolState = "🔧";
|
|
break;
|
|
}
|
|
const position = m.state.getCurrentPosition();
|
|
const roundedPosition = Math.round(position * 100) / 100;
|
|
|
|
let status;
|
|
switch (state) {
|
|
case "off":
|
|
status = { fill: "red", shape: "dot", text: `${mode}: OFF` };
|
|
break;
|
|
case "idle":
|
|
status = { fill: "blue", shape: "dot", text: `${mode}: ${symbolState}` };
|
|
break;
|
|
case "operational":
|
|
status = { fill: "green", shape: "dot", text: `${mode}: ${symbolState} | ${roundedPosition}% | 💨${flow}m³/h | ⚡${power}kW` };
|
|
break;
|
|
case "starting":
|
|
status = { fill: "yellow", shape: "dot", text: `${mode}: ${symbolState}` };
|
|
break;
|
|
case "warmingup":
|
|
status = { fill: "green", shape: "dot", text: `${mode}: ${symbolState} | ${roundedPosition}% | 💨${flow}m³/h | ⚡${power}kW` };
|
|
break;
|
|
case "accelerating":
|
|
status = { fill: "yellow", shape: "dot", text: `${mode}: ${symbolState} | ${roundedPosition}%| 💨${flow}m³/h | ⚡${power}kW` };
|
|
break;
|
|
case "stopping":
|
|
status = { fill: "yellow", shape: "dot", text: `${mode}: ${symbolState}` };
|
|
break;
|
|
case "coolingdown":
|
|
status = { fill: "yellow", shape: "dot", text: `${mode}: ${symbolState}` };
|
|
break;
|
|
case "decelerating":
|
|
status = { fill: "yellow", shape: "dot", text: `${mode}: ${symbolState} - ${roundedPosition}% | 💨${flow}m³/h | ⚡${power}kW` };
|
|
break;
|
|
default:
|
|
status = { fill: "grey", shape: "dot", text: `${mode}: ${symbolState}` };
|
|
}
|
|
return status;
|
|
} catch (error) {
|
|
this.node.error("Error in updateNodeStatus: " + error.message);
|
|
return { fill: "red", shape: "ring", text: "Status Error" };
|
|
}
|
|
}
|
|
/**
|
|
* Register this node as a child upstream and downstream.
|
|
* Delayed to avoid Node-RED startup race conditions.
|
|
*/
|
|
_registerChild() {
|
|
setTimeout(() => {
|
|
this.node.send([
|
|
null,
|
|
null,
|
|
{ topic: 'registerChild', payload: this.config.general.id, positionVsParent: this.config?.functionality?.positionVsParent || 'atEquipment' },
|
|
]);
|
|
}, 100);
|
|
}
|
|
|
|
/**
|
|
* Start the periodic tick loop.
|
|
*/
|
|
_startTickLoop() {
|
|
setTimeout(() => {
|
|
this._tickInterval = setInterval(() => this._tick(), 1000);
|
|
|
|
// Update node status on nodered screen every second ( this is not the best way to do this, but it works for now)
|
|
this._statusInterval = setInterval(() => {
|
|
const status = this._updateNodeStatus();
|
|
this.node.status(status);
|
|
}, 1000);
|
|
|
|
}, 1000);
|
|
}
|
|
|
|
/**
|
|
* Execute a single tick: update measurement, format and send outputs.
|
|
*/
|
|
_tick() {
|
|
//this.source.tick();
|
|
|
|
const raw = this.source.getOutput();
|
|
const processMsg = this._output.formatMsg(raw, this.source.config, 'process');
|
|
const influxMsg = this._output.formatMsg(raw, this.source.config, 'influxdb');
|
|
|
|
// Send only updated outputs on ports 0 & 1
|
|
this.node.send([processMsg, influxMsg]);
|
|
}
|
|
|
|
/**
|
|
* Attach the node's input handler, routing control messages to the class.
|
|
*/
|
|
_attachInputHandler() {
|
|
this.node.on('input', (msg, send, done) => {
|
|
/* Update to complete event based node by putting the tick function after an input event */
|
|
const m = this.source;
|
|
switch(msg.topic) {
|
|
case 'registerChild': {
|
|
// Register this node as a child of the parent node
|
|
const childId = msg.payload;
|
|
const childObj = this.RED.nodes.getNode(childId);
|
|
m.childRegistrationUtils.registerChild(childObj.source ,msg.positionVsParent);
|
|
break;
|
|
}
|
|
case 'setMode':
|
|
m.setMode(msg.payload);
|
|
break;
|
|
case 'execSequence': {
|
|
const { source, action, parameter } = msg.payload;
|
|
m.handleInput(source, action, parameter);
|
|
break;
|
|
}
|
|
case 'execMovement': {
|
|
const { source: mvSource, action: mvAction, setpoint } = msg.payload;
|
|
m.handleInput(mvSource, mvAction, Number(setpoint));
|
|
break;
|
|
}
|
|
case 'flowMovement': {
|
|
const { source: fmSource, action: fmAction, setpoint: fmSetpoint } = msg.payload;
|
|
m.handleInput(fmSource, fmAction, Number(fmSetpoint));
|
|
break;
|
|
}
|
|
case 'emergencystop': {
|
|
const { source: esSource, action: esAction } = msg.payload;
|
|
m.handleInput(esSource, esAction);
|
|
break;
|
|
}
|
|
case 'showWorkingCurves':
|
|
m.showWorkingCurves();
|
|
send({ topic : "Showing curve" , payload: m.showWorkingCurves() });
|
|
break;
|
|
case 'CoG':
|
|
m.showCoG();
|
|
send({ topic : "Showing CoG" , payload: m.showCoG() });
|
|
break;
|
|
}
|
|
});
|
|
}
|
|
|
|
/**
|
|
* Clean up timers and intervals when Node-RED stops the node.
|
|
*/
|
|
_attachCloseHandler() {
|
|
this.node.on('close', (done) => {
|
|
clearInterval(this._tickInterval);
|
|
clearInterval(this._statusInterval);
|
|
done();
|
|
});
|
|
}
|
|
}
|
|
|
|
module.exports = nodeClass;
|