File size: 2,625 Bytes
3c7404b | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 | import { serve } from '@hono/node-server';
import { Hono } from 'hono';
import { rateLimit } from 'express-rate-limit';
import { readFileSync } from 'node:fs';
import { join } from 'node:path';
import { executeBackendAgentAction, BackendAgentAction } from './runtime.js';
export function runHttpServer() {
const app = new Hono();
const PORT = Number(process.env.PORT) || 8080;
const rateLimiter = rateLimit({
windowMs: 60 * 1000,
max: 100,
message: 'Too many requests, please try again later.',
});
app.use('*', async (c, next) => {
return new Promise<void>((resolve) => {
const env = (c as any).env as any;
rateLimiter(env?.req as any, env?.res as any, () => {
next().then(resolve);
});
});
});
app.get('/health', (c) => c.json({ status: 'ok', agent: 'sin-backend' }));
app.get('/.well-known/agent-card.json', (c) => {
try {
const card = readFileSync(join(process.cwd(), '.well-known', 'agent-card.json'), 'utf8');
return c.json(JSON.parse(card));
} catch {
return c.json({ error: 'Agent card not found' }, 404);
}
});
app.get('/.well-known/agent.json', (c) => {
try {
const spec = readFileSync(join(process.cwd(), '.well-known', 'agent.json'), 'utf8');
return c.json(JSON.parse(spec));
} catch {
return c.json({ error: 'Agent spec not found' }, 404);
}
});
app.post('/a2a/v1', async (c) => {
try {
const body = await c.req.json();
const rpcMethod = body.method;
let action: BackendAgentAction;
if (rpcMethod === 'sin.backend.health') {
action = { action: 'sin.backend.health' };
} else if (rpcMethod === 'sin.backend.code.generate') {
action = { action: 'sin.backend.code.generate', prompt: body.params?.prompt, contextDir: body.params?.contextDir };
} else if (rpcMethod === 'sin.backend.code.review') {
action = { action: 'sin.backend.code.review', targetDir: body.params?.targetDir };
} else if (rpcMethod === 'agent.help' || body.action === 'agent.help') {
action = { action: 'agent.help' };
} else {
return c.json({ error: { code: -32601, message: 'Method not found' } }, 400);
}
const result = await executeBackendAgentAction(action);
return c.json({ jsonrpc: '2.0', id: body.id || null, result });
} catch (e: any) {
return c.json({ error: { code: -32000, message: e.message } }, 500);
}
});
serve({ fetch: app.fetch, port: PORT }, (info) => {
console.log(`SIN-Backend HTTP A2A server running at http://localhost:${info.port}`);
});
}
|