refactor(engine): use machine information module

PROCEED-Labs · Nov 18, 2024 · 885e09d · 885e09d
1 parent 2814a04
commit 885e09d
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 10 deletions.
diff --git a/src/engine/universal/core/src/messaging-setup.js b/src/engine/universal/core/src/messaging-setup.js
@@ -59,7 +59,7 @@ module.exports = {
       }
     }
   },
-  async setupMonitoringAndLogging(messaging, configModule, machineModule, logger, network) {
+  async setupMonitoringAndLogging(messaging, configModule, machineModule, logger) {
     let { serverAddress, baseTopic } = await configModule.readConfig('messaging');
     if (!serverAddress) return;
 
@@ -74,8 +74,8 @@ module.exports = {
 
     setInterval(async () => {
       try {
-        const monitoring = await network.loopback('get', '/machine/');
-        await messaging.publish(`${baseTopic}/engine/${machineId}/machine/monitoring`, monitoring);
+        const machineData = await machineModule.getMachineInformation();
+        await messaging.publish(`${baseTopic}/engine/${machineId}/machine/monitoring`, machineData);
       } catch (e) {
         logger.error('Failed to publish monitoring data');
       }

diff --git a/src/engine/universal/core/src/module.js b/src/engine/universal/core/src/module.js
@@ -53,13 +53,7 @@ module.exports = {
 
     if (enableMessaging) {
       await setupMessaging(system.messaging, config, machineInformation, logger);
-      await setupMonitoringAndLogging(
-        system.messaging,
-        config,
-        machineInformation,
-        logger,
-        system.network,
-      );
+      await setupMonitoringAndLogging(system.messaging, config, machineInformation, logger);
     }
 
     if (!options.silentMode) {