Function buildAnthropicModelsHandler

src/server/model/aiGateway.ts:1266–1338

(
  options: ModelsHandlerOptions
)

 * `x-api-key` and `anthropic-version` headers instead of a Bearer token.
 */
export function buildAnthropicModelsHandler(
  options: ModelsHandlerOptions
): RequestHandler {
  return async (req, res) => {
    const { workspaceId, gatewayId } = z
      .object({
        workspaceId: z.string(),
        gatewayId: z.string(),
      })
      .parse(req.params);

    const apiKey =
      (req.headers['x-api-key'] as string) ??
      (req.headers.authorization ?? '').replace('Bearer ', '');
    let modelApiKey = apiKey;
    const gatewayInfo = await getGatewayInfoCache(workspaceId, gatewayId);
    if (gatewayInfo?.modelApiKey) {
      await verifyUserApiKey(apiKey);
      modelApiKey = gatewayInfo.modelApiKey;
    }

    const baseUrl =
      options.isCustomRoute && gatewayInfo?.customModelBaseUrl
        ? gatewayInfo?.customModelBaseUrl
        : options.baseUrl;

    try {
      const queryString = new URLSearchParams(
        req.query as Record<string, string>
      ).toString();
      const upstreamUrl = `${baseUrl}/models${
        queryString ? `?${queryString}` : ''
      }`;
      const anthropicVersion =
        (req.headers['anthropic-version'] as string) ||
        DEFAULT_ANTHROPIC_VERSION;

      const headers: Record<string, string> = {
        'content-type': 'application/json',
        'x-api-key': modelApiKey,
        'anthropic-version': anthropicVersion,
        ...options.header?.(req),
      };

      const betaHeader = req.headers['anthropic-beta'];
      if (betaHeader) {
        headers['anthropic-beta'] = String(betaHeader);
      }

      const upstreamResponse = await fetch(upstreamUrl, {
        method: 'GET',
        headers,
      });

      const body = await upstreamResponse.text();
      res.status(upstreamResponse.status);
      res.setHeader(
        'content-type',