diff --git a/src/helper/childRegistrationUtils.js b/src/helper/childRegistrationUtils.js index f9b9cef..8f3106d 100644 --- a/src/helper/childRegistrationUtils.js +++ b/src/helper/childRegistrationUtils.js @@ -87,6 +87,11 @@ class ChildRegistrationUtils { this.logger.debug(`Registering linear actuator child: ${id}`); this.connectActuator(child,positionVsParent); break; + + case "reactor": + this.logger.debug(`Registering reactor child: ${id}`); + this.connectReactor(child); + break; default: this.logger.error(`Child registration unrecognized desc: ${desc}`); @@ -222,6 +227,20 @@ class ChildRegistrationUtils { } } + connectReactor(reactor) { + if (!reactor) { + this.logger.warn("Invalid reactor provided."); + return; + } + this.mainClass.upstreamReactor = reactor; // Add reactor to the main class + this.logger.info(`Reactor registered successfully.`); + + reactor.emitter.on("stateChange", (data) => { + this.mainClass.logger.debug(`State change of reactor detected: ${data}`); + this.mainClass.setInflux = data; + }); + } + //wanneer hij deze ontvangt is deltaP van een van de valves veranderd (kan ook zijn niet child zijn, maar dat maakt niet uit) }