Read and send messages

export ONLYX_API_KEY="onx_sk_..."

import os, time, uuid
import requests

API = "https://api.onlyx.ai/v1"
HEADERS = {"Authorization": f"Bearer {os.environ['ONLYX_API_KEY']}"}

const API = "https://api.onlyx.ai/v1";
const headers = { Authorization: `Bearer ${process.env.ONLYX_API_KEY}` };
const sleep = (ms) => new Promise((r) => setTimeout(r, ms));

curl "https://api.onlyx.ai/v1/conversations?creatorId=cre_5f2d9a1c7b3e4f60a2d1&unread=true&sort=spend&limit=20" \
  -H "Authorization: Bearer $ONLYX_API_KEY"

params = {"creatorId": "cre_5f2d9a1c7b3e4f60a2d1", "unread": "true", "sort": "spend", "limit": 20}
page = requests.get(f"{API}/conversations", headers=HEADERS, params=params, timeout=30).json()
for c in page["data"]:
    print(c["id"], c["fan"]["displayName"], c["status"], c["unreadCount"], c["totalSpentCents"])

const params = new URLSearchParams({ creatorId: "cre_5f2d9a1c7b3e4f60a2d1", unread: "true", sort: "spend", limit: "20" });
const page = await (await fetch(`${API}/conversations?${params}`, { headers })).json();
for (const c of page.data) console.log(c.id, c.fan.displayName, c.status, c.unreadCount, c.totalSpentCents);

# newest page
curl "https://api.onlyx.ai/v1/conversations/cnv_9f2c41d7a8b35e06c1f4/messages?limit=50" \
  -H "Authorization: Bearer $ONLYX_API_KEY"

# the page before it
curl "https://api.onlyx.ai/v1/conversations/cnv_9f2c41d7a8b35e06c1f4/messages?limit=50&before=msg_2c8e4a6f1b3d5079e2a4" \
  -H "Authorization: Bearer $ONLYX_API_KEY"

def full_history(conversation_id):
    """Every message in a conversation, oldest first."""
    messages, before = [], None
    while True:
        params = {"limit": 100, **({"before": before} if before else {})}
        page = requests.get(
            f"{API}/conversations/{conversation_id}/messages",
            headers=HEADERS, params=params, timeout=30,
        ).json()
        messages = page["data"] + messages  # each page is oldest-first
        if not page["hasMore"] or not page["data"]:
            return messages
        before = page["data"][0]["id"]

async function fullHistory(conversationId) {
  let messages = [];
  let before;
  for (;;) {
    const q = new URLSearchParams({ limit: "100", ...(before ? { before } : {}) });
    const page = await (await fetch(`${API}/conversations/${conversationId}/messages?${q}`, { headers })).json();
    messages = [...page.data, ...messages]; // each page is oldest-first
    if (!page.hasMore || page.data.length === 0) return messages;
    before = page.data[0].id;
  }
}

curl -X POST https://api.onlyx.ai/v1/conversations/cnv_9f2c41d7a8b35e06c1f4/messages \
  -H "Authorization: Bearer $ONLYX_API_KEY" \
  -H "Content-Type: application/json" \
  -H "Idempotency-Key: 3c5e7a9b-1d2f-4a6c-8e0b-2d4f6a8c0e1b" \
  -d '{"text": "haha you are trouble. how was your day?"}'

r = requests.post(
    f"{API}/conversations/cnv_9f2c41d7a8b35e06c1f4/messages",
    headers={**HEADERS, "Idempotency-Key": str(uuid.uuid4())},
    json={"text": "haha you are trouble. how was your day?"},
    timeout=30,
)
r.raise_for_status()
message = r.json()  # 202, delivery.status == "queued"

const res = await fetch(`${API}/conversations/cnv_9f2c41d7a8b35e06c1f4/messages`, {
  method: "POST",
  headers: { ...headers, "Content-Type": "application/json", "Idempotency-Key": crypto.randomUUID() },
  body: JSON.stringify({ text: "haha you are trouble. how was your day?" }),
});
const message = await res.json(); // 202, delivery.status === "queued"

curl -X POST https://api.onlyx.ai/v1/conversations/cnv_9f2c41d7a8b35e06c1f4/messages \
  -H "Authorization: Bearer $ONLYX_API_KEY" \
  -H "Content-Type: application/json" \
  -H "Idempotency-Key: 8a0c2e4f-6b8d-4f1a-9c3e-5b7d9f1a3c5e" \
  -d '{"text": "a little good morning for you", "previewMediaIds": ["4012345680"]}'

r = requests.post(
    f"{API}/conversations/cnv_9f2c41d7a8b35e06c1f4/messages",
    headers={**HEADERS, "Idempotency-Key": str(uuid.uuid4())},
    json={"text": "a little good morning for you", "previewMediaIds": ["4012345680"]},
    timeout=30,
)

