Use Brew with Vercel Connect

import { createMCPClient } from '@ai-sdk/mcp';
import {
  connectAuthProvider,
  ConsentRequiredError,
} from '@vercel/connect/ai-sdk';
import { stepCountIs, streamText } from 'ai';

export const maxDuration = 60;

export async function POST(request: Request) {
  const { prompt } = await request.json();
  // Take this from your authenticated session, never from the request body.
  const userId = 'user_123';
  let brew: Awaited<ReturnType<typeof createMCPClient>> | undefined;

  try {
    brew = await createMCPClient({
      transport: {
        type: 'http',
        url: 'https://brew.new/api/mcp',
        authProvider: connectAuthProvider(
          'brew',
          { subject: { type: 'user', id: userId } },
          { redirectUrl: new URL('/', request.url).toString() },
        ),
      },
    });

    const result = streamText({
      model: 'anthropic/claude-sonnet-5.5',
      tools: await brew.tools(),
      prompt,
      stopWhen: stepCountIs(8),
      onFinish: async () => {
        await brew?.close();
      },
    });

    return result.toTextStreamResponse();
  } catch (error) {
    await brew?.close();
    if (error instanceof ConsentRequiredError) {
      return Response.redirect(error.url, 303);
    }
    throw error;
  }
}

import { getToken } from '@vercel/connect';

export async function fireBrewTrigger(
  triggerEventId: string,
  payload: Record<string, unknown>,
  idempotencyKey: string,
) {
  const key = await getToken('brew-api', { subject: { type: 'app' } });

  const response = await fetch(
    `https://brew.new/api/v1/automations/triggers/${triggerEventId}/fire`,
    {
      method: 'POST',
      headers: {
        Authorization: `Bearer ${key}`,
        'Content-Type': 'application/json',
        'Idempotency-Key': idempotencyKey,
      },
      body: JSON.stringify({ payload }),
    },
  );
  if (!response.ok) {
    throw new Error(`Brew returned ${response.status}`);
  }
  return response.json();
}