Обновление документации и улучшение обработки аутентификации, включая поддержку двухфакторной аутентификации и исправления для работы с сокетами.

Author: ink-developer

redocs/source/release_notes.rst

@@ -85,59 +85,7 @@ Video
 
 ---
 
-Release Notes v1.2.3
-====================
-
-Новые функции
--------------
-
-**Загрузка фотографий профиля**
-    Профиль теперь может быть обновлен с загрузкой новой фотографии через метод ``change_profile()``.
-
-**Разрешение групп по ссылке**
-    Группы теперь могут быть разрешены (получены) прямо по их ссылке через метод ``resolve_group_by_link()``.
-
-**Поддержка контактов в сообщениях**
-    Сообщения теперь поддерживают вложения типа контакта с информацией о контакте (ContactAttach).
-
-**Список контактов клиента**
-    Клиент теперь ведет список всех контактов пользователя через свойство ``client.contacts``.
-
-Новые методы
-------------
-
-MaxClient.resolve_group_by_link(link: str) -> Chat | None
-    Разрешает группу по ссылке. Возвращает объект чата группы или None, если не найдено.
-
-MaxClient.change_profile(first_name, last_name, description, photo)
-    Изменяет информацию профиля текущего пользователя, включая загрузку новой фотографии.
-
-Новые типы
-----------
-
-ContactAttach
-    Представляет контакт в сообщении. Содержит информацию о контакте (ID, имя, фамилия, фото).
-
-Измененные типы
----------------
-
-Message
-    Теперь поддерживает вложения типа ContactAttach в список attaches.
-
-Names
-    Улучшен для работы с различными форматами имен пользователя.
-
-StickerAttach
-    Улучшено представление стикеров в сообщениях.
-
-Photo
-    Улучшено для работы с фотографиями профиля.
-
-AttachType
-    Добавлено значение CONTACT для контактов.
-
-Новые параметры
----------------
+Архив
+-----
 
-MaxClient.contacts: list[User]
-    Список контактов текущего пользователя.
+Предыдущие версии доступны в :doc:`release_notes_archive`.

redocs/source/release_notes_archive.rst

@@ -0,0 +1,61 @@
+Archive
+=======
+
+Архив предыдущих версий.
+
+v1.2.3 (24 декабря 2025)
+=========================
+
+Новые функции
+-------------
+
+**Загрузка фотографий профиля**
+    Профиль теперь может быть обновлен с загрузкой новой фотографии через метод ``change_profile()``.
+
+**Разрешение групп по ссылке**
+    Группы теперь могут быть разрешены (получены) прямо по их ссылке через метод ``resolve_group_by_link()``.
+
+**Поддержка контактов в сообщениях**
+    Сообщения теперь поддерживают вложения типа контакта с информацией о контакте (ContactAttach).
+
+**Список контактов клиента**
+    Клиент теперь ведет список всех контактов пользователя через свойство ``client.contacts``.
+
+Новые методы
+------------
+
+MaxClient.resolve_group_by_link(link: str) -> Chat | None
+    Разрешает группу по ссылке. Возвращает объект чата группы или None, если не найдено.
+
+MaxClient.change_profile(first_name, last_name, description, photo)
+    Изменяет информацию профиля текущего пользователя, включая загрузку новой фотографии.
+
+Новые типы
+----------
+
+ContactAttach
+    Представляет контакт в сообщении. Содержит информацию о контакте (ID, имя, фамилия, фото).
+
+Измененные типы
+---------------
+
+Message
+    Теперь поддерживает вложения типа ContactAttach в список attaches.
+
+Names
+    Улучшен для работы с различными форматами имен пользователя.
+
+StickerAttach
+    Улучшено представление стикеров в сообщениях.
+
+Photo
+    Улучшено для работы с фотографиями профиля.
+
+AttachType
+    Добавлено значение CONTACT для контактов.
+
+Новые параметры
+---------------
+
+MaxClient.contacts: list[User]
+    Список контактов текущего пользователя.

src/pymax/core.py

@@ -134,7 +134,7 @@ def __init__(
         self._background_tasks: set[asyncio.Task[Any]] = set()
         self._stop_event = asyncio.Event()
 
-        self._seq: int = 0
+        self._seq: int = 255
         self._error_count: int = 0
         self._circuit_breaker: bool = False
         self._last_error_time: float = 0.0
@@ -252,7 +252,15 @@ async def login_with_code(self, temp_token: str, code: str, start: bool = False)
         :rtype: None
         """
         resp = await self._send_code(code, temp_token)
-        token = resp.get("tokenAttrs", {}).get("LOGIN", {}).get("token")
+
+        login_attrs = resp.get("tokenAttrs", {}).get("LOGIN", {})
+        password_challenge = resp.get("passwordChallenge")
+
+        if password_challenge and not login_attrs:
+            token = await self._two_factor_auth(password_challenge)
+        else:
+            token = login_attrs.get("LOGIN", {}).get("token")
+
         if not token:
             raise ValueError("Login response did not contain tokenAttrs.LOGIN.token")
         self._token = token

src/pymax/interfaces.py

@@ -10,7 +10,7 @@
 
 from typing_extensions import Self
 
-from pymax.exceptions import WebSocketNotConnectedError
+from pymax.exceptions import SocketNotConnectedError, WebSocketNotConnectedError
 from pymax.filters import BaseFilter
 from pymax.formatter import ColoredFormatter
 from pymax.payloads import BaseWebSocketMessage, SyncPayload, UserAgentPayload
@@ -188,6 +188,7 @@ def _make_message(
         self._seq += 1
 
         msg = BaseWebSocketMessage(
+            ver=11,
             cmd=cmd,
             seq=self._seq,
             opcode=opcode.value,
@@ -206,8 +207,11 @@ async def _send_interactive_ping(self) -> None:
                     cmd=0,
                 )
                 self.logger.debug("Interactive ping sent successfully")
+            except SocketNotConnectedError:
+                self.logger.debug("Socket disconnected, exiting ping loop")
+                break
             except Exception:
-                self.logger.warning("Interactive ping failed", exc_info=True)
+                self.logger.warning("Interactive ping failed")
             await asyncio.sleep(DEFAULT_PING_INTERVAL)
 
     async def _handshake(self, user_agent: UserAgentPayload) -> dict[str, Any]:
@@ -283,6 +287,8 @@ async def _handle_file_upload(self, data: dict[str, Any]) -> None:
                     self.logger.debug("Fulfilled file upload waiter for %s=%s", key, id_)
 
     async def _send_notification_response(self, chat_id: int, message_id: str) -> None:
+        if self._socket is not None and self.is_connected:
+            return
         await self._send_and_wait(
             opcode=Opcode.NOTIF_MESSAGE,
             payload={"chatId": chat_id, "messageId": message_id},