From dcbcb0a600e93a4273b44af9541eb4284a1482b4 Mon Sep 17 00:00:00 2001
From: Alexey Polyakov <starwear3000@mail.ru>
Date: Fri, 10 Apr 2026 17:43:35 +0300
Subject: [PATCH] =?UTF-8?q?Common:=20=D0=B4=D0=BE=D0=B1=D0=B0=D0=B2=D0=B8?=
 =?UTF-8?q?=D0=BB=20=D1=81=D0=B6=D0=B0=D1=82=D0=B8=D0=B5=20lz4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/common/proto_tcp.py      | 53 ++++++++++++++++++++++++++++--------
 src/oneme/processors/auth.py |  6 ++--
 2 files changed, 45 insertions(+), 14 deletions(-)

diff --git a/src/common/proto_tcp.py b/src/common/proto_tcp.py
index 536c79b..646dffb 100644
--- a/src/common/proto_tcp.py
+++ b/src/common/proto_tcp.py
@@ -69,7 +69,7 @@ class MobileProto:
             payload = msgpack.unpackb(payload_bytes, raw=False, strict_map_key=False)
 
         self.logger.debug(
-            f"Распаковал - ver={ver} cmd={cmd} seq={seq} opcode={opcode} payload={payload}"
+            f"Распаковал - ver={ver} cmd={cmd} seq={seq} opcode={opcode} payload={payload} comp_flag={comp_flag}"
         )
 
         # Возвращаем
@@ -83,8 +83,8 @@ class MobileProto:
 
     def pack_packet(
         self,
-        ver: int = 11,
-        cmd: int = 0x100,
+        ver: int = 10,
+        cmd: int = 1,
         seq: int = 1,
         opcode: int = 6,
         payload: dict = {},
@@ -99,18 +99,49 @@ class MobileProto:
         payload_bytes: bytes | None = msgpack.packb(payload)
         if payload_bytes is None:
             payload_bytes = b""
-        payload_len = len(payload_bytes) & 0xFFFFFF
-        payload_len_b = payload_len.to_bytes(4, "big")
+
+        # Флаг сжатия
+        comp_flag = 0
+
+        # Пробуем сжать данные пакета
+        try:
+            payload_comp = lz4.block.compress(
+                payload_bytes,
+                mode='high_compression',
+                store_size=False,
+            )
+
+            # Если сжатие нам выгодно, то используем его
+            if len(payload_bytes) > len(payload_comp):
+                final_payload = payload_comp
+
+                # Официальный сервер MAX отправлял мне в качестве
+                # флага сжатия 2, поэтому думаю стоит использовать ее
+                comp_flag = 2
+            else:
+                # В случае если сжатие нам не выгодно, используем
+                # только запакованные данные через msgpack
+                final_payload = payload_bytes
+        except Exception as e:
+            self.logger.warning(f"Ошибка сжатия LZ4: {e}")
+
+            # В случае ошибки сжатия используем 
+            # только запакованные данные через msgpack
+            final_payload = payload_bytes
+
+        payload_len = len(final_payload) & 0xFFFFFF
+        packed_len = (comp_flag << 24) | payload_len
+        payload_len_b = packed_len.to_bytes(4, "big")
 
         self.logger.debug(
-            f"Упаковал - ver={ver} cmd={cmd} seq={seq} opcode={opcode} payload={payload}"
+            f"Упаковал - ver={ver} cmd={cmd} seq={seq} opcode={opcode} payload={payload} comp_flag={comp_flag}"
         )
 
         # Возвращаем пакет
-        return ver_b + cmd_b + seq_b + opcode_b + payload_len_b + payload_bytes
+        return ver_b + cmd_b + seq_b + opcode_b + payload_len_b + final_payload
 
     ### Констаты протокола
-    CMD_OK = 1  # 0x100
-    CMD_NOF = 2  # 0x200
-    CMD_ERR = 3  # 0x300
-    PROTO_VER = 11  # 10 для android клиента
+    CMD_OK = 1
+    CMD_NOF = 2
+    CMD_ERR = 3
+    PROTO_VER = 10
diff --git a/src/oneme/processors/auth.py b/src/oneme/processors/auth.py
index 652768a..c2c70bf 100644
--- a/src/oneme/processors/auth.py
+++ b/src/oneme/processors/auth.py
@@ -84,11 +84,11 @@ class AuthProcessors(BaseProcessor):
 
         # Данные пакета
         payload = {
+            "token": token,
+            "codeLength": 6,
             "requestMaxDuration": 60000,
             "requestCountLeft": 10,
-            "altActionDuration": 60000,
-            "codeLength": 6,
-            "token": token
+            "altActionDuration": 60000
         }
 
         # Собираем пакет