trigger.mjs

import { readFileSync, existsSync } from "node:fs";

if (existsSync(".env")) {
  for (const line of readFileSync(".env", "utf-8").split("\n")) {
    const match = line.match(/^([^#=]+)=(.*)$/);
    if (match && !process.env[match[1].trim()]) {
      process.env[match[1].trim()] = match[2].trim();
    }
  }
}

const prUrl = process.argv[2];
if (!prUrl) {
  console.error("Usage: node trigger.mjs <github-pr-url>");
  process.exit(1);
}

const WORKER_URL =
  process.env.WORKER_URL || "http://localhost:8787";

console.log(`Starting video generation for: ${prUrl}`);

const res = await fetch(`${WORKER_URL}/generate`, {
  method: "POST",
  headers: { "Content-Type": "application/json" },
  body: JSON.stringify({ prUrl }),
});

if (!res.ok) {
  const err = await res.text();
  console.error(`Failed to start job: ${err}`);
  process.exit(1);
}

const { jobId } = await res.json();
console.log(`Job started: ${jobId}`);

let status = "running";
let videoUrl = null;

while (status !== "complete" && status !== "errored") {
  await new Promise((r) => setTimeout(r, 5000));

  const poll = await fetch(`${WORKER_URL}/status/${jobId}`);
  const data = await poll.json();
  status = data.status;
  videoUrl = data.videoUrl;

  console.log(`Status: ${status}`);
}

if (status === "complete" && videoUrl) {
  console.log(`\nVideo ready: ${videoUrl}`);
} else {
  console.error("\nJob failed.");
  process.exit(1);
}