[pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

Author: pre-commit-ci[bot]

pyproject.toml

@@ -84,8 +84,8 @@ dependencies = [
     #   NOTE: 👇
     #   The versions of `black`, `ruff`, `codespell`,  must be consistent with the `.pre-commit-config.yaml`.
     #   Don't edit them manually, use `pre-commit run ver_sync` instead.
-    "black==23.12.0",
-    "ruff==0.1.8",
+    "black==24.3.0",
+    "ruff==0.3.4",
     "codespell==2.2.6",
     #   Don't write comments on these lines, because they will be removed by `pre-commit run ver_sync`.
     #   NOTE: 👆

src/fastapi_proxy_lib/__init__.py

@@ -1,6 +1,5 @@
 """fastapi_proxy_lib package."""
 
-
 # DO NOT EDIT THE `__version__` MANUALLY.
 # Use `hatch version {new_version}` instead.
 # Refer to `CONTRIBUTING.md` for more info.

src/fastapi_proxy_lib/core/_tool.py

@@ -80,8 +80,7 @@ def __call__(
         *,
         msg: object,
         exc_info: Union[BaseException, None, bool],
-    ) -> Any:
-        ...
+    ) -> Any: ...
 
 
 class ErrMsg(TypedDict):
@@ -316,9 +315,9 @@ def return_err_msg_response(
     if logger is not None:
         # 只要传入了logger，就一定记录日志
         logger(
-            msg=_msg
-            if _msg is not None
-            else err_response_json,  # 如果没有指定 _msg ，则使用content
+            msg=(
+                _msg if _msg is not None else err_response_json
+            ),  # 如果没有指定 _msg ，则使用content
             exc_info=_exc_info,
         )
     else:
@@ -395,13 +394,11 @@ def default_proxy_filter(url: httpx.URL) -> Union[None, str]:
 
 
 @overload
-def warn_for_none_filter(proxy_filter: _ProxyFilterTypeVar) -> _ProxyFilterTypeVar:
-    ...
+def warn_for_none_filter(proxy_filter: _ProxyFilterTypeVar) -> _ProxyFilterTypeVar: ...
 
 
 @overload
-def warn_for_none_filter(proxy_filter: None) -> ProxyFilterProto:
-    ...
+def warn_for_none_filter(proxy_filter: None) -> ProxyFilterProto: ...
 
 
 def warn_for_none_filter(

src/fastapi_proxy_lib/core/tool.py

@@ -1,6 +1,5 @@
 """User-oriented tool library."""
 
-
 from ._tool import ProxyFilterProto, default_proxy_filter
 
 __all__ = ("default_proxy_filter", "ProxyFilterProto")

src/fastapi_proxy_lib/core/websocket.py

@@ -368,7 +368,9 @@ async def _close_ws(
 """
             logging.warning(msg)
 
-    except Exception as e:  # pragma: no cover # 这个分支是一个保险分支，通常无法执行，所以只进行记录
+    except (
+        Exception
+    ) as e:  # pragma: no cover # 这个分支是一个保险分支，通常无法执行，所以只进行记录
         logging.error(
             f"{e} when close ws connection. client: {client_to_server_task}, server:{server_to_client_task}"
         )
@@ -482,9 +484,9 @@ async def send_request_to_target(  # pyright: ignore [reportIncompatibleMethodOv
         keepalive_ping_interval_seconds = self.keepalive_ping_interval_seconds
         keepalive_ping_timeout_seconds = self.keepalive_ping_timeout_seconds
 
-        client_request_subprotocols: Union[
-            List[str], None
-        ] = _get_client_request_subprotocols(websocket.scope)
+        client_request_subprotocols: Union[List[str], None] = (
+            _get_client_request_subprotocols(websocket.scope)
+        )
 
         # httpx.stream()
         # refer to: https://www.python-httpx.org/api/#helper-functions
@@ -612,7 +614,9 @@ async def send_request_to_target(  # pyright: ignore [reportIncompatibleMethodOv
                     task_group,
                     return_when=asyncio.FIRST_COMPLETED,
                 )
-                for pending_task in pending:  # NOTE: pending 一般为一个未结束任务，或者为空
+                for (
+                    pending_task
+                ) in pending:  # NOTE: pending 一般为一个未结束任务，或者为空
                     # 开始取消未结束的任务
                     try:
                         await asyncio.wait_for(pending_task, timeout=1)

src/fastapi_proxy_lib/fastapi/router.py

@@ -170,9 +170,9 @@ class RouterHelper:
 
     def __init__(self) -> None:
         """Initialize RouterHelper."""
-        self._registered_proxy: Set[
-            Union[_HttpProxyTypes, _WebSocketProxyTypes]
-        ] = set()
+        self._registered_proxy: Set[Union[_HttpProxyTypes, _WebSocketProxyTypes]] = (
+            set()
+        )
         self._registered_router_id: Set[int] = set()
 
     @property

tests/conftest.py

@@ -65,8 +65,7 @@ class LifeAppDataclass4Test(AppDataclass4Test):
 class UvicornServerFixture(Protocol):  # noqa: D101
     def __call__(  # noqa: D102
         self, config: uvicorn.Config, contx_exit_timeout: Union[int, float, None] = None
-    ) -> Coroutine[None, None, UvicornServer]:
-        ...
+    ) -> Coroutine[None, None, UvicornServer]: ...
 
 
 # https://anyio.readthedocs.io/en/stable/testing.html#specifying-the-backends-to-run-on