Function createCreativeAgentRouter

server/src/creative-agent/index.ts:71–191

()

}

export function createCreativeAgentRouter(): Router {
  const router = Router();

  // Clean expired previews every 5 minutes
  const cleanupInterval = setInterval(() => cleanExpiredPreviews(), 5 * 60 * 1000);
  cleanupInterval.unref();

  // Health check
  router.get('/health', (_req: Request, res: Response) => {
    res.json({ status: 'healthy', service: 'creative-agent' });
  });

  // adagents.json discovery
  router.get('/.well-known/adagents.json', (req: Request, res: Response) => {
    const agentBaseUrl = getAgentBaseUrl(req);

    res.json({
      $schema: '/schemas/adagents.json',
      contact: {
        name: 'AdCP Reference Creative Agent',
        url: 'https://adcontextprotocol.org',
      },
      agents: [{
        url: `${agentBaseUrl}/mcp`,
        type: 'creative',
        capabilities: ['list_creative_formats', 'preview_creative'],
      }],
      last_updated: STARTUP_TIME,
    });
  });

  // CORS preflight
  router.options('/mcp', (_req: Request, res: Response) => {
    setCORSHeaders(res);
    res.status(204).end();
  });

  // Rate limiting
  const mcpRateLimiter = rateLimit({
    windowMs: 60 * 1000,
    max: 60,
    standardHeaders: true,
    legacyHeaders: false,
    validate: { xForwardedForHeader: false, ip: false },
    handler: (_req: Request, res: Response) => {
      res.status(429).json({
        jsonrpc: '2.0',
        id: null,
        error: { code: -32000, message: 'Rate limit exceeded. Please try again later.' },
      });
    },
  });

  // MCP endpoint
  router.post('/mcp', mcpRateLimiter, requireToken, async (req: Request, res: Response) => {
    setCORSHeaders(res);

    let server: ReturnType<typeof createCreativeAgentServer> | null = null;