Extract a PDF

const baseUrl = process.env.HORIZON_BASE_URL ?? 'https://api.horizon.new/v1';

const pdfResponse = await fetchWithPayment(`${baseUrl}/extract/pdf`, {
  method: 'POST',
  headers: { 'Content-Type': 'application/json' },
  body: JSON.stringify({
    sourceUrl: 'https://cdn.example.com/handbooks/agent-playbook.pdf',
    sourceName: 'Agent Playbook 2025',
    options: { segmentLength: 1500, language: 'en', ocr: true },
    webhookUrl: 'https://example.com/webhooks/horizon/extraction',
  }),
});

const pdfJob = await pdfResponse.json();
console.log('pdf job', pdfJob.jobId);

import FormData from 'form-data';
import { createReadStream } from 'node:fs';

const form = new FormData();
form.append('file', createReadStream('./assets/agent-playbook.pdf'));
form.append('sourceName', 'Agent Playbook 2025');

const uploadResponse = await fetchWithPayment(`${baseUrl}/extract/pdf`, {
  method: 'POST',
  headers: form.getHeaders(),
  body: form,
});

const uploadJob = await uploadResponse.json();

if (pdfJob.status === 'completed' && pdfJob.result) {
  console.log('Inline chunks', pdfJob.result.chunks.length);
}

const status = await fetchWithPayment(pdfJob.statusUrl).then((res) => res.json());

if (status.state === 'processing') {
  await new Promise((resolve) => setTimeout(resolve, 3000));
}

if (status.state !== 'succeeded') {
  throw new Error(`PDF extraction failed: ${status.error?.code ?? 'unknown'}`);
}

console.log('chunks', status.result.chunks.length);