How do I set up per-agent inboxes for a multi-agent system?

// Create inbox for each agent at startup
const inboxes = await Promise.all([
  commune.inboxes.create({ localPart: 'support', domainId }),
  commune.inboxes.create({ localPart: 'outreach', domainId }),
  commune.inboxes.create({ localPart: 'billing', domainId }),
  commune.inboxes.create({ localPart: 'onboarding', domainId }),
]);

// Each has its own webhook
await commune.inboxes.setWebhook(domainId, inboxes[0].id, {
  endpoint: 'https://your-server.com/webhook/support',
});
await commune.inboxes.setWebhook(domainId, inboxes[1].id, {
  endpoint: 'https://your-server.com/webhook/outreach',
});
// etc.

async function createCampaignInbox(campaignId: string) {
  const inbox = await commune.inboxes.create({
    localPart: `campaign-${campaignId}`,
    domainId,
  });

  await commune.inboxes.setWebhook(domainId, inbox.id, {
    endpoint: `https://your-server.com/webhook/campaign/${campaignId}`,
  });

  return inbox;
}

// Campaign reply automatically routes to the right campaign handler

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

  const agentRoutes: Record<string, (m: any) => Promise<void>> = {
    billing: billingAgent.handle,
    technical: supportAgent.handle,
    cancellation: churnAgent.handle,
    general: supportAgent.handle,
  };

  const handler = agentRoutes[intent] ?? supportAgent.handle;
  await handler(message);
  res.json({ ok: true });
});

// Create inboxes with delay between them
for (const localPart of agentAddresses) {
  await commune.inboxes.create({ localPart, domainId });
  await sleep(2000); // stagger creation
}

async function healthCheck() {
  const { data: inboxes } = await commune.inboxes.list();

  for (const inbox of inboxes) {
    const { health } = inbox;
    if (health.bounceRate > 0.03) {
      await alertOps(`Inbox ${inbox.address} bounce rate: ${health.bounceRate}`);
    }
    if (health.complaintRate > 0.0005) {
      await alertOps(`Inbox ${inbox.address} complaint rate: ${health.complaintRate}`);
    }
  }
}

// Run every hour
setInterval(healthCheck, 60 * 60 * 1000);