Vercel AI SDK

npm install ai @ai-sdk/openai

import { createOpenAI } from "@ai-sdk/openai"

const xenovia = createOpenAI({
  apiKey: process.env.XENOVIA_API_KEY,
  baseURL: `https://runtime.xenovia.io/a/${process.env.XENOVIA_PROXY_ID}/openai/v1`
})

const model = xenovia("gpt-4o-mini")

import { streamText } from "ai"

const { textStream } = streamText({
  model,
  messages: [{ role: "user", content: "Explain AI governance in plain English" }]
})

for await (const chunk of textStream) {
  process.stdout.write(chunk)
}

// app/api/chat/route.ts
import { streamText } from "ai"
import { createOpenAI } from "@ai-sdk/openai"
import { randomUUID } from "crypto"

export async function POST(req: Request) {
  const { messages, sessionId } = await req.json()

  const xenovia = createOpenAI({
    apiKey: process.env.XENOVIA_API_KEY,
    baseURL: `https://runtime.xenovia.io/a/${process.env.XENOVIA_PROXY_ID}/openai/v1`,
    headers: {
      // Use a stable session ID from the client to group conversation turns
      "X-Xenovia-Session-Id": sessionId ?? randomUUID(),
      // Tag traces with application context
      "X-Xenovia-Property-route": "chat",
    }
  })

  const result = streamText({
    model: xenovia("gpt-4o-mini"),
    messages
  })

  return result.toDataStreamResponse()
}

import { streamText, tool } from "ai"
import { z } from "zod"

const result = streamText({
  model,
  messages: [{ role: "user", content: "What is the weather in London?" }],
  tools: {
    getWeather: tool({
      description: "Get the weather for a location",
      parameters: z.object({ location: z.string() }),
      execute: async ({ location }) => ({ temperature: "15°C", location })
    })
  }
})

const xenovia = createOpenAI({
  apiKey: process.env.XENOVIA_API_KEY,
  baseURL: `https://runtime.xenovia.io/a/${process.env.XENOVIA_PROXY_ID}/openai/v1`,
  headers: {
    "X-Xenovia-Session-Id": conversationId,  // stable ID from your DB or cookie
    "X-Xenovia-Session-Path": `users/${userId}/conversations`
  }
})

try {
  const result = streamText({ model, messages })
  return result.toDataStreamResponse()
} catch (error: any) {
  if (error?.status === 403) {
    return new Response(
      JSON.stringify({ error: "Request blocked by policy" }),
      { status: 403, headers: { "Content-Type": "application/json" } }
    )
  }
  throw error
}