Listing Photo → Video with Async Webhook Delivery

listing_id,image_url,video_prompt,property_type,delivery_target
LST-4201,https://cdn.example.com/listings/4201-living-room.jpg,"5-second cinematic walkthrough, warm afternoon light, smooth camera dolly forward",residential,mls-upload
LST-4202,https://cdn.example.com/listings/4202-kitchen.jpg,"5-second kitchen reveal, natural light from windows, slow pan left to right",residential,website-hero
LST-4203,https://cdn.example.com/listings/4203-exterior.jpg,"5-second aerial approach, golden hour, gentle zoom toward front entrance",luxury,social-ad

import fs from "node:fs/promises";

const API_KEY = process.env.CREATIVEAI_API_KEY;
const WEBHOOK_URL = "https://your-platform.com/webhooks/listing-video";
const INPUT_CSV = "listing-videos.csv";
const OUTPUT_JSONL = "listing-video-jobs.jsonl";
const MAX_CONCURRENCY = 3;

function parseCsv(csv) {
  const [headerLine, ...lines] = csv.trim().split("\n");
  const headers = headerLine.split(",").map((v) => v.trim());

  return lines
    .filter(Boolean)
    .map((line) => {
      const values = line
        .match(/("[^"]*"|[^,]+)/g)
        ?.map((v) => v.replace(/^"|"$/g, "").trim()) ?? [];
      return Object.fromEntries(headers.map((h, i) => [h, values[i] ?? ""]));
    });
}

async function submitListingVideo(row) {
  const response = await fetch("https://api.creativeai.run/v1/video/generations", {
    method: "POST",
    headers: {
      Authorization: "Bearer " + API_KEY,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({
      model: "kling-v3",
      prompt: row.video_prompt,
      image_url: row.image_url,
      duration: "5s",
      aspect_ratio: "16:9",
      webhook_url: WEBHOOK_URL,
    }),
  });

  const body = await response.json();
  if (!response.ok) {
    throw new Error("HTTP " + response.status + ": " + JSON.stringify(body));
  }

  return {
    listing_id: row.listing_id,
    property_type: row.property_type,
    delivery_target: row.delivery_target,
    generation_id: body.id,
    status: body.status,
    submitted_at: new Date().toISOString(),
  };
}

async function runWithConcurrency(rows, worker, limit) {
  const results = [];
  let index = 0;

  async function runner() {
    while (index < rows.length) {
      const current = index++;
      try {
        results[current] = await worker(rows[current]);
      } catch (error) {
        results[current] = {
          listing_id: rows[current].listing_id,
          status: "submit_failed",
          error: String(error),
        };
      }
    }
  }

  await Promise.all(Array.from({ length: Math.min(limit, rows.length) }, () => runner()));
  return results;
}

async function main() {
  if (!API_KEY) throw new Error("Set CREATIVEAI_API_KEY first");

  const csv = await fs.readFile(INPUT_CSV, "utf8");
  const rows = parseCsv(csv);
  const results = await runWithConcurrency(rows, submitListingVideo, MAX_CONCURRENCY);

  await fs.writeFile(
    OUTPUT_JSONL,
    results.map((r) => JSON.stringify(r)).join("\n") + "\n",
    "utf8"
  );

  const submitted = results.filter((r) => r.status === "pending").length;
  console.log("Submitted " + submitted + "/" + rows.length + " listing videos -> " + OUTPUT_JSONL);
}

main().catch((err) => { console.error(err); process.exit(1); });

import crypto from "node:crypto";
import fs from "node:fs/promises";

const API_KEY = process.env.CREATIVEAI_API_KEY;
const JOBS_PATH = "listing-video-jobs.jsonl";

function verifySignature(rawBody, signatureHeader) {
  const expected = crypto
    .createHmac("sha256", API_KEY)
    .update(rawBody)
    .digest("hex");

  const received = (signatureHeader || "").replace("sha256=", "");
  if (!received) return false;

  return crypto.timingSafeEqual(
    Buffer.from(expected),
    Buffer.from(received)
  );
}

export async function POST(request) {
  const rawBody = await request.text();
  const signature = request.headers.get("x-creativeai-signature");

  if (!verifySignature(rawBody, signature)) {
    return new Response("Invalid signature", { status: 401 });
  }

  const event = JSON.parse(rawBody);
  const lines = (await fs.readFile(JOBS_PATH, "utf8")).trim().split("\n");
  const jobs = lines.map((line) => JSON.parse(line));

  const updated = jobs.map((job) =>
    job.generation_id === event.id
      ? {
          ...job,
          status: event.status,
          output_url: event.output_url || null,
          completed_at: event.completed_at || null,
          error: event.error || null,
        }
      : job
  );

  await fs.writeFile(
    JOBS_PATH,
    updated.map((j) => JSON.stringify(j)).join("\n") + "\n",
    "utf8"
  );

  if (event.status === "completed") {
    // Push event.output_url to your MLS, website CMS, or listing platform here.
  }

  return Response.json({ ok: true });
}

{"listing_id":"LST-4201","property_type":"residential","delivery_target":"mls-upload","generation_id":"vgen_abc123","status":"completed","output_url":"https://cdn.creativeai.run/output/video-abc123.mp4","completed_at":"2026-03-12T09:22:17Z","error":null}
{"listing_id":"LST-4202","property_type":"residential","delivery_target":"website-hero","generation_id":"vgen_def456","status":"pending","submitted_at":"2026-03-12T09:20:01Z"}
{"listing_id":"LST-4203","property_type":"luxury","delivery_target":"social-ad","generation_id":"vgen_ghi789","status":"failed","error":"provider timeout after retry budget"}

[
  {
    "status": "pending",
    "agent_copy": "Queued — video render slot reserved, no action needed"
  },
  {
    "status": "processing",
    "agent_copy": "Rendering listing video — we'll notify you when it's ready"
  },
  {
    "status": "completed",
    "agent_copy": "Listing video ready — download or publish to MLS / website"
  },
  {
    "status": "failed",
    "agent_copy": "Render failed — retry or contact support with the job ID"
  }
]