1
// models.ts:719
2
api: ProviderStreams | Partial<Record<TApi, ProviderStreams>>;

1
scripts/generate-models.ts (手工维护, 含各家定价/规格)
2
    ↓ 生成
3
src/providers/<name>.models.ts      ← 每个厂商的汇总文件
4
    ↓ import
5
src/providers/data/<name>.json      ← 数据本体（.gitignore, 不在仓库里）

1
// deepseek.models.ts —— 自动生成
2
import values from "./data/deepseek.json" with { type: "json" };
3
import { flattenModelCatalog, type ModelCatalog } from "../model-catalog.ts";
4

5
export const DEEPSEEK_MODELS: ModelCatalog<typeof values, "deepseek"> =
6
    flattenModelCatalog("deepseek", values);

1
export interface ProviderAuth {
2
    apiKey?: ApiKeyAuth;   // API key 通道
3
    oauth?: OAuthAuth;     // OAuth 通道
4
}

1
// models.ts (ModelsImpl.streamSimple)
2
streamSimple(model, context, options) {
3
    return lazyStream(model, async () => {
4
        const provider = this.requireProvider(model);          // ① 找到厂商
5
        const { requestModel, requestOptions } = await this.applyAuth(model, options);  // ② 认证
6
        return provider.streamSimple(requestModel, context, requestOptions);
7
    });
8
}

1
const resolution = await this.getAuth(model, {...});          // ③ 解析凭证
2
const apiKey = options?.apiKey ?? auth.apiKey;                // ④ 显式传入优先于存储
3
let headers = mergeHeaders(auth.headers, options?.headers);   //    header 合并, 大小写不敏感
4
const requestModel = auth.baseUrl ? { ...model, baseUrl: auth.baseUrl } : model;  // ⑤ baseUrl 覆盖
5
return { requestModel, requestOptions };

1
// api/openai-completions.ts —— deepseek 的实际请求路径
2
streamSimple(model, context, options) {
3
    const base = buildBaseOptions(model, context, options, options?.apiKey);
4
    const clampedReasoning = options?.reasoning ? clampThinkingLevel(model, options.reasoning) : undefined;
5
    return stream(model, context, { ...base, reasoningEffort: clampedReasoning === "off" ? undefined : clampedReasoning });
6
}

1
export function lazyStream(model, setup) {
2
    const outer = new AssistantMessageEventStream();
3
    setup()                                          // 异步就绪（认证 / 加载模块）
4
        .then((inner) => forwardStream(outer, inner))
5
        .catch((error) => {                          // 失败编码进流, 不 throw
6
            const message = createSetupErrorMessage(model, error);
7
            outer.push({ type: "error", reason: "error", error: message });
8
            outer.end(message);
9
        });
10
    return outer;                                    // 立即返回空流
11
}

1
/**
2
 * Temporary compatibility entrypoint preserving the old global pi-ai API
3
 * surface... This module is deleted with the coding-agent ModelManager migration.
4
 */

1
// compat.ts:streamSimple
2
const builtinProvider = getBuiltinProviderForModel(model);   // 新集合优先
3
if (builtinProvider) {
4
    return builtinProvider.streamSimple(model, context, withEnvApiKey(model, options));
5
}
6
const provider = resolveApiProvider(model.api);              // 旧注册表兜底
7
return provider.streamSimple(model, context, withEnvApiKey(model, options));