Function get

packages/arctic/src/auth/codex.ts:355–401

(path: string)

  }

  export async function get<T>(path: string): Promise<T> {
    const auth = await Auth.get("codex")
    if (!auth || auth.type !== "codex") {
      throw new Error("Codex token not available")
    }

    if (Date.now() > auth.expiresAt) {
      try {
        const tokens = await refresh(auth.refreshToken)
        const idTokenInfo = parseIdToken(tokens.id_token)
        await Auth.set("codex", {
          ...auth,
          accessToken: tokens.access_token,
          refreshToken: tokens.refresh_token,
          idToken: tokens.id_token,
      expiresAt: Date.now() + (tokens.expires_in ?? 3600) * 1000,
          accountId: idTokenInfo?.chatgpt_account_id ?? auth.accountId,
        })
        auth.accessToken = tokens.access_token
      } catch (e) {
        throw new Error("Session expired, please login again")
      }
    }

    const url = `${normalizeBaseUrl(Config.chatgptBaseUrl)}${path}`
    const accountId = auth.accountId

    if (!accountId) {
      throw new Error("ChatGPT account ID not available, please re-run login")
    }

    const response = await fetch(url, {
      method: "GET",
      headers: {
        Authorization: `Bearer ${auth.accessToken}`,
        "chatgpt-account-id": accountId,
        "Content-Type": "application/json",
      },
    })

    if (!response.ok) {
      const body = await response.text()
      throw new Error(`Request failed with status ${response.status}: ${body}`)
    }

    return (await response.json()) as T
  }

  export async function ensureValidTokenFor(
    authKey: string,