RnD/generalFunctions
3
0
Fork 2
Code Issues 9 Pull Requests Actions Packages Projects Releases Wiki Activity

Added additional reactor handling

Browse Source
This commit is contained in:
p.vanderwilt
2025-07-24 15:09:04 +02:00
parent 475caa90db
commit 71643375fc
1 changed files with 12 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/helper/childRegistrationUtils.js
View File

@@ -233,7 +233,18 @@ class ChildRegistrationUtils {
this.logger.warn("Invalid reactor provided."); this.logger.warn("Invalid reactor provided.");
return; return;
} }
this.mainClass.upstreamReactor = reactor; // Add reactor to the main class
// this is poor code, it should be fixed at some point
if (this.mainClass?.upstreamReactor){
this.mainClass.upstreamReactor = reactor; // Add reactor to the main class
} else {
if (positionVsParent == "downstream") {
this.mainClass.reactors[0] = reactor;
}
if (positionVsParent == "upstream") {
this.mainClass.reactors[1] = reactor;
}
}
this.logger.info(`Reactor registered successfully.`); this.logger.info(`Reactor registered successfully.`);
reactor.emitter.on("stateChange", (data) => { reactor.emitter.on("stateChange", (data) => {