import { getQueuedFileWriter, type QueuedFileWriter } from "./queued-file-writer.js";

import { buildAgentTraceBase } from "./trace-base.js";

export type CacheTraceStage =

type CacheTraceStage =

| "cache:result"

| "cache:state"

| "session:loaded"

| "stream:context"

| "session:after";

export type CacheTraceEvent = {

type CacheTraceEvent = {

ts: string;

seq: number;

stage: CacheTraceStage;

error?: string;

};

export type CacheTrace = {

type CacheTrace = {

enabled: true;

filePath: string;

recordStage: (stage: CacheTraceStage, payload?: Partial<CacheTraceEvent>) => void;

import type { OAuthCredentials } from "@mariozechner/pi-ai";

import { normalizeOptionalString } from "../shared/string-coerce.js";

export const CHUTES_OAUTH_ISSUER = "https://api.chutes.ai";

const CHUTES_OAUTH_ISSUER = "https://api.chutes.ai";

export const CHUTES_AUTHORIZE_ENDPOINT = `${CHUTES_OAUTH_ISSUER}/idp/authorize`;

export const CHUTES_TOKEN_ENDPOINT = `${CHUTES_OAUTH_ISSUER}/idp/token`;

export const CHUTES_USERINFO_ENDPOINT = `${CHUTES_OAUTH_ISSUER}/idp/userinfo`;

const DEFAULT_EXPIRES_BUFFER_MS = 5 * 60 * 1000;

export type ChutesPkce = { verifier: string; challenge: string };

type ChutesPkce = { verifier: string; challenge: string };

export type ChutesUserInfo = {

type ChutesUserInfo = {

sub?: string;

username?: string;

created_at?: string;

scopes: string[];

};

export type ChutesStoredOAuth = OAuthCredentials & {

type ChutesStoredOAuth = OAuthCredentials & {

clientId?: string;

};

return Math.max(value, now + 30_000);

}

export async function fetchChutesUserInfo(params: {

async function fetchChutesUserInfo(params: {

accessToken: string;

fetchFn?: typeof fetch;

}): Promise<ChutesUserInfo | null> {