feat(s3-backend): 添加桌面平台专用的请求处理器以绕过CORS

Author: codedogQBY

packages/core/src/sync/s3-backend.ts

@@ -12,8 +12,85 @@ import {
   PutObjectCommand,
   S3Client,
 } from "@aws-sdk/client-s3";
+import { HttpResponse } from "@smithy/protocol-http";
+import { buildQueryString } from "@smithy/querystring-builder";
+import { getPlatformService } from "../services/platform";
 import type { ISyncBackend, RemoteFile, S3Config } from "./sync-backend";
 
+type SmithyHttpRequest = {
+  protocol: string;
+  hostname: string;
+  port?: number;
+  method: string;
+  path: string;
+  query?: Record<string, string | string[] | null>;
+  fragment?: string;
+  username?: string;
+  password?: string;
+  headers: Record<string, string>;
+  body?: BodyInit | null;
+};
+
+/**
+ * Desktop-only request handler that routes AWS SDK traffic through the platform
+ * fetch implementation. In Tauri this uses plugin-http, which avoids webview
+ * CORS restrictions for S3-compatible providers like UpYun.
+ */
+class PlatformFetchHttpHandler {
+  readonly metadata = { handlerProtocol: "h1" } as const;
+
+  async handle(request: SmithyHttpRequest): Promise<{ response: HttpResponse }> {
+    const platform = getPlatformService();
+    let path = request.path;
+    const queryString = buildQueryString(request.query ?? {});
+    if (queryString) {
+      path += `?${queryString}`;
+    }
+    if (request.fragment) {
+      path += `#${request.fragment}`;
+    }
+
+    let auth = "";
+    if (request.username != null || request.password != null) {
+      const username = request.username ?? "";
+      const password = request.password ?? "";
+      auth = `${username}:${password}@`;
+    }
+
+    const url = `${request.protocol}//${auth}${request.hostname}${request.port ? `:${request.port}` : ""}${path}`;
+    const response = await platform.fetch(url, {
+      method: request.method,
+      headers: request.headers,
+      body: request.method === "GET" || request.method === "HEAD" ? undefined : (request.body ?? undefined),
+    });
+
+    const transformedHeaders: Record<string, string> = {};
+    response.headers.forEach((value, key) => {
+      transformedHeaders[key] = value;
+    });
+
+    let responseBody: BodyInit | ReadableStream<Uint8Array> | undefined;
+    if (response.body) {
+      responseBody = response.body as ReadableStream<Uint8Array>;
+    } else {
+      responseBody = await response.blob();
+    }
+
+    return {
+      response: new HttpResponse({
+        headers: transformedHeaders,
+        reason: response.statusText,
+        statusCode: response.status,
+        body: responseBody,
+      }),
+    };
+  }
+
+  destroy(): void {
+    // No-op: platform fetch does not keep persistent sockets we need to tear down.
+  }
+}
+
 /**
  * S3 backend implementation.
  * Works with any S3-compatible storage service.
@@ -25,15 +102,28 @@ export class S3Backend implements ISyncBackend {
 
   constructor(config: S3Config, secretAccessKey: string) {
     this.config = config;
-    this.client = new S3Client({
+    let requestHandler: PlatformFetchHttpHandler | undefined;
+    try {
+      const platform = getPlatformService();
+      if (platform.isDesktop) {
+        requestHandler = new PlatformFetchHttpHandler();
+      }
+    } catch {
+      // Platform service may not be initialized in tests that never touch S3.
+    }
+
+    const clientConfig = {
       endpoint: config.endpoint,
       region: config.region,
       credentials: {
         accessKeyId: config.accessKeyId,
         secretAccessKey,
       },
       forcePathStyle: config.pathStyle ?? false,
-    });
+      ...(requestHandler ? { requestHandler } : {}),
+    };
+
+    this.client = new S3Client(clientConfig);
   }
 
   async testConnection(): Promise<boolean> {
@@ -45,7 +135,8 @@ export class S3Backend implements ISyncBackend {
         }),
       );
       return true;
-    } catch {
+    } catch (error) {
+      console.error("[S3Backend] testConnection failed:", error);
       return false;
     }
   }