WebSockets

const WebSocket = require("ws");

const ws = new WebSocket("wss://api.openmail.sh/v1/ws", {
  headers: { Authorization: `Bearer ${process.env.OPENMAIL_API_KEY}` },
});

const WebSocket = require("ws");

const OPENMAIL_API_KEY = process.env.OPENMAIL_API_KEY;

function connect() {
  const ws = new WebSocket("wss://api.openmail.sh/v1/ws", {
    headers: { Authorization: `Bearer ${OPENMAIL_API_KEY}` },
  });

  ws.on("open", () => {
    console.log("Connected to OpenMail");
    ws.send(JSON.stringify({ type: "subscribe" }));
  });

  ws.on("message", (data) => {
    const event = JSON.parse(data);

    if (event.type === "subscribed") {
      console.log("Subscribed to:", event.inbox_ids);
      return;
    }

    if (event.event === "message.received") {
      console.log(`New email from: ${event.message.from}`);
      console.log(`Subject: ${event.message.subject}`);

      // Route by external_id to the right agent/container
      const container = getContainerByUserId(event.external_id);
      container.deliverEmail({
        threadId: event.thread_id,
        message: event.message,
      });
    }
  });

  ws.on("close", () => {
    console.log("Disconnected, reconnecting in 5s...");
    setTimeout(connect, 5000);
  });

  ws.on("error", (err) => {
    console.error("WebSocket error:", err.message);
  });
}

connect();