создание группы

lib/backend/modules/chats.dart

@@ -1,7 +1,10 @@
 import 'dart:convert';
 
+import 'package:flutter/foundation.dart';
+
 import '../../core/protocol/opcode_map.dart';
 import '../../core/storage/app_database.dart';
+import '../../core/storage/token_storage.dart';
 import '../../core/utils/logger.dart';
 import '../api.dart';
 
@@ -115,6 +118,34 @@ class CachedChat {
 }
 
 class ChatsModule {
+  static final ValueNotifier<int> chatsChanged = ValueNotifier(0);
+  static void _bump() => chatsChanged.value = chatsChanged.value + 1;
+
+  static Future<CachedChat?> cacheServerChat(
+    Map<dynamic, dynamic> chat,
+    int accountId,
+  ) async {
+    final cachedAt = DateTime.now().millisecondsSinceEpoch;
+    final existingRows = await AppDatabase.loadChats(accountId);
+    final existing = {
+      for (final row in existingRows) row['id'] as int: CachedChat.fromDbRow(row),
+    };
+    final parsed = _parseChat(
+      chat,
+      accountId,
+      accountId,
+      const {},
+      const {},
+      const {},
+      existing,
+      cachedAt,
+    );
+    if (parsed == null) return null;
+    await AppDatabase.saveChats([parsed.toDbRow()]);
+    _bump();
+    return parsed;
+  }
+
   /// Парсит и кэширует чаты из payload opcode 19.
   ///
   /// Для диалогов разрезолвит имя и аватар из списка [contacts] того же
@@ -166,6 +197,7 @@ class ChatsModule {
 
       if (rows.isNotEmpty) {
         await AppDatabase.saveChats(rows);
+        _bump();
       }
     } catch (e) {
       logger.e("Ошибка при синке: $e");
@@ -355,4 +387,56 @@ class ChatsModule {
     });
     return packet.payload;
   }
+
+  static Future<CachedChat?> createGroupChat(
+    Api api, {
+    required String title,
+    required List<int> userIds,
+    bool notify = true,
+  }) async {
+    final payload = {
+      'message': {
+        'cid': DateTime.now().millisecondsSinceEpoch,
+        'attaches': [
+          {
+            '_type': 'CONTROL',
+            'event': 'new',
+            'chatType': 'CHAT',
+            'title': title,
+            'userIds': userIds,
+          },
+        ],
+      },
+      'notify': notify,
+    };
+    final packet = await api.sendRequest(Opcode.msgSend, payload);
+    if (!packet.isOk) return null;
+    final data = packet.payload;
+    if (data is! Map) return null;
+    final chat = data['chat'];
+    if (chat is! Map) return null;
+    final accountId = await TokenStorage.getActiveAccountId();
+    if (accountId == null) return null;
+    return cacheServerChat(chat, accountId);
+  }
+
+  static Future<String?> requestChatPhotoUploadUrl(Api api) async {
+    final packet = await api.sendRequest(Opcode.photoUpload, {'count': 1});
+    if (!packet.isOk) return null;
+    final data = packet.payload;
+    if (data is! Map) return null;
+    return data['url'] as String?;
+  }
+
+  static Future<bool> setChatPhoto(
+    Api api, {
+    required int chatId,
+    required String photoToken,
+  }) async {
+    final packet = await api.sendRequest(Opcode.chatUpdate, {
+      'chatId': chatId,
+      'photoToken': photoToken,
+    });
+    return packet.isOk;
+  }
 }

lib/backend/modules/file_uploader.dart

@@ -1,6 +1,7 @@
 import 'dart:async';
-import 'dart:convert' show utf8;
+import 'dart:convert' show jsonDecode, utf8;
 import 'dart:io';
+import 'dart:typed_data';
 
 import '../api.dart';
 import '../../core/config/proxy_config.dart';
@@ -163,12 +164,18 @@ class FileUploader {
     );
   }
 
