From 3007c1caa17a5e1551d6bb12285096c9e8ca492f Mon Sep 17 00:00:00 2001
From: Justin Oro <JustinOros@gmail.com>
Date: Mon, 24 Aug 2026 10:41:32 -0700
Subject: [PATCH] Stop stale-telemetry handling from overriding an active
 battery floor lock

---
 solixauto/engine.py | 69 ++++++++++++++++++++++++++++++++-------------
 1 file changed, 49 insertions(+), 20 deletions(-)

diff --git a/solixauto/engine.py b/solixauto/engine.py
index 791433d..31c5160 100644
--- a/solixauto/engine.py
+++ b/solixauto/engine.py
@@ -543,6 +543,13 @@ class Engine:
         self.stale_action_state = None
         self.pre_stale_state = None
 
+        if self.floor_latched:
+            self.report(
+                "battery floor is still active, not restoring pre-outage state",
+                force=True,
+            )
+            return
+
         if previous is None or previous == applied:
             return
 
@@ -886,16 +893,27 @@ class Engine:
             if self.profile.on_stale == "stop":
                 raise RuntimeError("stopping: MQTT session disconnected")
             if self.profile.on_stale == "safe_state":
-                if self.stale_action_state is None:
-                    self.pre_stale_state = self.last_commanded
-                    self.stale_action_state = self.profile.safe_state
-                await self.apply(
-                    session,
-                    self.profile.safe_state,
-                    "connection to Anker lost",
-                    now,
-                    cause="stale",
-                )
+                if self.floor_latched:
+                    floor_state = self.profile.battery_floor.desired_state()
+                    await self.apply(
+                        session,
+                        floor_state,
+                        "battery floor holding through a lost connection",
+                        now,
+                        force=True,
+                        cause="floor",
+                    )
+                else:
+                    if self.stale_action_state is None:
+                        self.pre_stale_state = self.last_commanded
+                        self.stale_action_state = self.profile.safe_state
+                    await self.apply(
+                        session,
+                        self.profile.safe_state,
+                        "connection to Anker lost",
+                        now,
+                        cause="stale",
+                    )
 
             if not self.stale_notified:
                 self.stale_notified = True
@@ -956,16 +974,27 @@ class Engine:
             if self.profile.on_stale == "stop":
                 raise RuntimeError("stopping: telemetry went stale")
             if self.profile.on_stale == "safe_state":
-                if self.stale_action_state is None:
-                    self.pre_stale_state = self.last_commanded
-                    self.stale_action_state = self.profile.safe_state
-                await self.apply(
-                    session,
-                    self.profile.safe_state,
-                    "telemetry went stale",
-                    now,
-                    cause="stale",
-                )
+                if self.floor_latched:
+                    floor_state = self.profile.battery_floor.desired_state()
+                    await self.apply(
+                        session,
+                        floor_state,
+                        "battery floor holding through stale telemetry",
+                        now,
+                        force=True,
+                        cause="floor",
+                    )
+                else:
+                    if self.stale_action_state is None:
+                        self.pre_stale_state = self.last_commanded
+                        self.stale_action_state = self.profile.safe_state
+                    await self.apply(
+                        session,
+                        self.profile.safe_state,
+                        "telemetry went stale",
+                        now,
+                        cause="stale",
+                    )
             return
 
         if self.stale_reported: