Stop scoring records. Score the moment someone asks.

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

const OFFER = 'a fractional RevOps lead who fixes CRM and pipeline reporting';  // what you sell, plainly
const QUERY = 'CRM';        // a word your buyers use when they ASK for help
const DAYS = 90;            // how far back to look
const BUY_MIN = 0.6;        // keep: likely buyer...
const VENDOR_MAX = 0.5;     // ...and probably not a seller

// Hacker News "Ask HN" posts: people asking a room for advice. Free, no key.
const since = Math.floor(Date.now() / 1000) - DAYS * 86400;
const url = 'https://hn.algolia.com/api/v1/search?tags=ask_hn&hitsPerPage=50' +
  '&numericFilters=created_at_i>' + since + '&query=' + encodeURIComponent(QUERY);
const hits = (await (await fetch(url)).json()).hits;

const posts = hits.map((h) => ({
  link: 'https://news.ycombinator.com/item?id=' + h.objectID,
  text: (h.title + '\n\n' + (h.story_text ?? '')).replace(/<[^>]+>/g, ' ').slice(0, 8000),
}));

const questions = {
  buying: { type: 'boolean', instructions: 'The author is currently looking for ' + OFFER +
    ', or for something that would do the same job, and would welcome a relevant reply.' },
  pain:   { type: 'boolean', instructions: 'The author describes a problem their own team has right now.' },
  vendor: { type: 'boolean', instructions: 'The author is promoting, launching, or hiring for their own product or service.' },
};

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

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

const leads = scored
  .filter((p) => p.buying >= BUY_MIN && p.vendor < VENDOR_MAX)
  .sort((a, b) => b.pain - a.pain || b.buying - a.buying);   // live pain first

writeFileSync('leads.csv', ['link,buying,pain,vendor',
  ...leads.map((p) => [p.link, p.buying, p.pain, p.vendor].map((v) => (typeof v === 'number' ? v.toFixed(2) : v)).join(','))].join('\n'));
console.log(leads.length, 'of', posts.length, 'posts look like buyers -> leads.csv');

// check-messages.mjs  |  node --env-file=.env check-messages.mjs
// outreach.json: [{ "who": "Head of Sales, 12 SDRs, Series B fintech", "message": "..." }, ...]
import { experimental_evaluate as evaluate } from 'ai';
import { readFileSync } from 'node:fs';

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

for (const d of drafts) {
  const { answers } = await evaluate({
    model: 'typesafe-ai/jev',
    state: 'RECIPIENT: ' + d.who + '\n\nMESSAGE THEY WILL RECEIVE:\n' + d.message,
    questions: {
      fit:   { type: 'boolean', instructions: 'This message was written for someone in this recipient\'s role, with a problem this recipient plausibly has.' },
      reply: { type: 'boolean', instructions: 'This recipient would reply to this message.' },
      generic: { type: 'boolean', instructions: 'This message could be sent unchanged to almost anyone.' },
    },
    maxRetries: 2,
  });
  const fit = answers.fit.probability, reply = answers.reply.probability, generic = answers.generic.probability;
  const verdict = fit < 0.5 ? 'WRONG PERSON: do not send'
    : generic >= 0.5 ? 'TEMPLATE: rewrite for this person'
    : reply < 0.5 ? 'WEAK: rewrite and re-check'
    : 'READY: read it, then send it yourself';
  console.log(fit.toFixed(2), reply.toFixed(2), generic.toFixed(2), verdict, '|', d.who);
}