Run

curl -X POST https://api.monid.ai/v1/run \
  -H "Authorization: Bearer monid_live_..." \
  -H "Content-Type: application/json" \
  -d '{
    "provider": "apify",
    "endpoint": "/apidojo/tweet-scraper",
    "input": {
      "searchTerms": ["AI"],
      "maxItems": 10
    }
  }'

const response = await fetch("https://api.monid.ai/v1/run", {
  method: "POST",
  headers: {
    "Authorization": "Bearer monid_live_...",
    "Content-Type": "application/json",
  },
  body: JSON.stringify({
    provider: "apify",
    endpoint: "/apidojo/tweet-scraper",
    input: {
      searchTerms: ["AI"],
      maxItems: 10,
    },
  }),
});

const data = await response.json();

if (response.status === 202) {
  // Async provider — poll for results
  const runId = data.runId;
  let result;
  while (true) {
    const poll = await fetch(`https://api.monid.ai/v1/runs/${runId}`, {
      headers: { "Authorization": "Bearer monid_live_..." },
    });
    result = await poll.json();
    if (["COMPLETED", "FAILED", "BLOCKED", "STOPPED", "TIMED_OUT"].includes(result.status)) break;
    await new Promise((resolve) => setTimeout(resolve, 5000));
  }
  console.log(result.output);
} else {
  // Sync provider (e.g. PDL) — run completed immediately.
  // The HTTP status mirrors the provider's status (200, 404, 429, ...).
  console.log(data.output);
}

import requests
import time

response = requests.post(
    "https://api.monid.ai/v1/run",
    headers={
        "Authorization": "Bearer monid_live_...",
        "Content-Type": "application/json",
    },
    json={
        "provider": "apify",
        "endpoint": "/apidojo/tweet-scraper",
        "input": {
            "searchTerms": ["AI"],
            "maxItems": 10,
        },
    },
)

data = response.json()

if response.status_code == 202:
    # Async provider — poll for results
    run_id = data["runId"]
    while True:
        result = requests.get(
            f"https://api.monid.ai/v1/runs/{run_id}",
            headers={"Authorization": "Bearer monid_live_..."},
        ).json()
        if result["status"] in ("COMPLETED", "FAILED", "BLOCKED", "STOPPED", "TIMED_OUT"):
            break
        time.sleep(5)
else:
    # Sync provider — run completed immediately.
    # The HTTP status mirrors the provider's status (200, 404, 429, ...).
    result = data

if result["status"] == "FAILED":
    print("Infrastructure error")
elif result["status"] in ("BLOCKED", "STOPPED", "TIMED_OUT"):
    print(f"Run {result['status'].lower()}: {result.get('reason', 'no output returned')}")
elif result.get("providerResponse", {}).get("httpStatus", 200) >= 400:
    print(f"Provider error: HTTP {result['providerResponse']['httpStatus']}")
else:
    print(f"Success: {result.get('output')}")