Presence Unification: Real-time process heartbeat & Mobile Offline detection

backend/app/scratch/subconscious_loop.py

@@ -83,9 +83,21 @@ async def get_system_status():
     with database.SessionLocal() as db:
         sov_lock = db.query(KeyValueStore).filter_by(key="safety_lock").first()
         learn_lock = db.query(KeyValueStore).filter_by(key="learning_lock").first()
+        heartbeat = db.query(KeyValueStore).filter_by(key="local_heartbeat").first()
+        
+        # Determine if the local process is actually running (15s threshold)
+        is_alive = False
+        if heartbeat:
+            try:
+                last_seen = float(heartbeat.value)
+                if time.time() - last_seen < 15:
+                    is_alive = True
+            except: pass
+
         return {
             "safety_lock": sov_lock.value if sov_lock else False,
-            "learning_lock": learn_lock.value if learn_lock else False
+            "learning_lock": learn_lock.value if learn_lock else False,
+            "is_alive": is_alive
         }
 
 @app.post("/system/safety-lock")
@@ -204,6 +216,22 @@ def subconscious_cycle():
             
             time.sleep(1.2) # High-speed pulse
 
+    # ── LOCAL LIFE SIGNAL SENTINEL ──
+    # This thread periodically whispers its presence to the DB
+    def life_signal():
+        logger.info("💓 [LIFE SIGNAL] Monitoring Presence. Cockpit Tether Online.")
+        while True:
+            try:
+                with database.SessionLocal() as db:
+                    hb = db.query(KeyValueStore).filter_by(key="local_heartbeat").first()
+                    if hb: hb.value = str(time.time())
+                    else: db.add(KeyValueStore(key="local_heartbeat", value=str(time.time()), category="system"))
+                    db.commit()
+            except Exception as e:
+                logger.error(f"[LIFE SIGNAL] Tether failure: {e}")
+            time.sleep(8) 
+
+    threading.Thread(target=life_signal, daemon=True).start()
     threading.Thread(target=state_poller, daemon=True).start()
     
     last_lock_log = 0

static/sovereign.html

@@ -164,6 +164,7 @@
     <script>
         let sovLocked = false;
         let learnLocked = false;
+        let isAlive = false;
         const API_BASE = window.location.origin;
 
         async function sync() {
@@ -173,6 +174,7 @@
                 
                 sovLocked = data.safety_lock;
                 learnLocked = data.learning_lock;
+                isAlive = data.is_alive;
                 
                 render();
             } catch (e) {
@@ -188,7 +190,11 @@
             const learnText = document.getElementById('learnText');
 
             // Sovereign UI
-            if (sovLocked) {
+            if (!isAlive) {
+                sovBadge.innerText = 'CORE OFFLINE';
+                sovBadge.style.color = '#888888';
+                box.classList.add('locked');
+            } else if (sovLocked) {
                 sovBadge.innerText = 'CORE STANDBY';
                 sovBadge.style.color = '#00f2ff';
                 box.classList.add('locked');