Sending & Receiving

-- Insert message
INSERT INTO messages (
  inbox_id,
  thread_id,
  message_id_header,
  from_email,
  to_email,
  subject,
  text_body,
  html_body,
  reply_body,
  links,
  cta_links,
  received_at
) VALUES (...);

-- Store raw MIME in R2
PUT /emails/{inbox_id}/{message_id}.eml

-- Store attachments in R2
PUT /attachments/{message_id}/{filename}

{
  "type": "message.received",
  "timestamp": "2026-03-16T14:23:45Z",
  "data": {
    "message_id": "msg_9kL2xYw1pQm3",
    "inbox_id": "inbox_abc123",
    "thread_id": "thread_xyz789",
    "from": "customer@company.com",
    "to": ["agent-abc123@daimon.email"],
    "subject": "Question about pricing",
    "text_body": "Hi, I'm interested in your product...",
    "reply_body": "Hi, I'm interested in your product...",
    "links": ["https://yoursite.com/pricing"],
    "cta_links": [],
    "received_at": "2026-03-16T14:23:45Z"
  }
}

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

  if (event.type === 'message.received') {
    const message = event.data;

    // Agent processes the email
    const response = await generateResponse(message.text_body);

    // Agent sends reply
    await daimonClient.inboxes.send(message.inbox_id, {
      to: message.from,
      subject: `Re: ${message.subject}`,
      text: response,
      thread_id: message.thread_id, // Keep in same thread
    });
  }

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

// Check for new messages every 30 seconds
setInterval(async () => {
  const messages = await client.inboxes.listMessages(inboxId, {
    received_after: lastCheckTime.toISOString(),
    limit: 100,
  });

  for (const message of messages.messages) {
    await handleInboundMessage(message);
  }

  lastCheckTime = new Date();
}, 30000);

import time
from datetime import datetime

last_check_time = datetime.now()

while True:
    # Poll for new messages
    messages = client.inboxes.list_messages(
        inbox_id=inbox_id,
        received_after=last_check_time.isoformat(),
        limit=100
    )

    for message in messages.messages:
        handle_inbound_message(message)

    last_check_time = datetime.now()
    time.sleep(30)  # Poll every 30 seconds

const sent = await client.inboxes.send(inboxId, {
  to: 'recipient@company.com',
  subject: 'Your support ticket is resolved',
  text: 'Hi, I found a solution to your issue...',
  html: '<p>Hi, I found a solution to your issue...</p>',
  attachments: [
    {
      filename: 'solution.pdf',
      content_type: 'application/pdf',
      data: base64EncodedPdf,
    },
  ],
  thread_id: 'thread_xyz789', // Optional: keep in thread
  send_at: '2026-03-17T09:00:00Z', // Optional: schedule for later
});

console.log(sent.message_id); // "msg_kLp9xYw2qRn4"
console.log(sent.status); // "queued" or "scheduled"

sent = client.inboxes.send(
    inbox_id=inbox_id,
    to='recipient@company.com',
    subject='Your support ticket is resolved',
    text='Hi, I found a solution to your issue...',
    html='<p>Hi, I found a solution to your issue...</p>',
    attachments=[{
        'filename': 'solution.pdf',
        'content_type': 'application/pdf',
        'data': base64_encoded_pdf
    }],
    thread_id='thread_xyz789',
    send_at='2026-03-17T09:00:00Z'
)

print(sent.message_id)  # "msg_kLp9xYw2qRn4"
print(sent.status)  # "queued" or "scheduled"

curl -X POST https://api.daimon.email/v1/inboxes/inbox_abc123/send \
  -H "Authorization: Bearer dm_live_..." \
  -H "Content-Type: application/json" \
  -d '{
    "to": "recipient@company.com",
    "subject": "Your support ticket is resolved",
    "text": "Hi, I found a solution to your issue...",
    "html": "<p>Hi, I found a solution to your issue...</p>",
    "thread_id": "thread_xyz789"
  }'

// Inbound message arrives
const inbound = await client.inboxes.getMessage(inboxId, 'msg_abc123');

// Send reply in same thread
const reply = await client.inboxes.send(inboxId, {
  to: inbound.from,
  subject: `Re: ${inbound.subject}`,
  text: 'Thanks for your email. Here is the answer...',
  thread_id: inbound.thread_id, // Auto-threading
  in_reply_to: inbound.message_id_header, // Sets In-Reply-To header
});

// Message inherits thread context
console.log(reply.thread_id === inbound.thread_id); // true

{
  "type": "message.sent",
  "timestamp": "2026-03-16T14:30:12Z",
  "data": {
    "message_id": "msg_kLp9xYw2qRn4",
    "inbox_id": "inbox_abc123",
    "to": ["recipient@company.com"],
    "subject": "Your support ticket is resolved",
    "smtp_message_id": "<abc123@daimon.email>",
    "delivered_at": "2026-03-16T14:30:12Z"
  }
}

{
  "type": "message.bounced",
  "timestamp": "2026-03-16T14:30:15Z",
  "data": {
    "message_id": "msg_kLp9xYw2qRn4",
    "inbox_id": "inbox_abc123",
    "to": ["invalid@nonexistent-domain.com"],
    "bounce_type": "permanent",
    "bounce_reason": "550 5.1.1 Recipient address rejected: User unknown",
    "smtp_code": 550
  }
}