Link 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 = 15;
let sent = 0;

const OUTREACH = {
  type: 'object',
  properties: {
    write: { type: 'boolean' },
    skip_reason: { type: 'string' },
    subject: { type: 'string' },
    body: { type: 'string' }
  },
  required: ['write']
};

for (const site of await candidateSites()) {
  if (sent >= DAILY_CAP) break;

  // Once per domain, ever, across every campaign.
  if ((await mm.search(`"${site.domain}"`, 3)).length) continue;

  const out = await ask({
    system: LINK_PROMPT,
    user: `Page: ${site.url}
The sentence with the problem: "${site.quote}"
Problem: ${site.problem}
Proposed replacement: ${site.replacement}`,
    schema: OUTREACH
  });

  // Declining is the common and correct outcome. Most pages do not qualify.
  if (!out.write) { console.log(site.domain, 'skipped:', out.skip_reason); continue; }

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

  // Recorded so no campaign ever writes here again. There is no follow-up.
  const [contact] = await mm.lookupContact(site.email);
  const saved = contact ?? (await mm.createContact({
    domains: [site.domain],
    channels: [{ kind: 'email', value: site.email }]
  }));
  await mm.rememberAboutContact(saved.id, `Outreach sent about ${site.url}. No follow-up.`);
}