Runner API

await runner.publishItems([
  {
    id: "unique-key-123",
    data: { name: "Product", price: "$10" },
    changefreq: "daily"
  }
]);

await runner.addTasks([
  { 
    href: "https://example.com/page/2", 
    strategy: "NAVIGATE",
    ctx: { category: "electronics" } 
  }
]);

const task = await runner.getCurrentTask();
console.log(`Current Depth: ${task.depth}`);
console.log(`Custom Context:`, task.taskDef.ctx);

const btn = document.querySelector("#submit");
await runner.humanClick(btn, "left");

const footerLink = document.querySelector("a.footer");
await runner.humanScrollInView(footerLink);

await runner.sleep(1000, 3000); // Sleep for 1-3 seconds

await runner.waitFor(".success-message", { timeoutMs: 15000 });

const button = runner.getByTextDeep("Load More", { exact: true });
button?.click();

const res = await runner.fetch("https://api.example.com/data");
const json = await res.json();

const downloads = await runner.getDownloads();
for (const file of downloads.files) {
    console.log(`Local: ${file.local_url}`);   // Internal address for script access
    console.log(`Public: ${file.public_url}`); // Publicly reachable via Relay
    console.log(`Type: ${file.mimeType}`);
    console.log(`Size: ${file.size} bytes`);
}

await runner.clearDownloads();

const res = await runner.getWebsocketMessages();
for (const event of res.events) {
    console.log(`Socket [${event.type}]: ${event.message}`);
}

const res = await runner.getSseMessages();
for (const event of res.events) {
    console.log(`SSE [${event.eventName}]: ${event.message}`);
}