From ff05fce350956e047c4aa30ed9598c80890b782b Mon Sep 17 00:00:00 2001
From: Parnic <github@parnic.com>
Date: Sat, 1 Feb 2025 15:52:10 -0600
Subject: [PATCH] Save last pH/ORP to restore across restarts

---
 .gitignore        |  2 ++
 eslint.config.mjs |  8 ++++++++
 node_helper.js    | 34 ++++++++++++++++++++++++++++++++--
 3 files changed, 42 insertions(+), 2 deletions(-)

diff --git a/.gitignore b/.gitignore
index 621038f..c25a954 100644
--- a/.gitignore
+++ b/.gitignore
@@ -56,3 +56,5 @@ typings/
 
 # dotenv environment variables file
 .env
+
+lastData.json
diff --git a/eslint.config.mjs b/eslint.config.mjs
index 89cb320..e503def 100644
--- a/eslint.config.mjs
+++ b/eslint.config.mjs
@@ -1,8 +1,16 @@
 import eslint from "@eslint/js";
+import globals from "globals";
 
 export default [
   eslint.configs.recommended,
   {
     ignores: ["eslint.config.mjs"],
   },
+  {
+    languageOptions: {
+      globals: {
+        ...globals.node,
+      },
+    },
+  },
 ];
diff --git a/node_helper.js b/node_helper.js
index 1171c24..cda6428 100644
--- a/node_helper.js
+++ b/node_helper.js
@@ -1,10 +1,13 @@
-/* global module require clearInterval clearTimeout setTimeout setInterval */
-
 var NodeHelper = require("node_helper");
 
 const { FindUnits, Unit } = require("node-intellicenter");
 const messages = require("node-intellicenter/messages");
 const Log = require("logger");
+const path = require("path");
+const fs = require("fs");
+const filename = "/lastData.json";
+
+var configFilename = path.resolve(__dirname + filename);
 
 const reconnectDelayMs = 10 * 1000;
 const unitFinderTimeoutMs = 5 * 1000;
@@ -39,6 +42,31 @@ let freezeObjnam = "";
 let initialConnectDone = false;
 
 module.exports = NodeHelper.create({
+  start() {
+    Log.info("##### Starting node helper for: " + this.name);
+
+    try {
+      const data = fs.readFileSync(configFilename);
+      if (data && data.length > 0) {
+        const parsed = JSON.parse(data);
+        poolData.lastPHVal = parsed.lastPH ?? 0;
+        poolData.lastOrpVal = parsed.lastOrp ?? 0;
+      }
+    } catch {
+      // no existing config
+    }
+  },
+
+  saveLast() {
+    const obj = {
+      lastPH: poolData.lastPHVal,
+      lastOrp: poolData.lastOrpVal,
+    };
+
+    const json = JSON.stringify(obj);
+    fs.writeFileSync(configFilename, json, "utf8");
+  },
+
   setCircuit(circuitState) {
     if (!foundUnit) {
       return;
@@ -209,9 +237,11 @@ module.exports = NodeHelper.create({
 
             if (poolData.phVal !== 0) {
               poolData.lastPHVal = poolData.phVal;
+              this.saveLast();
             }
             if (poolData.orp !== 0) {
               poolData.lastOrpVal = poolData.orp;
+              this.saveLast();
             }
           } else if (obj.objnam === poolObjnam) {
             Log.info("[MMM-IntelliCenter] received pool update");