From 8d7a1dacb55efe9713b1b2d9851c3fc973975d73 Mon Sep 17 00:00:00 2001
From: Alexey Polyakov <starwear3000@mail.ru>
Date: Sun, 22 Mar 2026 16:51:31 +0300
Subject: [PATCH] =?UTF-8?q?=D0=A2=D0=B5=D0=BF=D0=B5=D1=80=D1=8C=20=D0=BC?=
 =?UTF-8?q?=D1=8B=20=D0=BD=D0=B5=20=D0=B4=D0=BE=D0=BB=D0=B6=D0=BD=D1=8B=20?=
 =?UTF-8?q?=D0=BE=D1=82=D0=BF=D1=80=D0=B0=D0=B2=D0=BB=D1=8F=D1=82=D1=8C=20?=
 =?UTF-8?q?128=20=D0=BE=D0=BF=D0=BA=D0=BE=D0=B4=20=D1=81=D0=B0=D0=BC=D0=BE?=
 =?UTF-8?q?=D0=BC=D1=83=20=D1=81=D0=B5=D0=B1=D0=B5.=20=D0=B2=D1=80=D0=BE?=
 =?UTF-8?q?=D0=B4=D0=B5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/oneme/controller.py |  5 +++--
 src/oneme/models.py     |  4 ++--
 src/oneme/processors.py | 10 ++++------
 3 files changed, 9 insertions(+), 10 deletions(-)

diff --git a/src/oneme/controller.py b/src/oneme/controller.py
index 7f96fe8..924a194 100644
--- a/src/oneme/controller.py
+++ b/src/oneme/controller.py
@@ -71,8 +71,9 @@ class OnemeMobileController(ControllerBase):
             )
 
         # Отправляем пакет
-        writer.write(packet)
-        await writer.drain()
+        if writer != eventData.get("writer"):
+            writer.write(packet)
+            await writer.drain()
 
     def launch(self, api):
         async def _start_all():
diff --git a/src/oneme/models.py b/src/oneme/models.py
index fec8b80..8730784 100644
--- a/src/oneme/models.py
+++ b/src/oneme/models.py
@@ -10,12 +10,12 @@ class UserAgentModel(pydantic.BaseModel):
     pushDeviceType: str
     arch: str = None
     locale: str
-    buildNumber: int
+    buildNumber: int = None
     deviceName: str
     deviceLocale: str
 
 class HelloPayloadModel(pydantic.BaseModel):
-    clientSessionId: int
+    clientSessionId: int = None
     mt_instanceid: str = None
     userAgent: UserAgentModel
     deviceId: str
diff --git a/src/oneme/processors.py b/src/oneme/processors.py
index f9b5107..a8a0422 100644
--- a/src/oneme/processors.py
+++ b/src/oneme/processors.py
@@ -525,10 +525,6 @@ class Processors:
             "time": int(time.time() * 1000)
         }
 
-        print(
-            json.dumps(payload, indent=4)
-        )
-
         # Собираем пакет
         packet = self.proto.pack_packet(
             cmd=self.proto.CMD_OK, seq=seq, opcode=self.opcodes.LOGIN, payload=payload
@@ -692,7 +688,8 @@ class Processors:
                     "chatId": 0 if chatId == senderId else chatId,
                     "message": bodyMessage,
                     "prevMessageId": lastMessageId,
-                    "time": messageTime
+                    "time": messageTime,
+                    "writer": writer
                 }
             )
 
@@ -1263,7 +1260,8 @@ class Processors:
             user.get('id'),
             {
                 "eventType": "profile_updated",
-                "profile": profile
+                "profile": profile,
+                "writer": writer
             }     
         )