Compare commits

..

1 Commits

Author SHA1 Message Date
znetsixe
f4696618a6 updated registration of measurements 2025-09-04 17:07:29 +02:00

View File

@@ -92,7 +92,6 @@ class Machine {
this.measurements = new MeasurementContainer(); this.measurements = new MeasurementContainer();
this.interpolation = new interpolation(); this.interpolation = new interpolation();
this.flowDrift = null; this.flowDrift = null;
this.currentMode = this.config.mode.current; this.currentMode = this.config.mode.current;
@@ -116,62 +115,17 @@ class Machine {
} }
/*------------------- Register child events -------------------*/ /*------------------- Register child events -------------------*/
registerOnChildEvents() { registerChild(child, softwareType) {
this.logger.debug('Setting up child event listeners'); this.logger.debug('Setting up child event listeners');
const sensors = this.childRegistrationUtils.getChildrenOfType('measurement', 'sensor'); if(softwareType === "measurement"){
const position = child.config.functionality.positionVsParent;
if (sensors.length === 0) { const measurementType = child.config.asset.type;
this.logger.warn('No measurement sensors found to register events for');
return;
}
this.logger.debug(`Found ${sensors.length} sensors to register events for`);
// Group sensors by type and position to detect duplicates
const sensorGroups = new Map(); // Key: "type_position", Value: array of sensors
sensors.forEach(sensor => {
const position = sensor.config.functionality.positionVsParent;
const measurementType = sensor.config.asset.type;
const key = `${measurementType}_${position}`; const key = `${measurementType}_${position}`;
if (!sensorGroups.has(key)) {
sensorGroups.set(key, []);
}
sensorGroups.get(key).push(sensor);
});
// Set up event handlers based on whether we have single or multiple sensors
sensorGroups.forEach((sensorsArray, key) => {
const [measurementType, position] = key.split('_');
if (sensorsArray.length === 1) {
// ✅ Single sensor - direct handler
const sensor = sensorsArray[0];
this._registerSingleSensorEvents(sensor, measurementType, position);
} else {
// ✅ Multiple sensors - averaging handler with warning
const sensorNames = sensorsArray.map(s => s.config.general.name).join(', ');
this.logger.warn(`⚠️ Multiple ${measurementType} sensors at ${position} position: ${sensorNames}. Using automatic averaging.`);
this._registerMultipleSensorEvents(sensorsArray, measurementType, position);
}
});
this.logger.info(`✅ Event listeners registered for ${sensors.length} measurement sensors`);
this.childRegistrationUtils.logChildStructure();
}
// Handle single sensor (no averaging needed)
_registerSingleSensorEvents(sensor, measurementType, position) {
const sensorName = sensor.config.general.name;
const eventName = `${measurementType}.measured.${position}`; const eventName = `${measurementType}.measured.${position}`;
this.logger.debug(`Registering single ${measurementType} sensor: ${sensorName} at ${position}`); // Register event listener for measurement updates
child.measurements.emitter.on(eventName, (eventData) => {
sensor.measurements.emitter.on(eventName, (eventData) => {
this.logger.debug(`🔄 ${position} ${measurementType} from ${eventData.childName}: ${eventData.value} ${eventData.unit}`); this.logger.debug(`🔄 ${position} ${measurementType} from ${eventData.childName}: ${eventData.value} ${eventData.unit}`);
// Store directly in parent's measurement container // Store directly in parent's measurement container
@@ -184,45 +138,8 @@ _registerSingleSensorEvents(sensor, measurementType, position) {
// Call the appropriate handler // Call the appropriate handler
this._callMeasurementHandler(measurementType, eventData.value, position, eventData); this._callMeasurementHandler(measurementType, eventData.value, position, eventData);
}); });
}
this.logger.debug(`✅ Registered single sensor event: ${eventName}`); }
}
// Handle multiple sensors (with automatic averaging)
_registerMultipleSensorEvents(sensorsArray, measurementType, position) {
const eventName = `${measurementType}.measured.${position}`;
const sensorCount = sensorsArray.length;
this.logger.debug(`Registering ${sensorCount} ${measurementType} sensors at ${position} with averaging`);
// Register event handler for each sensor in the group
sensorsArray.forEach(sensor => {
sensor.measurements.emitter.on(eventName, (eventData) => {
this.logger.debug(`🔄 ${position} ${measurementType} from ${eventData.childName}: ${eventData.value} ${eventData.unit} (will be averaged)`);
// Store individual sensor value in parent's measurement container
this.measurements
.type(measurementType)
.variant("measured")
.position(position)
.value(eventData.value, eventData.timestamp, eventData.unit);
// Get the average from measurement container
const averageValue = this.measurements
.type(measurementType)
.variant("measured")
.position(position)
.getAverage();
this.logger.debug(`📊 Average ${position} ${measurementType} from ${sensorCount} sensors: ${averageValue}`);
// Call the handler with the averaged value
this._callMeasurementHandler(measurementType, averageValue, position, eventData);
});
});
this.logger.debug(`✅ Registered ${sensorCount} sensor events with averaging: ${eventName}`);
}
// Centralized handler dispatcher // Centralized handler dispatcher
_callMeasurementHandler(measurementType, value, position, context) { _callMeasurementHandler(measurementType, value, position, context) {