Cold outreach agent

import OpenAI from 'openai';
import { Mcpmailer } from '@mcpmailer/sdk';

/* ── your provider: this block is the only part that changes ── */
const client = new OpenAI({ apiKey: process.env.OPENAI_API_KEY });

const MODEL = process.env.MODEL;
if (!MODEL) throw new Error('Set MODEL to the model name your provider expects, e.g. export MODEL=gpt-4o-mini');

/** The only provider-specific code in any of these examples. */
async function ask({ system, user, schema }: {
  system: string;
  user: string;
  schema?: object;
}) {
  const res = await client.chat.completions.create({
    model: MODEL,
    messages: [
      { role: 'system', content: system },
      { role: 'user', content: user }
    ],
    // A schema turns the answer into an object instead of prose, which is what
    // the branching examples want. Without one you get the text back.
    ...(schema
      ? { response_format: { type: 'json_schema', json_schema: { name: 'out', schema, strict: true } } }
      : {})
  });

  const text = res.choices[0].message.content ?? '';
  return schema ? JSON.parse(text) : text;
}

/* ── the agent ── */

const mm = new Mcpmailer();
const DAILY_CAP = 20;
let sent = 0;

// Declining is a correct outcome, not a failure, so the model returns a
// decision rather than an email.
const DRAFT = {
  type: 'object',
  properties: {
    write: { type: 'boolean' },
    skip_reason: { type: 'string' },
    subject: { type: 'string' },
    body: { type: 'string' }
  },
  required: ['write']
};

for (const prospect of await todaysProspects()) {
  if (sent >= DAILY_CAP) break;

  // Check two: anyone at this company, ever. Cheaper than the model call and
  // catches the mistake that actually costs you the domain.
  const priorContact = await mm.search(`"${prospect.domain}"`, 3);
  if (priorContact.length) continue;

  const [known] = await mm.lookupContact(prospect.email);
  if (known?.notes?.includes('do not contact')) continue;

  const out = await ask({
    system: OUTREACH_PROMPT,
    user: `Company: ${prospect.company} (${prospect.domain})
Person: ${prospect.name}, ${prospect.role}
Reason to write: ${prospect.reason ?? 'none found'}`,
    schema: DRAFT
  });

  if (!out.write) { console.log(prospect.domain, 'skipped:', out.skip_reason); continue; }

  const result = await mm.send({ to: [prospect.email], subject: out.subject, body: out.body });
  if (result.status === 'sent') sent++;

  const contact = known ?? (await mm.createContact({
    company_name: prospect.company,
    domains: [prospect.domain],
    channels: [{ kind: 'email', value: prospect.email }]
  }));
  await mm.rememberAboutContact(contact.id, `Cold outreach sent: ${out.subject}`);
}