UniDataHub Business Data API

const API_BASE = "https://unidatahub.com/api/v1";
const API_KEY = "YOUR_API_KEY"; // Set via server environment variable

const headers = {
  "Authorization": `Bearer ${API_KEY}`,
  "Content-Type": "application/json"
};

async function runExtractionPipeline() {
  // 1. Submit extraction job
  const submitResp = await fetch(`${API_BASE}/jobs`, {
    method: "POST",
    headers,
    body: JSON.stringify({
      queries: ["dentists in Miami, FL", "orthodontists in Miami, FL"],
      depth: 20,
      email: true,
      json: true // Request JSON Lines
    })
  });

  const job = await submitResp.json();
  if (!submitResp.ok) throw new Error(job.message || "Submit failed");
  console.log(`Job submitted: ${job.job_id}`);

  // 2. Poll status
  let attempts = 0;
  while (attempts++ < 100) {
    await new Promise(r => setTimeout(r, 4000));
    const statusResp = await fetch(`${API_BASE}/jobs/${job.job_id}`, { headers });
    const statusData = await statusResp.json();

    if (statusData.status === "COMPLETED") {
      console.log(`Extraction complete. Total records: ${statusData.row_count}`);
      // 3. Fetch results
      const resultsResp = await fetch(`${API_BASE}/jobs/${job.job_id}/results/download`, { headers });
      const text = await resultsResp.text();
      console.log(`Received results data (${text.length} bytes).`);
      return text;
    }

    if (statusData.status === "FAILED") {
      throw new Error(`Job failed: ${statusData.error}`);
    }
  }
  throw new Error("Job timed out.");
}

runExtractionPipeline().catch(console.error);

# 1. Submit a job (returns 202 Accepted with job_id)
curl -i -X POST https://unidatahub.com/api/v1/jobs \
  -H "Authorization: Bearer YOUR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "queries": ["coffee shops in Brooklyn, NY"],
    "depth": 20,
    "email": true,
    "json": false
  }'

# 2. Poll job status
curl -i https://unidatahub.com/api/v1/jobs/YOUR_JOB_ID \
  -H "Authorization: Bearer YOUR_API_KEY"

# 3. Stream download CSV once status is COMPLETED
curl -L -o results.csv \
  "https://unidatahub.com/api/v1/jobs/YOUR_JOB_ID/results/download" \
  -H "Authorization: Bearer YOUR_API_KEY"