Class BaiduFileSystem

packages/filesystem/baidu/baidu.ts:7–162

import { BaiduFileReader, BaiduFileWriter } from "./rw";

export default class BaiduFileSystem implements FileSystem {
  accessToken?: string;

  path: string;

  constructor(path?: string, accessToken?: string) {
    this.path = path || "/apps";
    this.accessToken = accessToken;
  }

  async verify(): Promise<void> {
    const token = await AuthVerify("baidu");
    this.accessToken = token;
    return this.list().then();
  }

  async open(file: FileInfo): Promise<FileReader> {
    // 获取fsid
    return new BaiduFileReader(this, file);
  }

  async openDir(path: string): Promise<FileSystem> {
    return new BaiduFileSystem(joinPath(this.path, path), this.accessToken);
  }

  async create(path: string, _opts?: FileCreateOptions): Promise<FileWriter> {
    return new BaiduFileWriter(this, joinPath(this.path, path));
  }

  async createDir(dir: string, _opts?: FileCreateOptions): Promise<void> {
    dir = joinPath(this.path, dir);
    const urlencoded = new URLSearchParams();
    urlencoded.append("path", dir);
    urlencoded.append("size", "0");
    urlencoded.append("isdir", "1");
    urlencoded.append("rtype", "3");
    const myHeaders = new Headers();
    myHeaders.append("Content-Type", "application/x-www-form-urlencoded");
    const data = await this.request(
      `https://pan.baidu.com/rest/2.0/xpan/file?method=create&access_token=${this.accessToken}`,
      {
        method: "POST",
        headers: myHeaders,
        body: urlencoded,
        redirect: "follow",
      }
    );
    if (data.errno) {
      throw new Error(JSON.stringify(data));
    }
  }

  async request(url: string, config?: RequestInit) {
    config = config || {};
    const headers = <Headers>config.headers || new Headers();
    config.headers = headers;
    // 对百度网盘请求显式禁用 cookie，避免依赖全局 DNR 规则造成并发竞态
    config.credentials = "omit";