model-resolver.test.ts 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801
  1. import { describe, expect } from "bun:test"
  2. import { LLM, LanguageModel } from "@opencode-ai/ai"
  3. import { OpenAIChat } from "@opencode-ai/ai/protocols"
  4. import { compileRequest } from "@opencode-ai/ai/route/client"
  5. import { Effect } from "effect"
  6. import { Headers } from "effect/unstable/http"
  7. import { Credential } from "@opencode-ai/core/credential"
  8. import { Integration } from "@opencode-ai/core/integration"
  9. import { Compatibility, ID, Info, VariantID } from "@opencode-ai/core/model"
  10. import { Provider } from "@opencode-ai/core/provider"
  11. import { ModelResolver } from "@opencode-ai/core/model-resolver"
  12. import { it } from "./lib/effect"
  13. interface ModelOptions {
  14. readonly providerID?: Provider.ID
  15. readonly modelID?: string
  16. readonly compatibility?: Compatibility
  17. readonly settings?: Info["settings"]
  18. readonly headers?: Info["headers"]
  19. readonly body?: Info["body"]
  20. readonly variants?: Info["variants"]
  21. readonly limit?: Info["limit"]
  22. }
  23. const model = (packageName: string | undefined, options: ModelOptions = {}) =>
  24. Info.make({
  25. id: ID.make("test-model"),
  26. modelID: ID.make(options.modelID ?? "api-test-model"),
  27. providerID: options.providerID ?? Provider.ID.make("test-provider"),
  28. name: "Test model",
  29. compatibility: options.compatibility,
  30. package: packageName,
  31. settings: options.settings ?? {},
  32. headers: options.headers ?? { "x-test": "header" },
  33. body: options.body ?? { custom_extension: { enabled: true } },
  34. capabilities: { tools: true, input: ["text"], output: ["text"] },
  35. variants: options.variants ?? [],
  36. time: { released: 0 },
  37. cost: [],
  38. status: "active",
  39. enabled: true,
  40. limit: options.limit ?? { context: 100, output: 20 },
  41. })
  42. describe("ModelResolver", () => {
  43. it.effect("constructs native Azure requests with deployment IDs and projected resource URLs", () =>
  44. Effect.gen(function* () {
  45. const responses = yield* ModelResolver.fromCatalogModel(
  46. model(Provider.aisdk("@ai-sdk/azure"), {
  47. providerID: Provider.ID.azure,
  48. modelID: "responses-deployment",
  49. settings: { resourceName: "modern-resource", apiVersion: "2025-01-01-preview" },
  50. }),
  51. Credential.Key.make({ type: "key", key: "secret" }),
  52. )
  53. const chat = yield* ModelResolver.fromCatalogModel(
  54. model(Provider.aisdk("@ai-sdk/azure"), {
  55. providerID: Provider.ID.azure,
  56. modelID: "chat-deployment",
  57. settings: { resourceName: "modern-resource", useCompletionUrls: true },
  58. }),
  59. )
  60. const deployment = yield* ModelResolver.fromCatalogModel(
  61. model(Provider.aisdk("@ai-sdk/azure"), {
  62. providerID: Provider.ID.azure,
  63. modelID: "legacy-url-deployment",
  64. settings: {
  65. resourceName: "modern-resource",
  66. apiVersion: "2025-01-01-preview",
  67. useDeploymentBasedUrls: true,
  68. },
  69. }),
  70. )
  71. const compatible = yield* ModelResolver.fromCatalogModel(
  72. model(Provider.aisdk("@ai-sdk/openai-compatible"), {
  73. providerID: Provider.ID.azure,
  74. modelID: "legacy-deployment",
  75. settings: {
  76. resourceName: "legacy-resource",
  77. baseURL: "https://legacy-resource.cognitiveservices.azure.com/openai",
  78. },
  79. }),
  80. )
  81. expect(responses).toMatchObject({ id: "responses-deployment", provider: "azure" })
  82. expect(responses.route).toMatchObject({
  83. id: "azure-openai-responses",
  84. endpoint: {
  85. baseURL: "https://modern-resource.openai.azure.com/openai/v1",
  86. query: { "api-version": "2025-01-01-preview" },
  87. },
  88. })
  89. expect(chat).toMatchObject({ id: "chat-deployment", provider: "azure" })
  90. expect(chat.route.id).toBe("azure-openai-chat")
  91. expect(deployment).toMatchObject({ id: "legacy-url-deployment", provider: "azure" })
  92. expect(deployment.route.endpoint).toMatchObject({
  93. baseURL: "https://modern-resource.openai.azure.com/openai/deployments/legacy-url-deployment",
  94. query: { "api-version": "2025-01-01-preview" },
  95. })
  96. expect(compatible).toMatchObject({ id: "legacy-deployment", provider: "azure" })
  97. expect(compatible.route.endpoint.baseURL).toBe("https://legacy-resource.cognitiveservices.azure.com/openai")
  98. }),
  99. )
  100. it.effect("maps Bedrock Mantle models to native Responses and safeguards to Chat", () =>
  101. Effect.gen(function* () {
  102. const credential = Credential.Key.make({ type: "key", key: "secret" })
  103. const responses = yield* ModelResolver.fromCatalogModel(
  104. model(Provider.aisdk("@ai-sdk/amazon-bedrock/mantle"), {
  105. modelID: "openai.gpt-oss-120b",
  106. settings: { region: "us-east-2" },
  107. }),
  108. credential,
  109. )
  110. const chat = yield* ModelResolver.fromCatalogModel(
  111. model(Provider.aisdk("@ai-sdk/amazon-bedrock/mantle"), {
  112. modelID: "openai.gpt-oss-safeguard-20b",
  113. settings: { region: "us-east-2" },
  114. }),
  115. credential,
  116. )
  117. expect(responses.route).toMatchObject({
  118. id: "bedrock-mantle-responses",
  119. endpoint: { baseURL: "https://bedrock-mantle.us-east-2.api.aws/v1" },
  120. })
  121. expect(chat.route).toMatchObject({
  122. id: "bedrock-mantle-chat",
  123. endpoint: { baseURL: "https://bedrock-mantle.us-east-2.api.aws/v1" },
  124. })
  125. }),
  126. )
  127. it.effect("uses the API modelID instead of the catalog ID for native OpenAI routes", () =>
  128. Effect.gen(function* () {
  129. const catalog = model(Provider.aisdk("@ai-sdk/openai"), {
  130. settings: { baseURL: "https://openai.example/v1" },
  131. limit: { context: 100, input: 80, output: 20 },
  132. })
  133. const resolved = yield* ModelResolver.fromCatalogModel(catalog)
  134. expect(catalog.id).toBe(ID.make("test-model"))
  135. expect(resolved).toMatchObject({ id: "api-test-model", provider: "test-provider" })
  136. expect(resolved.route).toMatchObject({
  137. id: "openai-responses",
  138. providerMetadataKey: "openai",
  139. endpoint: { baseURL: "https://openai.example/v1" },
  140. defaults: {
  141. headers: { "x-test": "header" },
  142. limits: { context: 100, input: 80, output: 20 },
  143. http: { body: { custom_extension: { enabled: true } } },
  144. },
  145. })
  146. }),
  147. )
  148. it.effect("keeps catalog apiKey credentials out of provider JSON", () =>
  149. Effect.gen(function* () {
  150. const resolved = yield* ModelResolver.fromCatalogModel(
  151. model(Provider.aisdk("@ai-sdk/openai"), {
  152. settings: { apiKey: "secret", baseURL: "https://openai.example/v1" },
  153. }),
  154. )
  155. const prepared = yield* compileRequest(LLM.request({ model: resolved, prompt: "Hello" }))
  156. expect(JSON.stringify(prepared.body)).not.toContain("apiKey")
  157. expect(JSON.stringify(prepared.body)).not.toContain("secret")
  158. }),
  159. )
  160. it.effect("treats an empty configured API key as omitted", () =>
  161. Effect.gen(function* () {
  162. const resolved = yield* ModelResolver.fromCatalogModel(
  163. model(Provider.aisdk("@ai-sdk/openai"), {
  164. settings: { apiKey: "", baseURL: "https://openai.example/v1" },
  165. }),
  166. )
  167. const headers = yield* resolved.route.auth.apply({
  168. request: LLM.request({ model: resolved, prompt: "Hello" }),
  169. method: "POST",
  170. url: "https://openai.example/v1/responses",
  171. body: "{}",
  172. headers: Headers.empty,
  173. })
  174. expect(headers.authorization).toBeUndefined()
  175. }),
  176. )
  177. it.effect("uses merged API settings for OpenAI-compatible auth and request defaults", () =>
  178. Effect.gen(function* () {
  179. const resolved = yield* ModelResolver.fromCatalogModel(
  180. model(Provider.aisdk("@ai-sdk/openai-compatible"), {
  181. compatibility: { reasoningField: "vendor_reasoning" },
  182. settings: {
  183. apiKey: "settings-secret",
  184. baseURL: "https://compatible.example/v1",
  185. compatibility: "strict",
  186. },
  187. headers: {},
  188. body: {},
  189. }),
  190. )
  191. const request = LLM.request({ model: resolved, prompt: "Hello" })
  192. const headers = yield* resolved.route.auth.apply({
  193. request,
  194. method: "POST",
  195. url: "https://compatible.example/v1/chat/completions",
  196. body: "{}",
  197. headers: Headers.empty,
  198. })
  199. expect(headers.authorization).toBe("Bearer settings-secret")
  200. expect(resolved.route.id).toBe("openai-compatible-chat")
  201. expect(resolved.compatibility?.reasoningField).toBe("vendor_reasoning")
  202. expect(resolved.route.endpoint.baseURL).toBe("https://compatible.example/v1")
  203. expect(resolved.route.defaults.http?.body).toEqual({})
  204. }),
  205. )
  206. it.effect("overlays selected OpenAI variant settings and bodies", () =>
  207. Effect.gen(function* () {
  208. const catalog = model(Provider.aisdk("@ai-sdk/openai"), {
  209. settings: { baseURL: "https://openai.example/v1" },
  210. variants: [
  211. {
  212. id: VariantID.make("high"),
  213. settings: { reasoningEffort: "high" },
  214. headers: { "x-variant": "high" },
  215. body: {
  216. store: false,
  217. service_tier: "priority",
  218. temperature: 0.2,
  219. },
  220. },
  221. ],
  222. })
  223. const resolved = yield* ModelResolver.resolveModel(catalog, VariantID.make("high"))
  224. expect(resolved.route.defaults.headers).toMatchObject({ "x-test": "header", "x-variant": "high" })
  225. expect(resolved.route.defaults.http?.body).toEqual({
  226. custom_extension: { enabled: true },
  227. store: false,
  228. service_tier: "priority",
  229. temperature: 0.2,
  230. })
  231. expect(resolved.route.defaults.providerOptions).toEqual({
  232. openai: { store: false, reasoningEffort: "high" },
  233. })
  234. }),
  235. )
  236. it.effect("overlays selected OpenAI-compatible variant bodies", () =>
  237. Effect.gen(function* () {
  238. const catalog = model(Provider.aisdk("@ai-sdk/openai-compatible"), {
  239. settings: { baseURL: "https://compatible.example/v1" },
  240. variants: [
  241. {
  242. id: VariantID.make("high"),
  243. settings: {},
  244. headers: {},
  245. body: { store: false, reasoning_effort: "high" },
  246. },
  247. ],
  248. })
  249. const resolved = yield* ModelResolver.resolveModel(catalog, VariantID.make("high"))
  250. expect(resolved.route.defaults.http?.body).toEqual({
  251. custom_extension: { enabled: true },
  252. store: false,
  253. reasoning_effort: "high",
  254. })
  255. }),
  256. )
  257. it.effect("rejects an explicit unavailable variant during model resolution", () =>
  258. Effect.gen(function* () {
  259. const catalog = model(Provider.aisdk("@ai-sdk/openai"), {
  260. settings: { baseURL: "https://openai.example/v1" },
  261. })
  262. const failure = yield* ModelResolver.resolveModel(catalog, VariantID.make("unknown")).pipe(Effect.flip)
  263. expect(failure).toMatchObject({
  264. _tag: "SessionRunnerModel.VariantUnavailableError",
  265. providerID: "test-provider",
  266. modelID: "test-model",
  267. variant: "unknown",
  268. })
  269. expect(failure.message).toBe("Variant unavailable for test-provider/test-model: unknown")
  270. }),
  271. )
  272. it.effect("overlays selected Anthropic variant settings", () =>
  273. Effect.gen(function* () {
  274. const catalog = model(Provider.aisdk("@ai-sdk/anthropic"), {
  275. settings: { baseURL: "https://anthropic.example/v1" },
  276. variants: [
  277. {
  278. id: VariantID.make("high"),
  279. settings: { thinking: { type: "enabled", budgetTokens: 12000 } },
  280. headers: {},
  281. body: {},
  282. },
  283. ],
  284. })
  285. const resolved = yield* ModelResolver.resolveModel(catalog, VariantID.make("high"))
  286. expect(resolved.route.defaults.http?.body).toEqual({
  287. custom_extension: { enabled: true },
  288. })
  289. expect(resolved.route.defaults.providerOptions).toEqual({
  290. anthropic: { thinking: { type: "enabled", budgetTokens: 12000 } },
  291. })
  292. }),
  293. )
  294. it.effect("maps catalog Anthropic AI SDK models into native routes", () =>
  295. Effect.gen(function* () {
  296. const resolved = yield* ModelResolver.fromCatalogModel(
  297. model(Provider.aisdk("@ai-sdk/anthropic"), {
  298. settings: { baseURL: "https://anthropic.example/v1" },
  299. }),
  300. )
  301. expect(resolved.route).toMatchObject({
  302. id: "anthropic-messages",
  303. providerMetadataKey: "anthropic",
  304. endpoint: { baseURL: "https://anthropic.example/v1" },
  305. })
  306. }),
  307. )
  308. it.effect("uses resolved credentials for bearer auth", () =>
  309. Effect.gen(function* () {
  310. const resolved = yield* ModelResolver.fromCatalogModel(
  311. model(Provider.aisdk("@ai-sdk/openai"), {
  312. settings: { baseURL: "https://openai.example/v1" },
  313. headers: {},
  314. body: {},
  315. }),
  316. Credential.Key.make({ type: "key", key: "secret" }),
  317. )
  318. const request = LLM.request({ model: resolved, prompt: "Hello" })
  319. const headers = yield* resolved.route.auth.apply({
  320. request,
  321. method: "POST",
  322. url: "https://openai.example/v1/responses",
  323. body: "{}",
  324. headers: Headers.empty,
  325. })
  326. expect(headers.authorization).toBe("Bearer secret")
  327. }),
  328. )
  329. it.effect("prefers stored credentials over configured auth", () =>
  330. Effect.gen(function* () {
  331. const credential = Credential.Key.make({ type: "key", key: "stored-secret", metadata: { tenant: "work" } })
  332. const resolved = yield* ModelResolver.fromCatalogModel(
  333. model(Provider.aisdk("@ai-sdk/openai"), {
  334. settings: { apiKey: "configured-secret", baseURL: "https://openai.example/v1" },
  335. headers: {},
  336. body: {},
  337. }),
  338. credential,
  339. )
  340. const headers = yield* resolved.route.auth.apply({
  341. request: LLM.request({ model: resolved, prompt: "Hello" }),
  342. method: "POST",
  343. url: "https://openai.example/v1/responses",
  344. body: "{}",
  345. headers: Headers.empty,
  346. })
  347. expect(headers.authorization).toBe("Bearer stored-secret")
  348. expect(resolved.route.defaults.http?.body).toEqual({ tenant: "work" })
  349. }),
  350. )
  351. it.effect("does not project OAuth account metadata into the request body", () =>
  352. Effect.gen(function* () {
  353. const resolved = yield* ModelResolver.fromCatalogModel(
  354. model(Provider.aisdk("@ai-sdk/openai"), {
  355. settings: { baseURL: "https://openai.example/v1" },
  356. headers: {},
  357. body: {},
  358. }),
  359. Credential.OAuth.make({
  360. type: "oauth",
  361. methodID: Integration.MethodID.make("device"),
  362. access: "secret",
  363. refresh: "refresh",
  364. expires: Date.now() + 60_000,
  365. metadata: { server: "https://console.example", orgID: "org_123" },
  366. }),
  367. )
  368. expect(resolved.route.defaults.http?.body).toEqual({})
  369. }),
  370. )
  371. it.effect("applies plugin-projected OpenAI endpoint and headers", () =>
  372. Effect.gen(function* () {
  373. const resolved = yield* ModelResolver.fromCatalogModel(
  374. model("@opencode-ai/ai/providers/openai", {
  375. settings: { baseURL: "https://chatgpt.com/backend-api/codex" },
  376. headers: { "chatgpt-account-id": "acct_123" },
  377. body: {},
  378. }),
  379. Credential.OAuth.make({
  380. type: "oauth",
  381. methodID: Integration.MethodID.make("chatgpt-browser"),
  382. access: "chatgpt-token",
  383. refresh: "refresh",
  384. expires: Date.now() + 60_000,
  385. metadata: { accountID: "acct_123" },
  386. }),
  387. )
  388. const request = LLM.request({ model: resolved, prompt: "Hello" })
  389. const headers = yield* resolved.route.auth.apply({
  390. request,
  391. method: "POST",
  392. url: "https://chatgpt.com/backend-api/codex/responses",
  393. body: "{}",
  394. headers: Headers.empty,
  395. })
  396. expect(resolved.route).toMatchObject({
  397. id: "openai-responses",
  398. endpoint: { baseURL: "https://chatgpt.com/backend-api/codex" },
  399. })
  400. expect(resolved.route.defaults.headers).toMatchObject({ "chatgpt-account-id": "acct_123" })
  401. expect(headers.authorization).toBe("Bearer chatgpt-token")
  402. }),
  403. )
  404. it.effect("does not route native OpenAI-compatible packages to the codex backend", () =>
  405. Effect.gen(function* () {
  406. const resolved = yield* ModelResolver.fromCatalogModel(
  407. model("@opencode-ai/ai/providers/openai-compatible", {
  408. settings: { baseURL: "https://compatible.example/v1" },
  409. }),
  410. Credential.OAuth.make({
  411. type: "oauth",
  412. methodID: Integration.MethodID.make("chatgpt-browser"),
  413. access: "chatgpt-token",
  414. refresh: "refresh",
  415. expires: Date.now() + 60_000,
  416. metadata: { accountID: "acct_123" },
  417. }),
  418. )
  419. expect(resolved.route.id).toBe("openai-compatible-chat")
  420. expect(resolved.route.endpoint.baseURL).toBe("https://compatible.example/v1")
  421. }),
  422. )
  423. it.effect("maps legacy OpenAI organization and project settings to headers", () =>
  424. Effect.gen(function* () {
  425. const resolved = yield* ModelResolver.fromCatalogModel(
  426. model(Provider.aisdk("@ai-sdk/openai"), {
  427. settings: { organization: "org_123", project: "proj_123" },
  428. }),
  429. )
  430. expect(resolved.route.defaults.headers).toMatchObject({
  431. "OpenAI-Organization": "org_123",
  432. "OpenAI-Project": "proj_123",
  433. })
  434. }),
  435. )
  436. it.effect("keeps non-ChatGPT OAuth credentials on the configured endpoint", () =>
  437. Effect.gen(function* () {
  438. const resolved = yield* ModelResolver.fromCatalogModel(
  439. model(Provider.aisdk("@ai-sdk/openai"), {
  440. settings: { baseURL: "https://openai.example/v1" },
  441. headers: {},
  442. body: {},
  443. }),
  444. Credential.OAuth.make({
  445. type: "oauth",
  446. methodID: Integration.MethodID.make("device"),
  447. access: "oauth-token",
  448. refresh: "refresh",
  449. expires: Date.now() + 60_000,
  450. metadata: { accountID: "acct_123" },
  451. }),
  452. )
  453. const request = LLM.request({ model: resolved, prompt: "Hello" })
  454. const headers = yield* resolved.route.auth.apply({
  455. request,
  456. method: "POST",
  457. url: "https://openai.example/v1/responses",
  458. body: "{}",
  459. headers: Headers.empty,
  460. })
  461. expect(resolved.route.endpoint.baseURL).toBe("https://openai.example/v1")
  462. expect(headers.authorization).toBe("Bearer oauth-token")
  463. expect(headers["chatgpt-account-id"]).toBeUndefined()
  464. }),
  465. )
  466. it.effect("loads dynamic native provider packages through the injected package loader", () =>
  467. Effect.gen(function* () {
  468. const native = yield* ModelResolver.fromCatalogModel(
  469. model(Provider.aisdk("@ai-sdk/openai"), {
  470. settings: { baseURL: "https://openai.example/v1" },
  471. }),
  472. )
  473. const resolved = yield* ModelResolver.fromCatalogModel(
  474. model("@opencode-ai/ai/providers/custom", {
  475. settings: { region: "test" },
  476. headers: { "x-package": "header" },
  477. body: { custom: true },
  478. }),
  479. undefined,
  480. {
  481. loadPackage: (specifier) => {
  482. expect(specifier).toBe("@opencode-ai/ai/providers/custom")
  483. return Effect.succeed({
  484. model: (modelID, settings) => {
  485. expect(modelID).toBe("api-test-model")
  486. expect(settings).toEqual({
  487. region: "test",
  488. headers: { "x-package": "header" },
  489. body: { custom: true },
  490. limits: { context: 100, output: 20 },
  491. })
  492. return LanguageModel.make({ id: modelID, provider: "package-provider", route: native.route })
  493. },
  494. })
  495. },
  496. },
  497. )
  498. expect(resolved).toMatchObject({ id: "api-test-model", provider: "test-provider" })
  499. }),
  500. )
  501. it.effect("maps OAuth credentials to native provider auth settings", () =>
  502. Effect.gen(function* () {
  503. const native = yield* ModelResolver.fromCatalogModel(
  504. model(Provider.aisdk("@ai-sdk/openai"), {
  505. settings: { baseURL: "https://openai.example/v1" },
  506. }),
  507. )
  508. const credential = Credential.OAuth.make({
  509. type: "oauth",
  510. methodID: Integration.MethodID.make("device"),
  511. access: "oauth-token",
  512. refresh: "refresh",
  513. expires: Date.now() + 60_000,
  514. })
  515. const packages = [
  516. ["@opencode-ai/ai/providers/google-vertex", "accessToken"],
  517. ["@opencode-ai/ai/providers/google-vertex/gemini", "accessToken"],
  518. ["@opencode-ai/ai/providers/google-vertex/chat", "accessToken"],
  519. ["@opencode-ai/ai/providers/google-vertex/responses", "accessToken"],
  520. ["@opencode-ai/ai/providers/google-vertex/messages", "accessToken"],
  521. ["@opencode-ai/ai/providers/anthropic", "authToken"],
  522. ["@opencode-ai/ai/providers/anthropic-compatible", "authToken"],
  523. ] as const
  524. yield* Effect.forEach(packages, ([specifier, key]) =>
  525. ModelResolver.fromCatalogModel(model(specifier, { settings: { apiKey: "configured-key" } }), credential, {
  526. loadPackage: () =>
  527. Effect.succeed({
  528. model: (modelID, settings) => {
  529. expect(settings).toMatchObject({ [key]: "oauth-token" })
  530. expect(settings).not.toHaveProperty("apiKey")
  531. return LanguageModel.make({ id: modelID, provider: "package-provider", route: native.route })
  532. },
  533. }),
  534. }),
  535. )
  536. }),
  537. )
  538. it.effect("routes supported AISDK catalog packages through native provider packages", () =>
  539. Effect.gen(function* () {
  540. const native = yield* ModelResolver.fromCatalogModel(model(Provider.aisdk("@ai-sdk/openai")))
  541. const packages = [
  542. [
  543. "@ai-sdk/google",
  544. "@opencode-ai/ai/providers/google",
  545. { thinkingConfig: { thinkingLevel: "high" } },
  546. { gemini: { thinkingConfig: { thinkingLevel: "high" } } },
  547. ],
  548. [
  549. "@openrouter/ai-sdk-provider",
  550. "@opencode-ai/ai/providers/openrouter",
  551. { reasoning: { effort: "high" } },
  552. { openrouter: { reasoning: { effort: "high" } } },
  553. ],
  554. [
  555. "@ai-sdk/xai",
  556. "@opencode-ai/ai/providers/xai",
  557. { reasoningEffort: "high" },
  558. { xai: { reasoningEffort: "high" } },
  559. ],
  560. ] as const
  561. yield* Effect.forEach(packages, ([catalogPackage, nativePackage, sourceOptions, providerOptions]) =>
  562. ModelResolver.fromCatalogModel(
  563. model(Provider.aisdk(catalogPackage), {
  564. modelID: "api-model",
  565. settings: { baseURL: "https://provider.example/v1", ...sourceOptions },
  566. headers: { "x-provider": "header" },
  567. body: { custom: true },
  568. }),
  569. Credential.Key.make({ type: "key", key: "secret" }),
  570. {
  571. loadPackage: (specifier) => {
  572. expect(specifier).toBe(nativePackage)
  573. return Effect.succeed({
  574. model: (modelID, settings) => {
  575. expect(modelID).toBe("api-model")
  576. expect(settings).toMatchObject({
  577. apiKey: "secret",
  578. baseURL: "https://provider.example/v1",
  579. headers: { "x-provider": "header" },
  580. body: { custom: true },
  581. limits: { context: 100, output: 20 },
  582. providerOptions,
  583. })
  584. return LanguageModel.make({ id: modelID, provider: "native-provider", route: native.route })
  585. },
  586. })
  587. },
  588. loadAISDK: () => Effect.die("AI SDK loader should not be called"),
  589. },
  590. ),
  591. )
  592. }),
  593. )
  594. it.effect("merges mapped OpenRouter headers and body with catalog overlays", () =>
  595. ModelResolver.fromCatalogModel(
  596. model(Provider.aisdk("@openrouter/ai-sdk-provider"), {
  597. settings: {
  598. appName: "OpenCode",
  599. appUrl: "https://opencode.ai",
  600. extraBody: { transforms: ["middle-out"], provider: { sort: "price" } },
  601. },
  602. headers: { "X-OpenRouter-Title": "Custom" },
  603. body: { provider: { only: ["anthropic"] } },
  604. }),
  605. undefined,
  606. {
  607. loadPackage: () =>
  608. Effect.succeed({
  609. model: (modelID, settings) => {
  610. expect(settings.headers).toEqual({
  611. "HTTP-Referer": "https://opencode.ai",
  612. "X-OpenRouter-Title": "Custom",
  613. })
  614. expect(settings.body).toEqual({
  615. transforms: ["middle-out"],
  616. provider: { sort: "price", only: ["anthropic"] },
  617. })
  618. return LanguageModel.make({ id: modelID, provider: "openrouter", route: OpenAIChat.route })
  619. },
  620. }),
  621. },
  622. ),
  623. )
  624. it.effect("loads supported AISDK catalog packages as native routes", () =>
  625. Effect.gen(function* () {
  626. const google = yield* ModelResolver.fromCatalogModel(
  627. model(Provider.aisdk("@ai-sdk/google"), { settings: { thinkingConfig: { thinkingBudget: 1_024 } } }),
  628. )
  629. const openrouter = yield* ModelResolver.fromCatalogModel(
  630. model(Provider.aisdk("@openrouter/ai-sdk-provider"), {
  631. settings: { reasoning: { effort: "high" } },
  632. }),
  633. )
  634. const xai = yield* ModelResolver.fromCatalogModel(
  635. model(Provider.aisdk("@ai-sdk/xai"), { settings: { reasoningEffort: "high" } }),
  636. )
  637. const bedrock = yield* ModelResolver.fromCatalogModel(
  638. model(Provider.aisdk("@ai-sdk/amazon-bedrock"), {
  639. settings: { region: "us-east-1", topP: 0.8, serviceTier: "priority" },
  640. body: {},
  641. }),
  642. )
  643. const mantle = yield* ModelResolver.fromCatalogModel(
  644. model(Provider.aisdk("@ai-sdk/amazon-bedrock/mantle"), {
  645. modelID: "openai.gpt-oss-120b",
  646. settings: { region: "us-east-1" },
  647. }),
  648. )
  649. expect(google.route.id).toBe("gemini")
  650. expect(google.route.defaults.providerOptions).toEqual({
  651. gemini: { thinkingConfig: { thinkingBudget: 1_024 } },
  652. })
  653. expect(openrouter.route.id).toBe("openrouter")
  654. expect(openrouter.route.defaults.providerOptions).toEqual({ openrouter: { reasoning: { effort: "high" } } })
  655. expect(xai.route.id).toBe("openai-responses")
  656. expect(xai.route.defaults.providerOptions).toEqual({
  657. xai: { reasoningEffort: "high", store: false },
  658. })
  659. expect(bedrock.route.id).toBe("bedrock-converse")
  660. expect(bedrock.route.defaults.generation).toEqual({ topP: 0.8 })
  661. expect(bedrock.route.defaults.http?.body).toEqual({ serviceTier: { type: "priority" } })
  662. expect(mantle.route.id).toBe("bedrock-mantle-responses")
  663. }),
  664. )
  665. it.effect("loads arbitrary AISDK packages through the injected AISDK loader", () =>
  666. Effect.gen(function* () {
  667. const native = yield* ModelResolver.fromCatalogModel(
  668. model(Provider.aisdk("@ai-sdk/openai"), {
  669. settings: { baseURL: "https://openai.example/v1" },
  670. }),
  671. )
  672. const resolved = yield* ModelResolver.fromCatalogModel(
  673. model(Provider.aisdk("@ai-sdk/mistral"), {
  674. modelID: "mistral-api-model",
  675. settings: { project: "test" },
  676. headers: { "x-aisdk": "header" },
  677. body: { custom: true },
  678. }),
  679. Credential.Key.make({ type: "key", key: "fallback-secret" }),
  680. {
  681. loadAISDK: (runtime) =>
  682. Effect.sync(() => {
  683. expect(runtime).toMatchObject({
  684. id: "test-model",
  685. modelID: "mistral-api-model",
  686. providerID: "test-provider",
  687. package: Provider.aisdk("@ai-sdk/mistral"),
  688. settings: { project: "test", apiKey: "fallback-secret" },
  689. headers: { "x-aisdk": "header" },
  690. body: { custom: true },
  691. })
  692. return LanguageModel.make({
  693. id: runtime.modelID ?? runtime.id,
  694. provider: runtime.providerID,
  695. route: native.route,
  696. })
  697. }),
  698. },
  699. )
  700. expect(resolved).toMatchObject({ id: "mistral-api-model", provider: "test-provider" })
  701. }),
  702. )
  703. it.effect("rejects AISDK packages without an available loader", () =>
  704. Effect.gen(function* () {
  705. const failure = yield* ModelResolver.fromCatalogModel(
  706. model(Provider.aisdk("@ai-sdk/mistral"), {
  707. settings: { baseURL: "https://mistral.example/v1" },
  708. }),
  709. ).pipe(Effect.flip)
  710. expect(failure).toMatchObject({
  711. _tag: "SessionRunnerModel.UnsupportedPackageError",
  712. providerID: "test-provider",
  713. modelID: "test-model",
  714. package: "aisdk:@ai-sdk/mistral",
  715. })
  716. expect(failure.message).toBe("Unsupported package for test-provider/test-model: aisdk:@ai-sdk/mistral")
  717. }),
  718. )
  719. it.effect("drops an empty API key before loading an AISDK package", () =>
  720. Effect.gen(function* () {
  721. const native = yield* ModelResolver.fromCatalogModel(
  722. model(Provider.aisdk("@ai-sdk/openai"), {
  723. settings: { baseURL: "https://openai.example/v1" },
  724. }),
  725. )
  726. yield* ModelResolver.fromCatalogModel(
  727. model(Provider.aisdk("@ai-sdk/mistral"), {
  728. settings: { apiKey: "", baseURL: "https://mistral.example/v1" },
  729. }),
  730. undefined,
  731. {
  732. loadAISDK: (runtime) =>
  733. Effect.sync(() => {
  734. expect(runtime.settings).not.toHaveProperty("apiKey")
  735. return native
  736. }),
  737. },
  738. )
  739. }),
  740. )
  741. it.effect("reports whether a catalog model declares a provider package", () =>
  742. Effect.sync(() => {
  743. expect(ModelResolver.supported(model(Provider.aisdk("@ai-sdk/openai")))).toBe(true)
  744. expect(ModelResolver.supported(model("@opencode-ai/ai/providers/custom"))).toBe(true)
  745. expect(ModelResolver.supported(model(undefined))).toBe(false)
  746. }),
  747. )
  748. })