Claude Code: Target: Fix in Cain's event loop.

app.py

@@ -2182,6 +2182,11 @@ def create_agent_office_with_ws():
             logger.debug(f"[QUEUE_CANCEL] {request.url.path} - client disconnected")
             from fastapi.responses import Response
             return Response(status_code=204, content=None)
+        except Exception as e:
+            # Catch any other exceptions that might be raised from Gradio's internal queues
+            logger.debug(f"[MIDDLEWARE] Exception caught for {request.url.path}: {type(e).__name__}")
+            # Re-raise non-CancelledError exceptions
+            raise
 
     # Define API route handlers
     @fastapi_app.get("/api/thoughts")
@@ -2190,8 +2195,9 @@ def create_agent_office_with_ws():
         try:
             return ws_manager.get_recent_thoughts(limit)
         except asyncio.CancelledError:
-            logger.info("[API_CANCEL] /api/thoughts was cancelled")
-            raise
+            logger.debug("[API_CANCEL] /api/thoughts was cancelled")
+            from fastapi.responses import Response
+            return Response(status_code=204, content=None)
         except Exception as e:
             logger.error(f"[API_ERROR] /api/thoughts: {e}")
             return {"error": str(e)}
@@ -2202,8 +2208,9 @@ def create_agent_office_with_ws():
         try:
             return ws_manager.get_stats()
         except asyncio.CancelledError:
-            logger.info("[API_CANCEL] /api/thoughts/stats was cancelled")
-            raise
+            logger.debug("[API_CANCEL] /api/thoughts/stats was cancelled")
+            from fastapi.responses import Response
+            return Response(status_code=204, content=None)
         except Exception as e:
             logger.error(f"[API_ERROR] /api/thoughts/stats: {e}")
             return {"error": str(e)}
@@ -2215,8 +2222,9 @@ def create_agent_office_with_ws():
             ws_manager.clear_history()
             return {"status": "cleared"}
         except asyncio.CancelledError:
-            logger.info("[API_CANCEL] /api/thoughts/clear was cancelled")
-            raise
+            logger.debug("[API_CANCEL] /api/thoughts/clear was cancelled")
+            from fastapi.responses import Response
+            return Response(status_code=204, content=None)
         except Exception as e:
             logger.error(f"[API_ERROR] /api/thoughts/clear: {e}")
             return {"error": str(e)}
@@ -2227,8 +2235,9 @@ def create_agent_office_with_ws():
         try:
             return load_cain_status()
         except asyncio.CancelledError:
-            logger.info("[API_CANCEL] /api/agent/status was cancelled")
-            raise
+            logger.debug("[API_CANCEL] /api/agent/status was cancelled")
+            from fastapi.responses import Response
+            return Response(status_code=204, content=None)
         except Exception as e:
             logger.error(f"[API_ERROR] /api/agent/status: {e}")
             return {"error": str(e)}
@@ -2239,8 +2248,9 @@ def create_agent_office_with_ws():
         try:
             return load_agent_registry()
         except asyncio.CancelledError:
-            logger.info("[API_CANCEL] /api/agent/registry was cancelled")
-            raise
+            logger.debug("[API_CANCEL] /api/agent/registry was cancelled")
+            from fastapi.responses import Response
+            return Response(status_code=204, content=None)
         except Exception as e:
             logger.error(f"[API_ERROR] /api/agent/registry: {e}")
             return {"error": str(e)}
@@ -2251,8 +2261,9 @@ def create_agent_office_with_ws():
         try:
             return get_startup_report()
         except asyncio.CancelledError:
-            logger.info("[API_CANCEL] /api/agent/startup was cancelled")
-            raise
+            logger.debug("[API_CANCEL] /api/agent/startup was cancelled")
+            from fastapi.responses import Response
+            return Response(status_code=204, content=None)
         except Exception as e:
             logger.error(f"[API_ERROR] /api/agent/startup: {e}")
             return {"error": str(e)}
@@ -2264,8 +2275,9 @@ def create_agent_office_with_ws():
             status = ensure_cain_status_file()
             return {"success": True, "status": status}
         except asyncio.CancelledError:
