format files

Author: p1p1daster

pybotx/async_buffer.py

@@ -13,27 +13,30 @@ async def seek(
         self,
         cursor: int,
         whence: int = os.SEEK_SET,
-    ) -> int: ...  # noqa: WPS428, E704
+    ) -> int:
+        ...
 
-    async def tell(self) -> int: ...  # noqa: WPS428, E704
+    async def tell(self) -> int:
+        ...
 
 
 class AsyncBufferWritable(AsyncBufferBase):
     @abc.abstractmethod
-    async def write(self, content: bytes) -> int: ...  # noqa: WPS428, E704
+    async def write(self, content: bytes) -> int:
+        ...
 
 
 class AsyncBufferReadable(AsyncBufferBase):
     @abc.abstractmethod
     async def read(
         self,
         bytes_to_read: Optional[int] = None,
-    ) -> bytes: ...  # noqa: WPS428, E704
+    ) -> bytes:
+        ...
 
 
 async def get_file_size(async_buffer: AsyncBufferReadable) -> int:
     await async_buffer.seek(0, os.SEEK_END)
     file_size = await async_buffer.tell()
     await async_buffer.seek(0)
-
     return file_size

pybotx/bot/callbacks/callback_manager.py

@@ -69,14 +69,16 @@ def setup_callback_timeout_alarm(self, sync_id: UUID, timeout: float) -> None:
     def cancel_callback_timeout_alarm(
         self,
         sync_id: UUID,
-    ) -> None: ...  # noqa: WPS428, E704
+    ) -> None:
+        ...  # noqa: WPS428, E704
 
     @overload
     def cancel_callback_timeout_alarm(
         self,
         sync_id: UUID,
         return_remaining_time: Literal[True],
-    ) -> float: ...  # noqa: WPS428, E704
+    ) -> float:
+        ...  # noqa: WPS428, E704
 
     def cancel_callback_timeout_alarm(
         self,

pybotx/bot/callbacks/callback_repo_proto.py

@@ -16,22 +16,26 @@ class CallbackRepoProto(Protocol):
     async def create_botx_method_callback(
         self,
         sync_id: UUID,
-    ) -> None: ...  # noqa: WPS428, E704
+    ) -> None:
+        ...  # noqa: WPS428, E704
 
     async def set_botx_method_callback_result(
         self,
         callback: BotXMethodCallback,
-    ) -> None: ...  # noqa: WPS428, E704
+    ) -> None:
+        ...  # noqa: WPS428, E704
 
     async def wait_botx_method_callback(
         self,
         sync_id: UUID,
         timeout: float,
-    ) -> BotXMethodCallback: ...  # noqa: WPS428, E704
+    ) -> BotXMethodCallback:
+        ...  # noqa: WPS428, E704
 
     async def pop_botx_method_callback(
         self,
         sync_id: UUID,
-    ) -> "Future[BotXMethodCallback]": ...  # noqa: WPS428, E704
+    ) -> "Future[BotXMethodCallback]":
+        ...  # noqa: WPS428, E704
 
     async def stop_callbacks_waiting(self) -> None: ...  # noqa: WPS428, E704

pybotx/bot/handler.py

@@ -77,7 +77,10 @@ async def __call__(self, message: IncomingMessage, bot: "Bot") -> None:
         handler_func = self.handler_func
 
         for middleware in self.middlewares[::-1]:
-            handler_func = partial(middleware, call_next=handler_func)  # type: ignore[call-arg]
+            handler_func = partial(
+                middleware,
+                call_next=handler_func,  # type: ignore[call-arg]
+            )
 
         await handler_func(message, bot)
 

pybotx/bot/handler_collector.py

@@ -194,17 +194,16 @@ def decorator(
     def default_message_handler(
         self,
         handler_func: IncomingMessageHandlerFunc,
-    ) -> IncomingMessageHandlerFunc: ...  # noqa: WPS428, E704
+    ) -> IncomingMessageHandlerFunc:
+        ...  # noqa: WPS428, E704
 
     @overload
     def default_message_handler(
         self,
         *,
         middlewares: Optional[Sequence[Middleware]] = None,
-    ) -> Callable[
-        [IncomingMessageHandlerFunc],
-        IncomingMessageHandlerFunc,
-    ]: ...  # noqa: WPS428, E704
+    ) -> Callable[[IncomingMessageHandlerFunc], IncomingMessageHandlerFunc]:
+        ...  # noqa: WPS428, E704
 
     def default_message_handler(  # noqa: WPS320
         self,

pybotx/models/enums.py

@@ -307,13 +307,15 @@ def convert_chat_type_from_domain(chat_type: ChatTypes) -> APIChatTypes:
 @overload
 def convert_chat_type_to_domain(
     chat_type: APIChatTypes,
-) -> ChatTypes: ...  # noqa: WPS428, E704
+) -> ChatTypes:
+    ...  # noqa: WPS428, E704
 
 
 @overload
 def convert_chat_type_to_domain(
     chat_type: str,
-) -> UNSUPPORTED: ...  # noqa: WPS428, E704
+) -> UNSUPPORTED:
+    ...  # noqa: WPS428, E704
 
 
 def convert_chat_type_to_domain(
@@ -340,13 +342,15 @@ def convert_chat_type_to_domain(
 @overload
 def convert_sync_source_type_to_domain(
     sync_type: APISyncSourceTypes,
-) -> SyncSourceTypes: ...  # noqa: WPS428, E704
+) -> SyncSourceTypes:
+    ...  # noqa: WPS428, E704
 
 
 @overload
 def convert_sync_source_type_to_domain(
     sync_type: str,
-) -> UNSUPPORTED: ...  # noqa: WPS428, E704
+) -> UNSUPPORTED:
+    ...  # noqa: WPS428, E704
 
 
 def convert_sync_source_type_to_domain(

tests/test_handler_collector.py

@@ -562,6 +562,7 @@ async def test__handler_collector__sync_smartapp_event__decorator__handler_alrea
         @collector.sync_smartapp_event
         async def duplicated_handle_sync_smartapp_event(
             *_: Any,
-        ) -> Any: ...  # noqa: E704
+        ) -> Any:
+            ...  # noqa: E704
 
     assert str(exc.value) == "Handler for sync smartapp event already registered"

tests/test_middlewares.py

@@ -35,8 +35,7 @@ async def middleware(
             bot: Bot,
             call_next: IncomingMessageHandlerFunc,
         ) -> None:
-            # middlewares_called_order is already accessible in this scope
-            middlewares_called_order.append(number)
+            middlewares_called_order.append(number)  # noqa: F824
 
             await call_next(message, bot)
 
@@ -84,8 +83,7 @@ async def middleware(
             bot: Bot,
             call_next: IncomingMessageHandlerFunc,
         ) -> None:
-            # middlewares_called_order is already accessible in this scope
-            middlewares_called_order.append(number)
+            middlewares_called_order.append(number)  # noqa: F824
 
             await call_next(message, bot)
 
@@ -129,8 +127,7 @@ async def middleware(
             bot: Bot,
             call_next: IncomingMessageHandlerFunc,
         ) -> None:
-            # middlewares_called_order is already accessible in this scope
-            middlewares_called_order.append(number)
+            middlewares_called_order.append(number)  # noqa: F824
 
             await call_next(message, bot)
 
@@ -177,7 +174,7 @@ async def middleware(
             bot: Bot,
             call_next: IncomingMessageHandlerFunc,
         ) -> None:
-            nonlocal middlewares_called_order
+            nonlocal middlewares_called_order  # noqa: F824
             middlewares_called_order.append(number)
 
             await call_next(message, bot)