Claude Code: refactor error handling into dedicated error_handlers.py

- Create new error_handlers.py with specific exception handlers
- Move try/except blocks from app.py to dedicated handler functions
- handle_status_file_read: handles FileNotFoundError, PermissionError, JSONDecodeError
- handle_brain_response: handles ImportError, AttributeError, KeyError
- handle_websocket_send: handles ConnectionError, RuntimeError
- Refactor app.py to import and use these handlers

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

app.py

@@ -21,7 +21,7 @@ sys.path.insert(0, "/app")
 # Import system logger
 from openclaw.core.system_logger import log_startup, log_heartbeat, get_last_lines
 # Import error handlers
-from error_handlers import handle_status_file_read, handle_brain_response, handle_websocket_message
+from error_handlers import handle_status_file_read, handle_brain_response, handle_websocket_send
 
 
 @asynccontextmanager
@@ -149,12 +149,10 @@ async def websocket_endpoint(websocket: WebSocket):
     await websocket.accept()
     try:
         while True:
-            # Send heartbeat every 5 seconds
+            # Send heartbeat every 5 seconds using error handler
             status_data = get_cain_status()
-            await websocket.send_json({
-                "type": "heartbeat",
-                "status": status_data
-            })
+            if not await handle_websocket_send(websocket, status_data):
+                break
             await asyncio.sleep(5)
     except Exception as e:
         pass

error_handlers.py

@@ -85,28 +85,22 @@ def handle_brain_response(message: str) -> str:
         return f"Brain processing error: {type(e).__name__}: {str(e)}"
 
 
-def handle_websocket_message(websocket, status_func, sleep_func) -> bool:
+async def handle_websocket_send(websocket, status_data: dict) -> bool:
     """
-    Handle websocket message loop with specific exception handling.
+    Handle websocket send with specific exception handling.
 
     Args:
         websocket: The WebSocket connection object.
-        status_func: Function to get current status.
-        sleep_func: Async sleep function.
+        status_data: Status data to send.
 
     Returns:
-        True if loop should continue, False if it should break.
+        True if send succeeded, False if connection should close.
     """
     try:
-        status_data = status_func()
-        websocket.send_json({
+        await websocket.send_json({
             "type": "heartbeat",
             "status": status_data
         })
         return True
-    except ConnectionError:
-        return False
-    except RuntimeError:
-        return False
-    except Exception:
+    except (ConnectionError, RuntimeError, Exception):
         return False