Method httpRequestOnce

packages/kilo-chat/src/client.ts:451–490

(
    path: string,
    opts: {
      method?: string;
      body?: unknown;
      query?: Record<string, unknown>;
      schema: z.ZodType<T>;
    }
  )

      signal?: AbortSignal;
      deadlineMs?: number;
    }
  ): Promise<T> {
    const deadline = opts.deadlineMs ?? CONTROL_PLANE_DEADLINE_MS;
    return withDeadline(
      deadline,
      async signal => {
        try {
          return await this.httpRequestOnce(path, { ...opts, signal });
        } catch (err) {
          // Deadline/timeout errors must NOT trigger unauthorized recovery.
          const onUnauthorized = this.onUnauthorized;
          if (!this.shouldRecoverFromUnauthorized(err) || onUnauthorized === undefined) {
            throw err;
          }
          const decision = await onUnauthorized();
          if (decision !== 'retry') {
            throw err;
          }
          return this.httpRequestOnce(path, { ...opts, signal });
        }
      },
      opts.signal
    );
  }

  private shouldRecoverFromUnauthorized(err: unknown): err is KiloChatApiError {
    return (
      this.onUnauthorized !== undefined &&
      err instanceof KiloChatApiError &&
      (err.status === 401 || err.status === 403)
    );
  }

  private async httpRequestOnce<T>(
    path: string,
    opts: {
      method?: string;
      body?: unknown;
      query?: Record<string, unknown>;
      schema: z.ZodType<T>;
      signal?: AbortSignal;
    }
  ): Promise<T> {