Biến báo cáo sản phẩm thành landing page

const BASE = "https://openapi.felo.ai";
const headers = {
  Authorization: `Bearer ${process.env.FELO_API_KEY}`,
  "Content-Type": "application/json",
};

async function felo<T>(path: string, body?: unknown): Promise<T> {
  const res = await fetch(`${BASE}${path}`, {
    method: body ? "POST" : "GET",
    headers,
    body: body ? JSON.stringify(body) : undefined,
  });
  if (!res.ok) throw new Error(`${res.status}: ${await res.text()}`);
  return res.json() as Promise<T>;
}

type ChatData = {
  data: { answer: string; resources: { link: string; title: string }[] };
};
type ExtractData = { data: { content: string } };

const research = await felo<ChatData>("/v2/chat", {
  query: "Who is [audience] and what do they need from [product]?",
});

const pages = await Promise.all(
  research.data.resources.slice(0, 2).map((source) =>
    felo<ExtractData>("/v2/web/extract", {
      url: source.link,
      output_format: "markdown",
      with_readability: true,
    }).then((page) => ({ ...source, content: page.data.content })),
  ),
);

type LiveDocData = { data: { short_id: string } };

const doc = await felo<LiveDocData>("/v2/livedocs", {
  name: "Landing page: [product]",
  description: "Product brief, audience research and competitor notes",
});

await felo(`/v2/livedocs/${doc.data.short_id}/resources/doc`, {
  title: "Product brief",
  content: "[paste the brief: audience, problem, proof, pricing, CTA]",
});

await felo(`/v2/livedocs/${doc.data.short_id}/resources/urls`, {
  urls: pages.map((page) => ({ url: page.link, title: page.title })),
});

console.log(doc.data.short_id); // page context

type LandingTaskData = { data: { task_id: string } };

const task = await felo<LandingTaskData>("/v2/landing_page", {
  query:
    "Create a landing page for [product] for [audience]. Goal: [signup]. " +
    "Use the product brief and research in the LiveDoc. Return a hero, proof, " +
    "features, objections and one CTA. Do not invent claims.",
  livedoc_short_id: doc.data.short_id,
});

console.log(task.data.task_id);

type TaskState = {
  data: { task_status: string; ai_page_html?: string; ppt_url?: string };
};

async function waitForPage(taskId: string) {
  for (let attempt = 0; attempt < 40; attempt++) {
    const state = await felo<TaskState>(`/v2/tasks/${taskId}/historical`);
    if (state.data.task_status === "COMPLETED") {
      return state.data.ai_page_html ?? state.data.ppt_url;
    }
    if (["FAILED", "EXPIRED", "CANCELED"].includes(state.data.task_status)) {
      throw new Error(`Landing page task ${state.data.task_status}`);
    }
    await new Promise((resolve) => setTimeout(resolve, 3000));
  }
  throw new Error("Landing page task timed out");
}

const pageUrl = await waitForPage(task.data.task_id);
console.log(pageUrl);