Inbox triage 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 OWNER = 'ada@acme.com';

const TRIAGE = {
  type: 'object',
  properties: {
    pile: { type: 'string', enum: ['needs-you', 'draft', 'archive'] },
    line: { type: 'string' },
    draft: { type: 'string' }
  },
  required: ['pile', 'line']
};

const needsYou: string[] = [];
const drafted: string[] = [];
let archived = 0;

for (const mail of await mm.listMessages({ unreadOnly: true, limit: 100 })) {
  const [contact] = await mm.lookupContact(mail.from);

  const verdict = await ask({
    system: TRIAGE_PROMPT,
    user: `From: ${mail.from} (${contact ? 'known' : 'never written before'})
Subject: ${mail.subject}
Attachments: ${mail.attachments.length}

${mail.body ?? mail.snippet}`,
    schema: TRIAGE
  });

  if (verdict.pile === 'archive') {
    await mm.archiveMessage(mail.id);
    archived++;
  } else if (verdict.pile === 'draft' && verdict.draft) {
    // Saved, not sent. The whole point is that it stays a suggestion.
    await mm.createNote({ title: `draft:${mail.id}`, body: verdict.draft });
    drafted.push(verdict.line);
  } else {
    needsYou.push(verdict.line);
  }
}

await mm.send({
  to: [OWNER],
  subject: `${needsYou.length} need you, ${drafted.length} drafted`,
  body: [
    `Needs you (${needsYou.length})`,
    ...needsYou.map((l) => `- ${l}`),
    '',
    `Drafted (${drafted.length})`,
    ...drafted.map((l) => `- ${l}`),
    '',
    `Archived: ${archived}`
  ].join('\n'),
  style: 'plain'
});