AI 에이전트에게 전화기 주기

// vox.ai 음성 에이전트와 내 AI 에이전트를 잇는 최소 중계 서버. Node 18 이상, 의존성 없음.
import http from 'node:http';
import { randomUUID } from 'node:crypto';

const TOKEN = process.env.RELAY_TOKEN;
const PORT = Number(process.env.PORT || 8787);
const HOLD_MS = 50_000;
if (!TOKEN) throw new Error('RELAY_TOKEN 이 필요해요');

const events = new Map();     // call_id -> AI 에이전트가 읽는 질문 목록
const questions = new Map();  // id -> { answer, waiters }
const openByCall = new Map(); // call_id -> 아직 답하지 않은 질문 id
const listeners = new Map();  // call_id -> 질문을 기다리는 AI 에이전트

const json = (res, code, body) => { res.writeHead(code, { 'content-type': 'application/json' }); res.end(JSON.stringify(body)); };
const readBody = (req) => new Promise((ok) => { let b = ''; req.setEncoding('utf8'); req.on('data', (c) => (b += c)); req.on('end', () => { try { const v = JSON.parse(b || '{}'); ok(v && typeof v === 'object' ? v : {}); } catch { ok(null); } }); });
const wait = (list, ms) => new Promise((ok) => { const w = (v) => { clearTimeout(t); list.delete(w); ok(v); }; const t = setTimeout(() => w(null), ms); list.add(w); });

http.createServer(async (req, res) => {
  if (req.headers.authorization !== `Bearer ${TOKEN}`) return json(res, 401, { error: 'unauthorized' });
  const url = new URL(req.url, 'http://x');

  // 1. vox.ai 의 ask_brain 도구가 부른다: 질문을 올리고 답을 기다린다.
  const ask = url.pathname.match(/^\/ask\/([\w-]+)$/);
  if (req.method === 'POST' && ask) {
    const callId = ask[1], { question = '' } = (await readBody(req)) ?? {};
    let id = openByCall.get(callId);
    if (!id) {
      id = randomUUID();
      questions.set(id, { answer: null, waiters: new Set() });
      openByCall.set(callId, id);
      const list = events.get(callId) ?? [];
      events.set(callId, list);
      list.push({ index: list.length, id, question });
      listeners.get(callId)?.forEach((w) => w(true));
    }
    const q = questions.get(id);
    const answer = q.answer ?? (await wait(q.waiters, HOLD_MS));
    if (answer == null) return json(res, 200, { answer: '', instruction: '아직 확인 중이에요. 말없이 같은 질문으로 ask_brain 을 다시 부르세요.' });
    openByCall.delete(callId);
    return json(res, 200, { answer });
  }

  // 2. AI 에이전트가 부른다: 이 통화의 after 번째 질문이 올 때까지 기다렸다가 돌려준다.
  const next = url.pathname.match(/^\/next\/([\w-]+)$/);
  if (req.method === 'GET' && next) {
    const callId = next[1], after = Number(url.searchParams.get('after') || 0);
    if (!listeners.has(callId)) listeners.set(callId, new Set());
    if (!events.get(callId)?.[after]) await wait(listeners.get(callId), HOLD_MS);
    return json(res, 200, events.get(callId)?.[after] ?? { type: 'timeout' });
  }

  // 3. AI 에이전트가 부른다: 질문에 답한다.
  if (req.method === 'POST' && url.pathname === '/answer') {
    const body = await readBody(req);
    if (!body?.answer) return json(res, 400, { error: 'invalid_json_or_empty_answer' });
    const q = questions.get(body.id);
    if (!q) return json(res, 404, { error: 'unknown_id' });
    if (q.answer != null) return json(res, 409, { error: 'already_answered' });
    q.answer = String(body.answer);
    q.waiters.forEach((w) => w(q.answer));
    return json(res, 200, { ok: true });
  }
  json(res, 404, { error: 'not_found' });
}).listen(PORT, () => console.log(`relay on :${PORT}`));