updateChatAvatar method

Implementation

@override
Future<void> updateChatAvatar(
  ChatId id, {
  NativeFile? file,
  CropAreaInput? crop,
  void Function(int count, int total)? onSendProgress,
}) async {
  Log.debug(
    'updateChatAvatar($id, $file, crop: $crop, onSendProgress)',
    '$runtimeType',
  );

  late dio.MultipartFile upload;

  if (file != null) {
    await file.ensureCorrectMediaType();

    if (file.stream != null) {
      upload = dio.MultipartFile.fromStream(
        () => file.stream!,
        file.size,
        filename: file.name,
        contentType: file.mime,
      );
    } else if (file.bytes.value != null) {
      upload = dio.MultipartFile.fromBytes(
        file.bytes.value!,
        filename: file.name,
        contentType: file.mime,
      );
    } else if (file.path != null) {
      upload = await dio.MultipartFile.fromFile(
        file.path!,
        filename: file.name,
        contentType: file.mime,
      );
    } else {
      throw ArgumentError(
        'At least stream, bytes or path should be specified.',
      );
    }
  }

  final RxChatImpl? chat = chats[id];
  final ChatAvatar? avatar = chat?.chat.value.avatar;

  if (file == null) {
    chat?.chat.update((c) => c?.avatar = null);
  }

  if (id.isLocalWith(me)) {
    id = (await ensureRemoteMonolog()).id;
  }

  try {
    await _graphQlProvider.updateChatAvatar(
      id,
      file: file == null ? null : upload,
      crop: crop,
      onSendProgress: onSendProgress,
    );
  } catch (e) {
    if (file == null) {
      chat?.chat.update((c) => c?.avatar = avatar);
    }
    rethrow;
  }
}