Quickstart

curl -X POST \
  https://rpiqzfzokrwxavztrpmp.supabase.co/functions/v1/research \
  -H "Authorization: Bearer cp_live_..." \
  -H "Content-Type: application/json" \
  -d '{ "email": "john.doe@acmecorp.com" }'

{
  "research_id": "res_1a7b6e9c35a9b848",
  "status": "processing",
  "estimated_seconds": 30
}

curl \
  https://rpiqzfzokrwxavztrpmp.supabase.co/functions/v1/research-status/res_1a7b6e9c35a9b848 \
  -H "Authorization: Bearer cp_live_..."

{
  "research_id": "res_1a7b6e9c35a9b848",
  "status": "completed",
  "completed_at": "2026-05-05T10:27:08.004Z",
  "data": {
    "prospect": {
      "name": "John Doe",
      "title": "VP of Sales",
      "summary": "John is VP of Sales at Acme Corp...",
      "opening_talk": [
        "Your post about reducing sales cycles resonated...",
        ...
      ]
    },
    "company": { ... },
    "decision_makers": [ ... ]
  }
}

const API_KEY = 'cp_live_...';
const BASE_URL = 'https://rpiqzfzokrwxavztrpmp.supabase.co/functions/v1';

async function researchProspect(email) {
  // 1. Submit
  const res = await fetch(`${BASE_URL}/research`, {
    method: 'POST',
    headers: {
      'Authorization': `Bearer ${API_KEY}`,
      'Content-Type': 'application/json',
    },
    body: JSON.stringify({ email }),
  });
  const { research_id } = await res.json();
  console.log('Research started:', research_id);

  // 2. Poll until completed
  while (true) {
    await new Promise(r => setTimeout(r, 5000));

    const statusRes = await fetch(`${BASE_URL}/research-status/${research_id}`, {
      headers: { 'Authorization': `Bearer ${API_KEY}` },
    });
    const data = await statusRes.json();

    if (data.status === 'completed') return data;
    if (data.status === 'failed') throw new Error(data.error);

    console.log('Still processing...');
  }
}

// Usage
const result = await researchProspect('john.doe@acmecorp.com');
console.log(result.data.prospect.opening_talk);