وكيل صُرَد عبر خادمك

// قراءة الأحداث الحية بـ fetch (EventSource لا يرسل ترويسة Authorization)
const res = await fetch(API + '/api/v1/widget/conversations/' + conversationId + '/events', {
  headers: { Authorization: 'Bearer ' + token, Accept: 'text/event-stream' },
})
const reader = res.body.getReader()
const decoder = new TextDecoder()
let buffer = ''
for (;;) {
  const { value, done } = await reader.read()
  if (done) break
  buffer += decoder.decode(value, { stream: true })
  let end
  while ((end = buffer.indexOf('\n\n')) >= 0) {
    const frame = buffer.slice(0, end)
    buffer = buffer.slice(end + 2)
    const type = /^event: (.*)$/m.exec(frame)?.[1]
    const data = /^data: (.*)$/m.exec(frame)?.[1]
    if (type && data) onEvent(type, JSON.parse(data)) // data.payload يحمل التفاصيل
  }
}

# 1) خادمك: رمز جلسة قصير العمر (المفتاح لا يغادر الخادم)
curl -X POST https://app.surad-ai.com/api/v1/workspaces/$WORKSPACE_ID/widget/session-tokens \
  -H "Authorization: Bearer $SURAD_API_KEY" -H "Content-Type: application/json" \
  -d '{"agent_id":"'$AGENT_ID'","origin":"https://app.example.com","ttl_seconds":900}'

# 2) واجهتك: افتح جلسة بالرمز ونطاقك
curl -X POST https://app.surad-ai.com/api/v1/widget/sessions \
  -H "Authorization: Bearer $TOKEN" -H "Origin: https://app.example.com" \
  -H "Content-Type: application/json" -d '{"mode":"text"}'

# 3) دور نصي
curl -X POST https://app.surad-ai.com/api/v1/widget/conversations/$CONVERSATION_ID/turns \
  -H "Authorization: Bearer $TOKEN" -H "Origin: https://app.example.com" \
  -H "Content-Type: application/json" -d '{"text":"هل عندكم توصيل اليوم؟","mode":"text"}'

# 4) رسالة صوتية (WAV)
curl -X POST https://app.surad-ai.com/api/v1/widget/conversations/$CONVERSATION_ID/voice/utterance \
  -H "Authorization: Bearer $TOKEN" -H "Origin: https://app.example.com" \
  -F "file=@question.wav;type=audio/wav"

import base64, httpx

API = "https://app.surad-ai.com"
ORIGIN = "https://app.example.com"

def new_session(api_key: str, workspace_id: str, agent_id: str) -> tuple[str, str]:
    minted = httpx.post(
        f"{API}/api/v1/workspaces/{workspace_id}/widget/session-tokens",
        headers={"Authorization": f"Bearer {api_key}"},
        json={"agent_id": agent_id, "origin": ORIGIN, "ttl_seconds": 900},
    ).raise_for_status().json()
    token = minted["token"]
    opened = httpx.post(
        f"{API}/api/v1/widget/sessions",
        headers={"Authorization": f"Bearer {token}", "Origin": ORIGIN},
        json={"mode": "voice"},
    ).raise_for_status().json()
    return token, opened["conversation"]["conversation_id"]

def ask(token: str, conversation_id: str, text: str) -> dict:
    turn = httpx.post(
        f"{API}/api/v1/widget/conversations/{conversation_id}/turns",
        headers={"Authorization": f"Bearer {token}", "Origin": ORIGIN},
        json={"text": text, "mode": "voice"},
        timeout=60,
    ).raise_for_status().json()
    if turn.get("audio"):
        with open("reply.wav", "wb") as f:
            f.write(base64.b64decode(turn["audio"]["content_base64"]))
    return turn["reply"]  # {"display": "...", "spoken": "..."}