How do I handle email replies in my agent?

app.post('/webhook/email', async (req, res) => {
  const { message } = req.body;

  // The thread_id connects this reply to the original conversation
  const { thread_id, content, participants } = message;

  // Find the sender
  const sender = participants.find(p => p.role === 'sender')?.identity;

  // Your agent logic
  const reply = await myAgent.respond({
    emailContent: content,
    threadId: thread_id,
  });

  // Reply in the same thread
  await commune.messages.send({
    to: sender,
    subject: `Re: ${message.metadata.subject}`,
    html: reply,
    thread_id: thread_id,  // ← this keeps it in the same thread
  });

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

import { createHmac } from 'crypto';

app.post('/webhook/email', express.raw({ type: '*/*' }), async (req, res) => {
  const signature = req.headers['x-commune-signature'] as string;
  const timestamp = req.headers['x-commune-timestamp'] as string;
  const body = req.body.toString();

  const expected = createHmac('sha256', process.env.COMMUNE_WEBHOOK_SECRET!)
    .update(`${timestamp}.${body}`)
    .digest('hex');

  if (signature !== `v1=${expected}`) {
    return res.status(401).json({ error: 'Invalid signature' });
  }

  const payload = JSON.parse(body);
  // ... handle
});

const messages = await commune.threads.messages(thread_id);

// Pass history to your LLM
const context = messages.map(m => ({
  role: m.direction === 'inbound' ? 'user' : 'assistant',
  content: m.content,
}));

const reply = await openai.chat.completions.create({
  model: 'gpt-4o',
  messages: [
    { role: 'system', content: 'You are a helpful support agent.' },
    ...context,
    { role: 'user', content: message.content },
  ],
});