Add a creator

curl -X POST https://api.onlyx.ai/v1/creators \
  -H "Authorization: Bearer $ONLYX_API_KEY" \
  -H "Content-Type: application/json" \
  -H "Idempotency-Key: add-creator-miarose-2026-09-26" \
  -d '{"displayName": "Mia Rose", "handle": "miarose", "proxyCountry": "US"}'

import os, uuid, requests

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

r = requests.post(
    f"{API}/creators",
    headers={**HEADERS, "Idempotency-Key": str(uuid.uuid4())},
    json={"displayName": "Mia Rose", "handle": "miarose", "proxyCountry": "US"},
    timeout=30,
)
r.raise_for_status()  # 201 Created
creator = r.json()
print(creator["id"], creator["connection"]["status"])  # cre_... disconnected

const API = "https://api.onlyx.ai/v1";
const headers = { Authorization: `Bearer ${process.env.ONLYX_API_KEY}` };

const res = await fetch(`${API}/creators`, {
  method: "POST",
  headers: { ...headers, "Content-Type": "application/json", "Idempotency-Key": crypto.randomUUID() },
  body: JSON.stringify({ displayName: "Mia Rose", handle: "miarose", proxyCountry: "US" }),
});
if (res.status !== 201) throw new Error(`${res.status} ${await res.text()}`);
const creator = await res.json();
console.log(creator.id, creator.connection.status); // cre_... disconnected

curl -X POST https://api.onlyx.ai/v1/creators/cre_5f2d9a1c7b3e4f60a2d1/connect-link \
  -H "Authorization: Bearer $ONLYX_API_KEY"

link = requests.post(f"{API}/creators/{creator['id']}/connect-link", headers=HEADERS, timeout=30)
link.raise_for_status()
link = link.json()
print(link["url"], "valid until", link["expiresAt"])

const linkRes = await fetch(`${API}/creators/${creator.id}/connect-link`, { method: "POST", headers });
if (!linkRes.ok) throw new Error(`${linkRes.status} ${await linkRes.text()}`);
const link = await linkRes.json();
console.log(link.url, "valid until", link.expiresAt);

curl https://api.onlyx.ai/v1/creators/cre_5f2d9a1c7b3e4f60a2d1/connection \
  -H "Authorization: Bearer $ONLYX_API_KEY"

conn = requests.get(f"{API}/creators/{creator['id']}/connection", headers=HEADERS, timeout=30).json()
print(conn["status"], conn["nextStep"], conn["message"])

const conn = await (await fetch(`${API}/creators/${creator.id}/connection`, { headers })).json();
console.log(conn.status, conn.nextStep, conn.message);

"""Add an OnlyFans creator to OnlyX and wait for her to connect."""
import os
import time
import uuid
from datetime import datetime, timezone

import requests

API = "https://api.onlyx.ai/v1"
S = requests.Session()
S.headers["Authorization"] = f"Bearer {os.environ['ONLYX_API_KEY']}"


def call(method, path, **kw):
    for attempt in range(6):
        r = S.request(method, f"{API}{path}", timeout=30, **kw)
        if r.status_code == 429:
            time.sleep(int(r.headers.get("Retry-After", "10")))
            continue
        if r.status_code >= 500:
            time.sleep(2 ** attempt)
            continue
        if not r.ok:
            err = r.json().get("error", {})
            raise SystemExit(f"{r.status_code} {err.get('code')}: {err.get('message')} (request {err.get('requestId')})")
        return r.json() if r.content else None
    raise SystemExit("OnlyX did not answer after several retries")


# 1. Create the creator. Reusing this key on a retry returns the same creator.
creator = call(
    "POST",
    "/creators",
    headers={"Idempotency-Key": str(uuid.uuid4())},
    json={"displayName": "Mia Rose", "handle": "miarose", "proxyCountry": "US"},
)
cid = creator["id"]
print(f"Created {cid}")

# 2. Get her setup link (returns the live one if it already exists).
link = call("POST", f"/creators/{cid}/connect-link")
print(f"Send this link to the creator (valid until {link['expiresAt']}):\n  {link['url']}")
link_expires = datetime.fromisoformat(link["expiresAt"].replace("Z", "+00:00"))

