editChatMessage method

Implementation

@override
Future<void> editChatMessage(
  ChatMessage message, {
  model.ChatMessageTextInput? text,
  model.ChatMessageAttachmentsInput? attachments,
  model.ChatMessageRepliesInput? repliesTo,
}) async {
  Log.debug('editChatMessage($message, $text)', '$runtimeType');

  final Rx<ChatItem>? item = chats[message.chatId]?.messages.firstWhereOrNull(
    (e) => e.value.id == message.id,
  );

  ChatMessageText? previousText;
  List<Attachment>? previousAttachments;
  List<ChatItemQuote>? previousReplies;
  if (item?.value is ChatMessage) {
    previousText = (item?.value as ChatMessage).text;
    previousAttachments = (item?.value as ChatMessage).attachments;
    previousReplies = (item?.value as ChatMessage).repliesTo;

    item?.update((c) {
      (c as ChatMessage).text = text != null ? text.changed : previousText;
      c.attachments = attachments?.changed ?? previousAttachments!;
      c.repliesTo =
          repliesTo?.changed
              .map(
                (e) =>
                    c.repliesTo.firstWhereOrNull((a) => a.original?.id == e),
              )
              .nonNulls
              .toList() ??
          previousReplies!;
    });
  }

  final List<Future>? uploads =
      attachments?.changed
          .mapIndexed((i, e) {
            if (e is LocalAttachment) {
              return e.upload.value?.future.then(
                (a) {
                  attachments.changed[i] = a;
                  (item?.value as ChatMessage).attachments[i] = a;
                },
                onError: (_) {
                  // No-op, as failed upload attempts are handled below.
                },
              );
            }
          })
          .nonNulls
          .toList();

  await Future.wait(uploads ?? []);

  try {
    if (attachments?.changed.whereType<LocalAttachment>().isNotEmpty ==
        true) {
      throw const ConnectionException(
        EditChatMessageException(EditChatMessageErrorCode.unknownAttachment),
      );
    }

    await _graphQlProvider.editChatMessage(
      message.id,
      text: text == null ? null : ChatMessageTextInput(kw$new: text.changed),
      attachments:
          attachments == null
              ? null
              : ChatMessageAttachmentsInput(
                kw$new: attachments.changed.map((e) => e.id).toList(),
              ),
      repliesTo:
          repliesTo == null
              ? null
              : ChatMessageRepliesInput(kw$new: repliesTo.changed),
    );
  } catch (_) {
    if (item?.value is ChatMessage) {
      item?.update((c) {
        (c as ChatMessage).text = previousText;
        c.attachments = previousAttachments ?? [];
        c.repliesTo = previousReplies ?? [];
      });
    }

    rethrow;
  }
}