Webhooks

const BASE_URL = "https://api.muveya.com";
const headers = { Authorization: `Bearer ${process.env.MUVEYA_API_KEY}` };
const seen = new Map(); // orderId -> version; keep it in your database

async function pollOrders(status) {
  let cursor;
  do {
    const url = new URL("/v1/orders", BASE_URL);
    url.searchParams.set("limit", "200");
    url.searchParams.set("status", status);
    if (cursor) url.searchParams.set("cursor", cursor);

    const response = await fetch(url, { headers });
    if (response.status === 429) {
      const wait = Number(response.headers.get("retry-after") ?? "1");
      await new Promise((resolve) => setTimeout(resolve, wait * 1000));
      continue;
    }
    if (!response.ok) throw new Error(`HTTP ${response.status}`);
    const page = await response.json();

    for (const order of page.data) {
      if (seen.get(order.orderId) !== order.version) {
        seen.set(order.orderId, order.version);
        console.log(`Order #${order.number} is ${order.status}`);
      }
    }
    cursor = page.hasMore ? page.nextCursor : undefined;
  } while (cursor);
}

await pollOrders("pending_approval");

import os
import time
import requests

BASE_URL = "https://api.muveya.com"
session = requests.Session()
session.headers["Authorization"] = f"Bearer {os.environ['MUVEYA_API_KEY']}"
seen = {}  # orderId -> version; keep it in your database

def poll_orders(status):
    cursor = None
    while True:
        params = {"limit": 200, "status": status}
        if cursor:
            params["cursor"] = cursor
        response = session.get(f"{BASE_URL}/v1/orders", params=params, timeout=30)
        if response.status_code == 429:
            time.sleep(int(response.headers.get("Retry-After", "1")))
            continue
        response.raise_for_status()
        page = response.json()
        for order in page["data"]:
            if seen.get(order["orderId"]) != order["version"]:
                seen[order["orderId"]] = order["version"]
                print(f"Order #{order['number']} is {order['status']}")
        if not page["hasMore"]:
            return
        cursor = page["nextCursor"]

poll_orders("pending_approval")