updateChat method

Implementation

Future<void> updateChat(DtoChat newChat) async {
  Log.debug('updateChat($newChat)', '$runtimeType($id)');

  if (chat.value.id != newChat.value.id) {
    dto = newChat;
    chat.value = newChat.value;
    ver = newChat.ver;

    _initLocalSubscription();

    if (!_controller.isPaused && !_controller.isClosed) {
      _initRemoteSubscription();
    }

    // Retrieve all the [DtoChatItem]s to put them in the [newChat].
    final Iterable<DtoChatItem> saved = _pagination!.items.values.toList(
      growable: false,
    );

    await clear();

    for (var e in saved.whereType<DtoChatMessage>()) {
      // Copy the [DtoChatMessage] to the new [Pagination].
      final DtoChatMessage copy =
          e.copyWith()..value.chatId = newChat.value.id;

      if (copy.value.status.value == SendingStatus.error) {
        copy.value.status.value = SendingStatus.sending;
      }

      await put(copy, ignoreBounds: true);
    }

    await _initMessagesPagination();
    await _pagination?.around();
  }
}