AI agent integration

python
import requests, time

API_KEY = "ss_your_key_here"
BASE = "https://shopsniffer.com/api"
headers = {"X-API-Key": API_KEY, "Content-Type": "application/json"}

# 1. Create job
resp = requests.post(
    f"{BASE}/jobs",
    json={
        "domain": "allbirds.com",
        "webhook_url": "https://your-server.com/hook",
    },
    headers=headers,
)
job = resp.json()["job"]
print(f"Job {job['id']} created for {job['domain']}")

# 2. Poll for completion (or wait on your webhook)
while True:
    status = requests.get(f"{BASE}/jobs/{job['id']}/status").json()
    print(f"Status: {status['status']}")
    if status["status"] == "completed":
        break
    if status["status"] == "errored":
        raise RuntimeError(f"Job failed: {status}")
    time.sleep(10)

# 3. Get report data
report = requests.get(f"{BASE}/reports/{job['id']}").json()
print(f"Found {len(report.get('products', []))} products")

# 4. Download CSV
csv_url = (
    f"{BASE}/downloads?jobId={job['id']}&key=products.csv"
)
csv_data = requests.get(csv_url).text
with open("products.csv", "w") as f:
    f.write(csv_data)

typescript
const BASE = "https://shopsniffer.com/api";
const headers = {
  "X-API-Key": "ss_your_key_here",
  "Content-Type": "application/json",
};

// 1. Create job
const { job } = await fetch(`${BASE}/jobs`, {
  method: "POST",
  headers,
  body: JSON.stringify({
    domain: "allbirds.com",
    webhook_url: "https://your-server.com/hook",
  }),
}).then((r) => r.json());

console.log(`Job ${job.id} created`);

// 2. Poll until complete
let status: { status: string };
do {
  await new Promise((r) => setTimeout(r, 10_000));
  status = await fetch(`${BASE}/jobs/${job.id}/status`).then((r) => r.json());
  console.log(`Status: ${status.status}`);
  if (status.status === "errored") throw new Error("Job failed");
} while (status.status !== "completed");

// 3. Get report
const report = await fetch(`${BASE}/reports/${job.id}`).then((r) => r.json());
console.log(`Found ${report.products?.length ?? 0} products`);

// 4. Download CSV
const csvUrl = `${BASE}/downloads?jobId=${job.id}&key=products.csv`;
const csv = await fetch(csvUrl).then((r) => r.text());
await Deno.writeTextFile("products.csv", csv);

typescript
// Replace polling with real-time progress via WebSocket
const BASE_WS = "wss://shopsniffer.com/api";

// Create job first (as above), then:
const ws = new WebSocket(`${BASE_WS}/ws/${job.id}`);

ws.addEventListener("message", (evt) => {
  const msg = JSON.parse(evt.data);
  switch (msg.type) {
    case "status":
      console.log(`Stage: ${msg.step} (${Math.round(msg.progress * 100)}%)`);
      break;
    case "complete":
      console.log(`Done. Report: ${msg.report_url}`);
      ws.close();
      break;
    case "error":
      console.error(`Job failed: ${msg.error}`);
      ws.close();
      break;
  }
});