{
  "detail": "Authentification requise"
}

{
  "detail": "Invalid effort: xyz. Must be one of ['low', 'medium', 'high', 'max']"
}

{
  "detail": [
    {
      "type": "missing",
      "loc": ["body", "messages"],
      "msg": "Field required"
    }
  ]
}

event: error
data: {"type": "error", "data": {"error": "Limite quotidienne organisation atteinte (1,000,000 tokens). Reset dans 3h42.", "error_type": "RateLimitExceeded"}}

event: error
data: {"type": "error", "data": {"error": "Erreur interne du serveur"}}

const response = await fetch("https://api.inwealth.fr/api/agent", {
  method: "POST",
  headers: {
    "Content-Type": "application/json",
    "Authorization": "Bearer sk_live_your_key_here"
  },
  body: JSON.stringify({
    messages: [{ role: "user", content: "Your question" }],
    session_id: "session-001"
  })
});

// Handle HTTP errors (401, 400, 422)
if (!response.ok) {
  const error = await response.json();
  console.error(`HTTP ${response.status}:`, error.detail);
  return;
}

// Handle SSE stream (including SSE error events)
const reader = response.body.getReader();
const decoder = new TextDecoder();

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

  const chunk = decoder.decode(value);
  for (const line of chunk.split("\n")) {
    if (!line.startsWith("data: ")) continue;
    const data = JSON.parse(line.slice(6));

    if (data.type === "error") {
      // SSE error (429 rate limit, 500 internal)
      console.error(data.data.error);
      if (data.data.error_type === "RateLimitExceeded") {
        // Wait until quota resets at midnight UTC
      }
      return;
    }

    if (data.type === "delta" && data.delta?.content) {
      // Normal delta — append to display
    }
  }
}

import httpx
import json

with httpx.stream(
    "POST",
    "https://api.inwealth.fr/api/agent",
    headers={"Authorization": "Bearer sk_live_your_key_here"},
    json={
        "messages": [{"role": "user", "content": "Your question"}],
        "session_id": "session-001",
    },
) as response:
    # Handle HTTP errors
    if response.status_code != 200:
        print(f"HTTP {response.status_code}: {response.read()}")
    else:
        # Handle SSE stream
        for line in response.iter_lines():
            if not line.startswith("data: "):
                continue
            data = json.loads(line[6:])
            if data.get("type") == "error":
                print(f"SSE error: {data['data']['error']}")
                break