| 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}`); |
| }); |
| } |
|
|