-            logger.info("[API_CANCEL] /api/agent/reset-status was cancelled")
-            raise
+            logger.debug("[API_CANCEL] /api/agent/reset-status was cancelled")
+            from fastapi.responses import Response
+            return Response(status_code=204, content=None)
         except Exception as e:
             logger.error(f"[API_ERROR] /api/agent/reset-status: {e}")
             return {"success": False, "error": str(e)}
@@ -2278,8 +2290,9 @@ def create_agent_office_with_ws():
             try:
                 return get_analytics_stats_json()
             except asyncio.CancelledError:
-                logger.info("[API_CANCEL] /api/analytics/stats was cancelled")
-                raise
+                logger.debug("[API_CANCEL] /api/analytics/stats was cancelled")
+                from fastapi.responses import Response
+                return Response(status_code=204, content=None)
             except Exception as e:
                 logger.error(f"[API_ERROR] /api/analytics/stats: {e}")
                 return {"error": str(e)}
@@ -2290,8 +2303,9 @@ def create_agent_office_with_ws():
             try:
                 return {"summary": get_analytics_summary()}
             except asyncio.CancelledError:
-                logger.info("[API_CANCEL] /api/analytics/summary was cancelled")
-                raise
+                logger.debug("[API_CANCEL] /api/analytics/summary was cancelled")
+                from fastapi.responses import Response
+                return Response(status_code=204, content=None)
             except Exception as e:
                 logger.error(f"[API_ERROR] /api/analytics/summary: {e}")
                 return {"error": str(e)}
@@ -2302,8 +2316,9 @@ def create_agent_office_with_ws():
             try:
                 return get_conversation_history_json(limit)
             except asyncio.CancelledError:
-                logger.info("[API_CANCEL] /api/analytics/history was cancelled")
-                raise
+                logger.debug("[API_CANCEL] /api/analytics/history was cancelled")
+                from fastapi.responses import Response
+                return Response(status_code=204, content=None)
             except Exception as e:
                 logger.error(f"[API_ERROR] /api/analytics/history: {e}")
                 return {"error": str(e)}
@@ -2331,8 +2346,9 @@ def create_agent_office_with_ws():
 
                 return result
             except asyncio.CancelledError:
-                logger.info("[API_CANCEL] /api/analytics/sync was cancelled")
-                raise
+                logger.debug("[API_CANCEL] /api/analytics/sync was cancelled")
+                from fastapi.responses import Response
+                return Response(status_code=204, content=None)
             except Exception as e:
                 httpcore_breaker.record_failure()
                 logger.error(f"[API_ERROR] /api/analytics/sync: {e}")
@@ -2346,8 +2362,9 @@ def create_agent_office_with_ws():
                     analytics.reset()
                 return {"status": "reset"}
             except asyncio.CancelledError:
-                logger.info("[API_CANCEL] /api/analytics/reset was cancelled")
-                raise
+                logger.debug("[API_CANCEL] /api/analytics/reset was cancelled")
+                from fastapi.responses import Response
+                return Response(status_code=204, content=None)
             except Exception as e:
                 logger.error(f"[API_ERROR] /api/analytics/reset: {e}")
                 return {"error": str(e)}
@@ -2371,8 +2388,9 @@ def create_agent_office_with_ws():
                         "error": "Conversation storage not initialized"
                     }
             except asyncio.CancelledError:
-                logger.info("[API_CANCEL] /api/persistence/metrics was cancelled")
-                raise
+                logger.debug("[API_CANCEL] /api/persistence/metrics was cancelled")
+                from fastapi.responses import Response
+                return Response(status_code=204, content=None)
             except Exception as e:
                 write_error_log("api_error", "persistence_metrics", f"Failed to get metrics: {e}", exc_info=sys.exc_info())
                 return {
@@ -2393,8 +2411,9 @@ def create_agent_office_with_ws():
                         "error": "Conversation storage not initialized"
                     }
             except asyncio.CancelledError:
