deploy(S4): Blender headless pipeline + WebAR client + backend fixes

backend/main.py

@@ -547,7 +547,10 @@ async def websocket_hub(websocket: WebSocket):
                 try:
                     await websocket.close()
                 except Exception as e:
-                    import logging; logging.getLogger(__name__).error(f"Swallowed exception: {e}")
+                    # NO `import logging` here: it would make `logging` local to
+                    # heartbeat() and turn the warning three lines above into an
+                    # UnboundLocalError — silently killing the WS heartbeat.
+                    logging.getLogger(__name__).error(f"Swallowed exception: {e}")
                 break
                 
     heartbeat_task = asyncio.create_task(heartbeat())

backend/memory/episodic_memory.py

@@ -62,8 +62,7 @@ class EpisodicMemory:
             logging.error("chromadb is not installed. Episodic memory will not work.")
             self.client = None
             return
-            
-        import logging
+
         logging.getLogger("chromadb").setLevel(logging.ERROR)
         self.client = chromadb.PersistentClient(
             path=persist_dir,

backend/services/token_manager.py

@@ -610,7 +610,9 @@ async def _resume_checkpoint(checkpoint: dict):
                 )
                 conn.commit()
         except Exception as e:
-            import logging; logging.getLogger(__name__).error(f"Swallowed exception: {e}")
+            # No local `import logging` — it would shadow the module import for
+            # the whole of _resume_checkpoint() and break the logging calls above.
+            logging.getLogger(__name__).error(f"Swallowed exception: {e}")
     except Exception as e:
         logging.error(f"TokenManager: Resume error for [{task_id}]: {e}")
 

backend/services/usb_monitor.py

@@ -218,7 +218,7 @@ async def start_usb_monitor():
                         return mapping
                     wmi_drive_map = await loop.run_in_executor(None, fetch_wmi_letters)
                 except Exception as e:
-                    import logging; logging.getLogger(__name__).error(f"Swallowed exception: {e}")
+                    logging.getLogger(__name__).error(f"Swallowed exception: {e}")
 
             for dev in usb_devices:
                 vid, pid = dev["vid"], dev["pid"]

backend/voice/space_injection.py

@@ -81,7 +81,7 @@ async def speak_space_acknowledgement(new_space: SpaceKey, persona: str) -> None
                 try:
                     await conn.send_bytes(audio_bytes)
                 except Exception as e:
-                    import logging; logging.getLogger(__name__).error(f"Swallowed exception: {e}")
+                    logging.getLogger(__name__).error(f"Swallowed exception: {e}")
             # Signal end
             await ws_manager.broadcast({
                 "event": "voice:space_ack_end",

backend/ws/agent_ws.py

@@ -1,8 +1,31 @@
 import asyncio
+import json
 import logging
+import os
 from fastapi import WebSocket
 import uuid
 
+# EVERY import used by handle_client_event lives HERE, at module scope, and must
+# stay here.
+#
+# handle_client_event used to re-import logging, os, json and uuid inside its own
+# body. Python decides scope at compile time: one `import logging` anywhere in a
+# function makes `logging` a local name for the WHOLE function, so every use
+# *before* that line raises UnboundLocalError. The re-imports sat near the bottom,
+# in the chat branch, so the branches above them were all dead on arrival:
+#
+#   line 102  logging  -> client:identify        (PC relay registration)
+#   line 132  logging  -> voice:wake_word        (persona switch)
+#   line 154  logging  -> xr:gesture
+#   line 194  logging  -> switch_persona
+#   line 231  uuid     -> type=="chat"           (the ReAct agent loop)
+#
+# Each one killed the socket: the exception escaped the `while True` in
+# main.py::websocket_hub, which only catches WebSocketDisconnect, so the
+# connection was torn down and the client reconnected into the same crash. That
+# is precisely why the PC relay looked connected in netstat while never
+# registering — it was a reconnect loop, not a session.
+
 from backend.agent.react_agent import ReActAgent
 from backend.tools.tool_registry import TOOL_REGISTRY
 get_assistant_name = lambda: __import__('modules.assistant_identity', fromlist=['get_assistant_name']).get_assistant_name()
@@ -179,7 +202,6 @@ class ConnectionManager:
 
         if data.get("event") == "auth:handshake":
             pin = data.get("payload", {}).get("pin", "")
-            import os
             expected_pin = os.environ.get("JARVIS_PIN", "0000")
             if pin == expected_pin:
                 if websocket:
@@ -233,7 +255,6 @@ class ConnectionManager:
             detected_lang = data.get("language", "en")
             # Load config to check for forced override
             try:
-                import os, json
                 config_path = os.path.join(os.getcwd(), "config.json")
                 if os.path.exists(config_path):
                     with open(config_path, "r", encoding="utf-8") as f:
@@ -242,7 +263,7 @@ class ConnectionManager:
                     if forced_lang:
                         detected_lang = forced_lang
             except Exception as e:
-                import logging; logging.getLogger(__name__).error(f"Swallowed exception: {e}")
+                logging.getLogger(__name__).error(f"Swallowed exception: {e}")
             
             agent_name = context.get("ai", get_assistant_name()).upper()
             
@@ -421,8 +442,7 @@ class ConnectionManager:
 
                 asyncio.create_task(_propose_and_notify_or_execute())
 
-                import uuid as _uuid
-                save_message("assistant", ack, str(_uuid.uuid4()), agent_name.lower())
+                save_message("assistant", ack, str(uuid.uuid4()), agent_name.lower())
                 return
             # ── End §2.3+2.4 Interception ──────────────────────────────────
             
@@ -474,7 +494,6 @@ class ConnectionManager:
                 else:
                     await self.broadcast(msg_done)
                     
-                import uuid
                 save_message("assistant", full_response.strip(), str(uuid.uuid4()), agent_name.lower())
                 
                 # Auto-store memory in background without blocking response stream

dist/app-release.apk

@@ -1,3 +1,3 @@
 version https://git-lfs.github.com/spec/v1
-oid sha256:a3905dc8e7e13df42584f11579773098ec39330e80884ae6272082136c2cdffe
+oid sha256:3ad8ae06d51f018c394e07acd4492bd6d3ec89137891812596d50286595ecd3b
 size 116538395