Integrate with Node.js

// integrate.js — MultiCartAPI end-to-end example (Node.js)
// Requires Node 18+ for native fetch, or install axios and swap post() below.

const BASE_URL = "https://multicartapi.com/api/v1";
const API_KEY  = "YOUR_API_KEY";   // from Settings → API Key
const DOMAIN_ID       = 1;         // e.g. 1 = amazon.com.au  (/settings/domains/)
const POSTCODE_ID     = 15;        // Zipcode row ID           (/zipcodes/get-zipcodes/)

// ─── helpers ────────────────────────────────────────────────────────────────

/** POST JSON to a MultiCartAPI endpoint; throws on network error.
*  Branches on body.status: returns body.data on success, throws on failure. */
async function post(path, payload = {}) {
const res = await fetch(BASE_URL + path, {
  method: "POST",
  headers: {
    "x-api-key": API_KEY,
    "Content-Type": "application/json",
  },
  body: JSON.stringify(payload),
});

const body = await res.json();

if (body.status !== 1) {
  throw new Error(
    `API error on ${path}: code=${body.code} message=${JSON.stringify(body.data)}`
  );
}

return body.data;
}

/** Poll until is_download_generated is true (or timeout after maxWaitMs). */
async function pollForResults(collectionId, intervalMs = 10_000, maxWaitMs = 600_000) {
const deadline = Date.now() + maxWaitMs;

while (Date.now() < deadline) {
  const runs = await post("/schedules/collections/results/download/", {
    collection_id: collectionId,
    skip: 0,
    limit: 1,
  });

  const latest = runs[0];
  if (latest && latest.is_download_generated) {
    return latest;          // contains download_links
  }

  console.log("  still processing — waiting", intervalMs / 1000, "s …");
  await new Promise((r) => setTimeout(r, intervalMs));
}

throw new Error("Timed out waiting for results");
}

// ─── main flow ──────────────────────────────────────────────────────────────

(async () => {
// 1. Create a collection
console.log("Creating collection …");
const collection = await post("/schedules/add_schedule/", {
  name: "Node.js Example Collection",
  request_type: "amazon",
  schedule: "Manual",
  priority: "Normal",
  notification_email: "[email protected]",
  fetch_mode: "full",
});
const collectionId = collection.id;
console.log("  Created collection id =", collectionId);

// 2. Add ASINs (bulk string form — domain + postcode by value)
console.log("Adding ASINs …");
const added = await post("/schedules/amazon/asin/create/multiple/", {
  collection: collectionId,
  domain: "amazon.com.au",          // string value, not ID
  customer_postcode: "4500",         // postcode number as string
  asins: "B0DJQQ38TG,B0ABC12345,B0XYZ99999",
  including_raw_html: false,
});
console.log(
  `  Inserted ${added.success_count} ASINs; ${added.error_rows.length} skipped`
);

// 3. Trigger the run
console.log("Triggering run …");
const runMsg = await post("/schedules/run/result/", {
  collection_id: collectionId,
});
console.log(" ", runMsg);    // "Scraping Processing Queued!"

// 4. Poll until results are ready
console.log("Polling for results …");
const runner = await pollForResults(collectionId);
console.log(
  `  Run id=${runner.id} complete — ${runner.total_results} results`
);

// 5. Fetch the first result page
const pages = runner.download_links.pages;
if (!pages || pages.length === 0) {
  throw new Error("No result pages in download_links");
}

const fileUrl = pages[0];
console.log("Fetching result file:", fileUrl);
const fileRes = await fetch(fileUrl, {
  headers: { "x-api-key": API_KEY },
});

if (!fileRes.ok) {
  throw new Error(`File download failed: HTTP ${fileRes.status}`);
}

const results = await fileRes.json();
console.log(
  `Downloaded ${Array.isArray(results) ? results.length : "?"} product records.`
);
console.log("First record sample:", JSON.stringify(results[0], null, 2));
})();

{
"code": 200,
"data": {
  "id": 101,
  "name": "Node.js Example Collection",
  "status": "draft",
  "schedule_status": "Pending",
  "request_type": "amazon",
  "fetch_mode": "full",
  "created_at": "2026-06-20T10:00:00Z",
  "updated_at": "2026-06-20T10:00:00Z"
},
"status": 1
}

{
"code": 200,
"data": {
  "success_count": 2,
  "error_rows": [
    { "asin": "B0XYZ99999", "error": "Duplicate entry" }
  ]
},
"status": 1
}

{
"code": 200,
"data": "Scraping Processing Queued!",
"status": 1
}

{
"code": 200,
"data": [
  {
    "id": 88,
    "collection": 101,
    "is_download_generated": true,
    "download_links": {
      "pages": [
        "https://multicartapi.com/api/v1/results/101/88/Node.js Example Collection_88_Results_Page_1.json"
      ],
      "all_pages": "https://multicartapi.com/api/v1/results/101/88/Node.js Example Collection_88_Results_All_Pages.zip"
    },
    "total_exacted_result": 250,
    "total_results": 250,
    "created_at": "2026-06-20T12:00:00Z",
    "updated_at": "2026-06-20T12:05:00Z"
  }
],
"status": 1
}