Send email from Discord bots without losing oversight

import { Client, GatewayIntentBits, SlashCommandBuilder } from 'discord.js';

const client = new Client({ intents: [GatewayIntentBits.Guilds] });

client.on('interactionCreate', async (interaction) => {
  if (!interaction.isChatInputCommand()) return;
  if (interaction.commandName !== 'sendemail') return;

  const to = interaction.options.getString('to', true);
  const subject = interaction.options.getString('subject', true);
  const body = interaction.options.getString('body', true);

  await interaction.deferReply({ ephemeral: true });

  const response = await fetch('https://api.multimail.dev/v1/send_email', {
    method: 'POST',
    headers: {
      'Authorization': `Bearer ${process.env.MULTIMAIL_API_KEY}`,
      'Content-Type': 'application/json',
    },
    body: JSON.stringify({
      from: '[email protected]',
      to,
      subject,
      body,
      oversight_mode: 'gated_send',
      metadata: {
        discord_user: interaction.user.tag,
        discord_channel: interaction.channelId,
        discord_guild: interaction.guildId,
      },
    }),
  });

  const result = await response.json();

  if (result.status === 'queued') {
    await interaction.editReply(
      `Email queued for approval (ID: \`${result.message_id}\`). A reviewer will approve or reject it in the MultiMail dashboard.`
    );
  } else {
    await interaction.editReply(`Failed to queue email: ${result.error}`);
  }
});

client.login(process.env.DISCORD_TOKEN);

import { Client, GatewayIntentBits } from 'discord.js';

const client = new Client({ intents: [GatewayIntentBits.Guilds] });

client.on('interactionCreate', async (interaction) => {
  if (!interaction.isChatInputCommand()) return;
  if (interaction.commandName !== 'checkinbox') return;

  const mailbox = interaction.options.getString('mailbox') ?? '[email protected]';

  await interaction.deferReply({ ephemeral: true });

  const response = await fetch(
    `https:"cm">//api.multimail.dev/v1/check_inbox?mailbox=${encodeURIComponent(mailbox)}&limit=5`,
    {
      headers: {
        'Authorization': `Bearer ${process.env.MULTIMAIL_API_KEY}`,
      },
    }
  );

  const { emails } = await response.json();

  if (!emails.length) {
    await interaction.editReply(`No unread messages in ${mailbox}.`);
    return;
  }

  const lines = emails.map((e) =>
    `• **${e.subject}** — from \`${e.from}\` (${new Date(e.received_at).toLocaleString()})`
  );

  await interaction.editReply(
    `**${emails.length} unread in ${mailbox}:**\n${lines.join('\n')}`
  );
});

client.login(process.env.DISCORD_TOKEN);

import express from 'express';

const app = express();
app.use(express.json());

app.post('/webhooks/multimail', async (req, res) => {
  const event = req.body;

  if (event.type !== 'message.pending_approval') {
    return res.json({ ok: true });
  }

  const { message_id, to, subject, from, metadata } = event.data;

  const discordPayload = {
    content: '**Email approval required**',
    embeds: [
      {
        title: subject,
        fields: [
          { name: 'From', value: from, inline: true },
          { name: 'To', value: to, inline: true },
          { name: 'Triggered by', value: metadata?.discord_user ?? 'unknown', inline: true },
          { name: 'Message ID', value: `\`${message_id}\``, inline: false },
        ],
        description: `Approve at https:"cm">//app.multimail.dev/approvals/${message_id}`,
        color: 0xf59e0b,
      },
    ],
  };

  await fetch(process.env.DISCORD_WEBHOOK_URL, {
    method: 'POST',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify(discordPayload),
  });

  res.json({ ok: true });
});

app.listen(3000);

import os
import discord
from discord.ext import commands
import httpx

bot = commands.Bot(command_prefix=&"cm">#039;!')
MULTIMAIL_BASE = &"cm">#039;https://api.multimail.dev/v1'
HEADERS = {&"cm">#039;Authorization': f'Bearer {os.environ["MULTIMAIL_API_KEY"]}'}

@bot.command(name=&"cm">#039;reply')
async def reply_email(ctx, thread_id: str, *, reply_body: str):
    """Reply to an email thread: !reply <thread_id> <body>"""
    async with httpx.AsyncClient() as client:
        resp = await client.post(
            f&"cm">#039;{MULTIMAIL_BASE}/reply_email',
            headers=HEADERS,
            json={
                &"cm">#039;thread_id': thread_id,
                &"cm">#039;body': reply_body,
                &"cm">#039;oversight_mode': 'gated_send',
                &"cm">#039;metadata': {
                    &"cm">#039;discord_user': str(ctx.author),
                    &"cm">#039;discord_channel': str(ctx.channel.id),
                },
            },
        )
        result = resp.json()

    if result.get(&"cm">#039;status') == 'queued':
        await ctx.reply(f&"cm">#039;Reply queued for approval (`{result["message_id"]}`). Awaiting review.')
    else:
        await ctx.reply(f&"cm">#039;Error: {result.get("error", "unknown")}')

bot.run(os.environ[&"cm">#039;DISCORD_TOKEN'])