Email infrastructure for Inngest workflows

import { Inngest } from 'inngest';

const inngest = new Inngest({ id: 'my-app' });

export const sendWelcomeEmail = inngest.createFunction(
  { id: 'send-welcome-email' },
  { event: 'user/signed-up' },
  async ({ event, step }) => {
    const result = await step.run('send-welcome', async () => {
      const res = await fetch('https://api.multimail.dev/send_email', {
        method: 'POST',
        headers: {
          'Authorization': `Bearer ${process.env.MULTIMAIL_API_KEY}`,
          'Content-Type': 'application/json',
          'Idempotency-Key': `welcome-${event.data.userId}-${event.id}`,
        },
        body: JSON.stringify({
          from: '[email protected]',
          to: event.data.email,
          subject: 'Welcome to Acme',
          text: `Hi ${event.data.name}, your account is ready.`,
          oversight_mode: 'autonomous',
        }),
      });
      if (!res.ok) throw new Error(`MultiMail error: ${res.status}`);
      return res.json();
    });

    return { messageId: result.id };
  }
);

import { Inngest } from 'inngest';

const inngest = new Inngest({ id: 'my-app' });

export const agentEmailDraft = inngest.createFunction(
  { id: 'agent-email-draft' },
  { event: 'agent/draft-ready' },
  async ({ event, step }) => {
    "cm">// Queue email for human approval
    const queued = await step.run('queue-for-approval', async () => {
      const res = await fetch('https://api.multimail.dev/send_email', {
        method: 'POST',
        headers: {
          'Authorization': `Bearer ${process.env.MULTIMAIL_API_KEY}`,
          'Content-Type': 'application/json',
        },
        body: JSON.stringify({
          from: '[email protected]',
          to: event.data.recipient,
          subject: event.data.subject,
          text: event.data.body,
          oversight_mode: 'gated_send',
          metadata: { runId: event.id },
        }),
      });
      return res.json();
    });

    "cm">// Wait up to 48 hours for approval webhook
    const approval = await step.waitForEvent('wait-for-approval', {
      event: 'multimail/email.decided',
      timeout: '48h',
      match: 'data.message_id',
      "cm">// data.message_id must equal queued.id
      "cm">// configure your Inngest event key in the MultiMail webhook settings
    });

    if (!approval || approval.data.decision !== 'approved') {
      return { status: 'rejected', messageId: queued.id };
    }

    return { status: 'sent', messageId: queued.id };
  }
);

import { Inngest } from 'inngest';

const inngest = new Inngest({ id: 'my-app' });

"cm">// In your webhook handler (e.g. a Next.js API route or Hono endpoint):
"cm">// POST /api/webhooks/multimail
"cm">// Forward the parsed payload to Inngest:
"cm">//   await inngest.send({ name: 'multimail/email.received', data: req.body });

export const classifyInboundEmail = inngest.createFunction(
  { id: 'classify-inbound-email' },
  { event: 'multimail/email.received' },
  async ({ event, step }) => {
    const email = event.data;

    "cm">// Read full email body via MultiMail API
    const full = await step.run('read-email', async () => {
      const res = await fetch(
        `https:"cm">//api.multimail.dev/read_email?id=${email.id}`,
        { headers: { Authorization: `Bearer ${process.env.MULTIMAIL_API_KEY}` } }
      );
      return res.json();
    });

    "cm">// Tag based on subject keywords
    const tag = full.subject.toLowerCase().includes('urgent') ? 'urgent' : 'normal';

    await step.run('tag-email', async () => {
      await fetch('https://api.multimail.dev/tag_email', {
        method: 'POST',
        headers: {
          'Authorization': `Bearer ${process.env.MULTIMAIL_API_KEY}`,
          'Content-Type': 'application/json',
        },
        body: JSON.stringify({ id: email.id, tags: [tag] }),
      });
    });

    return { emailId: email.id, tag };
  }
);

import { Inngest } from 'inngest';

const inngest = new Inngest({ id: 'my-app' });

export const dailyDigest = inngest.createFunction(
  { id: 'daily-digest' },
  { cron: '0 8 * * *' },
  async ({ step }) => {
    const [inbox, pending] = await step.run('fetch-email-state', async () => {
      const [inboxRes, pendingRes] = await Promise.all([
        fetch('https:"cm">//api.multimail.dev/[email protected]&unread=true&limit=50', {
          headers: { Authorization: `Bearer ${process.env.MULTIMAIL_API_KEY}` },
        }),
        fetch('https:"cm">//api.multimail.dev/[email protected]', {
          headers: { Authorization: `Bearer ${process.env.MULTIMAIL_API_KEY}` },
        }),
      ]);
      return Promise.all([inboxRes.json(), pendingRes.json()]);
    });

    const digestText = [
      `Daily digest for [email protected]`,
      `Unread messages: ${inbox.emails.length}`,
      `Pending approvals: ${pending.messages.length}`,
      '',
      ...pending.messages.map((m: any) => `- [PENDING] ${m.subject} → ${m.to}`),
    ].join('\n');

    await step.run('send-digest', async () => {
      await fetch('https://api.multimail.dev/send_email', {
        method: 'POST',
        headers: {
          'Authorization': `Bearer ${process.env.MULTIMAIL_API_KEY}`,
          'Content-Type': 'application/json',
        },
        body: JSON.stringify({
          from: '[email protected]',
          to: '[email protected]',
          subject: `Agent email digest — ${new Date().toLocaleDateString()}`,
          text: digestText,
          oversight_mode: 'autonomous',
        }),
      });
    });

    return { sent: true, unread: inbox.emails.length, pending: pending.messages.length };
  }
);