keep history on the server side

Author: mike-enker

octoprint_external_temp_reader/ExternalTempReaderPlugin.py

@@ -3,10 +3,10 @@
 from xml.etree import ElementTree as ET
 
 import requests
-from octoprint.plugin import SettingsPlugin, StartupPlugin, ShutdownPlugin, TemplatePlugin, AssetPlugin
+from octoprint.plugin import SettingsPlugin, StartupPlugin, ShutdownPlugin, TemplatePlugin, AssetPlugin, SimpleApiPlugin
 
 
-class ExternalTempReaderPlugin(SettingsPlugin, TemplatePlugin, AssetPlugin, StartupPlugin, ShutdownPlugin):
+class ExternalTempReaderPlugin(SettingsPlugin, TemplatePlugin, AssetPlugin, StartupPlugin, ShutdownPlugin, SimpleApiPlugin):
     def __init__(self):
         super().__init__()
         self.polling_thread = None
@@ -16,9 +16,14 @@ def __init__(self):
         self.polling_interval = 10
         self.xml_temp_path = None  # XPath-like path for XML parsing
         self.current_chamber_temp = None
+        self.temperature_history = []  # Store temperature history
+        self.max_history_hours = 24  # Maximum hours of history to keep
 
     def on_after_startup(self):
         self._logger.info("ExternalTempReader plugin loaded. Loading configuration...")
+        # Clear history on startup
+        self.temperature_history = []
+        self._logger.info("Temperature history cleared on startup")
         self.load_configuration()
         self.start_polling_thread()
 
@@ -88,6 +93,9 @@ def poll_external_temp(self):
                         self.current_chamber_temp = temp
                         self._logger.info(f"Chamber temperature updated: {temp:.2f}°C")
 
+                        # Add to history
+                        self._add_to_history(temp)
+                        
                         # Send temperature update to frontend
                         self._send_temperature_update(temp)
                 except Exception as e:
@@ -195,3 +203,31 @@ def _send_temperature_update(self, temperature):
             self._logger.debug(f"Sent temperature update to frontend: {temperature:.2f}°C")
         except Exception as e:
             self._logger.error(f"Failed to send temperature update to frontend: {e}")
+    
+    def _add_to_history(self, temperature):
+        """Add temperature reading to history and cleanup old data."""
+        import time
+        current_time = int(time.time() * 1000)  # milliseconds
+        
+        # Add new data point
+        self.temperature_history.append({
+            "time": current_time,
+            "temperature": temperature
+        })
+        
+        # Cleanup old data (older than max_history_hours)
+        cutoff_time = current_time - (self.max_history_hours * 3600 * 1000)
+        self.temperature_history = [
+            point for point in self.temperature_history 
+            if point["time"] >= cutoff_time
+        ]
+        
+        self._logger.debug(f"History size: {len(self.temperature_history)} points")
+    
+    def on_api_get(self, request):
+        """Handle API GET requests."""
+        # Send full temperature history when requested
+        return {
+            "history": self.temperature_history,
+            "current_temp": self.current_chamber_temp
+        }

octoprint_external_temp_reader/static/js/external_temp_reader.js

@@ -274,12 +274,49 @@ $(function() {
         };
 
         self.onAfterBinding = function() {
+            // Load temperature history from server
+            $.ajax({
+                url: API_BASEURL + "plugin/external_temp_reader",
+                type: "GET",
+                dataType: "json",
+                success: function(response) {
+                    if (response.history && Array.isArray(response.history)) {
+                        console.log("External Temp Reader: Loaded " + response.history.length + " historical data points");
+                        self.temperatureHistory = response.history;
+                        
+                        // Update statistics with loaded data
+                        self.updateStatistics();
+                        
+                        // Update current temperature if available
+                        if (response.current_temp !== null && response.current_temp !== undefined) {
+                            self.temperature(response.current_temp.toFixed(1) + "°C");
+                            self.connectionStatus("Connected");
+                            var lastPoint = response.history[response.history.length - 1];
+                            if (lastPoint) {
+                                self.lastUpdate(new Date(lastPoint.time).toLocaleTimeString());
+                            }
+                        }
+                        
+                        // Initialize chart with loaded data
+                        if ($("#chamber-temperature-chart").length > 0) {
+                            self.initializeChart();
+                            self.updateChart();
+                        }
+                    }
+                },
+                error: function(xhr, status, error) {
+                    console.error("External Temp Reader: Failed to load history:", error);
+                }
+            });
+            
             // Wait for tab to be visible and Flot to be available
             setTimeout(function() {
                 // Check if we're on the tab and Flot is available
                 if ($("#chamber-temperature-chart").length > 0) {
                     console.log("External Temp Reader: Initializing chart");
-                    self.initializeChart();
+                    if (!self.chart) {
+                        self.initializeChart();
+                    }
 
                     // Set up periodic chart updates (every 5 seconds)
                     setInterval(function() {