create method

  1. @override
Future<Message> create(
  1. covariant MessageBuilder builder
)
override

Create a new instance of the type of this manager.

Implementers should ensure this method updates the cache.

Implementation

@override
Future<Message> create(MessageBuilder builder) async {
  final route = HttpRoute()
    ..channels(id: channelId.toString())
    ..messages();

  final HttpRequest request;
  if (!identical(builder.attachments, sentinelList) && builder.attachments?.isNotEmpty == true) {
    final attachments = builder.attachments!;
    final payload = builder.build();

    final files = <MultipartFile>[];
    for (int i = 0; i < attachments.length; i++) {
      files.add(MultipartFile.fromBytes(
        'files[$i]',
        attachments[i].data,
        filename: attachments[i].fileName,
      ));

      ((payload['attachments'] as List)[i] as Map)['id'] = i.toString();
    }

    request = MultipartRequest(
      route,
      method: 'POST',
      jsonPayload: jsonEncode(payload),
      files: files,
    );
  } else {
    request = BasicRequest(route, method: 'POST', body: jsonEncode(builder.build()));
  }

  final response = await client.httpHandler.executeSafe(request);
  final message = parse(response.jsonBody as Map<String, Object?>);

  client.updateCacheWith(message);
  return message;
}