Generate videos in bulk

import { writeFile } from "node:fs/promises";

// Each entry becomes a separate video.
const CUSTOMERS = [
  { name: "Acme Corp", product: "Analytics Dashboard", cta: "Start your free trial" },
  { name: "Globex Inc", product: "Workflow Automation", cta: "Book a demo today" },
  { name: "Initech", product: "Team Collaboration", cta: "See it in action" },
];


// One prompt per row, built from a fixed template.
function buildPrompt(customer) {
  return [
    "Create a 30-second product demo video.",
    "Open with the text '" + customer.name + "' as a title card.",
    "Show the product name '" + customer.product + "' with a sleek animation.",
    "End with a call-to-action: '" + customer.cta + "'.",
    "Use professional background music.",
  ].join(" ");
}


// Start one agent run. Returns before any editing happens.
async function startJob(customer) {
  const response = await fetch(`${API}/agent`, {
    method: "POST",
    headers,
    body: JSON.stringify({ prompt: buildPrompt(customer) }),
  });

  if (!response.ok) {
    throw new Error("Could not start a job: " + response.status);
  }

  const body = await response.json();
  const data = body.data;

  return { ...customer, job_id: data.job_id, project_id: data.project_id };
}


// Render one finished project and save the MP4 beside this script.
async function exportAndDownload(name, job) {
  const response = await fetch(`${API}/export`, {
    method: "POST",
    headers,
    body: JSON.stringify({ project_id: job.project_id }),
  });

  const body = await response.json();

  let exportJob;
  try {
    exportJob = await waitForJob(body.data.job_id);
  } catch (error) {
    console.log("  Export failed for " + name + ": " + error.message);
    return;
  }

  // The finished job carries a signed URL. Download it before it expires.
  const file = await fetch(exportJob.output.url);

  if (!file.ok) {
    console.log("  Download failed for " + name + ": " + file.status);
    return;
  }

  const filename = name.toLowerCase().replace(/ /g, "-") + ".mp4";
  const bytes = Buffer.from(await file.arrayBuffer());

  await writeFile(filename, bytes);
  console.log("  Saved " + filename);
}


// Each worker owns one row from start through download. That keeps the
// number of active agent edits bounded for the whole run.
const MAX_CONCURRENT = 1; // Raise this only when your plan allows more active edits.
let nextIndex = 0;


async function worker() {
  while (nextIndex < CUSTOMERS.length) {
    const customer = CUSTOMERS[nextIndex++];

    try {
      const started = await startJob(customer);
      const finished = await waitForAgentJob(started.job_id);
      await exportAndDownload(customer.name, finished);
    } catch (error) {
      console.log("  Failed " + customer.name + ": " + error.message);
    }
  }
}


console.log("Processing " + CUSTOMERS.length + " videos...");

const workers = Array.from(
  { length: Math.min(MAX_CONCURRENT, CUSTOMERS.length) },
  () => worker(),
);

await Promise.all(workers);
console.log("Done!");