From 839ae2f3da6c5483bc72a768c9210c28574cb9dc Mon Sep 17 00:00:00 2001 From: "p.vanderwilt" Date: Wed, 16 Jul 2025 15:34:58 +0200 Subject: [PATCH 1/3] feat: add reactor registration and handling in ChildRegistrationUtils --- src/helper/childRegistrationUtils.js | 19 +++++++++++++++++++ 1 file changed, 19 insertions(+) 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) } From 7cdfc87c834486ea4b9b3500bfc6a551bba49266 Mon Sep 17 00:00:00 2001 From: "p.vanderwilt" Date: Wed, 16 Jul 2025 16:04:32 +0200 Subject: [PATCH 2/3] Add state update on recieving child signal --- src/helper/childRegistrationUtils.js | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/helper/childRegistrationUtils.js b/src/helper/childRegistrationUtils.js index 8f3106d..8b90cb1 100644 --- a/src/helper/childRegistrationUtils.js +++ b/src/helper/childRegistrationUtils.js @@ -226,6 +226,8 @@ class ChildRegistrationUtils { } } } + + //wanneer hij deze ontvangt is deltaP van een van de valves veranderd (kan ook zijn niet child zijn, maar dat maakt niet uit) connectReactor(reactor) { if (!reactor) { @@ -238,10 +240,10 @@ class ChildRegistrationUtils { reactor.emitter.on("stateChange", (data) => { this.mainClass.logger.debug(`State change of reactor detected: ${data}`); this.mainClass.setInflux = data; + this.mainClass.updateState(data.timestamp); }); } - //wanneer hij deze ontvangt is deltaP van een van de valves veranderd (kan ook zijn niet child zijn, maar dat maakt niet uit) } module.exports = ChildRegistrationUtils; From 8c9301b128d8f9d107a6a6012af5f483141184bf Mon Sep 17 00:00:00 2001 From: "p.vanderwilt" Date: Mon, 21 Jul 2025 14:14:30 +0200 Subject: [PATCH 3/3] Remove undefined reference to 'desc' --- src/helper/childRegistrationUtils.js | 1 - 1 file changed, 1 deletion(-) diff --git a/src/helper/childRegistrationUtils.js b/src/helper/childRegistrationUtils.js index f9b9cef..e018a0b 100644 --- a/src/helper/childRegistrationUtils.js +++ b/src/helper/childRegistrationUtils.js @@ -89,7 +89,6 @@ class ChildRegistrationUtils { break; default: - this.logger.error(`Child registration unrecognized desc: ${desc}`); this.logger.error(`Unrecognized softwareType: ${softwareType}`); } }