import { createA2AExpressApp } from '@reaatech/a2a-reference-server';
 
const app = createA2AExpressApp({
  agentCard: { /* ... */ },
  executor: {
    async execute(context, eventBus) { /* your logic */ },
  },
});
 
app.listen(3000);

// Express
const app = createA2AExpressApp({ agentCard, executor });
 
// Hono (edge-compatible)
const app = createA2AHonoApp({ agentCard, executor });

const app = createA2AExpressApp({
  agentCard,
  executor,
  healthChecks: [{ name: 'db', check: async () => ({ status: 'ok' }) }],
});
// GET /healthz, GET /readyz

import { RateLimiter } from '@reaatech/a2a-reference-server';
 
const app = createA2AExpressApp({
  agentCard,
  executor,
  rateLimiter: new RateLimiter({ windowMs: 60_000, maxRequests: 100 }),
});

import { PushNotificationManager } from '@reaatech/a2a-reference-server';
 
const app = createA2AExpressApp({
  agentCard: { ...agentCard, capabilities: { pushNotifications: true } },
  executor,
  pushNotificationManager: new PushNotificationManager({ maxRetries: 3 }),
});

const app = createA2AExpressApp({
  agentCard,
  executor,
  extendedAgentCard: { customData: '...' },
});
// GET /.well-known/agent-card/extended
// RPC: tasks/extendedAgentCard

import { RedisSseCoordinator } from '@reaatech/a2a-reference-server';
import { Redis } from 'ioredis';
 
const coordinator = new RedisSseCoordinator({
  redis: new Redis(),
  connectOnInit: true, // auto-connects
});

const app = createA2AExpressApp({
  agentCard,
  executor,
  authStrategy: new JwtStrategy({ jwksUri: 'https://auth.example.com/jwks' }),
});