Generic base middleware class (#6)

src/huntflow_base_metrics/web_frameworks/_middleware.py

@@ -1,6 +1,6 @@
 import abc
 from dataclasses import dataclass
-from typing import Any, Optional, Set
+from typing import Generic, Optional, Set, TypeVar
 
 from huntflow_base_metrics._context import METRIC_CONTEXT
 
@@ -11,13 +11,16 @@ class PathTemplate:
     is_handled: bool
 
 
-class PrometheusMiddleware(abc.ABC):
+RequestType = TypeVar("RequestType")
+
+
+class PrometheusMiddleware(abc.ABC, Generic[RequestType]):
     include_routes: Optional[Set[str]] = None
     exclude_routes: Optional[Set[str]] = None
 
     @staticmethod
     @abc.abstractmethod
-    def get_path_template(request: Any) -> PathTemplate:
+    def get_path_template(request: RequestType) -> PathTemplate:
         pass
 
     @classmethod

src/huntflow_base_metrics/web_frameworks/aiohttp.py

@@ -18,7 +18,7 @@
 __all__ = ["add_middleware", "get_http_response_metrics"]
 
 
-class _PrometheusMiddleware(PrometheusMiddleware):
+class _PrometheusMiddleware(PrometheusMiddleware[Request]):
     @classmethod
     @middleware
     async def dispatch(cls, request: Request, handler: Callable) -> Response:

src/huntflow_base_metrics/web_frameworks/fastapi.py

@@ -22,7 +22,7 @@
 __all__ = ["add_middleware", "get_http_response_metrics"]
 
 
-class _PrometheusMiddleware(PrometheusMiddleware, BaseHTTPMiddleware):
+class _PrometheusMiddleware(PrometheusMiddleware[Request], BaseHTTPMiddleware):
     async def dispatch(self, request: Request, call_next: RequestResponseEndpoint) -> Response:
         method = request.method
         path_template = self.get_path_template(request)

src/huntflow_base_metrics/web_frameworks/litestar.py

@@ -44,7 +44,7 @@ class _RequestSpan:
     status_code: int = 200
 
 
-class _PrometheusMiddleware(PrometheusMiddleware, AbstractMiddleware):
+class _PrometheusMiddleware(PrometheusMiddleware[Request], AbstractMiddleware):
     scopes = {ScopeType.HTTP}
 
     def __init__(self, app: ASGIApp, *args: Any, **kwargs: Any) -> None: