Orchestrator Agent

curl -X POST https://api.ivory.finance/v1/rag/orchestrate \
  -H "X-API-Key: your-api-key" \
  -H "Content-Type: application/json" \
  -H "Accept: text/event-stream" \
  -d '{
    "query": "Show me Apple'\''s litigation risk trend over the past 3 annual filings and correlate with revenue",
    "config": {
      "llm_provider": "openai",
      "llm_model": "gpt-4o"
    }
  }'

data: {"type":"plan","steps":[
  {"agent":"research_sec_filing","task":"Find Apple 10-K filings FY2023–2025"},
  {"agent":"analyze_filing_risks","task":"Extract litigation risk signals from each filing"},
  {"agent":"generate_chart","task":"Dual-axis: litigation count vs revenue over time"}
]}

data: {"type":"agent_step","tool":"research_sec_filing","args":{"cik":"0000320193","form_types":["10-K"],"after_date":"2023-01-01","max_filings":3},"status":"running"}
data: {"type":"agent_step","tool":"research_sec_filing","status":"done","summary":"Found 3 10-K filings for APPLE INC\n[S1] — Risk Factors (2025)..."}

data: {"type":"agent_step","tool":"analyze_filing_risks","args":{"accession_number":"0000320193-25-000001"},"status":"running"}
data: {"type":"agent_step","tool":"analyze_filing_risks","status":"done","summary":"Risk Score: 7.8/10 | Highest: Litigation (167 mentions, 3.4‰)"}

data: {"type":"agent_step","tool":"generate_chart","args":{"chart_type":"dual_axis","title":"Litigation Risk vs Revenue — $AAPL","spec":{...}},"status":"running"}
data: {"type":"agent_step","tool":"generate_chart","status":"done","summary":"Chart generated (chart_id: chart_1)"}

data: {"type":"sources","sources":[...],"web_sources":[],"doc_sources":[]}
data: {"type":"chart","chart_id":"chart_1","title":"Litigation Risk vs Revenue — $AAPL","chart_type":"dual_axis","plotly":{"data":[...],"layout":{...}}}
data: {"type":"token","token":"## Apple Litigation Risk Trend\n\n"}
data: {"type":"token","token":"Apple's litigation risk increased from **134** (FY2023) to **167** (FY2025) [S1][S2][S3]. See [Chart 1].\n\n"}
data: {"type":"done"}

const response = await fetch('https://api.ivory.finance/v1/rag/orchestrate', {
  method: 'POST',
  headers: {
    'X-API-Key': 'your-api-key',
    'Content-Type': 'application/json',
    'Accept': 'text/event-stream',
  },
  body: JSON.stringify({ query: 'Apple risk trend 2023–2025' }),
})

const reader = response.body.getReader()
const decoder = new TextDecoder()
let buffer = ''

while (true) {
  const { value, done } = await reader.read()
  if (done) break

  buffer += decoder.decode(value, { stream: true })
  const lines = buffer.split('\n\n')
  buffer = lines.pop()   // incomplete last chunk

  for (const line of lines) {
    if (!line.startsWith('data: ')) continue
    const event = JSON.parse(line.slice(6))

    switch (event.type) {
      case 'plan':
        showResearchPlan(event.steps)
        break
      case 'agent_step':
        updateProgressIndicator(event)
        break
      case 'sources':
        // event.sources    — SEC chunks
        // event.web_sources — web + news results
        // event.doc_sources — user-uploaded doc chunks
        setSources(event.sources, event.web_sources, event.doc_sources)
        break
      case 'chart':
        Plotly.newPlot(`chart-${event.chart_id}`, event.plotly.data, event.plotly.layout)
        break
      case 'token':
        appendToAnswer(event.token)
        break
      case 'conversation_state':
        await saveConversationHistory(event.chat_id, event.messages)
        break
      case 'done':
        finalizeAnswer()
        break
      case 'error':
        showError(event.detail)
        break
    }
  }
}