uploadAttachment method

Implementation

@override
Future<Attachment> uploadAttachment(LocalAttachment attachment) async {
  Log.debug('uploadAttachment($attachment)', '$runtimeType');

  if (attachment.upload.value?.isCompleted != false) {
    attachment.upload.value = Completer();
  }

  if (attachment.read.value?.isCompleted != false) {
    attachment.read.value = Completer();
  }

  attachment.status.value = SendingStatus.sending;
  await attachment.file.ensureCorrectMediaType();

  try {
    dio.MultipartFile upload;

    await attachment.file.readFile();
    attachment.read.value?.complete(null);
    attachment.status.refresh();

    if (attachment.file.bytes.value != null) {
      upload = dio.MultipartFile.fromBytes(
        attachment.file.bytes.value!,
        filename: attachment.file.name,
        contentType: attachment.file.mime,
      );
    } else if (attachment.file.path != null) {
      upload = await dio.MultipartFile.fromFile(
        attachment.file.path!,
        filename: attachment.file.name,
        contentType: attachment.file.mime,
      );
    } else {
      throw ArgumentError(
        'At least stream, bytes or path should be specified.',
      );
    }

    var response = await _graphQlProvider.uploadAttachment(
      upload,
      onSendProgress: (now, max) => attachment.progress.value = now / max,
    );

    var model = response.attachment.toModel();
    attachment.id = model.id;
    attachment.filename = model.filename;
    attachment.original = model.original;
    attachment.upload.value?.complete(model);
    attachment.status.value = SendingStatus.sent;
    attachment.progress.value = 1;
    return model;
  } catch (e) {
    if (attachment.read.value?.isCompleted == false) {
      attachment.read.value?.complete(null);
    }
    attachment.upload.value?.completeError(e);
    attachment.status.value = SendingStatus.error;
    attachment.progress.value = 0;
    rethrow;
  }
}