uploadFile function

Future<List<PapercupsAttachment>> uploadFile(PapercupsProps p, { OnUploadProgressCallback? onUploadProgress, String? fileName, Uint8List? fileBytes, String? filePath, })

Implementation

Future<List<PapercupsAttachment>> uploadFile(
  PapercupsProps p, {
  OnUploadProgressCallback? onUploadProgress,
  String? fileName,
  Uint8List? fileBytes,
  String? filePath,
}) async {
  List<PapercupsAttachment>? pa = [];
  try {
    var uri = Uri.parse("https://${p.baseUrl}/api/upload");
    final httpClient = HttpClient();
    final request = await httpClient.postUrl(uri);
    var client = MultipartRequest("POST", uri)
      ..fields['account_id'] = p.accountId;

    if (Platform.isAndroid ||
        Platform.isIOS ||
        Platform.isLinux ||
        Platform.isMacOS ||
        Platform.isWindows) {
      client.files.add(await MultipartFile.fromPath('file', filePath ?? ''));
      var msStream = client.finalize();
      var totalByteLength = client.contentLength;
      request.contentLength = totalByteLength;

      request.headers.set(
        HttpHeaders.contentTypeHeader,
        client.headers[HttpHeaders.contentTypeHeader] ?? '',
      );
      int byteCount = 0;

      Stream<List<int>> streamUpload = msStream.transform(
        StreamTransformer.fromHandlers(
          handleData: (data, sink) {
            sink.add(data);

            byteCount += data.length;

            onUploadProgress?.call(byteCount, totalByteLength);
          },
          handleError: (error, stack, sink) {
            throw error;
          },
          handleDone: (sink) {
            sink.close();
          },
        ),
      );

      await request.addStream(streamUpload);

      final httpResponse = await request.close();

      var statusCode = httpResponse.statusCode;

      if (statusCode ~/ 100 != 2) {
        throw Exception(
            'Error uploading file, Status code: ${httpResponse.statusCode}');
      } else {
        var body = await convertToString(httpResponse);
        var data = jsonDecode(body)["data"];
        pa.add(
          PapercupsAttachment(
            id: data["id"],
            fileName: data["filename"],
            fileUrl: data["file_url"],
            contentType: data["content_type"],
          ),
        );
      }
    } else {
      final length = fileBytes!.length;
      client.files.add(
        MultipartFile(
          'file',
          ByteStream.fromBytes(fileBytes),
          length,
          filename: fileName ?? '',
        ),
      );
      var res = await client.send();
      var charCodes = await res.stream.last;
      var body = String.fromCharCodes(charCodes);
      var data = jsonDecode(body)["data"];
      pa.add(
        PapercupsAttachment(
          id: data["id"],
          fileName: data["filename"],
          fileUrl: data["file_url"],
          contentType: data["content_type"],
        ),
      );
    }
  } catch (e) {
    rethrow;
  }
  return pa;
}