First API request

export LEGNEXT_API_KEY="your-api-key"

import { writeFile } from "node:fs/promises";
import { setTimeout as delay } from "node:timers/promises";

const baseUrl = "https://api.legnext.ai/api";
const apiKey = process.env.LEGNEXT_API_KEY;

if (!apiKey) throw new Error("Set LEGNEXT_API_KEY before running this example");

async function readResponse(response) {
  const body = await response.json();
  if (!response.ok) {
    throw new Error(body.error?.message || body.message || `HTTP ${response.status}`);
  }
  return body;
}

const submitted = await readResponse(
  await fetch(`${baseUrl}/v1/diffusion`, {
    method: "POST",
    headers: {
      "content-type": "application/json",
      "x-api-key": apiKey,
    },
    body: JSON.stringify({
      text: "A cinematic mountain observatory at sunrise --v 8.2 --ar 16:9",
    }),
  }),
);

console.log(`Submitted ${submitted.job_id}`);

let task = submitted;
for (let attempt = 0; attempt < 120; attempt += 1) {
  if (task.status === "completed" || task.status === "failed") break;

  await delay(5_000);
  task = await readResponse(
    await fetch(`${baseUrl}/v1/job/${submitted.job_id}`),
  );
  console.log(task.status);
}

if (task.status === "failed") {
  throw new Error(task.error?.message || task.error?.raw_message || "Task failed");
}
if (task.status !== "completed") {
  throw new Error("Client timeout: task is still running");
}

const outputUrl = task.output?.image_url || task.output?.image_urls?.[0];
if (!outputUrl) throw new Error("Completed task did not contain an image URL");

const imageResponse = await fetch(outputUrl);
if (!imageResponse.ok) throw new Error(`Image download failed: ${imageResponse.status}`);

await writeFile("legnext-output.png", Buffer.from(await imageResponse.arrayBuffer()));
console.log("Saved legnext-output.png");

node legnext-example.mjs