coderabbit fixes

Author: smokeyScraper

backend/app/agents/devrel/nodes/handlers/__init__.py

@@ -2,7 +2,8 @@
 from typing import Dict, Any
 from app.agents.state import AgentState
 from langchain_core.messages import HumanMessage
-from ...prompts.search_prompt import EXTRACT_SEARCH_QUERY_PROMPT
+from app.agents.devrel.prompts.search_prompt import EXTRACT_SEARCH_QUERY_PROMPT
+
 
 logger = logging.getLogger(__name__)
 

backend/app/agents/devrel/nodes/handlers/web_search.py

@@ -1,13 +1,18 @@
 import logging
-from fastapi import APIRouter, HTTPException
+from fastapi import APIRouter, HTTPException, Depends
 from app.database.weaviate.client import get_weaviate_client
+from app.core.dependencies import get_app_instance
+from typing import TYPE_CHECKING
+
+if TYPE_CHECKING:
+    from main import DevRAIApplication
 
 router = APIRouter()
 logger = logging.getLogger(__name__)
 
 
 @router.get("/health")
-async def health_check():
+async def health_check(app_instance: "DevRAIApplication" = Depends(get_app_instance)):
     """
     General health check endpoint to verify services are running.
 
@@ -18,8 +23,6 @@ async def health_check():
         async with get_weaviate_client() as client:
             weaviate_ready = await client.is_ready()
 
-        from main import app_instance
-
         return {
             "status": "healthy",
             "services": {
@@ -35,7 +38,7 @@ async def health_check():
                 "status": "unhealthy",
                 "error": str(e)
             }
-        )
+        ) from e
 
 
 @router.get("/health/weaviate")
@@ -58,15 +61,13 @@ async def weaviate_health():
                 "status": "unhealthy",
                 "error": str(e)
             }
-        )
+        ) from e
 
 
 @router.get("/health/discord")
-async def discord_health():
+async def discord_health(app_instance: "DevRAIApplication" = Depends(get_app_instance)):
     """Check specifically Discord bot health."""
     try:
-        from main import app_instance
-
         bot_status = "running" if app_instance.discord_bot and not app_instance.discord_bot.is_closed() else "stopped"
 
         return {
@@ -82,4 +83,4 @@ async def discord_health():
                 "status": "unhealthy",
                 "error": str(e)
             }
-        )
+        ) from e

backend/app/api/v1/health.py

@@ -0,0 +1,12 @@
+from fastapi import Request
+from typing import TYPE_CHECKING
+
+if TYPE_CHECKING:
+    from main import DevRAIApplication
+
+async def get_app_instance(request: Request) -> "DevRAIApplication":
+    """
+    Dependency to get the application instance from FastAPI's state.
+    This avoids circular imports by using dependency injection.
+    """
+    return request.app.state.app_instance

backend/app/core/dependencies.py

@@ -91,6 +91,7 @@ async def lifespan(app: FastAPI):
     """
     Lifespan manager for the FastAPI application. Handles startup and shutdown events.
     """
+    app.state.app_instance = app_instance
     await app_instance.start_background_tasks()
     yield
     await app_instance.stop_background_tasks()