Խոսակցություններ

# Walks every page; stops when next_cursor is null.
cursor=""
while :; do
  url="$CHATTLER_BASE_URL/v1/agents/$CHATTLER_AGENT_ID/conversations?limit=100"
  [ -n "$cursor" ] && url="$url&cursor=$cursor"
  page=$(curl -s "$url" -H "Authorization: Bearer $CHATTLER_API_KEY")
  echo "$page" | jq -c '.data[]'
  cursor=$(echo "$page" | jq -r '.next_cursor // empty')
  [ -z "$cursor" ] && break
done

import os

import httpx

BASE_URL = os.environ["CHATTLER_BASE_URL"]
AGENT_ID = os.environ["CHATTLER_AGENT_ID"]
HEADERS = {"Authorization": f"Bearer {os.environ['CHATTLER_API_KEY']}"}


def iter_conversations():
    cursor = None
    while True:
        params = {"limit": 100}
        if cursor:
            params["cursor"] = cursor
        page = httpx.get(
            f"{BASE_URL}/v1/agents/{AGENT_ID}/conversations",
            headers=HEADERS,
            params=params,
        ).json()
        yield from page["data"]
        cursor = page["next_cursor"]
        if not cursor:
            break

async function* iterConversations() {
  let cursor = null;
  for (;;) {
    const url = new URL(`${baseUrl}/v1/agents/${agentId}/conversations`);
    url.searchParams.set("limit", "100");
    if (cursor) url.searchParams.set("cursor", cursor);
    const page = await (
      await fetch(url, { headers: { Authorization: `Bearer ${apiKey}` } })
    ).json();
    yield* page.data;
    cursor = page.next_cursor;
    if (!cursor) break;
  }
}