putObject method

Future<void> putObject({ required String bucket, required String key, String? filePath, Uint8List? byteArr, void progress(int uploadedBytes, int totalBytes)?, String? region, Map<String, String>? headers, Map<String, String>? params, })

上传对象 参考文档： https://cloud.tencent.com/document/product/436/7749 filePath 文件路径 byteArr 文件字节数组，需要自行传入 Content-Type 头部

Implementation

Future<void> putObject({
  required String bucket,
  required String key,
  String? filePath,
  Uint8List? byteArr,
  void Function(int uploadedBytes, int totalBytes)? progress,
  String? region,
  Map<String, String>? headers,
  Map<String, String>? params,
}) async {
  COSLogger.t('putObject: begin');

  assert(filePath != null || byteArr != null, 'filePath or byteArr is null');

  if (byteArr != null) {
    assert(headers != null && headers['Content-Type'] != null,
        'Content-Type header is required');
  }

  return send(COSFetchConfig(
      bucket: bucket,
      key: key,
      method: 'PUT',
      region: region,
      headers: headers,
      params: params,
      reqHandlers: [
        (COSFetchContext context) async {
          final req = context.req;

          if (req != null) {
            if (filePath != null) {
              final mime = lookupMimeType(filePath);
              final file = File(filePath);
              final fileLength = file.lengthSync();
              final fs = file.openRead();
              int uploadedBytes = 0;

              req.headers
                  .add('Content-Type', mime ?? 'application/octet-stream');
              req.headers.add('Content-Length', fileLength);

              await req.addStream(fs.map((size) {
                uploadedBytes += size.length;

                if (progress != null) {
                  progress(uploadedBytes, fileLength);
                }

                return size;
              }));
            } else if (byteArr != null) {
              req.headers.add('Content-Length', byteArr.length);

              req.add(byteArr);
            } else {
              throw COSException(message: 'filePath and byteArr is null');
            }
          } else {
            throw COSException(message: 'req is null');
          }
        }
      ],
      resHandlers: [
        (fetchContext, data) async {
          final res = fetchContext.res;

          if (res != null) {
            if (res.statusCode != HttpStatus.ok) {
              throw await COSException.fromResponse(res);
            }
          } else {
            throw COSException(message: 'res is null');
          }

          COSLogger.t('putObject: end');
        }
      ]));
}