Recruiting coordinator

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 RECRUITER = 'jules@acme.com';

// Anything on this list is a person's job, checked before the model runs.
const HUMAN_ONLY = /\b(salary|compensation|equity|offer|feedback|rejected|why did|start date)\b/i;

for (const mail of await mm.listMessages({ unreadOnly: true })) {
  const text = mail.body ?? mail.snippet;

  if (HUMAN_ONLY.test(text)) {
    await mm.forward(mail.id, [RECRUITER], { body: 'Candidate asked about an offer or feedback.' });
    await mm.reply(mail.id, 'Thanks for asking. Jules handles that side and will come back to you here.');
    await mm.markUnread(mail.id, false);
    continue;
  }

  const [contact] = await mm.lookupContact(mail.from);
  const slots = await panelSlots(3);           // your availability source

  const body = await ask({
    system: RECRUITING_PROMPT,
    user: [
      contact?.notes ? `Candidate notes: ${contact.notes}` : 'New candidate.',
      `Available slots: ${slots.join(' | ')}`,
      `From: ${mail.from}`,
      '',
      text
    ].join('\n')
  });

  await mm.reply(mail.id, body);
  if (contact) await mm.rememberAboutContact(contact.id, `Asked: ${mail.subject}`, mail.id);
  await mm.markUnread(mail.id, false);
}