Publish current refresh interval value to new topic

BigThunderSR · Mar 15, 2024 · 52dcfc6 · 52dcfc6
1 parent f92db44
commit 52dcfc6
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/src/index.js b/src/index.js
@@ -412,12 +412,15 @@ logger.info('Starting OnStar2MQTT Polling');
 
         let refreshInterval;
         const refreshIntervalTopic = mqttHA.getRefreshIntervalTopic();
+        const refreshIntervalCurrentValTopic = mqttHA.getRefreshIntervalCurrentValTopic();
         logger.info(`refreshIntervalTopic: ${refreshIntervalTopic}`);
+        logger.info(`refreshIntervalCurrentValTopic: ${refreshIntervalCurrentValTopic}`);
         // Subscribe to the topic
         client.subscribe(refreshIntervalTopic);
         // Set initial interval
         refreshInterval = setInterval(main, onstarConfig.refreshInterval);
         logger.info(`Initial refreshInterval: ${onstarConfig.refreshInterval}`);
+        client.publish(refreshIntervalCurrentValTopic, onstarConfig.refreshInterval.toString(), { retain: true });
         //client.publish(refreshIntervalTopic, onstarConfig.refreshInterval.toString(), { retain: true });
 
         client.on('message', async (topic, message) => {
@@ -428,6 +431,7 @@ logger.info('Starting OnStar2MQTT Polling');
                 // Start new interval with updated refresh interval
                 refreshInterval = setInterval(main, newRefreshInterval);
                 logger.info(`Updated refreshInterval to ${newRefreshInterval}`);
+                client.publish(refreshIntervalCurrentValTopic, newRefreshInterval.toString(), { retain: true });
             }
         });
 

diff --git a/src/mqtt.js b/src/mqtt.js
@@ -106,6 +106,10 @@ class MQTT {
         return `${this.prefix}/${this.instance}/refresh_interval`;
     }
 
+    getRefreshIntervalCurrentValTopic() {
+        return `${this.prefix}/${this.instance}/refresh_interval_current_val`;
+    }
+
     /**
      *
      * @param {DiagnosticElement} diag