Class AskSageApi

packages/openai-adapters/src/apis/AskSage.ts:52–501

}

export class AskSageApi implements BaseLlmApi {
  private apiBase: string;
  private userApiUrl: string;
  private apiKey?: string;
  private email?: string;
  private sessionTokenPromise: Promise<string> | null = null;
  private tokenTimestamp: number = 0;
  private fetchFn: typeof fetch;

  constructor(private config: AskSageConfig) {
    this.apiBase = config.apiBase ?? DEFAULT_API_URL;
    this.userApiUrl = config.env?.userApiUrl ?? DEFAULT_USER_API_URL;
    this.apiKey = config.apiKey;
    this.email = config.env?.email;
    this.fetchFn = customFetch(config.requestOptions);
  }

  /**
   * Get session token from API key + email, or use API key directly
   */
  private async getSessionToken(): Promise<string> {
    if (!this.apiKey) {
      throw new Error(
        "AskSage adapter: missing apiKey. Provide it in your configuration.",
      );
    }

    // If no email, use API key directly
    if (!this.email || this.email.length === 0) {
      return this.apiKey;
    }

    const url = this.userApiUrl.replace(/\/$/, "") + "/get-token-with-api-key";
    const res = await this.fetchFn(url, {
      method: "POST",
      headers: { "Content-Type": "application/json" },
      body: JSON.stringify({ email: this.email, api_key: this.apiKey }),
    });

    const data = (await res.json()) as AskSageTokenResponse;
    if (parseInt(String(data.status)) !== 200) {
      throw new Error("Error getting access token: " + JSON.stringify(data));
    }
    return data.response.access_token;
  }

  /**
   * Get cached token or refresh if expired
   */
  private async getToken(): Promise<string> {
    if (
      !this.sessionTokenPromise ||
      Date.now() - this.tokenTimestamp > TOKEN_TTL
    ) {
      this.sessionTokenPromise = this.getSessionToken();
      this.tokenTimestamp = Date.now();
      // Clear cache on failure so transient errors don't prevent retries
      this.sessionTokenPromise.catch(() => {