добавил chat_marker для fetch_chats

Author: ink-developer

src/pymax/core.py

@@ -121,6 +121,7 @@ def __init__(
         self.channels: list[Channel] = []
         self.me: Me | None = None
         self.contacts: list[User] = []
+        self.chat_marker: int | None = None
         self._users: dict[int, User] = {}
 
         self._work_dir: str = work_dir
@@ -143,7 +144,7 @@ def __init__(
         self._sock_lock = asyncio.Lock()
         self._read_buffer = bytearray()
 
-        self._seq: int = 0
+        self._seq: int = -1
         self._error_count: int = 0
         self._circuit_breaker: bool = False
         self._last_error_time: float = 0.0

src/pymax/interfaces.py

@@ -527,17 +527,20 @@ async def _sync(self, user_agent: UserAgentPayload | None = None) -> None:
             token=self._token,
             chats_sync=0,
             contacts_sync=0,
-            presence_sync=0,
+            presence_sync=-1,
             drafts_sync=0,
             chats_count=40,
             user_agent=user_agent,
-        ).model_dump(by_alias=True)
+        ).model_dump(by_alias=True, exclude_none=True, exclude_unset=True)
         try:
             data = await self._send_and_wait(opcode=Opcode.LOGIN, payload=payload)
             raw_payload = data.get("payload", {})
 
             if error := raw_payload.get("error"):
                 MixinsUtils.handle_error(data)
+            chat_marker = raw_payload.get("chatMarker")
+            if chat_marker:
+                self.chat_marker = chat_marker
 
             for raw_chat in raw_payload.get("chats", []):
                 try:

src/pymax/mixins/websocket.py

@@ -84,6 +84,7 @@ async def _recv_loop(self) -> None:
         while True:
             try:
                 raw = await self._ws.recv()
+                self.logger.debug("RAW IN: %s", raw)
                 data = self._parse_json(raw)
 
                 if data is None:
@@ -97,7 +98,7 @@ async def _recv_loop(self) -> None:
                 await self._dispatch_incoming(data)
 
             except websockets.exceptions.ConnectionClosed as e:
-                self.logger.info(
+                self.logger.exception(
                     f"WebSocket connection closed with error: {e.code}, {e.reason}; exiting recv loop"
                 )
                 for fut in self._pending.values():

src/pymax/payloads.py

@@ -76,7 +76,7 @@ class SyncPayload(CamelModel):
     token: str
     chats_sync: int = 0
     contacts_sync: int = 0
-    presence_sync: int = 0
+    presence_sync: int = -1
     drafts_sync: int = 0
     chats_count: int = 40
     user_agent: UserAgentPayload = Field(

src/pymax/protocols.py

@@ -45,6 +45,7 @@ def __init__(self, logger: Logger) -> None:
         self.channels: list[Channel] = []
         self.contacts: list[User] = []
         self.me: Me | None = None
+        self.chat_marker: int | None = None
         self.host: str
         self.port: int
         self.proxy: str | Literal[True] | None