# 3. Wait for her to sign in (at most until the link expires).
FINAL = {"connected", "not_a_creator", "duplicate"}
last = None
while True:
    if datetime.now(timezone.utc) > link_expires:
        raise SystemExit("The link expired before she connected. Create a new link and send it again.")
    conn = call("GET", f"/creators/{cid}/connection")
    if conn["status"] != last:
        print(f"[{conn['checkedAt']}] {conn['status']}: {conn['message']} (next step: {conn['nextStep']})")
        last = conn["status"]
    if conn["status"] in FINAL:
        break
    if conn["status"] == "disconnected":
        current = call("GET", f"/creators/{cid}/connect-link")
        if current["status"] in ("expired", "revoked", "none"):
            raise SystemExit("The link is no longer active and she has not connected. Create a new link.")
    time.sleep(15)

if conn["status"] == "not_a_creator":
    raise SystemExit("She signed in with a fan account. Delete this creator in the dashboard and add her again.")
if conn["status"] == "duplicate":
    raise SystemExit(f"Already connected as {conn['duplicateOfCreatorId']}. Use that creator.")

# 4. Report sync progress until the first phase is done (checks for up to an hour).
for _ in range(60):
    sync = call("GET", f"/creators/{cid}/connection")["sync"]
    print(f"sync: {sync['phase']} {sync['progress']}%")
    if sync["phase"] not in (None, "initial"):
        break
    time.sleep(60)
print("Connected. Inbox, sending and the AI are working; older history keeps syncing.")

// Add an OnlyFans creator to OnlyX and wait for her to connect. Node.js 18+.
const API = "https://api.onlyx.ai/v1";
const auth = { Authorization: `Bearer ${process.env.ONLYX_API_KEY}` };
const sleep = (ms) => new Promise((r) => setTimeout(r, ms));

async function call(method, path, { body, headers = {} } = {}) {
  for (let attempt = 0; attempt < 6; attempt++) {
    const res = await fetch(`${API}${path}`, {
      method,
      headers: { ...auth, ...headers, ...(body ? { "Content-Type": "application/json" } : {}) },
      body: body ? JSON.stringify(body) : undefined,
    });
    if (res.status === 429) { await sleep(Number(res.headers.get("Retry-After") ?? 10) * 1000); continue; }
    if (res.status >= 500) { await sleep(2 ** attempt * 1000); continue; }
    const text = await res.text();
    const data = text ? JSON.parse(text) : null;
    if (!res.ok) throw new Error(`${res.status} ${data?.error?.code}: ${data?.error?.message} (request ${data?.error?.requestId})`);
    return data;
  }
  throw new Error("OnlyX did not answer after several retries");
}

// 1. Create the creator. Reusing this key on a retry returns the same creator.
const creator = await call("POST", "/creators", {
  headers: { "Idempotency-Key": crypto.randomUUID() },
  body: { displayName: "Mia Rose", handle: "miarose", proxyCountry: "US" },
});
console.log(`Created ${creator.id}`);

// 2. Get her setup link (returns the live one if it already exists).
const link = await call("POST", `/creators/${creator.id}/connect-link`);
console.log(`Send this link to the creator (valid until ${link.expiresAt}):\n  ${link.url}`);
const linkExpires = Date.parse(link.expiresAt);

// 3. Wait for her to sign in (at most until the link expires).
const FINAL = new Set(["connected", "not_a_creator", "duplicate"]);
let conn, last;
for (;;) {
  if (Date.now() > linkExpires) throw new Error("The link expired before she connected. Create a new link and send it again.");
  conn = await call("GET", `/creators/${creator.id}/connection`);
  if (conn.status !== last) {
    console.log(`[${conn.checkedAt}] ${conn.status}: ${conn.message} (next step: ${conn.nextStep})`);
    last = conn.status;
  }
  if (FINAL.has(conn.status)) break;
  if (conn.status === "disconnected") {
    const current = await call("GET", `/creators/${creator.id}/connect-link`);
    if (["expired", "revoked", "none"].includes(current.status)) {
      throw new Error("The link is no longer active and she has not connected. Create a new link.");
    }
  }
  await sleep(15_000);
}

if (conn.status === "not_a_creator") throw new Error("She signed in with a fan account. Delete this creator in the dashboard and add her again.");
if (conn.status === "duplicate") throw new Error(`Already connected as ${conn.duplicateOfCreatorId}. Use that creator.`);

// 4. Report sync progress until the first phase is done (checks for up to an hour).
for (let i = 0; i < 60; i++) {
  const { sync } = await call("GET", `/creators/${creator.id}/connection`);
  console.log(`sync: ${sync.phase} ${sync.progress}%`);
  if (sync.phase && sync.phase !== "initial") break;
  await sleep(60_000);
}
console.log("Connected. Inbox, sending and the AI are working; older history keeps syncing.");