rtc.js

module.exports = function (opts) {
  const WebSocketServer = require("ws").Server;
  const wss = new WebSocketServer(opts);
  const board = require("rtc-switch")();
  let connections = [];

  wss.on("connection", function connection(ws) {
    const peer = board.connect();

    // add the socket to the connection list
    connections.push(ws);

    ws.on("message", peer.process);
    peer.on("data", function (data) {
      if (ws.readyState === 1) {
        ws.send(data);
      }
    });

    ws.on("close", function () {
      // trigger the peer leave
      peer.leave();

      // splice out the connection
      connections = connections.filter(function (conn) {
        return conn !== ws;
      });
    });
  });

  // add a reset helper
  board.reset = function () {
    connections.splice(0).forEach(function (conn) {
      conn.close();
    });
  };

  return board;
};