refactor: clean up imports and improve code formatting in logging and roadmap repository services

Author: alimkhann

commitly-backend/app/core/logging.py

@@ -1,11 +1,11 @@
 from __future__ import annotations
 
 import contextvars
+from datetime import datetime, timezone
 import json
 import logging
 from logging.config import dictConfig
 import time
-from datetime import datetime, timezone
 from typing import Any, Dict, MutableMapping, Optional
 from uuid import uuid4
 
@@ -171,7 +171,9 @@ async def dispatch(
             raise
         else:
             elapsed_ms = (time.perf_counter() - start) * 1000
-            claims: Optional[Dict[str, Any]] = getattr(request.state, "clerk_claims", None)
+            claims: Optional[Dict[str, Any]] = getattr(
+                request.state, "clerk_claims", None
+            )
             user_id = claims.get("sub") if isinstance(claims, dict) else None
 
             bind_request_context(
@@ -186,4 +188,4 @@ async def dispatch(
             )
             return response
         finally:
-            clear_request_context()
+            clear_request_context()

commitly-backend/app/main.py

@@ -13,8 +13,7 @@
 from app.core.auth import ClerkAuthMiddleware, ClerkClaims, require_clerk_auth
 from app.core.config import settings
 from app.core.database import SessionLocal
-from app.core.logging import configure_logging, StructuredLoggingMiddleware
-
+from app.core.logging import StructuredLoggingMiddleware, configure_logging
 
 configure_logging()
 logger = logging.getLogger(__name__)

commitly-backend/app/services/roadmap_repository.py

@@ -330,13 +330,13 @@ def _recreate_schema(self) -> None:
         bind = self._session.get_bind()
         if bind is None:
             return
-        UserSyncedRepo.__table__.create(bind=bind, checkfirst=True)  # type: ignore[attr-defined]
-        GeneratedRoadmap.__table__.create(bind=bind, checkfirst=True)  # type: ignore[attr-defined]
+        UserSyncedRepo.__table__.create(bind=bind, checkfirst=True) # noqa E501 # type: ignore[attr-defined]
+        GeneratedRoadmap.__table__.create(bind=bind, checkfirst=True) # noqa E501 # type: ignore[attr-defined]
 
     def pin(self, user_id: str | None, full_name: str) -> None:
         if not user_id:
             return
-        
+
         def operation() -> None:
             try:
                 record = (
@@ -373,14 +373,13 @@ def operation() -> None:
     def list(self, user_id: str | None) -> list[RoadmapResponse]:
         if not user_id:
             return []
-        
+
         def operation() -> list[RoadmapResponse]:
             records: Iterable[GeneratedRoadmap] = (
                 self._session.query(GeneratedRoadmap)
                 .join(
                     UserSyncedRepo,
-                    UserSyncedRepo.repo_full_name
-                    == GeneratedRoadmap.repo_full_name,
+                    UserSyncedRepo.repo_full_name == GeneratedRoadmap.repo_full_name,
                 )
                 .filter(UserSyncedRepo.user_id == user_id)
                 .order_by(UserSyncedRepo.pinned_at.desc())
@@ -434,14 +433,13 @@ def operation() -> bool:
     def list_states(self, user_id: str | None) -> list[UserRepoStateResponse]:
         if not user_id:
             return []
-        
+
         def operation() -> list[UserRepoStateResponse]:
             results = (
                 self._session.query(UserSyncedRepo, GeneratedRoadmap)
                 .outerjoin(
                     GeneratedRoadmap,
-                    GeneratedRoadmap.repo_full_name
-                    == UserSyncedRepo.repo_full_name,
+                    GeneratedRoadmap.repo_full_name == UserSyncedRepo.repo_full_name,
                 )
                 .filter(UserSyncedRepo.user_id == user_id)
                 .order_by(UserSyncedRepo.pinned_at.desc())
@@ -469,6 +467,7 @@ def operation() -> list[UserRepoStateResponse]:
 
     def archive(self, user_id: str, full_name: str) -> None:
         """Archive a repository for a user."""
+
         def operation() -> None:
             try:
                 record = (
@@ -488,6 +487,7 @@ def operation() -> None:
 
     def unarchive(self, user_id: str, full_name: str) -> None:
         """Unarchive a repository for a user."""
+
         def operation() -> None:
             try:
                 record = (
@@ -509,14 +509,13 @@ def list_archived(self, user_id: str | None) -> list[UserRepoStateResponse]:
         """List archived repositories for a user."""
         if not user_id:
             return []
-        
+
         def operation() -> list[UserRepoStateResponse]:
             results = (
                 self._session.query(UserSyncedRepo, GeneratedRoadmap)
                 .outerjoin(
                     GeneratedRoadmap,
-                    GeneratedRoadmap.repo_full_name
-                    == UserSyncedRepo.repo_full_name,
+                    GeneratedRoadmap.repo_full_name == UserSyncedRepo.repo_full_name,
                 )
                 .filter(
                     UserSyncedRepo.user_id == user_id,