鸿蒙(Harmony) SDK

ohpm install @qiniu/upload

import { createDirectUploadTask, createMultipartUploadV1Task, createMultipartUploadV2Task, UploadFile } from '@qiniu/upload';

// 创建上传数据
const file = UploadFile.fromUri('datashare://xxxx')
const file = UploadFile.fromPath('/data/storage/xxx')
const file = UploadFile.fromString('string content')
const file = UploadFile.fromArrayBuffer(new ArrayBuffer(1e3))

// 创建直传任务
const uploadTask = createDirectUploadTask(file, config);

// 创建分片上传任务
const uploadTask = createMultipartUploadV2Task(file, config);

// 部分老私有云不支持 v2，推荐用 v1
const uploadTask = createMultipartUploadV1Task(file, config);

// 设置进度回调函数
uploadTask.onProgress((progress, context) => {
  // 处理进度回调
});

// 设置完成回调函数
uploadTask.onComplete((result, context) => {
  // 处理完成回调
});

// 设置错误回调函数
uploadTask.onError((error, context) => {
  // 处理错误回调
});

uploadTask.start()

createMultipartUploadV2Task(file, config).start()
 .then((result) => {
    // 处理任务完成结果
  })
  .catch((error) => {
    // 处理任务启动失败错误
  });

type TokenProvider = () => Promise<string>

interface Context<ProgressKey extends string = string> {
  host?: Host;
  token?: Token;
  result?: string;
  error?: UploadError;
  progress: Progress<ProgressKey>;
}

interface UploadConfig {
  tokenProvider: TokenProvider;
  apiServerUrl?: string;
  uploadHosts?: []string;
  logLevel?: LogLevel;
  protocol?: HttpProtocol;
  vars?: Record<string, string>;
}

type OnError = (error: UploadError, context: Context) => void;

type OnProgress = (progress: Progress, context: Context) => void;

type Progress<Key extends string = string> = {
  /** 上传的文件总大小；单位 byte */
  size: number
  /** 目前处理的百分比进度；范围 0-1 */
  percent: number
  /** 具体每个部分的进度信息； */
  details: Record<Key, {
    /** 子任务的处理数据大小；单位 byte */
    size: number
    /** 目前处理的百分比进度；范围 0-1 */
    percent: number
    /** 该处理是否复用了缓存； */
    fromCache: boolean
  }>
}

type OnComplete = (result: string, context: Context) => void;

interface UploadTask {
  onProgress(fn: OnProgress): void;
  onComplete(fn: OnComplete): void;
  onError(fn: OnError): void;
  cancel(): Promise<Result>;
  start(): Promise<Result>;
}