Function fetchProviderModelsStrict

packages/runtime/src/model-fetcher.ts:158–281

(
  connection: ConnectionEffectConnection,
  apiKey: string,
  fetchFn: ConnectionEffectFetch | undefined,
)

}

async function fetchProviderModelsStrict(
  connection: ConnectionEffectConnection,
  apiKey: string,
  fetchFn: ConnectionEffectFetch | undefined,
): Promise<ModelInfo[]> {
  const baseUrl = effectiveBaseUrl(connection);
  const definition = PROVIDER_DEFAULTS[connection.providerType];
  // Unknown providerType → no discovery path. Throw a clear error (caught and
  // generalized by the caller) rather than crashing on `.modelDiscovery`.
  // Mirrors `isFakeBackend` in @maka/core/connection-readiness.ts.
  if (!definition) {
    throw new Error(`Unknown provider type "${connection.providerType}"`);
  }
  const discovery = definition.modelDiscovery;

  if (discovery.kind === 'fallback') {
    return definition.fallbackModels.map((id) => ({ id }));
  }
  if (discovery.kind === 'ollama') {
    const r = await fetchForConnectionEffect(fetchFn, `${ollamaRoot(baseUrl)}/api/tags`, {
      timeoutMs: MODEL_FETCH_TIMEOUT_MS,
    });
    if (!r.ok) {
      await r.cancel();
      throw new ConnectionEffectHttpError(r.status);
    }
    const data = await readProviderJson<{ models?: unknown }>(r);
    return providerObjectArray<{ name?: string }>(data.models, 'Ollama models').flatMap((model) =>
      model.name ? [{ id: model.name }] : [],
    );
  }
  if (discovery.kind === 'fireworks') {
    return fetchFireworksModels(baseUrl, apiKey, discovery, fetchFn);
  }
  if (discovery.kind === 'cohere') {
    return fetchCohereModels(baseUrl, apiKey, fetchFn);
  }
  if (discovery.kind === 'cloudflare') {
    return fetchCloudflareModels(baseUrl, apiKey, fetchFn);
  }
  if (discovery.auth === 'github-copilot') {
    return fetchGitHubCopilotModels(baseUrl, apiKey, fetchFn);
  }
  if (discovery.auth === 'openai-codex') {
    return fetchOpenAiCodexModels(baseUrl, apiKey, fetchFn);
  }

  switch (definition.protocol) {
    case 'anthropic': {
      const r = await fetchForConnectionEffect(fetchFn, anthropicV1Url(baseUrl, '/models'), {
        headers: anthropicModelHeaders(
          discovery.auth === 'claude-subscription' ? discovery.auth : undefined,
          apiKey,
        ),
        timeoutMs: MODEL_FETCH_TIMEOUT_MS,
      });
      if (!r.ok) {
        await r.cancel();