style: apply black formatting to all Python files

- Reformatted 78 files with black
- Fixed code style issues across app/ and tests/
- Ensures consistent formatting for CI/CD checks

Author: zakariaf

app/api/middleware/__init__.py

@@ -63,4 +63,3 @@
     "create_gzip_middleware",
     "default_compression_config",
 ]
-

app/api/middleware/auth.py

@@ -210,9 +210,7 @@ def __init__(
         self._config = config or AuthConfig()
         self._authenticator = authenticator or APIKeyAuthenticator(self._config)
 
-    async def dispatch(
-        self, request: Request, call_next: Callable
-    ) -> Response:
+    async def dispatch(self, request: Request, call_next: Callable) -> Response:
         """
         Process request with authentication.
 
@@ -236,4 +234,3 @@ async def dispatch(
     auth_type=AuthType.API_KEY,
     api_keys=[],
 )
-

app/api/middleware/compression.py

@@ -107,9 +107,7 @@ def _compress(self, body: bytes) -> bytes:
         """Compress body using gzip."""
         return gzip.compress(body, compresslevel=self._config.compression_level)
 
-    async def dispatch(
-        self, request: Request, call_next: Callable
-    ) -> Response:
+    async def dispatch(self, request: Request, call_next: Callable) -> Response:
         """
         Process request with compression.
 
@@ -166,4 +164,3 @@ def create_gzip_middleware(minimum_size: int = 500):
     minimum_size=500,
     compression_level=6,
 )
-

app/api/middleware/logging.py

@@ -77,9 +77,7 @@ def _truncate(self, text: str, max_length: int) -> str:
             return text
         return text[:max_length] + "...[truncated]"
 
-    async def dispatch(
-        self, request: Request, call_next: Callable
-    ) -> Response:
+    async def dispatch(self, request: Request, call_next: Callable) -> Response:
         """
         Process request with logging.
 
@@ -159,4 +157,3 @@ async def dispatch(
     log_response_body=False,
     slow_request_threshold_ms=1000.0,
 )
-

app/api/middleware/rate_limiter.py

@@ -148,9 +148,7 @@ def __init__(
         self._config = config or RateLimitConfig()
         self._limiter = rate_limiter or InMemoryRateLimiter(self._config)
 
-    async def dispatch(
-        self, request: Request, call_next: Callable
-    ) -> Response:
+    async def dispatch(self, request: Request, call_next: Callable) -> Response:
         """
         Process request with rate limiting.
 
@@ -176,9 +174,7 @@ async def dispatch(
 
         # Add rate limit headers
         remaining = self._limiter.get_remaining(request)
-        response.headers["X-RateLimit-Limit"] = str(
-            self._config.requests_per_minute
-        )
+        response.headers["X-RateLimit-Limit"] = str(self._config.requests_per_minute)
         response.headers["X-RateLimit-Remaining"] = str(remaining)
         response.headers["X-RateLimit-Reset"] = str(int(time.time()) + 60)
 
@@ -192,4 +188,3 @@ async def dispatch(
     burst_size=10,
     enabled=True,
 )
-

app/api/routes/__init__.py

@@ -7,4 +7,3 @@
 from app.api.routes import docs, health, metrics, query
 
 __all__ = ["health", "query", "metrics", "docs"]
-

app/api/routes/docs.py

@@ -145,4 +145,3 @@ def get_openapi_config() -> Dict[str, Any]:
     },
     "latency_ms": 45.2,
 }
-

app/api/routes/health.py

@@ -50,11 +50,15 @@ async def check_redis_health(request: Request) -> ComponentHealth:
 
     try:
         if not hasattr(request.app.state, "app_state"):
-            return ComponentHealth(status="unhealthy", message="App state not initialized")
+            return ComponentHealth(
+                status="unhealthy", message="App state not initialized"
+            )
 
         app_state = request.app.state.app_state
         if not app_state.redis_pool:
-            return ComponentHealth(status="unhealthy", message="Redis pool not available")
+            return ComponentHealth(
+                status="unhealthy", message="Redis pool not available"
+            )
 
         from app.repositories.redis_repository import RedisRepository
 
@@ -78,7 +82,9 @@ async def check_qdrant_health(request: Request) -> ComponentHealth:
 
     try:
         if not hasattr(request.app.state, "app_state"):
-            return ComponentHealth(status="unhealthy", message="App state not initialized")
+            return ComponentHealth(
+                status="unhealthy", message="App state not initialized"
+            )
 
         app_state = request.app.state.app_state
         if not app_state.qdrant_client:

