Бэкенд agentic-воркфлоу для многошаговых AI-агентов

exports.orchestrator = async function* (ctx) {
  const { query, runId } = ctx.getInput();

  // Step 1: search — retries 3x with exponential backoff on failure
  const searchResults = yield ctx.callActivityWithRetry(
    'search-docs',
    { maxNumberOfAttempts: 3, backoffCoefficient: 2, firstRetryIntervalInMilliseconds: 1000 },
    { query }
  );

  // Step 2: generate draft — single attempt, deterministic
  const draft = yield ctx.callActivity('generate-draft', { query, searchResults });

  // Step 3: human approval gate — wait up to 24h for external event
  const approved = yield ctx.waitForExternalEvent('Approval', 86_400_000);
  if (!approved) return { runId, status: 'rejected', draft };

  // Step 4: durable timer — wait 5 min before publishing (rate-limit guard)
  yield ctx.createTimer(new Date(Date.now() + 5 * 60 * 1000));

  // Step 5: publish result
  const published = yield ctx.callActivity('publish-result', { runId, draft });
  return { runId, status: 'published', url: published.url };
};

export async function handler(event) {
  // API key auth enforced at the gateway route before this code runs
  const { query } = JSON.parse(event.body || '{}');
  const results = await searchInternalDocs(query); // DB_URL from workspace secrets
  return { statusCode: 200, body: JSON.stringify({ results, count: results.length }) };
}

export async function handler(event) {
  const { query, runId } = JSON.parse(event.body || '{}');
  if (!query) return { statusCode: 400, body: JSON.stringify({ error: 'query required' }) };
  // Start the durable orchestrator — returns HTTP 202 with status/event/terminate URIs
  const { instanceId } = await global.durable.startNew('research-agent', undefined, { query, runId });
  return { statusCode: 202, body: JSON.stringify({ instanceId, status: 'started' }) };
}