Function buildModelsHandler

src/proxy/router/models_route.js:18–50

({ anthropicProxy, openAIProxy, logger } = {})

}

function buildModelsHandler({ anthropicProxy, openAIProxy, logger } = {}) {
  if (typeof anthropicProxy !== 'function' || typeof openAIProxy !== 'function') {
    throw new Error('buildModelsHandler requires anthropicProxy(path,body,opts) + openAIProxy(path,body,opts)');
  }
  const log = logger || console;

  return async ({ headers }) => {
    const inboundHeaders = headers || {};
    const provider = detectModelsProvider(inboundHeaders);
    const [proxyFn, reqPath, mode] = provider === 'anthropic'
      ? [anthropicProxy, '/v1/models', 'anthropic']
      : [openAIProxy, '/models', 'openai'];

    let up;
    try {
      up = await proxyFn(reqPath, null, { method: 'GET', inboundHeaders, upstreamMode: mode });
    } catch (err) {
      const status = Number(err && err.statusCode) || 502;
      return { status, body: { error: (err && err.message) || 'models upstream request failed' } };
    }

    let raw = '';
    try { raw = up.text ? await up.text() : ''; } catch { raw = ''; }
    let body;
    try {
      body = raw ? JSON.parse(raw) : {};
    } catch {
      log.warn?.(JSON.stringify({ event: 'models_fallback', reason: 'upstream_non_json', upstream_status: up.status }));
      body = { error: raw };
    }
    return { status: up.status, body };
  };
}

module.exports = { buildModelsHandler, detectModelsProvider };