Vendor quote 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 BRIEF = await Bun.file('./brief.md').text();
const SUPPLIERS = ['sales@one.example', 'quotes@two.example', 'info@three.example'];

// One thread each. Never a shared To or CC: suppliers must not see each other.
const threads: Record<string, string> = {};
for (const supplier of SUPPLIERS) {
  const sent = await mm.send({
    to: [supplier],
    subject: 'Quote request: 400 units, delivery before 1 October',
    body: BRIEF
  });
  if (sent.status === 'sent') {
    const message = await mm.getMessage(sent.messageId);
    threads[supplier] = message.thread_id!;
  }
}

// Three days later: one reminder to whoever has not answered. Never two.
for (const [supplier, threadId] of Object.entries(threads)) {
  const thread = await mm.getThread(threadId);
  const answered = thread.messages.some((m) => m.direction === 'in');
  if (answered) continue;

  await mm.send({
    to: [supplier],
    subject: 'Re: Quote request: 400 units',
    body: 'A reminder that quotes are due Friday 15 August at 17:00 CET.',
    replyToMessageId: thread.messages[0].id
  });
}

// After the deadline: extract, do not evaluate.
const quotes = await Promise.all(
  Object.entries(threads).map(async ([supplier, threadId]) => {
    const thread = await mm.getThread(threadId);
    const reply = thread.messages.find((m) => m.direction === 'in');
    return { supplier, quote: reply ? (reply.body ?? reply.snippet) : null };
  })
);

await mm.send({
  to: ['jules@acme.com'],
  subject: 'Quotes in: 400 units',
  body: await tabulate(quotes)        // your formatting, or one model call
});