✨ CAT.agent.opfs.write 支持 Blob 和 data URL 二进制写入

- writeWorkspaceFile 支持 Uint8Array、Blob、data URL 字符串三种输入
- data URL 自动检测并解码为原始二进制存储
- OPFSApiRequest write content 类型扩展为 string | Blob
- GM API CAT.agent.opfs.write 参数同步更新

Author: CodFrm

src/app/service/agent/opfs_helpers.ts

@@ -63,22 +63,47 @@ export function decodeDataUrl(dataUrl: string): { data: Uint8Array; mimeType: st
   return { data: bytes, mimeType };
 }
 
+/** 检测字符串是否是 data URL */
+export function isDataUrl(str: string): boolean {
+  return /^data:[^;]+;base64,/.test(str);
+}
+
 /** 将二进制数据写入 OPFS workspace 指定路径 */
 export async function writeWorkspaceFile(
   path: string,
-  data: Uint8Array | string
+  data: Uint8Array | Blob | string
 ): Promise<{ path: string; size: number }> {
   const safePath = sanitizePath(path);
   if (!safePath) throw new Error("path is required");
 
+  // data URL 字符串自动解码为二进制
+  if (typeof data === "string" && isDataUrl(data)) {
+    const decoded = decodeDataUrl(data);
+    data = decoded.data;
+  }
+
   const workspace = await getWorkspaceRoot(true);
   const { dirPath, fileName } = splitPath(safePath);
   const dir = dirPath ? await getDirectory(workspace, dirPath, true) : workspace;
   const fileHandle = await dir.getFileHandle(fileName, { create: true });
   const writable = await fileHandle.createWritable();
-  await writable.write(data instanceof Uint8Array ? (data.buffer as ArrayBuffer) : data);
+
+  if (data instanceof Blob) {
+    await writable.write(data);
+  } else if (data instanceof Uint8Array) {
+    await writable.write(data.buffer as ArrayBuffer);
+  } else {
+    await writable.write(data);
+  }
   await writable.close();
 
-  const size = typeof data === "string" ? new Blob([data]).size : data.byteLength;
+  let size: number;
+  if (data instanceof Blob) {
+    size = data.size;
+  } else if (data instanceof Uint8Array) {
+    size = data.byteLength;
+  } else {
+    size = new Blob([data]).size;
+  }
   return { path: safePath, size };
 }

src/app/service/agent/tools/opfs_tools.ts

@@ -109,7 +109,7 @@ export function createOPFSTools(): {
 } {
   const writeExecutor: ToolExecutor = {
     execute: async (args: Record<string, unknown>) => {
-      const result = await writeWorkspaceFile(args.path as string, args.content as string);
+      const result = await writeWorkspaceFile(args.path as string, args.content as string | Blob);
       return JSON.stringify(result);
     },
   };

src/app/service/agent/types.ts

@@ -251,7 +251,7 @@ export type SkillApiRequest =
 
 // CAT.agent.opfs API 请求
 export type OPFSApiRequest =
-  | { action: "write"; path: string; content: string; scriptUuid: string }
+  | { action: "write"; path: string; content: string | Blob; scriptUuid: string }
   | { action: "read"; path: string; format?: "text" | "bloburl"; scriptUuid: string }
   | { action: "list"; path?: string; scriptUuid: string }
   | { action: "delete"; path: string; scriptUuid: string };

src/app/service/content/gm_api/cat_agent_opfs.ts

@@ -25,7 +25,7 @@ export default class CATAgentOPFSApi {
   protected scriptRes?: { uuid: string };
 
   @GMContext.API({ follow: "CAT.agent.opfs" })
-  public "CAT.agent.opfs.write"(path: string, content: string): Promise<{ path: string; size: number }> {
+  public "CAT.agent.opfs.write"(path: string, content: string | Blob): Promise<{ path: string; size: number }> {
     const ctx = this as unknown as GMBaseContext;
     return ctx.sendMessage("CAT_agentOPFS", [
       { action: "write", path, content, scriptUuid: ctx.scriptRes?.uuid || "" } as OPFSApiRequest,