Track orders

curl https://api.vane.xyz/api/v1/orders/7f9c2e4a-1b3d-4c5e-8f6a-2d9b0c1e3f5a

const terminal = new Set(["COMPLETED", "ERROR", "TIMED_OUT"]);

async function track(uuid: string) {
  while (true) {
    const order = await fetch(`https://api.vane.xyz/api/v1/orders/${uuid}`).then((r) => r.json());
    if (terminal.has(order.status)) return order;
    await new Promise((r) => setTimeout(r, 5000));
  }
}

import time, requests

TERMINAL = {"COMPLETED", "ERROR", "TIMED_OUT"}

def track(uuid):
    while True:
        order = requests.get(f"https://api.vane.xyz/api/v1/orders/{uuid}").json()
        if order["status"] in TERMINAL:
            return order
        time.sleep(5)

UUID=7f9c2e4a-1b3d-4c5e-8f6a-2d9b0c1e3f5a
curl -s https://api.vane.xyz/api/v1/orders/$UUID | jq .status   # state first
# then subscribe; no /v1 in this path. The server closes a silent stream after 60 s, so loop.
while :; do curl -sN https://api.vane.xyz/api/orders/$UUID/status-stream; sleep 5; done

const api = "https://api.vane.xyz/api";
const uuid = "7f9c2e4a-1b3d-4c5e-8f6a-2d9b0c1e3f5a";
const terminal = new Set(["COMPLETED", "ERROR", "TIMED_OUT"]);
const get = () => fetch(`${api}/v1/orders/${uuid}`).then((r) => r.json());

let order = await get(); // state first; the stream won't repeat it
render(order);

if (!terminal.has(order.status)) {
  const stream = new EventSource(`${api}/orders/${uuid}/status-stream`); // no /v1
  const sync = async () => {
    order = await get();
    render(order);
    if (terminal.has(order.status)) stream.close();
  };
  stream.onopen = sync; // runs on first connect and after every reconnect
  stream.addEventListener("orders:status-update", sync); // named event, so onmessage never fires
}