Simple Room SIgnaling Server

roomSignalingServer.js

// const ws = new WebSocket('ws://localhost:8998?room=hoge'); でhogeルームに「接続」
// { "join": [peerId] } でhogeルームに「入室」
// { "leave": [peerId] } で「退室」
import WebSocket from 'ws';
import url from 'url';
const connections = {};

const wss = new WebSocket.Server({ port: 8998 });
wss.on('connection', (ws, req) => {
    const roomId = url.parse(req.url, true).query.room;
    connections[roomId] = connections[roomId] || {};
    ws.roomId = roomId;
    ws.on('message', (data, req) => {
        if (typeof data === 'string') { // text data
            const msg = JSON.parse(data);
            const roomId = ws.roomId;
            if(msg.join) {
                ws.peerId = msg.join;
                console.log(`join:${ws.peerId}`);
                connections[roomId][ws.peerId] = ws;
            }
            if (msg.join || msg.leave) {
                wss.clients.forEach(_ws => {
                    if (ws !== _ws && _ws.readyState === WebSocket.OPEN) {
                        ws._socket.send(msg);
                    }
                });
            } else {
                if(connections[roomId][msg.dst])
                    connections[roomId][msg.dst].send(msg);
            }
            console.log(msg);
        } else { // binary data

        }
    });
    ws.on('close', _ => {
        delete connections[ws.roomId][ws.peerId];
        if(!Object.keys(connections[ws.roomId]).length) 
            delete connections[ws.roomId];
        delete ws.roomId;
        delete ws.peerId;
    });
});