From 07dd71b0add78ddcce9ac9fd8ca97bd56aa37feb Mon Sep 17 00:00:00 2001 From: Alexey Polyakov Date: Thu, 12 Mar 2026 19:25:09 +0300 Subject: [PATCH] =?UTF-8?q?=D0=A2=D0=B5=D0=BF=D0=B5=D1=80=D1=8C=20=D0=B2?= =?UTF-8?q?=D1=81=D0=B5=20=D0=B4=D0=BE=D0=BB=D0=B6=D0=BD=D0=BE=20=D1=80?= =?UTF-8?q?=D0=B0=D0=B1=D0=BE=D1=82=D0=B0=D1=82=D1=8C=20=D0=B8=D1=81=D0=BF?= =?UTF-8?q?=D1=80=D0=B0=D0=B2=D0=BD=D0=BE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/oneme_tcp/processors.py | 5 ----- src/oneme_tcp/server.py | 12 ++++++------ 2 files changed, 6 insertions(+), 11 deletions(-) diff --git a/src/oneme_tcp/processors.py b/src/oneme_tcp/processors.py index 05bf8de..05f7bed 100644 --- a/src/oneme_tcp/processors.py +++ b/src/oneme_tcp/processors.py @@ -436,11 +436,6 @@ class Processors: cid = message.get("cid") or 0 text = message.get("text") or "" - # Если клиент вообще ничего не указал в пакете, то выбрасываем ошибку - if not all([userId, chatId, elements, attaches, cid, text]): - await self._send_error(seq, self.proto.MSG_SEND, self.error_types.INVALID_PAYLOAD, writer) - return - # Время отправки сообщения messageTime = int(time.time() * 1000) diff --git a/src/oneme_tcp/server.py b/src/oneme_tcp/server.py index c49ab8d..210c3d3 100644 --- a/src/oneme_tcp/server.py +++ b/src/oneme_tcp/server.py @@ -76,23 +76,23 @@ class OnemeMobileServer: ) case self.proto.MSG_SEND: await self.auth_required( - userPhone, self.processors.process_send_message, payload, seq, writer, senderId=userId, db_pool=self.db_pool + userPhone, self.processors.process_send_message, payload, seq, writer, userId, self.db_pool ) case self.proto.FOLDERS_GET: await self.auth_required( - userPhone, self.processors.process_get_folders, payload, seq, writer, senderPhone=userPhone + userPhone, self.processors.process_get_folders, payload, seq, writer, userPhone ) case self.proto.SESSIONS_INFO: await self.auth_required( - userPhone, self.processors.process_get_sessions, payload, seq, writer, senderPhone=userPhone, hashedToken=hashedToken + userPhone, self.processors.process_get_sessions, payload, seq, writer, userPhone, hashedToken ) case self.proto.CHAT_INFO: await self.auth_required( - userPhone, self.processors.process_search_chats, payload, seq, writer, senderId=userId + userPhone, self.processors.process_search_chats, payload, seq, writer, userId ) case self.proto.CONTACT_INFO_BY_PHONE: await self.auth_required( - userPhone, self.processors.process_search_by_phone, payload, seq, writer, senderId=userId + userPhone, self.processors.process_search_by_phone, payload, seq, writer, userId ) case self.proto.OK_TOKEN: await self.auth_required( @@ -100,7 +100,7 @@ class OnemeMobileServer: ) case self.proto.MSG_TYPING: await self.auth_required( - userPhone, self.processors.process_typing, payload, seq, writer, senderId=userId + userPhone, self.processors.process_typing, payload, seq, writer, userId ) case self.proto.CONTACT_INFO: await self.auth_required(