Class GoogleDriveFileWriter

packages/filesystem/googledrive/rw.ts:44–131

}

export class GoogleDriveFileWriter implements FileWriter {
  path: string;

  fs: GoogleDriveFileSystem;

  constructor(fs: GoogleDriveFileSystem, path: string) {
    this.fs = fs;
    this.path = path;
  }

  async write(content: string | Blob): Promise<void> {
    try {
      return await this.writeWithResolvedParent(content);
    } catch (error) {
      if (!isNotFoundError(error)) {
        throw error;
      }
      this.fs.clearPathCache();
      return await this.writeWithResolvedParent(content);
    }
  }

  private async writeWithResolvedParent(content: string | Blob): Promise<void> {
    // 解析文件路径和文件名
    const pathParts = this.path.split("/").filter(Boolean);
    const fileName = pathParts.pop() || ""; // 获取文件名
    const dirPath = "/" + pathParts.join("/"); // 重建目录路径

    // 使用优化的方法确保目录存在并获取ID
    const parentId = await this.fs.ensureDirExists(dirPath);

    // 使用优化的查找方法
    const existingFileId = await this.fs.findFileInDirectory(fileName, parentId);

    if (existingFileId) {
      // 如果文件存在，则更新
      return this.updateFile(existingFileId, content);
    } else {
      // 如果文件不存在，则创建
      return this.createNewFile(fileName, parentId, content);
    }
  }

  private async updateFile(fileId: string, content: string | Blob): Promise<void> {
    // 不设置Content-Type，让浏览器自动处理multipart/form-data边界

    const metadata = {
      // 只更新内容，不更新元数据
    };

    const formData = new FormData();
    formData.append("metadata", new Blob([JSON.stringify(metadata)], { type: "application/json" }));
    formData.append("file", content instanceof Blob ? content : new Blob([content]));

    await this.fs.request(
      `https://www.googleapis.com/upload/drive/v3/files/${fileId}?uploadType=multipart&spaces=appDataFolder`,
      {
        method: "PATCH",