sendText method

Implementation

Future<TextStreamInfo> sendText(String text, {SendTextOptions? options}) async {
  final streamId = Uuid().v4();
  final textInBytes = text.codeUnits;
  final totalTextLength = textInBytes.length;

  final fileIds = options?.attachments.map((f) => Uuid().v4()).toList();
  var len = 0;
  if (fileIds != null && fileIds.isNotEmpty) {
    len = fileIds.length + 1;
  } else {
    len = 1;
  }
  final progresses = List<num>.filled(len, 0);

  handleProgress(num progress, int idx) {
    progresses[idx] = progress;
    final totalProgress = progresses.reduce((acc, val) => acc + val);
    options?.onProgress?.call(totalProgress.toDouble() / len);
  }

  final writer = await streamText(StreamTextOptions(
    streamId: streamId,
    totalSize: totalTextLength,
    destinationIdentities: options?.destinationIdentities ?? [],
    topic: options?.topic,
    attachedStreamIds: fileIds ?? [],
    attributes: options?.attributes ?? {},
  ));

  await writer.write(text);
  // set text part of progress to 1
  handleProgress(1, 0);

  await writer.close();

  if (options?.attachments != null) {
    var idx = 0;
    await Future.wait<void>(
      options?.attachments.map(
            (file) {
              final curIdx = idx++;
              return _sendFile(
                fileIds![curIdx],
                file,
                SendFileOptions(
                    topic: options.topic,
                    mimeType: mime(basename(file.path)),
                    onProgress: (progress) {
                      handleProgress(progress, curIdx + 1);
                    }),
              );
            },
          ).toList() ??
          [],
    );
  }
  return writer.info;
}