Create an AI Agent with Vercel AI SDK

// server.ts
import express from "express";
import cors from "cors";
import bodyParser from "body-parser";
import {
  convertCometChatMessagesToVercelMessages,
  convertCometChatToolsToVercelAISDKTools,
  mapVercelStreamChunkToCometChatEvent,
} from "vercel-cometchat-adaptor";
import { runVercelAgent } from "./vercel/agent";

const app = express();
const port = process.env.PORT || 4000;

app.use(cors());
app.use(bodyParser.json());

app.post("/agent/vercel", async (req, res) => {
  try {
    const cometChatTools = Array.isArray(req.body.tools)
      ? convertCometChatToolsToVercelAISDKTools(req.body.tools)
      : {};

    const messages = convertCometChatMessagesToVercelMessages(req.body.messages);
    if (!Array.isArray(messages) || messages.length === 0) {
      return res.status(400).json({ error: "Invalid request" });
    }

    res.setHeader("Content-Type", "text/event-stream");
    res.setHeader("Cache-Control", "no-cache");
    res.setHeader("Connection", "keep-alive");

    const runId = req.body.runId || `run_${Date.now()}`;
    const threadId = req.body.threadId || "thread_1";

    const stream = await runVercelAgent({ messages, tools: cometChatTools });

    for await (const chunk of stream.fullStream) {
      const events = mapVercelStreamChunkToCometChatEvent(chunk);
      for (const event of events) {
        event.runId = runId;
        event.threadId = threadId;
        event.timestamp = event.timestamp || Date.now();
        res.write(`data: ${JSON.stringify(event)}\n\n`);
      }
    }

    res.end();
  } catch (error) {
    console.error(error);
    res.write(
      `data: ${JSON.stringify({
        type: "error",
        message: "Agent processing failed",
        timestamp: Date.now(),
      })}\n\n`
    );
    res.end();
  }
});

app.listen(port, () => {
  console.log(`Server running at http://localhost:${port}/agent/vercel`);
});