Обновил версию до 1.2.6 и оптимизировал импорты в SocketMixin

Author: ink-developer

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "maxapi-python"
-version = "1.2.5"
+version = "1.2.6"
 description = "Python wrapper для API мессенджера Max"
 readme = "README.md"
 requires-python = ">=3.10"

src/pymax/mixins/socket.py

@@ -4,10 +4,7 @@
 import socket
 import ssl
 import sys
-import time
-import traceback
-from collections.abc import Callable
-from typing import Any, Literal
+from typing import Any
 from urllib.parse import urlparse
 
 import lz4.block
@@ -17,31 +14,22 @@
 from pymax.exceptions import Error, SocketNotConnectedError, SocketSendError
 from pymax.filters import BaseFilter
 from pymax.interfaces import BaseTransport
-from pymax.payloads import BaseWebSocketMessage, SyncPayload, UserAgentPayload
-from pymax.protocols import ClientProtocol
+from pymax.payloads import UserAgentPayload
 from pymax.static.constant import (
-    DEFAULT_PING_INTERVAL,
     DEFAULT_TIMEOUT,
     RECV_LOOP_BACKOFF_DELAY,
 )
-from pymax.static.enum import ChatType, MessageStatus, Opcode
+from pymax.static.enum import Opcode
 from pymax.types import (
-    Channel,
     Chat,
-    Dialog,
-    Me,
-    Message,
-    ReactionCounter,
-    ReactionInfo,
-    User,
 )
 
 
 class SocketMixin(BaseTransport):
     def _close_socket_safely(self) -> None:
         if self._socket is not None:
             sock = self._socket
-            self._socket = None  # Nullify reference first to prevent double-closes
+            self._socket = None
             with contextlib.suppress(ssl.SSLError, Exception):
                 sock.close()
 
@@ -365,13 +353,15 @@ async def _recv_loop(self) -> None:
 
         while True:
             try:
-                sock = self._socket  # Get fresh reference on each iteration
+                sock = self._socket
                 if sock is None:
                     self.logger.warning("Socket became None, exiting recv loop")
                     break
 
                 header = await self._parse_header(loop, sock)
 
+                self.logger.debug("Received header: %s", header)
+
                 if not header:
                     break