From df621507e3b39e52e5e245c903c156ea05fdc3ca Mon Sep 17 00:00:00 2001
From: Fotis Paraskevopoulos <fotis@existanze.com>
Date: Fri, 13 Feb 2026 18:20:53 +0200
Subject: [PATCH 1/2] Fixing invalid  messages with no correlation ID

---
 modules/application/index.js |  9 +++++++--
 modules/exn/index.js         | 20 ++++++++++++++------
 modules/influxdb/index.js    |  1 +
 3 files changed, 22 insertions(+), 8 deletions(-)

diff --git a/modules/application/index.js b/modules/application/index.js
index 29e90be..b9fd645 100644
--- a/modules/application/index.js
+++ b/modules/application/index.js
@@ -1445,7 +1445,6 @@ module.exports = {
                         const interval = req.query.interval || '-30d'
 
                         const credentials = await self.apos.modules.exn.getApplicationInfluxDBCredentials(doc.uuid)
-                        console.log("Got credentials ",credentials)
                         if (!credentials) {
                             throw self.apos.error('error', "Could not retrieve credentials");
                         }
@@ -1473,7 +1472,13 @@ module.exports = {
                         const range = req.query.range || 10
                         const slice = req.query.slice || 5
 
-                        const res = await self.apos.modules.influxdb.getTimeSeriesForMeasurements(doc.uuid, measurements, interval)
+                        const credentials = await self.apos.modules.exn.getApplicationInfluxDBCredentials(doc.uuid)
+                        if (!credentials) {
+                            throw self.apos.error('error', "Could not retrieve credentials");
+                        }
+                        console.log(new Date(), "Fetching data ")
+                        const res = await self.apos.modules.influxdb.getTimeSeriesForMeasurements(credentials,doc.uuid, measurements, interval)
+                        console.log(new Date(), "Fetched data ... ")
                         return {
                             application: doc.title,
                             uuid: doc.uuid,
diff --git a/modules/exn/index.js b/modules/exn/index.js
index c4a106a..6671693 100644
--- a/modules/exn/index.js
+++ b/modules/exn/index.js
@@ -117,7 +117,11 @@ module.exports = {
                             return
                         }
                         if (context.message.to === "topic://eu.nebulouscloud.app_cluster.influxdb.get.reply") {
-                            correlations[context.message.correlation_id]['resolve'](context.message.body)
+                            if (context.message.correlation_id in correlations) {
+                                correlations[context.message.correlation_id]['resolve'](context.message.body)
+                            }else{
+                                console.warn("Ignoring reply, not initiated by us, correlation id ", context.message.correlation_id, "is not in", correlations);
+                            }
                             return
                         }
 
@@ -400,9 +404,7 @@ module.exports = {
                 return new Promise((resolve, reject) => {
 
                     const correlation_id = uuidv4()
-                    correlations[correlation_id] = {
-                        'resolve': resolve, 'reject': reject,
-                    };
+
                      const req = aposSelf.apos.task.getReq()
                      const message = {
                         to: sender_app_influxdb.options.target.address,
@@ -414,9 +416,15 @@ module.exports = {
                    const timer = setTimeout(() => {
                         console.warn("InfluxDB Crendetials not retrieved for application = ",uuid)
                         resolve(false)
-                    }, 7000);
-
+                    }, 10000);
                     console.log("[getApplicationInfluxDBCrendetials] Send ", JSON.stringify( message))
+                    correlations[correlation_id] = {
+                        'resolve': (data)=>{
+                            clearTimeout(timer)
+                            resolve(data)
+                        }, 'reject': reject,
+                    };
+
                     sender_app_influxdb.send(message)
                 })
             },
diff --git a/modules/influxdb/index.js b/modules/influxdb/index.js
index f9a5b2b..2714b13 100644
--- a/modules/influxdb/index.js
+++ b/modules/influxdb/index.js
@@ -76,6 +76,7 @@ module.exports = {
                         queryApi.queryRows(fluxQuery, {
                             next(row, tableMeta) {
                                 const o = tableMeta.toObject(row);
+                                console.debug("Handling row")
                                 timeSeriesData.push({
                                     time: o._time,
                                     measurement: o._measurement,

From 23b7f53b761767793df22f7a56458d51bb123eed Mon Sep 17 00:00:00 2001
From: Fotis Paraskevopoulos <fotis@existanze.com>
Date: Fri, 13 Feb 2026 18:35:30 +0200
Subject: [PATCH 2/2] Removing unnecessary message

---
 modules/influxdb/index.js | 1 -
 1 file changed, 1 deletion(-)

diff --git a/modules/influxdb/index.js b/modules/influxdb/index.js
index 2714b13..f9a5b2b 100644
--- a/modules/influxdb/index.js
+++ b/modules/influxdb/index.js
@@ -76,7 +76,6 @@ module.exports = {
                         queryApi.queryRows(fluxQuery, {
                             next(row, tableMeta) {
                                 const o = tableMeta.toObject(row);
-                                console.debug("Handling row")
                                 timeSeriesData.push({
                                     time: o._time,
                                     measurement: o._measurement,