Order status 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 HUMAN = 'orders@kernsupply.com';
const MONEY = /\b(refund|return|damaged|broken|lost|missing|chargeback|discount|coupon)\b/i;

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

  // Money questions never reach the model. One less way to get it wrong.
  if (MONEY.test(text)) {
    await mm.forward(mail.id, [HUMAN], { body: 'Money or returns question.' });
    await mm.reply(mail.id, 'A person is picking this up and will reply here today.');
    await mm.markUnread(mail.id, false);
    continue;
  }

  // Three ways in, because people rarely write from the address they ordered with.
  const orders = [
    ...(await ordersByEmail(mail.from)),
    ...(await ordersByNumber(text.match(/\b[A-Z]{2}-?\d{5,}\b/)?.[0]))
  ];

  const body = await ask({
    system: ORDER_PROMPT,
    user: `Orders found: ${JSON.stringify(orders)}

From: ${mail.from}
${text}`
  });

  await mm.reply(mail.id, body);
  await mm.markUnread(mail.id, false);
}