-                logger.info("[API_CANCEL] /api/persistence/sync was cancelled")
-                raise
+                logger.debug("[API_CANCEL] /api/persistence/sync was cancelled")
+                from fastapi.responses import Response
+                return Response(status_code=204, content=None)
             except Exception as e:
                 write_error_log("api_error", "persistence_sync", f"Sync failed: {e}", exc_info=sys.exc_info())
                 return {
@@ -2416,8 +2435,9 @@ def create_agent_office_with_ws():
                 "timestamp": datetime.utcnow().isoformat() + "Z"
             }
         except asyncio.CancelledError:
-            logger.info("[API_CANCEL] /health was cancelled")
-            raise
+            logger.debug("[API_CANCEL] /health was cancelled")
+            from fastapi.responses import Response
+            return Response(status_code=204, content=None)
         except Exception as e:
             return {
                 "status": "unhealthy",
@@ -2459,8 +2479,9 @@ def create_agent_office_with_ws():
 
             return result
         except asyncio.CancelledError:
-            logger.info("[API_CANCEL] /api/health was cancelled")
-            raise
+            logger.debug("[API_CANCEL] /api/health was cancelled")
+            from fastapi.responses import Response
+            return Response(status_code=204, content=None)
         except Exception as e:
             write_error_log("api_error", "health", f"Health check failed: {e}", exc_info=sys.exc_info())
             return {
@@ -2496,8 +2517,9 @@ def create_agent_office_with_ws():
                 "total": len(logs)
             }
         except asyncio.CancelledError:
-            logger.info("[API_CANCEL] /api/logs was cancelled")
-            raise
+            logger.debug("[API_CANCEL] /api/logs was cancelled")
+            from fastapi.responses import Response
+            return Response(status_code=204, content=None)
         except Exception as e:
             return {
                 "success": False,
@@ -2516,8 +2538,9 @@ def create_agent_office_with_ws():
                 return FileResponse(office_html, media_type="text/html")
             return JSONResponse(status_code=404, content={"error": "Office UI not found"})
         except asyncio.CancelledError:
-            logger.info("[API_CANCEL] /office was cancelled")
-            raise
+            logger.debug("[API_CANCEL] /office was cancelled")
+            from fastapi.responses import Response
+            return Response(status_code=204, content=None)
         except Exception as e:
             logger.error(f"[API_ERROR] /office: {e}")
             return JSONResponse(status_code=500, content={"error": str(e)})
@@ -2531,8 +2554,9 @@ def create_agent_office_with_ws():
                 return FileResponse(invite_html, media_type="text/html")
             return JSONResponse(status_code=404, content={"error": "Invite page not found"})
         except asyncio.CancelledError:
-            logger.info("[API_CANCEL] /invite was cancelled")
-            raise
+            logger.debug("[API_CANCEL] /invite was cancelled")
+            from fastapi.responses import Response
+            return Response(status_code=204, content=None)
         except Exception as e:
             logger.error(f"[API_ERROR] /invite: {e}")
             return JSONResponse(status_code=500, content={"error": str(e)})
@@ -2546,8 +2570,9 @@ def create_agent_office_with_ws():
                 return FileResponse(join_html, media_type="text/html")
             return JSONResponse(status_code=404, content={"error": "Join page not found"})
         except asyncio.CancelledError:
-            logger.info("[API_CANCEL] /join was cancelled")
-            raise
+            logger.debug("[API_CANCEL] /join was cancelled")
+            from fastapi.responses import Response
+            return Response(status_code=204, content=None)
         except Exception as e:
             logger.error(f"[API_ERROR] /join: {e}")
             return JSONResponse(status_code=500, content={"error": str(e)})
@@ -2561,8 +2586,9 @@ def create_agent_office_with_ws():
                 return FileResponse(dashboard_html, media_type="text/html")
             return JSONResponse(status_code=404, content={"error": "Agent dashboard not found"})
         except asyncio.CancelledError:
-            logger.info("[API_CANCEL] /agent-dashboard was cancelled")
-            raise
+            logger.debug("[API_CANCEL] /agent-dashboard was cancelled")
+            from fastapi.responses import Response
+            return Response(status_code=204, content=None)
         except Exception as e:
             logger.error(f"[API_ERROR] /agent-dashboard: {e}")
             return JSONResponse(status_code=500, content={"error": str(e)})