|
5 | 5 |
|
6 | 6 | import logging |
7 | 7 | from collections.abc import Awaitable, Callable |
8 | | -from typing import Any, Union |
| 8 | +from typing import Any |
9 | 9 |
|
10 | 10 | from aiohttp import web |
11 | 11 | from aiohttp.web_request import Request |
@@ -37,7 +37,7 @@ def is_api_request(request: web.Request, api_version: str) -> bool: |
37 | 37 | return bool(request.path.startswith(base_path)) |
38 | 38 |
|
39 | 39 |
|
40 | | -def error_middleware_factory( |
| 40 | +def error_middleware_factory( # noqa: C901 |
41 | 41 | api_version: str, |
42 | 42 | ) -> Middleware: |
43 | 43 | _is_prod: bool = is_production_environ() |
@@ -69,7 +69,7 @@ def _process_and_raise_unexpected_error(request: web.BaseRequest, err: Exception |
69 | 69 | raise http_error |
70 | 70 |
|
71 | 71 | @web.middleware |
72 | | - async def _middleware_handler(request: web.Request, handler: Handler): |
| 72 | + async def _middleware_handler(request: web.Request, handler: Handler): # noqa: C901 |
73 | 73 | """ |
74 | 74 | Ensure all error raised are properly enveloped and json responses |
75 | 75 | """ |
@@ -147,12 +147,14 @@ async def _middleware_handler(request: web.Request, handler: Handler): |
147 | 147 | return _middleware_handler |
148 | 148 |
|
149 | 149 |
|
150 | | -_ResponseOrBodyData = Union[StreamResponse, Any] |
| 150 | +_ResponseOrBodyData = StreamResponse | Any |
151 | 151 | HandlerFlexible = Callable[[Request], Awaitable[_ResponseOrBodyData]] |
152 | 152 | MiddlewareFlexible = Callable[[Request, HandlerFlexible], Awaitable[StreamResponse]] |
153 | 153 |
|
154 | 154 |
|
155 | | -def envelope_middleware_factory(api_version: str) -> MiddlewareFlexible: |
| 155 | +def envelope_middleware_factory( |
| 156 | + api_version: str, |
| 157 | +) -> Callable[..., Awaitable[StreamResponse]]: |
156 | 158 | # FIXME: This data conversion is very error-prone. Use decorators instead! |
157 | 159 | _is_prod: bool = is_production_environ() |
158 | 160 |
|
|
0 commit comments