Email infrastructure for Replicate-powered agents

import Replicate from 'replicate';

const replicate = new Replicate({ auth: process.env.REPLICATE_API_TOKEN });

"cm">// Generate email body from a prompt
const output = await replicate.run(
  'meta/llama-3-8b-instruct',
  {
    input: {
      prompt: 'Write a 3-sentence project status update for Q2 sprint completion. Tone: direct, no filler.',
      max_tokens: 200
    }
  }
);

const body = Array.isArray(output) ? output.join('') : String(output);

"cm">// Send via MultiMail — oversight mode enforced server-side
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: '[email protected]',
    subject: 'Q2 Sprint Status Update',
    body,
    metadata: {
      model: 'meta/llama-3-8b-instruct',
      source: 'replicate'
    }
  })
});

const result = await response.json();

if (result.status === 'pending_approval') {
  console.log(`Message queued for approval: ${result.message_id}`);
} else {
  console.log(`Sent: ${result.message_id}`);
}

import replicate
import httpx
import os

MULTIMAIL_API_KEY = os.environ["MULTIMAIL_API_KEY"]
MULTIMAIL_BASE = "https://api.multimail.dev/v1"

def caption_and_queue(image_url: str, recipient: str) -> dict:
    "cm"># Run Replicate vision model
    output = replicate.run(
        "salesforce/blip:2e1dddc8621f72155f24cf2e0adbde548458d3cab9f00c0139eea840d0ac4746",
        input={"image": image_url, "task": "image_captioning"}
    )
    caption = str(output)

    "cm"># Queue email — mailbox is configured gated_send, so it holds for approval
    with httpx.Client() as client:
        resp = client.post(
            f"{MULTIMAIL_BASE}/send_email",
            headers={"Authorization": f"Bearer {MULTIMAIL_API_KEY}"},
            json={
                "from": "[email protected]",
                "to": recipient,
                "subject": "Image Analysis Result",
                "body": f"Caption generated by vision model:\n\n{caption}",
                "metadata": {"model": "salesforce/blip", "source_image": image_url}
            }
        )
        return resp.json()

def approve_pending() -> list:
    with httpx.Client() as client:
        pending = client.get(
            f"{MULTIMAIL_BASE}/list_pending",
            headers={"Authorization": f"Bearer {MULTIMAIL_API_KEY}"}
        ).json()

        approved = []
        for msg in pending.get("messages", []):
            decision = client.post(
                f"{MULTIMAIL_BASE}/decide_email",
                headers={"Authorization": f"Bearer {MULTIMAIL_API_KEY}"},
                json={"message_id": msg["id"], "action": "approve"}
            ).json()
            approved.append(decision)
        return approved

"cm"># Usage
result = caption_and_queue(
    "https://upload.wikimedia.org/wikipedia/commons/thumb/4/47/PNG_transparency_demonstration_1.png/280px-PNG_transparency_demonstration_1.png",
    "[email protected]"
)
print(result)  "cm"># {"status": "pending_approval", "message_id": "msg_..."}

import Replicate from 'replicate';
import { Hono } from 'hono';

const app = new Hono();
const replicate = new Replicate({ auth: process.env.REPLICATE_API_TOKEN });

app.post('/webhooks/multimail', async (c) => {
  const event = await c.req.json();

  if (event.type !== 'email.received') {
    return c.json({ ok: true });
  }

  "cm">// Read the full email via MultiMail
  const emailResp = await fetch(
    `https:"cm">//api.multimail.dev/v1/read_email?message_id=${event.message_id}`,
    { headers: { 'Authorization': `Bearer ${process.env.MULTIMAIL_API_KEY}` } }
  );
  const email = await emailResp.json();

  "cm">// Generate reply with Replicate
  const output = await replicate.run(
    'meta/llama-3-8b-instruct',
    {
      input: {
        prompt: `Reply to this email professionally in 2-3 sentences:\n\n${email.body}`,
        max_tokens: 150,
        system_prompt: 'You are a helpful assistant. Be concise and direct.'
      }
    }
  );

  const replyBody = Array.isArray(output) ? output.join('') : String(output);

  "cm">// Send reply via MultiMail's reply_email to preserve thread
  await fetch('https:"cm">//api.multimail.dev/v1/reply_email', {
    method: 'POST',
    headers: {
      'Authorization': `Bearer ${process.env.MULTIMAIL_API_KEY}`,
      'Content-Type': 'application/json'
    },
    body: JSON.stringify({
      in_reply_to: event.message_id,
      body: replyBody,
      metadata: { model: 'meta/llama-3-8b-instruct', generated: true }
    })
  });

  return c.json({ ok: true });
});

export default app;

"cm">// This pattern works when MultiMail MCP server is configured in your client.
"cm">// The agent calls Replicate directly, then uses MultiMail MCP tools for email actions.

"cm">// 1. Agent calls Replicate REST API for inference
const replicateResp = await fetch('https://api.replicate.com/v1/predictions', {
  method: 'POST',
  headers: {
    'Authorization': `Token ${process.env.REPLICATE_API_TOKEN}`,
    'Content-Type': 'application/json'
  },
  body: JSON.stringify({
    version: 'ac944f2e49c55c7e965fc3d93ad9a7d9d947866d6793fb849dd6b4747d0c061c',
    input: {
      prompt: 'Summarize the following support ticket in one paragraph: ...',
      max_new_tokens: 256
    }
  })
});

"cm">// Poll until complete (simplified)
let prediction = await replicateResp.json();
while (prediction.status === 'processing' || prediction.status === 'starting') {
  await new Promise(r => setTimeout(r, 1000));
  const poll = await fetch(`https:"cm">//api.replicate.com/v1/predictions/${prediction.id}`, {
    headers: { 'Authorization': `Token ${process.env.REPLICATE_API_TOKEN}` }
  });
  prediction = await poll.json();
}

const summary = prediction.output?.join?.('') ?? prediction.output;

"cm">// 2. Use MultiMail MCP send_email tool to deliver the summary
"cm">// (In MCP context, this is a tool call — shown here as the equivalent REST call)
const sendResp = 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: '[email protected]',
    subject: 'Support Ticket Summary',
    body: summary
  })
});

console.log(await sendResp.json());