fix: wrap sync DB calls in executor for authenticated endpoints

- GitHub OAuth status endpoint: wrap store.get_token() in executor
- User repos endpoint: wrap pin_store.list_states() in executor
- Archived repos endpoint: wrap pin_store.list_archived() in executor
- Prevents blocking async event loop with synchronous SQLAlchemy queries
- Fixes 10-second timeout issue on authenticated endpoints

Author: alimkhann

commitly-backend/app/api/github.py

@@ -57,8 +57,16 @@ async def github_status(
     current_user: ClerkClaims = Depends(require_clerk_auth),
     session: Session = Depends(get_db),
 ):
-    store = GitHubTokenStore(session)
-    record = store.get_token(current_user["sub"])
+    import asyncio
+    
+    # Wrap sync DB call in executor to avoid blocking event loop
+    def get_status():
+        store = GitHubTokenStore(session)
+        return store.get_token(current_user["sub"])
+    
+    loop = asyncio.get_event_loop()
+    record = await loop.run_in_executor(None, get_status)
+    
     if record is None:
         return OAuthStatusResponse(connected=False)
     return OAuthStatusResponse(

commitly-backend/app/api/roadmap.py

@@ -214,7 +214,12 @@ async def list_user_repositories(
     current_user: ClerkClaims = Depends(require_clerk_auth),
     service: RoadmapService = Depends(get_roadmap_service),
 ) -> list[UserRepoStateResponse]:
-    return await service.list_user_repos(get_user_id(current_user))
+    import asyncio
+    
+    # Wrap sync DB call in executor to avoid blocking event loop
+    user_id = get_user_id(current_user)
+    loop = asyncio.get_event_loop()
+    return await loop.run_in_executor(None, lambda: service._pin_store.list_states(user_id))
 
 
 @router.post("/sync/{owner}/{repo}", response_model=UserRepoStateResponse)
@@ -263,7 +268,12 @@ async def list_archived_repositories(
     current_user: ClerkClaims = Depends(require_clerk_auth),
     service: RoadmapService = Depends(get_roadmap_service),
 ) -> list[UserRepoStateResponse]:
-    return await service.list_archived_repos(get_user_id(current_user))
+    import asyncio
+    
+    # Wrap sync DB call in executor to avoid blocking event loop
+    user_id = get_user_id(current_user)
+    loop = asyncio.get_event_loop()
+    return await loop.run_in_executor(None, lambda: service._pin_store.list_archived(user_id))
 
 
 @router.post("/{owner}/{repo}/rating", response_model=RatingResponse)