Fix protocol header layout: cmd uint8 + seq uint16 to match server

Author: klockky

lib/api/api_registration_service.dart

@@ -26,7 +26,8 @@ typedef Lz4Decompress =
 
 class RegistrationService {
   Socket? _socket;
-  int _seq = 0;
+  // Начинаем с 1, чтобы seq=0 (server push) не совпал с pending.
+  int _seq = 1;
   final Map<int, Completer<dynamic>> _pending = {};
   bool _isConnected = false;
   final _random = Random();
@@ -160,15 +161,12 @@ class RegistrationService {
 
   void _processPacket(Uint8List packet) {
     try {
-      final ver = packet[0];
-      final cmd = ByteData.view(packet.buffer).getUint16(1, Endian.big);
-      final seq = packet[3];
-      final opcode = ByteData.view(packet.buffer).getUint16(4, Endian.big);
-      final packedLen = ByteData.view(
-        packet.buffer,
-        6,
-        4,
-      ).getUint32(0, Endian.big);
+      final bd = ByteData.view(packet.buffer, packet.offsetInBytes, packet.lengthInBytes);
+      final ver = bd.getUint8(0);
+      final cmd = bd.getUint8(1);
+      final seq = bd.getUint16(2, Endian.big);
+      final opcode = bd.getUint16(4, Endian.big);
+      final packedLen = bd.getUint32(6, Endian.big);
 
       final compFlag = packedLen >> 24;
       final payloadLen = packedLen & 0x00FFFFFF;
@@ -215,20 +213,19 @@ class RegistrationService {
     int opcode,
     Map<String, dynamic> payload,
   ) {
-    final verB = Uint8List(1)..[0] = ver;
-    final cmdB = Uint8List(2)
-      ..buffer.asByteData().setUint16(0, cmd, Endian.big);
-    final seqB = Uint8List(1)..[0] = seq;
-    final opcodeB = Uint8List(2)
-      ..buffer.asByteData().setUint16(0, opcode, Endian.big);
+    // Заголовок: ver(1) + cmd(1) + seq(2 BE) + opcode(2 BE) + packedLen(4 BE) = 10 байт
+    final header = ByteData(10);
+    header.setUint8(0, ver);
+    header.setUint8(1, cmd);
+    header.setUint16(2, seq & 0xFFFF, Endian.big);
+    header.setUint16(4, opcode, Endian.big);
 
     final payloadBytes = msgpack.serialize(payload);
     final payloadLen = payloadBytes.length & 0xFFFFFF;
-    final payloadLenB = Uint8List(4)
-      ..buffer.asByteData().setUint32(0, payloadLen, Endian.big);
+    header.setUint32(6, payloadLen, Endian.big);
 
     final packet = Uint8List.fromList(
-      verB + cmdB + seqB + opcodeB + payloadLenB + payloadBytes,
+      header.buffer.asUint8List() + payloadBytes,
     );
 
     print('═══════════════════════════════════════════════════════════');
@@ -585,7 +582,7 @@ class RegistrationService {
       throw Exception('Не подключено к серверу');
     }
 
-    _seq = (_seq + 1) % 256;
+    _seq = (_seq + 1) & 0xFFFF;
     final seq = _seq;
     final packet = _packPacket(10, 0, seq, opcode, payload);
 

lib/api/api_service.dart

@@ -101,7 +101,8 @@ class ApiService {
   StreamSubscription? _socketSubscription;
   Timer? _pingTimer;
   Timer? _analyticsTimer;
-  int _seq = 0;
+  // Начинаем с 1, чтобы seq=0 (которым обычно приходят server pushes) никогда не совпал с pending request.
+  int _seq = 1;
 
   late final PendingRequestsManager _pendingManager;
   bool _socketConnected = false;
@@ -359,7 +360,7 @@ class ApiService {
 
       // Проверяем ответ
       final cmd = response['cmd'] as int?;
-      if (cmd != 0x100 && cmd != 256) {
+      if (cmd != 1) {
         return null;
       }
 
@@ -762,11 +763,13 @@ class ApiService {
       // Отправляем в стрим
       _emitLocal(message);
 
-      // Завершаем pending только для пакетов-ответов (cmd ∈ {256/0x100=ok, 512/0x200=notFound, 768/0x300=error}).
-      // Пуши от сервера приходят с cmd=0/request и могут случайно совпасть по seq c нашим pending,
-      // что и приводило к крешам типа `payload=40` — pending получал чужой push вместо ответа.
+      // Завершаем pending только для пакетов-ответов (ok/notFound/error).
+      // Push'и от сервера (cmd=push) имеют то же значение, что и ok, и тоже могут совпасть
+      // по seq с нашим pending. Их фильтрация делается на уровне seq: server pushes обычно
+      // приходят с seq=0 (мы свой counter стартуем с 1+) либо seq, не выданным нашим клиентом.
+      // Здесь же отсеиваем только request-пакеты (cmd=0), которых от сервера быть не должно.
       final cmd = parsed.cmd;
-      final isResponse = cmd == 256 || cmd == 512 || cmd == 768;
+      final isResponse = cmd == CmdType.ok || cmd == CmdType.notFound || cmd == CmdType.error;
       if (isResponse) {
         // Передаем ВЕСЬ message (включая cmd), а не только payload
         _pendingManager.complete(parsed.seq, message);
@@ -810,7 +813,7 @@ class ApiService {
       }
     }
 
-    final seq = _seq++ % 256;
+    final seq = _seq++ & 0xFFFF;
 
     final completer = _pendingManager.register(
       seq,
@@ -856,7 +859,7 @@ class ApiService {
       }
     }
 
-    final seq = _seq++ % 256;
+    final seq = _seq++ & 0xFFFF;
 
     final completer = _pendingManager.register(
       seq,
@@ -883,21 +886,18 @@ class ApiService {
       int opcode,
       Map<String, dynamic> payload,
       ) {
-    final verB = Uint8List(1)..[0] = ver;
-    final cmdB = Uint8List(2)
-      ..buffer.asByteData().setUint16(0, cmd, Endian.big);
-    final seqB = Uint8List(1)..[0] = seq;
-    final opcodeB = Uint8List(2)
-      ..buffer.asByteData().setUint16(0, opcode, Endian.big);
+    // Заголовок: ver(1) + cmd(1) + seq(2 BE) + opcode(2 BE) + packedLen(4 BE) = 10 байт
+    final header = ByteData(10);
+    header.setUint8(0, ver);
+    header.setUint8(1, cmd);
+    header.setUint16(2, seq & 0xFFFF, Endian.big);
+    header.setUint16(4, opcode, Endian.big);
 
     final payloadBytes = msgpack.serialize(payload);
     final payloadLen = payloadBytes.length & 0xFFFFFF;
-    final payloadLenB = Uint8List(4)
-      ..buffer.asByteData().setUint32(0, payloadLen, Endian.big);
+    header.setUint32(6, payloadLen, Endian.big);
 
-    return Uint8List.fromList(
-      verB + cmdB + seqB + opcodeB + payloadLenB + payloadBytes,
-    );
+    return Uint8List.fromList(header.buffer.asUint8List() + payloadBytes);
   }
 
   Future<int> _sendMessage(
@@ -937,7 +937,7 @@ class ApiService {
       }
     }
 
-    final seq = _seq++ % 256;
+    final seq = _seq++ & 0xFFFF;
 
     // Регистрируем pending request ДО отправки
     _pendingManager.register(
@@ -1087,7 +1087,7 @@ class ApiService {
 
       final resp64 = await messages.firstWhere((m) => m['seq'] == seq64);
       final cmd = resp64['cmd'] as int?;
-      if (cmd == 0x300 || cmd == 768) {
+      if (cmd == 3) {
         final err = resp64['payload'];
         if (err is Map && err['error'] == 'attachment.not.ready') {
           throw err;

lib/api/api_service_calls.dart

@@ -134,7 +134,7 @@ extension ApiServiceCalls on ApiService {
 
       // Проверяем cmd ответа
       final cmd = response['cmd'] as int?;
-      if (cmd != 0x100 && cmd != 256) {
+      if (cmd != 1) {
         final error = response['payload']?['error'] ?? 'Неизвестная ошибка';
         throw Exception('Ошибка инициации звонка: $error');
       }
@@ -199,7 +199,7 @@ extension ApiServiceCalls on ApiService {
 
       // Проверяем cmd ответа
       final cmd = response['cmd'] as int?;
-      if (cmd != 0x100 && cmd != 256) {
+      if (cmd != 1) {
         final error = response['payload']?['error'] ?? 'Неизвестная ошибка';
         throw Exception('Ошибка начала группового звонка: $error');
       }
@@ -266,7 +266,7 @@ extension ApiServiceCalls on ApiService {
 
       // Проверяем cmd ответа
       final cmd = response['cmd'] as int?;
-      if (cmd != 0x100 && cmd != 256) {
+      if (cmd != 1) {
         final error = response['payload']?['error'] ?? 'Неизвестная ошибка';
         throw Exception('Ошибка присоединения к звонку: $error');
       }

lib/api/api_service_chats.dart

@@ -367,7 +367,7 @@ extension ApiServiceChats on ApiService {
       }
 
       if (opcode == 19 &&
-          (chatResponse['cmd'] == 0x100 || chatResponse['cmd'] == 256)) {
+          (chatResponse['cmd'] == 1)) {
         print("✅ Авторизация (opcode 19) успешна. Сессия ГОТОВА.");
 
         _isSessionReady = true;
@@ -1412,7 +1412,7 @@ extension ApiServiceChats on ApiService {
           return false;
         }
 
-        return response['cmd'] == 0x100 || response['cmd'] == 256;
+        return response['cmd'] == 1;
       } catch (e) {
         print('Ошибка при редактировании сообщения: $e');
         return false;
@@ -1534,7 +1534,7 @@ extension ApiServiceChats on ApiService {
           return false;
         }
 
-        return response['cmd'] == 0x100 || response['cmd'] == 256;
+        return response['cmd'] == 1;
       } catch (e) {
         print('Ошибка при удалении сообщения: $e');
         return false;
@@ -1651,7 +1651,7 @@ extension ApiServiceChats on ApiService {
 
       final resp64 = await sendRequest(64, payload);
       final cmd = resp64['cmd'] as int?;
-      if (cmd == 0x300 || cmd == 768) {
+      if (cmd == 3) {
         final err = resp64['payload'];
         if (err is Map && err['error'] == 'attachment.not.ready') {
           throw err;
@@ -1772,7 +1772,7 @@ extension ApiServiceChats on ApiService {
 
       final resp64 = await sendRequest(64, payload);
       final cmd = resp64['cmd'] as int?;
-      if (cmd == 0x300 || cmd == 768) {
+      if (cmd == 3) {
         final err = resp64['payload'];
         if (err is Map && err['error'] == 'attachment.not.ready') {
           throw err;
@@ -1897,7 +1897,7 @@ extension ApiServiceChats on ApiService {
 
       final resp64 = await sendRequest(64, payload);
       final cmd = resp64['cmd'] as int?;
-      if (cmd == 0x300 || cmd == 768) {
+      if (cmd == 3) {
         final err = resp64['payload'];
         if (err is Map && err['error'] == 'attachment.not.ready') {
           throw err;