sendMessage method

Future<SendMessageResponse> sendMessage(Message message, { bool skipPush = false, })

Send a message to this channel.

If skipPush is true the message will not send a push notification.

Waits for a _messageAttachmentsUploadCompleter to complete before actually sending the message.

Implementation

Future<SendMessageResponse> sendMessage(
  Message message, {
  bool skipPush = false,
}) async {
  _checkInitialized();
  // Cancelling previous completer in case it's called again in the process
  // Eg. Updating the message while the previous call is in progress.
  _messageAttachmentsUploadCompleter
      .remove(message.id)
      ?.completeError('Message Cancelled');

  final quotedMessage = state!.messages.firstWhereOrNull(
    (m) => m.id == message.quotedMessageId,
  );
  // ignore: parameter_assignments
  message = message.copyWith(
    createdAt: message.createdAt,
    user: _client.state.currentUser,
    quotedMessage: quotedMessage,
    status: MessageSendingStatus.sending,
    attachments: message.attachments.map(
      (it) {
        if (it.uploadState.isSuccess) return it;
        return it.copyWith(uploadState: const UploadState.preparing());
      },
    ).toList(),
  );

  state!.updateMessage(message);

  try {
    if (message.attachments.any((it) => !it.uploadState.isSuccess)) {
      final attachmentsUploadCompleter = Completer<Message>();
      _messageAttachmentsUploadCompleter[message.id] =
          attachmentsUploadCompleter;

      _uploadAttachments(
        message.id,
        message.attachments.map((it) => it.id),
      );

      // ignore: parameter_assignments
      message = await attachmentsUploadCompleter.future;
    }

    final response = await _client.sendMessage(
      message,
      id!,
      type,
      skipPush: skipPush,
    );
    state!.updateMessage(response.message);
    if (cooldown > 0) cooldownStartedAt = DateTime.now();
    return response;
  } catch (e) {
    if (e is StreamChatNetworkError && e.isRetriable) {
      state!._retryQueue.add([message]);
    }
    rethrow;
  }
}