Claude Code: Fix A2A communication - remove non-existent think_async() call

- Fixed /a2a/jsonrpc endpoint: removed call to non-existent brain_minimal.think_async()
- Fixed /hello endpoint: removed call to non-existent brain_minimal.think_async()
- Now using handle_brain_response() from error_handlers for proper message processing
- A2A endpoint now correctly extracts message text and processes through brain
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

app.py

@@ -69,12 +69,14 @@ async def hello():
         # Import directly since .openclaw is in sys.path after openclaw import
         import openclaw  # Trigger sys.path setup
         from agents import brain_minimal
-        brain = brain_minimal
 
-        # Try to use brain
-        result = await brain.think_async("Hello") if hasattr(brain, 'think_async') else None
-        if result:
+        # Try to use brain via the response handler
+        from error_handlers import handle_brain_response
+        result = handle_brain_response("Hello")
+        if result and not result.startswith("Error:") and not result.startswith("Brain"):
             return {"message": result, "brain": "active"}
+        else:
+            return {"message": "Hello World from Cain!", "brain": "fallback"}
     except ImportError:
         # Brain module not available - survival mode
         return {"message": "Brain offline. Cain is in survival mode."}
@@ -82,9 +84,6 @@ async def hello():
         # Brain exists but failed - survival mode
         return {"message": f"Brain error: {e}. Cain is in survival mode."}
 
-    # Fallback: Brain imported but didn't respond
-    return {"message": "Hello World from Cain!", "brain": "fallback"}
-
 @app.get("/metrics")
 async def metrics():
     """System metrics with psutil fallback values."""
@@ -159,10 +158,6 @@ async def a2a_jsonrpc(request: Request):
 
         # Handle message/send method
         if method == "message/send":
-            # Lazy load brain for processing
-            import openclaw  # Sets up sys.path
-            from agents import brain_minimal
-
             message = params.get("message", {})
             message_text = ""
             for part in message.get("parts", []):
@@ -170,38 +165,31 @@ async def a2a_jsonrpc(request: Request):
                     message_text = part.get("text", "")
                     break
 
-            # Process the message through brain
+            # Process the message - use brain for response if available
+            response = None
             try:
-                response = await brain_minimal.think_async(message_text) if hasattr(brain_minimal, 'think_async') else None
-                if not response:
-                    response = f"Cain received: {message_text}"
-
-                # Build A2A JSON-RPC response
-                return {
-                    "jsonrpc": "2.0",
-                    "id": msg_id,
-                    "result": {
-                        "status": {
-                            "state": "completed",
-                            "message": {
-                                "parts": [{"type": "text", "text": response}]
-                            }
-                        }
-                    }
-                }
-            except Exception as e:
-                return {
-                    "jsonrpc": "2.0",
-                    "id": msg_id,
-                    "result": {
-                        "status": {
-                            "state": "failed",
-                            "message": {
-                                "parts": [{"type": "text", "text": f"Error: {str(e)}"}]
-                            }
+                import openclaw  # Sets up sys.path
+                from agents import brain_minimal
+                from error_handlers import handle_brain_response
+
+                # Use the brain response handler for proper processing
+                response = handle_brain_response(message_text)
+            except Exception as brain_error:
+                response = f"Cain received: {message_text}"
+
+            # Build A2A JSON-RPC response
+            return {
+                "jsonrpc": "2.0",
+                "id": msg_id,
+                "result": {
+                    "status": {
+                        "state": "completed",
+                        "message": {
+                            "parts": [{"type": "text", "text": response}]
                         }
                     }
                 }
+            }
 
         # Unknown method
         return JSONResponse(