Method request

client-sdks/client-js/src/resources/base.ts:89–141

* 发送 HTTP 请求 * 自动处理重试、超时、错误

(path: string, options: RequestOptions = {})

   * 自动处理重试、超时、错误
   */
  protected async request<T>(path: string, options: RequestOptions = {}): Promise<T> {
    const url = this.buildUrl(path, options.params);
    const timeout = options.timeout ?? this.options.timeout;

    let lastError: Error | null = null;
    const maxRetries = this.options.retry!.maxRetries!;

    // 重试循环
    for (let attempt = 0; attempt <= maxRetries; attempt++) {
      try {
        // 创建 AbortController 用于超时
        const controller = new AbortController();
        const timeoutId = setTimeout(() => controller.abort(), timeout);

        try {
          const response = await this.fetchImpl(url, {
            method: options.method ?? "GET",
            headers: this.buildHeaders(options.headers),
            body: options.body ? JSON.stringify(options.body) : undefined,
            signal: options.signal ?? controller.signal,
          });

          clearTimeout(timeoutId);

          // 检查是否需要重试
          if (!response.ok && this.shouldRetry(response.status) && attempt < maxRetries) {
            lastError = new Error(`HTTP ${response.status}: ${response.statusText}`);
            await this.delay(this.getBackoffDelay(attempt));
            continue;
          }

          // 处理响应
          return await this.handleResponse<T>(response);
        } finally {
          clearTimeout(timeoutId);
        }
      } catch (error: any) {
        lastError = error;

        // 超时或网络错误，可以重试
        if (attempt < maxRetries && this.isRetryableError(error)) {
          await this.delay(this.getBackoffDelay(attempt));
          continue;
        }

        // 不可重试，直接抛出
        throw this.wrapError(error, path);
      }
    }

    // 所有重试都失败了
    throw this.wrapError(lastError!, path);
  }

  /**
   * 构建完整 URL