Method request

packages/filesystem/s3/client.ts:271–323

* 发送 S3 请求 * @param method HTTP 方法 * @param bucket Bucket 名称 * @param key 对象 Key（可选） * @param options 请求选项 * @returns 成功时返回 Response * @throws {S3Error} S3 服务端错误

(
    method: string,
    bucket: string,
    key?: string,
    options?: {
      queryParams?: Record<string, string>;
      body?: string | Uint8Array;
      headers?: Record<string, string>;
    }
  )

   * @throws {S3Error} S3 服务端错误
   */
  async request(
    method: string,
    bucket: string,
    key?: string,
    options?: {
      queryParams?: Record<string, string>;
      body?: string | Uint8Array;
      headers?: Record<string, string>;
    }
  ): Promise<Response> {
    const queryParams = options?.queryParams || {};
    // 规范化 headers（全部小写 key）
    const headers: Record<string, string> = {};
    if (options?.headers) {
      for (const [k, v] of Object.entries(options.headers)) {
        headers[k.toLowerCase()] = v;
      }
    }

    // 计算 payload SHA-256
    let payloadHash: string;
    if (options?.body) {
      const bodyBytes = typeof options.body === "string" ? new TextEncoder().encode(options.body) : options.body;
      payloadHash = await sha256Hex(bodyBytes);
    } else {
      payloadHash = await sha256Hex("");
    }

    // 签名
    await this.signRequest(method, bucket, key, queryParams, headers, payloadHash);

    // 发送请求（移除 host 头，fetch 会自动设置）
    const url = this.buildUrl(bucket, key, queryParams);
    const fetchHeaders = { ...headers };
    delete fetchHeaders["host"];

    const response = await fetch(url, {
      method,
      headers: fetchHeaders,
      body: options?.body
        ? options.body instanceof Uint8Array
          ? (options.body.buffer as ArrayBuffer)
          : options.body
        : undefined,
    });

    // 非 2xx 响应视为错误
    if (!response.ok) {
      throw await parseS3Error(response);
    }

    return response;
  }

  /** 获取 endpoint URL */
  getEndpointUrl(): string {