Extrakce dat

const schema = await client.schemas.create({
  name: "Product Catalog",
  columns: [
    { key: "product_name", label: "Product Name", type: "text", required: true },
    { key: "price", label: "Price", type: "number" },
    { key: "description", label: "Description", type: "text" },
    { key: "seo_title", label: "SEO title", type: "text" },
    { key: "description_de", label: "German description", type: "text" },
    { key: "image_url", label: "Image", type: "image" },
  ],
});

console.log(schema.id);

const file = new File([buffer], "catalog.pdf", { type: "application/pdf" });
const uploaded = await client.files.upload(file, "catalog.pdf");

console.log(uploaded.id); // "4be9e43c-f03a-4309-938c-d2e9482752cf"

const table = await client.tables.create({
  schema_id: schema.id,
  name: "Q1 Product Catalog",
  file_ids: [uploaded.id],
});

console.log(table.id);     // "d2b3dbe0-c77d-40d8-a5d2-480722489c64"
console.log(table.status); // "queued_for_processing"

let completed;
for (let attempt = 0; attempt < 100; attempt++) {
  const current = await client.tables.get(table.id);
  if (current.status === "completed") {
    completed = current;
    break;
  }
  if (["error", "cancelled"].includes(current.status)) {
    throw new Error(current.error_message ?? `Extraction ${current.status}`);
  }
  await new Promise((resolve) => setTimeout(resolve, 3000));
}
if (!completed) throw new Error("Timed out waiting for extraction");

console.log(completed.status);     // "completed"
console.log(completed.total_rows); // 42

const rows = await client.tables.rows(completed.id, { limit: 100 });

for (const row of rows.data) {
  console.log(row.data.product_name, row.data.price);
}