await fetch(`${API}/conversations/cnv_9f2c41d7a8b35e06c1f4/messages`, {
  method: "POST",
  headers: { ...headers, "Content-Type": "application/json", "Idempotency-Key": crypto.randomUUID() },
  body: JSON.stringify({ text: "a little good morning for you", previewMediaIds: ["4012345680"] }),
});

curl -X POST https://api.onlyx.ai/v1/conversations/cnv_9f2c41d7a8b35e06c1f4/messages \
  -H "Authorization: Bearer $ONLYX_API_KEY" \
  -H "Content-Type: application/json" \
  -H "Idempotency-Key: e1f3a5c7-9b0d-4e2f-8a4c-6e8a0c2e4f6a" \
  -d '{
        "text": "the red lace set you asked about... 8 pics",
        "previewMediaIds": ["4012345678"],
        "mediaIds": ["4012345679", "4012345681", "4012345682"],
        "priceCents": 1500
      }'

r = requests.post(
    f"{API}/conversations/cnv_9f2c41d7a8b35e06c1f4/messages",
    headers={**HEADERS, "Idempotency-Key": str(uuid.uuid4())},
    json={
        "text": "the red lace set you asked about... 8 pics",
        "previewMediaIds": ["4012345678"],
        "mediaIds": ["4012345679", "4012345681", "4012345682"],
        "priceCents": 1500,  # $15.00
    },
    timeout=30,
)
if r.status_code == 409 and r.json()["error"]["code"] == "SALES_OPTED_OUT":
    print("This fan asked not to be sold to. Send text only.")

const res = await fetch(`${API}/conversations/cnv_9f2c41d7a8b35e06c1f4/messages`, {
  method: "POST",
  headers: { ...headers, "Content-Type": "application/json", "Idempotency-Key": crypto.randomUUID() },
  body: JSON.stringify({
    text: "the red lace set you asked about... 8 pics",
    previewMediaIds: ["4012345678"],
    mediaIds: ["4012345679", "4012345681", "4012345682"],
    priceCents: 1500, // $15.00
  }),
});

def wait_for_delivery(conversation_id, message_id, timeout_s=900):
    deadline = time.time() + timeout_s
    while time.time() < deadline:
        m = requests.get(
            f"{API}/conversations/{conversation_id}/messages/{message_id}",
            headers=HEADERS, timeout=30,
        ).json()
        status = m["delivery"]["status"]
        if status != "queued":
            return status, m["delivery"]["reason"]
        time.sleep(10)
    return "queued", "still queued; check again later"

status, reason = wait_for_delivery(message["conversationId"], message["id"])
if status == "unconfirmed":
    print("Probably delivered. Do NOT resend.")
elif status == "failed":
    print("Not delivered:", reason)

async function waitForDelivery(conversationId, messageId, timeoutMs = 900_000) {
  const deadline = Date.now() + timeoutMs;
  while (Date.now() < deadline) {
    const m = await (await fetch(`${API}/conversations/${conversationId}/messages/${messageId}`, { headers })).json();
    if (m.delivery.status !== "queued") return m.delivery;
    await sleep(10_000);
  }
  return { status: "queued", reason: "still queued; check again later" };
}

const delivery = await waitForDelivery(message.conversationId, message.id);
if (delivery.status === "unconfirmed") console.log("Probably delivered. Do NOT resend.");
if (delivery.status === "failed") console.log("Not delivered:", delivery.reason);

curl -X POST https://api.onlyx.ai/v1/conversations/cnv_9f2c41d7a8b35e06c1f4/takeover \
  -H "Authorization: Bearer $ONLYX_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"holdMinutes": 120}'

conv = requests.post(
    f"{API}/conversations/cnv_9f2c41d7a8b35e06c1f4/takeover",
    headers=HEADERS, json={"holdMinutes": 120}, timeout=30,
).json()
print(conv["status"], conv["takenOverUntil"])  # team, two hours from now

const conv = await (await fetch(`${API}/conversations/cnv_9f2c41d7a8b35e06c1f4/takeover`, {
  method: "POST",
  headers: { ...headers, "Content-Type": "application/json" },
  body: JSON.stringify({ holdMinutes: 120 }),
})).json();
console.log(conv.status, conv.takenOverUntil); // team, two hours from now

curl -X PUT https://api.onlyx.ai/v1/conversations/cnv_9f2c41d7a8b35e06c1f4/ai \
  -H "Authorization: Bearer $ONLYX_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"enabled": false}'

conv = requests.put(
    f"{API}/conversations/cnv_9f2c41d7a8b35e06c1f4/ai",
    headers=HEADERS, json={"enabled": False}, timeout=30,
).json()
assert conv["status"] == "ai_off"

const conv = await (await fetch(`${API}/conversations/cnv_9f2c41d7a8b35e06c1f4/ai`, {
  method: "PUT",
  headers: { ...headers, "Content-Type": "application/json" },
  body: JSON.stringify({ enabled: false }),
})).json();