From 2a07084f9e293fed8e7a174f715776d592d1a4f9 Mon Sep 17 00:00:00 2001
From: Dirk Heilig <heilig@adesso-mobile.de>
Date: Mon, 23 Sep 2024 15:08:48 +0200
Subject: [PATCH] persist data

---
 mqtt2prom/run | 20 ++++++++++++++++++--
 1 file changed, 18 insertions(+), 2 deletions(-)

diff --git a/mqtt2prom/run b/mqtt2prom/run
index fa15699..d7c49dc 100755
--- a/mqtt2prom/run
+++ b/mqtt2prom/run
@@ -24,7 +24,15 @@ $ignoreRetained = getEnvWithDefaultInt("IGNORE_RETAINED", 1) ? 1 : 0;
 
 $mqtt = new Mosquitto\Client($mqttClientId);
 
-$data = [];
+$data = null;
+if (is_file("/www/metrics/raw")) {
+    $data = json_decode(strval(file_get_contents("/www/metrics/raw")), true);
+}
+
+if (!is_array($data)) {
+    $data = [];
+}
+
 $mqtt->setCredentials($mqttUser, $mqttPass);
 
 $usedConfig = [
@@ -140,7 +148,7 @@ while ($isRunning) {
         $mqtt->loop(100);
     }
 
-    if ($lastGC + 60*15 < time()) {
+    if ($lastGC + 60 * 15 < time()) {
         logit("doing Garbage collection...");
         $c = gc_collect_cycles();
         logit("Garbage collection done, $c cycles collected");
@@ -355,6 +363,14 @@ function output(): void
             JSON_PRETTY_PRINT + JSON_UNESCAPED_SLASHES + JSON_UNESCAPED_UNICODE
         )
     );
+    file_put_contents(
+        "/www/metrics/raw",
+        json_encode(
+            $data,
+            JSON_PRETTY_PRINT + JSON_UNESCAPED_SLASHES + JSON_UNESCAPED_UNICODE
+        )
+    );
+
     rename("/www/metrics/new.json", "/www/metrics/metrics.json");
     rename("/www/metrics/new.prom", "/www/metrics/index.prom");
     // return $prom;