-  void _writeHeaders(Socket socket, Uri uri, String filename, int total) {
+  void _writeHeaders(
+    Socket socket,
+    Uri uri,
+    String filename,
+    int total, {
+    String contentType = 'application/x-binary; charset=x-user-defined',
+  }) {
     final path = '${uri.path}${uri.hasQuery ? "?${uri.query}" : ""}';
     final headers = StringBuffer()
       ..write('POST $path HTTP/1.1\r\n')
       ..write('Host: ${uri.host}\r\n')
-      ..write('Content-Type: application/x-binary; charset=x-user-defined\r\n')
+      ..write('Content-Type: $contentType\r\n')
       ..write('Content-Disposition: attachment; filename=$filename\r\n')
       ..write('Connection: keep-alive\r\n')
       ..write('User-Agent: ${Uri.encodeComponent('OKMessages/26.14.1 (Android 11; TECNO MOBILE LIMITED TECNO LE7n; xxhdpi 480dpi 1080x2208)')}\r\n')
@@ -178,6 +185,91 @@ class FileUploader {
     socket.add(utf8.encode(headers.toString()));
   }
 
+  Future<String?> uploadImage(Uri uri, Uint8List bytes, {String filename = 'avatar.jpg'}) async {
+    Socket? socket;
+    try {
+      socket = await _openSocket(uri);
+      _writeHeaders(socket, uri, filename, bytes.length, contentType: 'image/jpeg');
+      socket.add(bytes);
+      await socket.flush();
+
+      final response = await _readFullResponse(
+        socket,
+        timeout: const Duration(minutes: 2),
+      );
+      try {
+        socket.destroy();
+      } catch (_) {}
+
+      if (response == null) return null;
+      final (status, body) = response;
+      if (status != 200) return null;
+      return _parsePhotoToken(body);
+    } catch (_) {
+      try {
+        socket?.destroy();
+      } catch (_) {}
+      return null;
+    }
+  }
+
+  Future<(int, String)?> _readFullResponse(
+    Socket socket, {
+    required Duration timeout,
+  }) {
+    final bytes = <int>[];
+    final completer = Completer<(int, String)?>();
+    Timer? timer;
+    StreamSubscription<List<int>>? sub;
+
+    void finish() {
+      timer?.cancel();
+      sub?.cancel();
+      if (completer.isCompleted) return;
+      final headerEnd = _findHeaderEnd(bytes);
+      if (headerEnd == -1) {
+        completer.complete(null);
+        return;
+      }
+      final headerStr = utf8.decode(bytes.sublist(0, headerEnd), allowMalformed: true);
+      final statusLine = headerStr.split('\r\n').first;
+      final parts = statusLine.split(' ');
+      final status = parts.length >= 2 ? (int.tryParse(parts[1]) ?? 0) : 0;
+      final body = utf8.decode(bytes.sublist(headerEnd), allowMalformed: true);
+      completer.complete((status, body));
+    }
+
+    void fail() {
+      timer?.cancel();
+      sub?.cancel();
+      if (!completer.isCompleted) completer.complete(null);
+    }
+
+    sub = socket.listen(bytes.addAll, onError: (_) => fail(), onDone: finish);
+    timer = Timer(timeout, fail);
+    return completer.future;
+  }
+
+  String? _parsePhotoToken(String body) {
+    try {
+      final json = jsonDecode(body);
+      if (json is Map) {
+        final photos = json['photos'];
+        if (photos is Map) {
+          for (final v in photos.values) {
+            if (v is Map) {
+              final token = v['token'];
+              if (token is String && token.isNotEmpty) return token;
+            }
+          }
+        }
+        final pt = json['photoToken'];
+        if (pt is String && pt.isNotEmpty) return pt;
+      }
+    } catch (_) {}
+    return null;
+  }
+
   Future<int> _readResponse(
     Socket socket, {
     required Duration autoForceAfter,