app/api/routes/metrics.py

@@ -90,53 +90,38 @@ async def get_prometheus_metrics(request: Request) -> str:
     lines = []
 
     # Application info
-    lines.append(
-        f'# HELP ragcache_info Application information'
-    )
-    lines.append(
-        f'# TYPE ragcache_info gauge'
-    )
-    lines.append(
-        f'ragcache_info{{version="0.1.0",environment="{config.app_env}"}} 1'
-    )
+    lines.append(f"# HELP ragcache_info Application information")
+    lines.append(f"# TYPE ragcache_info gauge")
+    lines.append(f'ragcache_info{{version="0.1.0",environment="{config.app_env}"}} 1')
 
     # Pipeline metrics
     pipeline = metrics.get("pipeline", {})
     if pipeline:
-        lines.append(f'# HELP ragcache_requests_total Total requests processed')
-        lines.append(f'# TYPE ragcache_requests_total counter')
-        lines.append(
-            f'ragcache_requests_total {pipeline.get("total_requests", 0)}'
-        )
-
-        lines.append(f'# HELP ragcache_cache_hits_total Total cache hits')
-        lines.append(f'# TYPE ragcache_cache_hits_total counter')
+        lines.append(f"# HELP ragcache_requests_total Total requests processed")
+        lines.append(f"# TYPE ragcache_requests_total counter")
+        lines.append(f'ragcache_requests_total {pipeline.get("total_requests", 0)}')
+
+        lines.append(f"# HELP ragcache_cache_hits_total Total cache hits")
+        lines.append(f"# TYPE ragcache_cache_hits_total counter")
         lines.append(f'ragcache_cache_hits_total {pipeline.get("cache_hits", 0)}')
 
-        lines.append(f'# HELP ragcache_cache_hit_rate Cache hit rate')
-        lines.append(f'# TYPE ragcache_cache_hit_rate gauge')
-        lines.append(
-            f'ragcache_cache_hit_rate {pipeline.get("cache_hit_rate", 0)}'
-        )
+        lines.append(f"# HELP ragcache_cache_hit_rate Cache hit rate")
+        lines.append(f"# TYPE ragcache_cache_hit_rate gauge")
+        lines.append(f'ragcache_cache_hit_rate {pipeline.get("cache_hit_rate", 0)}')
 
-        lines.append(f'# HELP ragcache_avg_latency_ms Average latency in ms')
-        lines.append(f'# TYPE ragcache_avg_latency_ms gauge')
-        lines.append(
-            f'ragcache_avg_latency_ms {pipeline.get("avg_latency_ms", 0)}'
-        )
+        lines.append(f"# HELP ragcache_avg_latency_ms Average latency in ms")
+        lines.append(f"# TYPE ragcache_avg_latency_ms gauge")
+        lines.append(f'ragcache_avg_latency_ms {pipeline.get("avg_latency_ms", 0)}')
 
     # Redis metrics
     cache = metrics.get("cache", {})
     if cache:
-        lines.append(f'# HELP ragcache_redis_keys Total Redis keys')
-        lines.append(f'# TYPE ragcache_redis_keys gauge')
+        lines.append(f"# HELP ragcache_redis_keys Total Redis keys")
+        lines.append(f"# TYPE ragcache_redis_keys gauge")
         lines.append(f'ragcache_redis_keys {cache.get("total_keys", 0)}')
 
-        lines.append(f'# HELP ragcache_redis_memory_bytes Redis memory usage')
-        lines.append(f'# TYPE ragcache_redis_memory_bytes gauge')
-        lines.append(
-            f'ragcache_redis_memory_bytes {cache.get("memory_used_bytes", 0)}'
-        )
+        lines.append(f"# HELP ragcache_redis_memory_bytes Redis memory usage")
+        lines.append(f"# TYPE ragcache_redis_memory_bytes gauge")
+        lines.append(f'ragcache_redis_memory_bytes {cache.get("memory_used_bytes", 0)}')
 
     return "\n".join(lines)
-

app/api/versioning.py

@@ -79,9 +79,7 @@ def get_router(self, version: APIVersion) -> APIRouter:
             APIRouter for the version
         """
         if version not in self._routers:
-            self._routers[version] = APIRouter(
-                prefix=f"{self._prefix}/{version.value}"
-            )
+            self._routers[version] = APIRouter(prefix=f"{self._prefix}/{version.value}")
         return self._routers[version]
 
     def include_router(
@@ -209,4 +207,3 @@ async def wrapper(*args, **kwargs):
         return wrapper
 
     return decorator
-