FIXES: Fix authentication, repo-stats API, and Discord bot startup issues

backend/app/core/dependencies.py

@@ -47,7 +47,7 @@ async def get_current_user(authorization: str = Header(None)) -> UUID:
     try:
         supabase = get_supabase_client()
         # Verify the token and get user
-        user_response = supabase.auth.get_user(token)
+        user_response = await supabase.auth.get_user(token)
 
         if not user_response or not user_response.user:
             raise HTTPException(

backend/integrations/discord/cogs.py

@@ -29,10 +29,12 @@ def __init__(self, bot: DiscordBot, queue_manager: AsyncQueueManager):
 
     def cog_load(self):
         """Called when the cog is loaded"""
+        # Start the cleanup task - it will wait for the bot to be ready via before_loop
         self.cleanup_expired_tokens.start()
 
     def cog_unload(self):
-        self.cleanup_expired_tokens.cancel()
+        if self.cleanup_expired_tokens.is_running():
+            self.cleanup_expired_tokens.cancel()
 
     @tasks.loop(minutes=5)
     async def cleanup_expired_tokens(self):
@@ -47,7 +49,9 @@ async def cleanup_expired_tokens(self):
     @cleanup_expired_tokens.before_loop
     async def before_cleanup(self):
         """Wait until the bot is ready before starting cleanup"""
+        print("--> Waiting for bot to be ready before starting cleanup task...")
         await self.bot.wait_until_ready()
+        print("--> Bot is ready, starting cleanup task...")
 
     @app_commands.command(name="reset", description="Reset your DevRel thread and memory.")
     async def reset_thread(self, interaction: discord.Interaction):

backend/main.py

@@ -14,6 +14,7 @@
 from app.database.weaviate.client import get_weaviate_client
 from integrations.discord.bot import DiscordBot
 from discord.ext import commands
+from routes import router as legacy_router
 # DevRel commands are now loaded dynamically (commented out below)
 # from integrations.discord.cogs import DevRelCommands
 
@@ -124,6 +125,7 @@ async def favicon():
     return Response(status_code=204)
 
 api.include_router(api_router)
+api.include_router(legacy_router, prefix="/api", tags=["Legacy"])
 
 
 if __name__ == "__main__":

backend/routes.py

@@ -7,6 +7,8 @@
 from app.core.events.base import BaseEvent
 from app.core.handler.handler_registry import HandlerRegistry
 from pydantic import BaseModel
+from app.core.config import settings
+import httpx
 
 router = APIRouter()
 
@@ -35,6 +37,63 @@ def register_event_handlers():
     event_bus.register_handler(EventType.PR_COMMENTED, sample_handler, PlatformType.GITHUB)
     event_bus.register_handler(EventType.PR_MERGED, sample_handler, PlatformType.GITHUB)
 
+@router.post("/repo-stats")
+async def get_repo_stats(request: RepoRequest):
+    """
+    Get repository statistics from GitHub
+    """
+    try:
+        # Parse repo URL to extract owner and repo name
+        repo_url = request.repo_url.rstrip('/')
+        parts = repo_url.split('github.com/')[-1].split('/')
+        if len(parts) < 2:
+            raise HTTPException(status_code=400, detail="Invalid GitHub repository URL")
+
+        owner, repo = parts[0], parts[1]
+
+        # Fetch repository stats from GitHub API
+        headers = {
+            "Authorization": f"token {settings.github_token}",
+            "Accept": "application/vnd.github.v3+json"
+        }
+
+        async with httpx.AsyncClient() as client:
+            response = await client.get(
+                f"https://api.github.com/repos/{owner}/{repo}",
+                headers=headers,
+                timeout=10.0
+            )
+
+            if response.status_code != 200:
+                raise HTTPException(
+                    status_code=response.status_code,
+                    detail=f"GitHub API error: {response.text}"
+                )
+
+            repo_data = response.json()
+
+            return {
+                "name": repo_data.get("name"),
+                "full_name": repo_data.get("full_name"),
+                "description": repo_data.get("description"),
+                "stars": repo_data.get("stargazers_count", 0),
+                "forks": repo_data.get("forks_count", 0),
+                "open_issues": repo_data.get("open_issues_count", 0),
+                "language": repo_data.get("language"),
+                "created_at": repo_data.get("created_at"),
+                "updated_at": repo_data.get("updated_at"),
+                "url": repo_data.get("html_url"),
+                "owner": {
+                    "login": repo_data.get("owner", {}).get("login"),
+                    "avatar_url": repo_data.get("owner", {}).get("avatar_url"),
+                }
+            }
+    except HTTPException:
+        raise
+    except Exception as e:
+        logging.error(f"Error fetching repo stats: {e}")
+        raise HTTPException(status_code=500, detail=str(e))
+
 @router.post("/github/webhook")
 async def github_webhook(request: Request):
     payload = await request.json()