1.8 million posts.
53 seconds. 65 cents.

0.66    0.90   send            Head of Sales, SDRs drowning in account research
0.17    0.08   WRONG PERSON    Backend engineer, same message
0.19    0.32   WRONG PERSON    VP Marketing, "Hi {first_name}, I help companies grow"

// npm install ai
// .env:  AI_GATEWAY_API_KEY=...
// run:   node --env-file=.env find-buyers.mjs
import { experimental_evaluate as evaluate } from 'ai';
import { writeFileSync } from 'node:fs';

const PRODUCT = 'a CRM for a small sales team';   // what you sell, in plain words
const SEARCH = 'CRM';                              // where buyers ask, not what they mention
const SINCE_DAYS = 3650;                           // tighten to 30 for live prospecting
const KEEP = 0.60;                                 // buying score to keep

const since = Math.floor(Date.now() / 1000) - SINCE_DAYS * 86400;
const res = await fetch('https://hn.algolia.com/api/v1/search?tags=ask_hn&hitsPerPage=30' +
  '&numericFilters=created_at_i>' + since + '&query=' + encodeURIComponent(SEARCH));
const posts = (await res.json()).hits.map((h) => ({
  url: 'https://news.ycombinator.com/item?id=' + h.objectID,
  text: (h.title + ' -- ' + (h.story_text ?? '')).replace(/<[^>]+>/g, ' ').slice(0, 6000),
}));

const questions = {                                // ONE call per post, all three questions
  buying: { type: 'boolean', instructions: 'The author is actively looking for ' + PRODUCT +
            ' right now, and would welcome a reply offering one.' },
  pain:   { type: 'boolean', instructions: 'The author describes a problem they personally have today.' },
  vendor: { type: 'boolean', instructions: 'The author is promoting or selling their own product or service.' },
};

async function pool(items, n, fn) {                // a few at a time: bursts get rate-limited
  const out = []; let next = 0;
  await Promise.all(Array.from({ length: n }, async () => {
    while (next < items.length) { const i = next++; out[i] = await fn(items[i]); }
  }));
  return out;
}

const scored = await pool(posts, 3, async (p) => {
  const { answers } = await evaluate({ model: 'typesafe-ai/jev', state: p.text, questions, maxRetries: 3 });
  return { ...p, buy: answers.buying.probability, pain: answers.pain.probability, vendor: answers.vendor.probability };
});

const leads = scored
  .filter((p) => p.buy >= KEEP && p.vendor < 0.5)  // sellers mention the topic too — drop them
  .sort((a, b) => b.buy - a.buy);

writeFileSync('leads.csv', ['url,buying,pain,vendor',
  ...leads.map((p) => [p.url, p.buy.toFixed(2), p.pain.toFixed(2), p.vendor.toFixed(2)].join(','))].join('\n'));
console.log(leads.length, 'of', posts.length, 'posts are buyers -> leads.csv');

// npm install ai
// .env:  AI_GATEWAY_API_KEY=...
// run:   node --env-file=.env check-messages.mjs
// outreach.json: [{ "lead": "who they are, in a sentence", "message": "what you are about to send" }, ...]
import { experimental_evaluate as evaluate } from 'ai';
import { readFileSync } from 'node:fs';

const rows = JSON.parse(readFileSync('outreach.json', 'utf8'));

const questions = {
  reply: { type: 'boolean', instructions: 'This person would reply to this message.' },
  fit:   { type: 'boolean', instructions: "This message was written for someone in this person's role, with this person's problem." },
};

for (const r of rows) {
  const { answers } = await evaluate({
    model: 'typesafe-ai/jev',
    state: 'LEAD: ' + r.lead + '\nMESSAGE THEY ARE ABOUT TO RECEIVE: ' + r.message,
    questions,
    maxRetries: 3,
  });
  const fit = answers.fit.probability, reply = answers.reply.probability;
  const verdict = fit < 0.5 ? 'WRONG PERSON — rewrite or skip' : reply < 0.5 ? 'weak — rewrite' : 'send';
  console.log(reply.toFixed(2), fit.toFixed(2), verdict, ' ', r.lead.slice(0, 60));
}