Feedback collection 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();

// Ask.
for (const moment of await recentlyClosedTickets()) {
  const [contact] = await mm.lookupContact(moment.email);
  if (contact?.notes?.includes('feedback asked')) continue;      // cooldown

  // Never ask somebody with something still open.
  const live = await mm.search(`"${moment.email}"`, 5);
  if (live.some((h) => Date.now() - +new Date(h.created_at) < 3 * 864e5)) continue;

  await mm.send({
    to: [moment.email],
    subject: 'what were you trying to do?',
    body: 'You wrote in last week about the export. What were you actually trying to do when you hit it?\n\nJules',
    style: 'plain'
  });
  if (contact) await mm.rememberAboutContact(contact.id, 'feedback asked');
}

// Read.
const HANDLE = {
  type: 'object',
  properties: {
    reply: { type: 'string' },
    route_to: { type: 'string' },
    fact: { type: 'string' }
  },
  required: ['reply']
};

for (const answer of await mm.listMessages({ unreadOnly: true })) {
  const out = await ask({
    system: FEEDBACK_PROMPT,
    user: answer.body ?? answer.snippet,
    schema: HANDLE
  });

  await mm.reply(answer.id, out.reply);
  // Their words, not a summary of them: the phrasing is the useful part.
  if (out.route_to) await mm.forward(answer.id, [out.route_to], { body: out.fact ?? '' });
  await mm.markUnread(answer.id, false);
}