Connect to Anthropic

ANTHROPIC_FEDERATION_RULE_ID=fdrl_...
ANTHROPIC_ORGANIZATION_ID=00000000-0000-0000-0000-000000000000
ANTHROPIC_SERVICE_ACCOUNT_ID=svac_...

import { auth } from "@trigger.dev/sdk";
import { createAnthropic } from "@ai-sdk/anthropic";
import { oidcFederationProvider } from "@anthropic-ai/sdk/lib/credentials/oidc-federation";
import { TokenCache } from "@anthropic-ai/sdk/lib/credentials/token-cache";

export function claude() {
  const anthropicToken = new TokenCache(
    oidcFederationProvider({
      // Anthropic accepts each token's jti once, so mint a fresh one per exchange.
      identityTokenProvider: async () => {
        const { token } = await auth.getOIDCToken({ audience: "https://api.anthropic.com" });
        return token;
      },
      federationRuleId: process.env.ANTHROPIC_FEDERATION_RULE_ID!,
      organizationId: process.env.ANTHROPIC_ORGANIZATION_ID!,
      serviceAccountId: process.env.ANTHROPIC_SERVICE_ACCOUNT_ID!,
      baseURL: "https://api.anthropic.com",
      fetch,
    })
  );

  return createAnthropic({ authToken: () => anthropicToken.getToken() });
}

import { chat } from "@trigger.dev/sdk/ai";
import { stepCountIs } from "ai";
import { claude } from "./claude";

export const supportChat = chat.agent({
  id: "support-chat",
  run: async ({ messages, signal, streamText }) => {
    const anthropic = claude();

    return streamText({
      model: anthropic("claude-sonnet-5-5"),
      messages,
      abortSignal: signal,
      stopWhen: stepCountIs(10),
    });
  },
});

import { task } from "@trigger.dev/sdk";
import { generateText } from "ai";
import { claude } from "./claude";

export const summarize = task({
  id: "summarize",
  run: async (payload: { text: string }) => {
    const anthropic = claude();

    const { text } = await generateText({
      model: anthropic("claude-sonnet-5-5"),
      prompt: `Summarize in two sentences:\n\n${payload.text}`,
    });

    return { summary: text };
  },
});