ref

.eslintrc.json

@@ -1,19 +0,0 @@
-{
-    "extends": [
-        "eslint:recommended"
-    ],
-    "env": {
-        "node": true,
-        "es6": true,
-        "mocha": true
-    },
-    "parserOptions": {
-        "ecmaVersion": 2018,
-        "sourceType": "module",
-        "allowImportExportEverywhere": true
-    },
-    "rules": {
-        "no-var": "error",
-        "no-console": "off"
-    }
-}

.gitignore

@@ -14,4 +14,6 @@ results
 node_modules
 npm-debug.log
 
-.idea
+.idea
+.cache
+.vscode

bin/peerjs

@@ -1,69 +1,70 @@
 #!/usr/bin/env node
+// tslint:disable
 
-const path = require('path');
-const pkg = require('../package.json');
-const fs = require('fs');
+const path = require("path");
+const pkg = require("../package.json");
+const fs = require("fs");
 const version = pkg.version;
-const PeerServer = require('../src').PeerServer;
-const opts = require('optimist')
-  .usage('Usage: $0')
+const { PeerServer } = require("../dist/src");
+const opts = require("optimist")
+  .usage("Usage: $0")
   .options({
     expire_timeout: {
       demand: false,
-      alias: 't',
-      description: 'timeout (milliseconds)',
+      alias: "t",
+      description: "timeout (milliseconds)",
       default: 5000
     },
     concurrent_limit: {
       demand: false,
-      alias: 'c',
-      description: 'concurrent limit',
+      alias: "c",
+      description: "concurrent limit",
       default: 5000
     },
     alive_timeout: {
       demand: false,
-      description: 'broken connection check timeout (milliseconds)',
+      description: "broken connection check timeout (milliseconds)",
       default: 60000
     },
     key: {
       demand: false,
-      alias: 'k',
-      description: 'connection key',
-      default: 'peerjs'
+      alias: "k",
+      description: "connection key",
+      default: "peerjs"
     },
     sslkey: {
       demand: false,
-      description: 'path to SSL key'
+      description: "path to SSL key"
     },
     sslcert: {
       demand: false,
-      description: 'path to SSL certificate'
+      description: "path to SSL certificate"
     },
     port: {
       demand: true,
-      alias: 'p',
-      description: 'port'
+      alias: "p",
+      description: "port"
     },
     path: {
       demand: false,
-      description: 'custom path',
-      default: '/'
+      description: "custom path",
+      default: "/"
     },
     allow_discovery: {
       demand: false,
-      description: 'allow discovery of peers'
+      description: "allow discovery of peers"
     },
     proxied: {
       demand: false,
-      description: 'Set true if PeerServer stays behind a reverse proxy',
+      description: "Set true if PeerServer stays behind a reverse proxy",
       default: false
     }
   })
-  .boolean('allow_discovery')
+  .boolean("allow_discovery")
   .argv;
 
-process.on('uncaughtException', function (e) {
-  console.error('Error: ' + e);
+process.on("uncaughtException", function (e) {
+  console.error("Error: " + e);
 });
 
 if (opts.sslkey || opts.sslcert) {
@@ -76,8 +77,8 @@ if (opts.sslkey || opts.sslcert) {
     delete opts.sslkey;
     delete opts.sslcert;
   } else {
-    console.error('Warning: PeerServer will not run because either ' +
-      'the key or the certificate has not been provided.');
+    console.error("Warning: PeerServer will not run because either " +
+      "the key or the certificate has not been provided.");
     process.exit(1);
   }
 }
@@ -88,15 +89,15 @@ const server = PeerServer(opts, server => {
   const port = server.address().port;
 
   console.log(
-    'Started PeerServer on %s, port: %s, path: %s (v. %s)',
-    host, port, userPath || '/', version
+    "Started PeerServer on %s, port: %s, path: %s (v. %s)",
+    host, port, userPath || "/", version
   );
 });
 
-server.on('connection', client => {
+server.on("connection", client => {
   console.log(`Client connected: ${client.getId()}`);
 });
 
-server.on('disconnect', client => {
+server.on("disconnect", client => {
   console.log(`Client disconnected: ${client.getId()}`);
 });

config/index.js

@@ -1,15 +0,0 @@
-module.exports = {
-  port: 9000,
-  expire_timeout: 5000,
-  alive_timeout: 60000,
-  key: 'peerjs',
-  path: '/myapp',
-  concurrent_limit: 5000,
-  allow_discovery: false,
-  proxied: false,
-  cleanup_out_msgs: 1000,
-  ssl: {
-    key: '',
-    cert: ''
-  }
-};

config/index.ts

@@ -0,0 +1,33 @@
+export interface IConfig {
+  readonly port: number;
+  readonly expire_timeout: number;
+  readonly alive_timeout: number;
+  readonly key: string;
+  readonly path: string;
+  readonly concurrent_limit: number;
+  readonly allow_discovery: boolean;
+  readonly proxied: boolean | string;
+  readonly cleanup_out_msgs: number;
+  readonly ssl: {
+    key: string;
+    cert: string;
+  };
+}
+
+const defaultConfig: IConfig = {
+  port: 9000,
+  expire_timeout: 5000,
+  alive_timeout: 60000,
+  key: "peerjs",
+  path: "/myapp",
+  concurrent_limit: 5000,
+  allow_discovery: false,
+  proxied: false,
+  cleanup_out_msgs: 1000,
+  ssl: {
+    key: "",
+    cert: ""
+  }
+};
+
+export default defaultConfig;

dist/app.json

@@ -0,0 +1,5 @@
+{
+    "name": "PeerJS Server",
+    "description": "A server side element to broker connections between PeerJS clients.",
+    "website": "http://peerjs.com/"
+}

dist/config/index.js

@@ -0,0 +1,18 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+const defaultConfig = {
+    port: 9000,
+    expire_timeout: 5000,
+    alive_timeout: 60000,
+    key: "peerjs",
+    path: "/myapp",
+    concurrent_limit: 5000,
+    allow_discovery: false,
+    proxied: false,
+    cleanup_out_msgs: 1000,
+    ssl: {
+        key: "",
+        cert: ""
+    }
+};
+exports.default = defaultConfig;

dist/src/api/index.js

@@ -0,0 +1,24 @@
+"use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+const body_parser_1 = __importDefault(require("body-parser"));
+const cors_1 = __importDefault(require("cors"));
+const express_1 = __importDefault(require("express"));
+const app_json_1 = __importDefault(require("../../app.json"));
+const auth_1 = require("./middleware/auth");
+const calls_1 = __importDefault(require("./v1/calls"));
+const public_1 = __importDefault(require("./v1/public"));
+exports.Api = ({ config, realm, messageHandler }) => {
+    const authMiddleware = new auth_1.AuthMiddleware(config, realm);
+    const app = express_1.default.Router();
+    const jsonParser = body_parser_1.default.json();
+    app.use(cors_1.default());
+    app.get("/", (_, res) => {
+        res.send(app_json_1.default);
+    });
+    app.use("/:key", public_1.default({ config, realm }));
+    app.use("/:key/:id/:token", authMiddleware.handle, jsonParser, calls_1.default({ realm, messageHandler }));
+    return app;
+};

dist/src/api/middleware/auth/index.js

@@ -0,0 +1,27 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+const enums_1 = require("../../../enums");
+class AuthMiddleware {
+    constructor(config, realm) {
+        this.config = config;
+        this.realm = realm;
+    }
+    handle(req, res, next) {
+        const { id, token, key } = req.params;
+        if (key !== this.config.key) {
+            return res.status(401).send(enums_1.Errors.INVALID_KEY);
+        }
+        if (!id) {
+            return res.sendStatus(401);
+        }
+        const client = this.realm.getClientById(id);
+        if (!client) {
+            return res.sendStatus(401);
+        }
+        if (client.getToken() && token !== client.getToken()) {
+            return res.status(401).send(enums_1.Errors.INVALID_TOKEN);
+        }
+        next();
+    }
+}
+exports.AuthMiddleware = AuthMiddleware;

dist/src/api/middleware/middleware.js

@@ -0,0 +1,2 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });

dist/src/api/v1/calls/index.js

@@ -0,0 +1,30 @@
+"use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+const express_1 = __importDefault(require("express"));
+exports.default = ({ realm, messageHandler }) => {
+    const app = express_1.default.Router();
+    const handle = (req, res, next) => {
+        const { id } = req.params;
+        if (!id) {
+            return next();
+        }
+        const client = realm.getClientById(id);
+        const { type, dst, payload } = req.body;
+        const message = {
+            type,
+            src: id,
+            dst,
+            payload
+        };
+        messageHandler.handle(client, message);
+        res.sendStatus(200);
+    };
+    app.post("/offer", handle);
+    app.post("/candidate", handle);
+    app.post("/answer", handle);
+    app.post("/leave", handle);
+    return app;
+};

dist/src/api/v1/public/index.js

@@ -0,0 +1,23 @@
+"use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+const express_1 = __importDefault(require("express"));
+exports.default = ({ config, realm }) => {
+    const app = express_1.default.Router();
+    // Retrieve guaranteed random ID.
+    app.get("/id", (_, res) => {
+        res.contentType("html");
+        res.send(realm.generateClientId());
+    });
+    // Get a list of all peers for a key, enabled by the `allowDiscovery` flag.
+    app.get("/peers", (_, res) => {
+        if (config.allow_discovery) {
+            const clientsIds = realm.getClientsIds();
+            return res.send(clientsIds);
+        }
+        res.sendStatus(401);
+    });
+    return app;
+};

dist/src/enums.js

@@ -0,0 +1,21 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+var Errors;
+(function (Errors) {
+    Errors["INVALID_KEY"] = "Invalid key provided";
+    Errors["INVALID_TOKEN"] = "Invalid token provided";
+    Errors["INVALID_WS_PARAMETERS"] = "No id, token, or key supplied to websocket server";
+    Errors["CONNECTION_LIMIT_EXCEED"] = "Server has reached its concurrent user limit";
+})(Errors = exports.Errors || (exports.Errors = {}));
+var MessageType;
+(function (MessageType) {
+    MessageType["OPEN"] = "OPEN";
+    MessageType["LEAVE"] = "LEAVE";
+    MessageType["CANDIDATE"] = "CANDIDATE";
+    MessageType["OFFER"] = "OFFER";
+    MessageType["ANSWER"] = "ANSWER";
+    MessageType["EXPIRE"] = "EXPIRE";
+    MessageType["HEARTBEAT"] = "HEARTBEAT";
+    MessageType["ID_TAKEN"] = "ID-TAKEN";
+    MessageType["ERROR"] = "ERROR";
+})(MessageType = exports.MessageType || (exports.MessageType = {}));

dist/src/index.js

@@ -0,0 +1,106 @@
+"use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+const express_1 = __importDefault(require("express"));
+const http_1 = __importDefault(require("http"));
+const https_1 = __importDefault(require("https"));
+const config_1 = __importDefault(require("../config"));
+const api_1 = require("./api");
+const messageHandler_1 = require("./messageHandler");
+const realm_1 = require("./models/realm");
+const checkBrokenConnections_1 = require("./services/checkBrokenConnections");
+const messagesExpire_1 = require("./services/messagesExpire");
+const webSocketServer_1 = require("./services/webSocketServer");
+const init = ({ app, server, options }) => {
+    const config = options;
+    const realm = new realm_1.Realm();
+    const messageHandler = new messageHandler_1.MessageHandler(realm);
+    const api = api_1.Api({ config, realm, messageHandler });
+    const messagesExpire = new messagesExpire_1.MessagesExpire({ realm, config, messageHandler });
+    const checkBrokenConnections = new checkBrokenConnections_1.CheckBrokenConnections({
+        realm,
+        config,
+        onClose: (client) => {
+            app.emit("disconnect", client);
+        }
+    });
+    app.use(options.path, api);
+    const wss = new webSocketServer_1.WebSocketServer({
+        server,
+        realm,
+        config: Object.assign({}, config)
+    });
+    wss.on("connection", (client) => {
+        const messageQueue = realm.getMessageQueueById(client.getId());
+        if (messageQueue) {
+            let message;
+            // tslint:disable
+            while (message = messageQueue.readMessage()) {
+                messageHandler.handle(client, message);
+            }
+            realm.clearMessageQueue(client.getId());
+        }
+        app.emit("connection", client);
+    });
+    wss.on("message", (client, message) => {
+        app.emit("message", client, message);
+        messageHandler.handle(client, message);
+    });
+    wss.on("close", (client) => {
+        app.emit("disconnect", client);
+    });
+    wss.on("error", (error) => {
+        app.emit("error", error);
+    });
+    messagesExpire.startMessagesExpiration();
+    checkBrokenConnections.start();
+};
+function ExpressPeerServer(server, options) {
+    const app = express_1.default();
+    const newOptions = Object.assign({}, config_1.default, options);
+    if (newOptions.proxied) {
+        app.set("trust proxy", newOptions.proxied === "false" ? false : !!newOptions.proxied);
+    }
+    app.on("mount", () => {
+        if (!server) {
+            throw new Error("Server is not passed to constructor - " +
+                "can't start PeerServer");
+        }
+        init({ app, server, options: newOptions });
+    });
+    return app;
+}
+exports.ExpressPeerServer = ExpressPeerServer;
+function PeerServer(options = {}, callback) {
+    const app = express_1.default();
+    const newOptions = Object.assign({}, config_1.default, options);
+    let path = newOptions.path;
+    const port = newOptions.port;
+    if (path[0] !== "/") {
+        path = "/" + path;
+    }
+    if (path[path.length - 1] !== "/") {
+        path += "/";
+    }
+    let server;
+    if (newOptions.ssl && newOptions.ssl.key && newOptions.ssl.cert) {
+        server = https_1.default.createServer(options.ssl, app);
+        // @ts-ignore
+        delete newOptions.ssl;
+    }
+    else {
+        server = http_1.default.createServer(app);
+    }
+    const peerjs = ExpressPeerServer(server, newOptions);
+    app.use(peerjs);
+    if (callback) {
+        server.listen(port, () => callback(server));
+    }
+    else {
+        server.listen(port);
+    }
+    return peerjs;
+}
+exports.PeerServer = PeerServer;

dist/src/messageHandler/handler.js

@@ -0,0 +1,2 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });

dist/src/messageHandler/handlers/heartbeat/index.js

@@ -0,0 +1,8 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+function default_1(client) {
+    const nowTime = new Date().getTime();
+    client.setLastPing(nowTime);
+    return true;
+}
+exports.default = default_1;

dist/src/messageHandler/handlers/transmission/index.js

@@ -0,0 +1,57 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+const enums_1 = require("../../../enums");
+function default_1({ realm }) {
+    const handle = (client, message) => {
+        const type = message.type;
+        const srcId = message.src;
+        const dstId = message.dst;
+        const destinationClient = realm.getClientById(dstId);
+        // User is connected!
+        if (destinationClient) {
+            try {
+                if (destinationClient.getSocket()) {
+                    const data = JSON.stringify(message);
+                    destinationClient.getSocket().send(data);
+                }
+                else {
+                    // Neither socket no res available. Peer dead?
+                    throw new Error("Peer dead");
+                }
+            }
+            catch (e) {
+                // This happens when a peer disconnects without closing connections and
+                // the associated WebSocket has not closed.
+                // Tell other side to stop trying.
+                if (destinationClient.getSocket()) {
+                    destinationClient.getSocket().close();
+                }
+                else {
+                    realm.removeClientById(destinationClient.getId());
+                }
+                handle(client, {
+                    type: enums_1.MessageType.LEAVE,
+                    src: dstId,
+                    dst: srcId
+                });
+            }
+        }
+        else {
+            // Wait for this client to connect/reconnect (XHR) for important
+            // messages.
+            if (type !== enums_1.MessageType.LEAVE && type !== enums_1.MessageType.EXPIRE && dstId) {
+                realm.addMessageToQueue(dstId, message);
+            }
+            else if (type === enums_1.MessageType.LEAVE && !dstId) {
+                realm.removeClientById(srcId);
+            }
+            else {
+                // Unavailable destination specified with message LEAVE or EXPIRE
+                // Ignore
+            }
+        }
+        return true;
+    };
+    return handle;
+}
+exports.default = default_1;

dist/src/messageHandler/index.js

@@ -0,0 +1,35 @@
+"use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+const enums_1 = require("../enums");
+const heartbeat_1 = __importDefault(require("./handlers/heartbeat"));
+const transmission_1 = __importDefault(require("./handlers/transmission"));
+const messageHandlers_1 = require("./messageHandlers");
+class MessageHandler {
+    constructor(realm) {
+        this.messageHandlers = new messageHandlers_1.MessageHandlers();
+        const transmissionHandler = transmission_1.default({ realm });
+        const heartbeatHandler = heartbeat_1.default;
+        const handleTransmission = (client, message) => {
+            return transmissionHandler(client, {
+                type: message.type,
+                src: message.src,
+                dst: message.dst,
+                payload: message.payload
+            });
+        };
+        const handleHeartbeat = (client, message) => heartbeatHandler(client, message);
+        this.messageHandlers.registerHandler(enums_1.MessageType.HEARTBEAT, handleHeartbeat);
+        this.messageHandlers.registerHandler(enums_1.MessageType.OFFER, handleTransmission);
+        this.messageHandlers.registerHandler(enums_1.MessageType.ANSWER, handleTransmission);
+        this.messageHandlers.registerHandler(enums_1.MessageType.CANDIDATE, handleTransmission);
+        this.messageHandlers.registerHandler(enums_1.MessageType.LEAVE, handleTransmission);
+        this.messageHandlers.registerHandler(enums_1.MessageType.EXPIRE, handleTransmission);
+    }
+    handle(client, message) {
+        return this.messageHandlers.handle(client, message);
+    }
+}
+exports.MessageHandler = MessageHandler;

dist/src/messageHandler/messageHandlers.js

@@ -0,0 +1,22 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+class MessageHandlers {
+    constructor() {
+        this.handlers = new Map();
+    }
+    registerHandler(messageType, handler) {
+        if (this.handlers.has(messageType)) {
+            return;
+        }
+        this.handlers.set(messageType, handler);
+    }
+    handle(client, message) {
+        const { type } = message;
+        const handler = this.handlers.get(type);
+        if (!handler) {
+            return false;
+        }
+        return handler(client, message);
+    }
+}
+exports.MessageHandlers = MessageHandlers;

dist/src/models/client.js

@@ -0,0 +1,32 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+class Client {
+    constructor({ id, token }) {
+        this.socket = null;
+        this.lastPing = new Date().getTime();
+        this.id = id;
+        this.token = token;
+    }
+    getId() {
+        return this.id;
+    }
+    getToken() {
+        return this.token;
+    }
+    getSocket() {
+        return this.socket;
+    }
+    setSocket(socket) {
+        this.socket = socket;
+    }
+    getLastPing() {
+        return this.lastPing;
+    }
+    setLastPing(lastPing) {
+        this.lastPing = lastPing;
+    }
+    send(data) {
+        this.socket.send(JSON.stringify(data));
+    }
+}
+exports.Client = Client;

dist/src/models/message.js

@@ -0,0 +1,2 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });

dist/src/models/messageQueue.js

@@ -0,0 +1,25 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+class MessageQueue {
+    constructor() {
+        this.lastReadAt = new Date().getTime();
+        this.messages = [];
+    }
+    getLastReadAt() {
+        return this.lastReadAt;
+    }
+    addMessage(message) {
+        this.messages.push(message);
+    }
+    readMessage() {
+        if (this.messages.length > 0) {
+            this.lastReadAt = new Date().getTime();
+            return this.messages.shift();
+        }
+        return null;
+    }
+    getMessages() {
+        return this.messages;
+    }
+}
+exports.MessageQueue = MessageQueue;

dist/src/models/realm.js

@@ -0,0 +1,50 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+const messageQueue_1 = require("./messageQueue");
+class Realm {
+    constructor() {
+        this.clients = new Map();
+        this.messageQueues = new Map();
+    }
+    getClientsIds() {
+        return [...this.clients.keys()];
+    }
+    getClientById(clientId) {
+        return this.clients.get(clientId);
+    }
+    getClientsIdsWithQueue() {
+        return [...this.messageQueues.keys()];
+    }
+    setClient(client, id) {
+        this.clients.set(id, client);
+    }
+    removeClientById(id) {
+        const client = this.getClientById(id);
+        if (!client) {
+            return false;
+        }
+        this.clients.delete(id);
+        return true;
+    }
+    getMessageQueueById(id) {
+        return this.messageQueues.get(id);
+    }
+    addMessageToQueue(id, message) {
+        if (!this.getMessageQueueById(id)) {
+            this.messageQueues.set(id, new messageQueue_1.MessageQueue());
+        }
+        this.getMessageQueueById(id).addMessage(message);
+    }
+    clearMessageQueue(id) {
+        this.messageQueues.delete(id);
+    }
+    generateClientId() {
+        const randomId = () => (Math.random().toString(36) + "0000000000000000000").substr(2, 16);
+        let clientId = randomId();
+        while (this.getClientById(clientId)) {
+            clientId = randomId();
+        }
+        return clientId;
+    }
+}
+exports.Realm = Realm;

dist/src/services/checkBrokenConnections/index.js

@@ -0,0 +1,56 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+const DEFAULT_CHECK_INTERVAL = 300;
+class CheckBrokenConnections {
+    constructor({ realm, config, checkInterval = DEFAULT_CHECK_INTERVAL, onClose }) {
+        this.realm = realm;
+        this.config = config;
+        this.onClose = onClose;
+        this.checkInterval = checkInterval;
+    }
+    start() {
+        if (this.timeoutId) {
+            clearTimeout(this.timeoutId);
+        }
+        this.timeoutId = setTimeout(() => {
+            this.checkConnections();
+            this.timeoutId = null;
+            this.start();
+        }, this.checkInterval);
+    }
+    stop() {
+        if (this.timeoutId) {
+            clearTimeout(this.timeoutId);
+            this.timeoutId = null;
+        }
+    }
+    checkConnections() {
+        const clientsIds = this.realm.getClientsIds();
+        const now = new Date().getTime();
+        const aliveTimeout = this.config.alive_timeout;
+        for (const clientId of clientsIds) {
+            const client = this.realm.getClientById(clientId);
+            const timeSinceLastPing = now - client.getLastPing();
+            if (timeSinceLastPing < aliveTimeout) {
+                continue;
+            }
+            try {
+                if (client.getSocket()) {
+                    client.getSocket().close();
+                }
+            }
+            catch (e) {
+                // @ts-nocheck
+            }
+            finally {
+                this.realm.clearMessageQueue(clientId);
+                this.realm.removeClientById(clientId);
+                client.setSocket(null);
+                if (this.onClose) {
+                    this.onClose(client);
+                }
+            }
+        }
+    }
+}
+exports.CheckBrokenConnections = CheckBrokenConnections;

dist/src/services/messagesExpire/index.js

@@ -0,0 +1,54 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+const enums_1 = require("../../enums");
+class MessagesExpire {
+    constructor({ realm, config, messageHandler }) {
+        this.timeoutId = null;
+        this.realm = realm;
+        this.config = config;
+        this.messageHandler = messageHandler;
+    }
+    startMessagesExpiration() {
+        if (this.timeoutId) {
+            clearTimeout(this.timeoutId);
+        }
+        // Clean up outstanding messages
+        this.timeoutId = setTimeout(() => {
+            this.pruneOutstanding();
+            this.timeoutId = null;
+            this.startMessagesExpiration();
+        }, this.config.cleanup_out_msgs);
+    }
+    stopMessagesExpiration() {
+        if (this.timeoutId) {
+            clearTimeout(this.timeoutId);
+            this.timeoutId = null;
+        }
+    }
+    pruneOutstanding() {
+        const destinationClientsIds = this.realm.getClientsIdsWithQueue();
+        const now = new Date().getTime();
+        const maxDiff = this.config.expire_timeout;
+        const seen = {};
+        for (const destinationClientId of destinationClientsIds) {
+            const messageQueue = this.realm.getMessageQueueById(destinationClientId);
+            const lastReadDiff = now - messageQueue.getLastReadAt();
+            if (lastReadDiff < maxDiff) {
+                continue;
+            }
+            const messages = messageQueue.getMessages();
+            for (const message of messages) {
+                if (!seen[message.src]) {
+                    this.messageHandler.handle(null, {
+                        type: enums_1.MessageType.EXPIRE,
+                        src: message.dst,
+                        dst: message.src
+                    });
+                    seen[message.src] = true;
+                }
+            }
+            this.realm.clearMessageQueue(destinationClientId);
+        }
+    }
+}
+exports.MessagesExpire = MessagesExpire;

dist/src/services/webSocketServer/index.js

@@ -0,0 +1,91 @@
+"use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+const events_1 = __importDefault(require("events"));
+const url_1 = __importDefault(require("url"));
+const ws_1 = __importDefault(require("ws"));
+const enums_1 = require("../../enums");
+const client_1 = require("../../models/client");
+class WebSocketServer extends events_1.default {
+    constructor({ server, realm, config }) {
+        super();
+        this.setMaxListeners(0);
+        this.realm = realm;
+        this.config = config;
+        const path = this.config.path;
+        this.path = path + (path[path.length - 1] !== "/" ? "/" : "") + "peerjs";
+        this.webSocketServer = new ws_1.default.Server({ path, server });
+        this.webSocketServer.on("connection", (socket, req) => this._onSocketConnection(socket, req));
+        this.webSocketServer.on("error", (error) => this._onSocketError(error));
+    }
+    _onSocketConnection(socket, req) {
+        const { query = {} } = url_1.default.parse(req.url, true);
+        const { id, token, key } = query;
+        if (!id || !token || !key) {
+            return this._sendErrorAndClose(socket, enums_1.Errors.INVALID_WS_PARAMETERS);
+        }
+        if (key !== this.config.key) {
+            return this._sendErrorAndClose(socket, enums_1.Errors.INVALID_KEY);
+        }
+        const client = this.realm.getClientById(id);
+        if (client) {
+            if (token !== client.getToken()) {
+                // ID-taken, invalid token
+                socket.send(JSON.stringify({
+                    type: enums_1.MessageType.ID_TAKEN,
+                    payload: { msg: "ID is taken" }
+                }));
+                return socket.close();
+            }
+            return this._configureWS(socket, client);
+        }
+        this._registerClient({ socket, id, token });
+    }
+    _onSocketError(error) {
+        // handle error
+        this.emit("error", error);
+    }
+    _registerClient({ socket, id, token }) {
+        // Check concurrent limit
+        const clientsCount = this.realm.getClientsIds().length;
+        if (clientsCount >= this.config.concurrent_limit) {
+            return this._sendErrorAndClose(socket, enums_1.Errors.CONNECTION_LIMIT_EXCEED);
+        }
+        const newClient = new client_1.Client({ id, token });
+        this.realm.setClient(newClient, id);
+        socket.send(JSON.stringify({ type: enums_1.MessageType.OPEN }));
+        this._configureWS(socket, newClient);
+    }
+    _configureWS(socket, client) {
+        client.setSocket(socket);
+        // Cleanup after a socket closes.
+        socket.on("close", () => {
+            if (client.getSocket() === socket) {
+                this.realm.removeClientById(client.getId());
+                this.emit("close", client);
+            }
+        });
+        // Handle messages from peers.
+        socket.on("message", (data) => {
+            try {
+                const message = JSON.parse(data);
+                message.src = client.getId();
+                this.emit("message", client, message);
+            }
+            catch (e) {
+                this.emit("error", e);
+            }
+        });
+        this.emit("connection", client);
+    }
+    _sendErrorAndClose(socket, msg) {
+        socket.send(JSON.stringify({
+            type: enums_1.MessageType.ERROR,
+            payload: { msg }
+        }));
+        socket.close();
+    }
+}
+exports.WebSocketServer = WebSocketServer;

dist/src/services/webSocketServer/webSocket.js

@@ -0,0 +1,2 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });

package.json

@@ -2,7 +2,7 @@
   "name": "peer",
   "version": "0.3.0",
   "description": "PeerJS server component",
-  "main": "src/index.js",
+  "main": "dist/peerjs.server.min.js",
   "bin": {
     "peerjs": "./bin/peerjs"
   },
@@ -13,10 +13,23 @@
   "author": "Michelle Bu, Eric Zhang",
   "license": "MIT",
   "scripts": {
-    "test": "eslint . && mocha \"test/**/*.js\"",
-    "start": "bin/peerjs --port ${PORT:=9000}"
+    "build": "tsc",
+    "clean": "rimraf ./dist",
+    "lint": "tslint -c tslint.json -p tsconfig.json --fix",
+    "tsc": "tsc",
+    "prebuild": "npm run lint",
+    "test": "npm run lint && mocha \"test/**/*.js\"",
+    "start": "bin/peerjs --port ${PORT:=9000}",
+    "dev:start": "npm-run-all build start",
+    "dev": "nodemon --watch src -e ts --exec npm run dev:start"
+  },
+  "release": {
+    "branch": "master"
   },
   "dependencies": {
+    "@types/cors": "^2.8.6",
+    "@types/express": "^4.17.1",
+    "@types/ws": "^6.0.2",
     "body-parser": "^1.19.0",
     "cors": "~2.8.4",
     "express": "^4.17.1",
@@ -24,13 +37,20 @@
     "ws": "^7.1.2"
   },
   "devDependencies": {
+    "@types/chai": "^4.1.7",
+    "@types/mocha": "^5.2.7",
+    "@types/node": "^10.14.16",
     "chai": "^4.2.0",
-    "eslint": "^6.2.1",
     "mocha": "^6.2.0",
-    "semistandard": "^14.0.1",
-    "sinon": "^7.4.1"
+    "nodemon": "^1.19.1",
+    "npm-run-all": "^4.1.5",
+    "rimraf": "^3.0.0",
+    "sinon": "^7.4.1",
+    "ts-node": "^8.3.0",
+    "tslint": "^5.19.0",
+    "typescript": "^3.5.3"
   },
   "engines": {
     "node": "^10"
   }
-}
+}

src/api/index.js

@@ -1,23 +0,0 @@
-const express = require('express');
-const cors = require('cors');
-const bodyParser = require('body-parser');
-const publicContent = require('../../app.json');
-
-module.exports = ({ config, realm, messageHandler }) => {
-  const authMiddleware = require('./middleware/auth')({ config, realm });
-
-  const app = express.Router();
-
-  const jsonParser = bodyParser.json();
-
-  app.use(cors());
-
-  app.get('/', (req, res) => {
-    res.send(publicContent);
-  });
-
-  app.use('/:key', require('./v1/public')({ config, realm }));
-  app.use('/:key/:id/:token', authMiddleware, jsonParser, require('./v1/calls')({ realm, messageHandler }));
-
-  return app;
-};

src/api/index.ts

@@ -0,0 +1,33 @@
+import bodyParser from "body-parser";
+import cors from "cors";
+import express from "express";
+import publicContent from "../../app.json";
+import { IConfig } from "../../config/";
+import { IMessageHandler } from "../messageHandler";
+import { IRealm } from "../models/realm";
+import { AuthMiddleware } from "./middleware/auth";
+import CallsApi from "./v1/calls";
+import PublicApi from "./v1/public";
+
+export const Api = ({ config, realm, messageHandler }: {
+  config: IConfig,
+  realm: IRealm,
+  messageHandler: IMessageHandler
+}): express.Router => {
+  const authMiddleware = new AuthMiddleware(config, realm);
+
+  const app = express.Router();
+
+  const jsonParser = bodyParser.json();
+
+  app.use(cors());
+
+  app.get("/", (_, res) => {
+    res.send(publicContent);
+  });
+
+  app.use("/:key", PublicApi({ config, realm }));
+  app.use("/:key/:id/:token", authMiddleware.handle, jsonParser, CallsApi({ realm, messageHandler }));
+
+  return app;
+};

src/api/middleware/auth/index.js

@@ -1,25 +0,0 @@
-const { Errors } = require('../../../enums');
-
-module.exports = ({ config, realm }) => (req, res, next) => {
-  const { id, token, key } = req.params;
-
-  if (key !== config.key) {
-    return res.status(401).send(Errors.INVALID_KEY);
-  }
-
-  if (!id) {
-    return res.sendStatus(401);
-  }
-
-  const client = realm.getClientById(id);
-
-  if (!client) {
-    return res.sendStatus(401);
-  }
-
-  if (client.getToken() && token !== client.getToken()) {
-    return res.status(401).send(Errors.INVALID_TOKEN);
-  }
-
-  next();
-};

src/api/middleware/auth/index.ts

@@ -0,0 +1,35 @@
+import express from "express";
+import { IConfig } from "../../../../config";
+import { Errors } from "../../../enums";
+import { IRealm } from "../../../models/realm";
+import { IMiddleware } from "../middleware";
+
+export class AuthMiddleware implements IMiddleware {
+
+  constructor(private readonly config: IConfig, private readonly realm: IRealm) { }
+
+  public handle(req: express.Request, res: express.Response, next: express.NextFunction): any {
+    const { id, token, key } = req.params;
+
+    if (key !== this.config.key) {
+      return res.status(401).send(Errors.INVALID_KEY);
+    }
+
+    if (!id) {
+      return res.sendStatus(401);
+    }
+
+    const client = this.realm.getClientById(id);
+
+    if (!client) {
+      return res.sendStatus(401);
+    }
+
+    if (client.getToken() && token !== client.getToken()) {
+      return res.status(401).send(Errors.INVALID_TOKEN);
+    }
+
+    next();
+  }
+
+}

src/api/middleware/middleware.ts

@@ -0,0 +1,5 @@
+import express from "express";
+
+export interface IMiddleware {
+    handle(req: express.Request, res: express.Response, next: express.NextFunction): any;
+}

src/api/v1/calls/index.js

@@ -1,36 +0,0 @@
-const express = require('express');
-
-module.exports = ({ realm, messageHandler }) => {
-  const app = express.Router();
-
-  const handle = (req, res, next) => {
-    const { id } = req.params;
-
-    if (!id) return next();
-
-    const client = realm.getClientById(id);
-
-    const { type, dst, payload } = req.body;
-
-    const message = {
-      type,
-      src: id,
-      dst,
-      payload
-    };
-
-    messageHandler(client, message);
-
-    res.sendStatus(200);
-  };
-
-  app.post('/offer', handle);
-
-  app.post('/candidate', handle);
-
-  app.post('/answer', handle);
-
-  app.post('/leave', handle);
-
-  return app;
-};

src/api/v1/calls/index.ts

@@ -0,0 +1,36 @@
+import express from "express";
+import { IMessageHandler } from "../../../messageHandler";
+import { IMessage } from "../../../models/message";
+import { IRealm } from "../../../models/realm";
+
+export default ({ realm, messageHandler }: { realm: IRealm, messageHandler: IMessageHandler }): express.Router => {
+  const app = express.Router();
+
+  const handle = (req: express.Request, res: express.Response, next: express.NextFunction): any => {
+    const { id } = req.params;
+
+    if (!id) { return next(); }
+
+    const client = realm.getClientById(id);
+
+    const { type, dst, payload } = req.body;
+
+    const message: IMessage = {
+      type,
+      src: id,
+      dst,
+      payload
+    };
+
+    messageHandler.handle(client, message);
+
+    res.sendStatus(200);
+  };
+
+  app.post("/offer", handle);
+  app.post("/candidate", handle);
+  app.post("/answer", handle);
+  app.post("/leave", handle);
+
+  return app;
+};

src/api/v1/public/index.js → src/api/v1/public/index.ts

@@ -1,16 +1,20 @@
-const express = require('express');
+import express from "express";
+import { IConfig } from "../../../../config";
+import { IRealm } from "../../../models/realm";
 
-module.exports = ({ config, realm }) => {
+export default ({ config, realm }: {
+  config: IConfig, realm: IRealm
+}): express.Router => {
   const app = express.Router();
 
   // Retrieve guaranteed random ID.
-  app.get('/id', (req, res) => {
-    res.contentType = 'text/html';
+  app.get("/id", (_, res: express.Response) => {
+    res.contentType("html");
     res.send(realm.generateClientId());
   });
 
   // Get a list of all peers for a key, enabled by the `allowDiscovery` flag.
-  app.get('/peers', (req, res) => {
+  app.get("/peers", (_, res: express.Response) => {
     if (config.allow_discovery) {
       const clientsIds = realm.getClientsIds();
 

src/enums.js

@@ -1,18 +0,0 @@
-module.exports.Errors = {
-  INVALID_KEY: 'Invalid key provided',
-  INVALID_TOKEN: 'Invalid token provided',
-  INVALID_WS_PARAMETERS: 'No id, token, or key supplied to websocket server',
-  CONNECTION_LIMIT_EXCEED: 'Server has reached its concurrent user limit'
-};
-
-module.exports.MessageType = {
-  OPEN: 'OPEN',
-  LEAVE: 'LEAVE',
-  CANDIDATE: 'CANDIDATE',
-  OFFER: 'OFFER',
-  ANSWER: 'ANSWER',
-  EXPIRE: 'EXPIRE',
-  HEARTBEAT: 'HEARTBEAT',
-  ID_TAKEN: 'ID-TAKEN',
-  ERROR: 'ERROR'
-};

src/enums.ts

@@ -0,0 +1,18 @@
+export enum Errors {
+  INVALID_KEY = "Invalid key provided",
+  INVALID_TOKEN = "Invalid token provided",
+  INVALID_WS_PARAMETERS = "No id, token, or key supplied to websocket server",
+  CONNECTION_LIMIT_EXCEED = "Server has reached its concurrent user limit"
+}
+
+export enum MessageType {
+  OPEN = "OPEN",
+  LEAVE = "LEAVE",
+  CANDIDATE = "CANDIDATE",
+  OFFER = "OFFER",
+  ANSWER = "ANSWER",
+  EXPIRE = "EXPIRE",
+  HEARTBEAT = "HEARTBEAT",
+  ID_TAKEN = "ID-TAKEN",
+  ERROR = "ERROR"
+}

src/index.js

@@ -1,134 +0,0 @@
-const express = require('express');
-const http = require('http');
-const https = require('https');
-
-const defaultConfig = require('../config');
-const WebSocketServer = require('./services/webSocketServer');
-const Realm = require('./models/realm');
-
-const init = ({ app, server, options }) => {
-  const config = options;
-  const realm = new Realm();
-  const messageHandler = require('./messageHandler')({ realm });
-  const api = require('./api')({ config, realm, messageHandler });
-
-  const { startMessagesExpiration } = require('./services/messagesExpire')({ realm, config, messageHandler });
-  const checkBrokenConnections = require('./services/checkBrokenConnections')({
-    realm, config, onClose: (client) => {
-      app.emit('disconnect', client);
-    }
-  });
-
-  app.use(options.path, api);
-
-  const wss = new WebSocketServer({
-    server,
-    realm,
-    config: {
-      ...config,
-    }
-  });
-
-  wss.on('connection', client => {
-    const messageQueue = realm.getMessageQueueById(client.getId());
-
-    if (messageQueue) {
-      let message;
-      // eslint-disable-next-line no-cond-assign
-      while (message = messageQueue.readMessage()) {
-        messageHandler(client, message);
-      }
-      realm.clearMessageQueue(client.getId());
-    }
-
-    app.emit('connection', client);
-  });
-
-  wss.on('message', (client, message) => {
-    app.emit('message', client, message);
-    messageHandler(client, message);
-  });
-
-  wss.on('close', client => {
-    app.emit('disconnect', client);
-  });
-
-  wss.on('error', error => {
-    app.emit('error', error);
-  });
-
-  startMessagesExpiration();
-
-  checkBrokenConnections.start();
-};
-
-function ExpressPeerServer(server, options) {
-  const app = express();
-
-  options = {
-    ...defaultConfig,
-    ...options
-  };
-
-  if (options.proxied) {
-    app.set('trust proxy', options.proxied === 'false' ? false : options.proxied);
-  }
-
-  app.on('mount', () => {
-    if (!server) {
-      throw new Error('Server is not passed to constructor - ' +
-        'can\'t start PeerServer');
-    }
-
-    init({ app, server, options });
-  });
-
-  return app;
-}
-
-function PeerServer(options = {}, callback) {
-  const app = express();
-
-  options = {
-    ...defaultConfig,
-    ...options
-  };
-
-  let path = options.path;
-  const port = options.port;
-
-  if (path[0] !== '/') {
-    path = '/' + path;
-  }
-
-  if (path[path.length - 1] !== '/') {
-    path += '/';
-  }
-
-  let server;
-
-  if (options.ssl && options.ssl.key && options.ssl.cert) {
-    server = https.createServer(options.ssl, app);
-    delete options.ssl;
-  } else {
-    server = http.createServer(app);
-  }
-
-  const peerjs = ExpressPeerServer(server, options);
-  app.use(peerjs);
-
-  if (callback) {
-    server.listen(port, () => {
-      callback(server);
-    });
-  } else {
-    server.listen(port);
-  }
-
-  return peerjs;
-}
-
-exports = module.exports = {
-  ExpressPeerServer: ExpressPeerServer,
-  PeerServer: PeerServer
-};

src/index.ts

@@ -0,0 +1,152 @@
+import { IRealm } from "./models/realm";
+
+import express from "express";
+import http from "http";
+import https from "https";
+
+import { Server } from "net";
+import defaultConfig, { IConfig } from "../config";
+import { Api } from "./api";
+import { MessageHandler } from "./messageHandler";
+import { IClient } from "./models/client";
+import { IMessage } from "./models/message";
+import { Realm } from "./models/realm";
+import { CheckBrokenConnections } from "./services/checkBrokenConnections";
+import { IMessagesExpire, MessagesExpire } from "./services/messagesExpire";
+import { IWebSocketServer, WebSocketServer } from "./services/webSocketServer";
+
+const init = ({ app, server, options }: {
+  app: express.Express,
+  server: Server,
+  options: IConfig
+}) => {
+  const config = options;
+  const realm: IRealm = new Realm();
+  const messageHandler = new MessageHandler(realm);
+  const api = Api({ config, realm, messageHandler });
+
+  const messagesExpire: IMessagesExpire = new MessagesExpire({ realm, config, messageHandler });
+  const checkBrokenConnections = new CheckBrokenConnections({
+    realm,
+    config,
+    onClose: (client: IClient) => {
+      app.emit("disconnect", client);
+    }
+  });
+
+  app.use(options.path, api);
+
+  const wss: IWebSocketServer = new WebSocketServer({
+    server,
+    realm,
+    config: {
+      ...config,
+    }
+  });
+
+  wss.on("connection", (client: IClient) => {
+    const messageQueue = realm.getMessageQueueById(client.getId());
+
+    if (messageQueue) {
+      let message: IMessage | null;
+
+      // tslint:disable
+      while (message = messageQueue.readMessage()) {
+        messageHandler.handle(client, message);
+      }
+      realm.clearMessageQueue(client.getId());
+    }
+
+    app.emit("connection", client);
+  });
+
+  wss.on("message", (client: IClient, message: IMessage) => {
+    app.emit("message", client, message);
+    messageHandler.handle(client, message);
+  });
+
+  wss.on("close", (client: IClient) => {
+    app.emit("disconnect", client);
+  });
+
+  wss.on("error", (error: Error) => {
+    app.emit("error", error);
+  });
+
+  messagesExpire.startMessagesExpiration();
+  checkBrokenConnections.start();
+};
+
+function ExpressPeerServer(server: Server, options?: IConfig) {
+  const app = express();
+
+  const newOptions: IConfig = {
+    ...defaultConfig,
+    ...options
+  };
+
+  if (newOptions.proxied) {
+    app.set("trust proxy", newOptions.proxied === "false" ? false : !!newOptions.proxied);
+  }
+
+  app.on("mount", () => {
+    if (!server) {
+      throw new Error("Server is not passed to constructor - " +
+        "can't start PeerServer");
+    }
+
+    init({ app, server, options: newOptions });
+  });
+
+  return app;
+}
+
+type Optional<T> = {
+  [P in keyof T]?: (T[P] | undefined);
+};
+
+function PeerServer(options: Optional<IConfig> = {}, callback?: (server: Server) => void) {
+  const app = express();
+
+  const newOptions: IConfig = {
+    ...defaultConfig,
+    ...options
+  };
+
+  let path = newOptions.path;
+  const port = newOptions.port;
+
+  if (path[0] !== "/") {
+    path = "/" + path;
+  }
+
+  if (path[path.length - 1] !== "/") {
+    path += "/";
+  }
+
+  let server: Server;
+
+  if (newOptions.ssl && newOptions.ssl.key && newOptions.ssl.cert) {
+    server = https.createServer(options.ssl, app);
+    // @ts-ignore
+    delete newOptions.ssl;
+  } else {
+    server = http.createServer(app);
+  }
+
+  const peerjs = ExpressPeerServer(server, newOptions);
+  app.use(peerjs);
+
+  if (callback) {
+    server.listen(port, () => callback(server));
+  } else {
+    server.listen(port);
+  }
+
+  return peerjs;
+}
+
+export {
+  ExpressPeerServer,
+  PeerServer
+};

src/messageHandler/handler.ts

@@ -0,0 +1,4 @@
+import { IClient } from "../models/client";
+import { IMessage } from "../models/message";
+
+export type Handler = (client: IClient, message: IMessage) => boolean;

src/messageHandler/handlers/heartbeat/index.js

@@ -1,4 +0,0 @@
-module.exports = (client) => {
-  const nowTime = new Date().getTime();
-  client.setLastPing(nowTime);
-};

src/messageHandler/handlers/heartbeat/index.ts

@@ -0,0 +1,7 @@
+import { IClient } from "../../../models/client";
+
+export default function(client: IClient): boolean {
+  const nowTime = new Date().getTime();
+  client.setLastPing(nowTime);
+  return true;
+}

src/messageHandler/handlers/transmission/index.js

@@ -1,49 +0,0 @@
-const { MessageType } = require('../../../enums');
-
-module.exports = ({ realm }) => (client, message) => {
-  const type = message.type;
-  const srcId = message.src;
-  const dstId = message.dst;
-
-  const destinationClient = realm.getClientById(dstId);
-
-  // User is connected!
-  if (destinationClient) {
-    try {
-      if (destinationClient.socket) {
-        const data = JSON.stringify(message);
-
-        destinationClient.socket.send(data);
-      } else {
-        // Neither socket no res available. Peer dead?
-        throw new Error('Peer dead');
-      }
-    } catch (e) {
-      // This happens when a peer disconnects without closing connections and
-      // the associated WebSocket has not closed.
-      // Tell other side to stop trying.
-      if (destinationClient.socket) {
-        destinationClient.socket.close();
-      } else {
-        realm.removeClientById(destinationClient.getId());
-      }
-
-      module.exports({ realm })(client, {
-        type: MessageType.LEAVE,
-        src: dstId,
-        dst: srcId
-      });
-    }
-  } else {
-    // Wait for this client to connect/reconnect (XHR) for important
-    // messages.
-    if (type !== MessageType.LEAVE && type !== MessageType.EXPIRE && dstId) {
-      realm.addMessageToQueue(dstId, message);
-    } else if (type === MessageType.LEAVE && !dstId) {
-      realm.removeClientById(srcId);
-    } else {
-      // Unavailable destination specified with message LEAVE or EXPIRE
-      // Ignore
-    }
-  }
-};

src/messageHandler/handlers/transmission/index.ts

@@ -0,0 +1,58 @@
+import { MessageType } from "../../../enums";
+import { IClient } from "../../../models/client";
+import { IMessage } from "../../../models/message";
+import { IRealm } from "../../../models/realm";
+
+export default function({ realm }: { realm: IRealm }): (client: IClient, message: IMessage) => boolean {
+  const handle = (client: IClient, message: IMessage) => {
+    const type = message.type;
+    const srcId = message.src;
+    const dstId = message.dst;
+
+    const destinationClient = realm.getClientById(dstId);
+
+    // User is connected!
+    if (destinationClient) {
+      try {
+        if (destinationClient.getSocket()) {
+          const data = JSON.stringify(message);
+
+          destinationClient.getSocket().send(data);
+        } else {
+          // Neither socket no res available. Peer dead?
+          throw new Error("Peer dead");
+        }
+      } catch (e) {
+        // This happens when a peer disconnects without closing connections and
+        // the associated WebSocket has not closed.
+        // Tell other side to stop trying.
+        if (destinationClient.getSocket()) {
+          destinationClient.getSocket().close();
+        } else {
+          realm.removeClientById(destinationClient.getId());
+        }
+
+        handle(client, {
+          type: MessageType.LEAVE,
+          src: dstId,
+          dst: srcId
+        });
+      }
+    } else {
+      // Wait for this client to connect/reconnect (XHR) for important
+      // messages.
+      if (type !== MessageType.LEAVE && type !== MessageType.EXPIRE && dstId) {
+        realm.addMessageToQueue(dstId, message);
+      } else if (type === MessageType.LEAVE && !dstId) {
+        realm.removeClientById(srcId);
+      } else {
+        // Unavailable destination specified with message LEAVE or EXPIRE
+        // Ignore
+      }
+    }
+
+    return true;
+  };
+
+  return handle;
+}

src/messageHandler/index.js

@@ -1,49 +0,0 @@
-const { MessageType } = require('../enums');
-
-class MessageHandlers {
-  constructor() {
-    this.handlers = {};
-  }
-
-  registerHandler(messageType, handler) {
-    this.handlers[messageType] = handler;
-  }
-
-  handle(client, message) {
-    const { type } = message;
-
-    const handler = this.handlers[type];
-
-    if (!handler) {
-      return;
-    }
-
-    handler(client, message);
-  }
-}
-module.exports = ({ realm }) => {
-  const transmissionHandler = require('./handlers/transmission')({ realm });
-  const heartbeatHandler = require('./handlers/heartbeat');
-
-  const messageHandlers = new MessageHandlers();
-
-  const handleTransmission = (client, message) => {
-    transmissionHandler(client, {
-      type: message.type,
-      src: message.src,
-      dst: message.dst,
-      payload: message.payload
-    });
-  };
-
-  const handleHeartbeat = (client) => heartbeatHandler(client);
-
-  messageHandlers.registerHandler(MessageType.HEARTBEAT, handleHeartbeat);
-  messageHandlers.registerHandler(MessageType.OFFER, handleTransmission);
-  messageHandlers.registerHandler(MessageType.ANSWER, handleTransmission);
-  messageHandlers.registerHandler(MessageType.CANDIDATE, handleTransmission);
-  messageHandlers.registerHandler(MessageType.LEAVE, handleTransmission);
-  messageHandlers.registerHandler(MessageType.EXPIRE, handleTransmission);
-
-  return (client, message) => messageHandlers.handle(client, message);
-};

src/messageHandler/index.ts

@@ -0,0 +1,43 @@
+import { MessageType } from "../enums";
+import { IClient } from "../models/client";
+import { IMessage } from "../models/message";
+import { IRealm } from "../models/realm";
+import { Handler } from "./handler";
+import HeartbeatHandler from "./handlers/heartbeat";
+import TransmissionHandler from "./handlers/transmission";
+import { IMessageHandlers, MessageHandlers } from "./messageHandlers";
+
+export interface IMessageHandler {
+  handle(client: IClient, message: IMessage): boolean;
+}
+
+export class MessageHandler implements IMessageHandler {
+  private readonly messageHandlers: IMessageHandlers = new MessageHandlers();
+
+  constructor(realm: IRealm) {
+    const transmissionHandler: Handler = TransmissionHandler({ realm });
+    const heartbeatHandler: Handler = HeartbeatHandler;
+
+    const handleTransmission: Handler = (client: IClient, message: IMessage): boolean => {
+      return transmissionHandler(client, {
+        type: message.type,
+        src: message.src,
+        dst: message.dst,
+        payload: message.payload
+      });
+    };
+
+    const handleHeartbeat = (client: IClient, message: IMessage) => heartbeatHandler(client, message);
+
+    this.messageHandlers.registerHandler(MessageType.HEARTBEAT, handleHeartbeat);
+    this.messageHandlers.registerHandler(MessageType.OFFER, handleTransmission);
+    this.messageHandlers.registerHandler(MessageType.ANSWER, handleTransmission);
+    this.messageHandlers.registerHandler(MessageType.CANDIDATE, handleTransmission);
+    this.messageHandlers.registerHandler(MessageType.LEAVE, handleTransmission);
+    this.messageHandlers.registerHandler(MessageType.EXPIRE, handleTransmission);
+  }
+
+  public handle(client: IClient, message: IMessage): boolean {
+    return this.messageHandlers.handle(client, message);
+  }
+}

src/messageHandler/messageHandlers.ts

@@ -0,0 +1,29 @@
+import { MessageType } from "../enums";
+import { IClient } from "../models/client";
+import { IMessage } from "../models/message";
+import { Handler } from "./handler";
+
+export interface IMessageHandlers {
+    registerHandler(messageType: MessageType, handler: Handler): void;
+    handle(client: IClient, message: IMessage): boolean;
+}
+
+export class MessageHandlers implements IMessageHandlers {
+    private readonly handlers: Map<MessageType, Handler> = new Map();
+
+    public registerHandler(messageType: MessageType, handler: Handler): void {
+        if (this.handlers.has(messageType)) { return; }
+
+        this.handlers.set(messageType, handler);
+    }
+
+    public handle(client: IClient, message: IMessage): boolean {
+        const { type } = message;
+
+        const handler = this.handlers.get(type);
+
+        if (!handler) { return false; }
+
+        return handler(client, message);
+    }
+}

src/models/client.js

@@ -1,38 +0,0 @@
-class Client {
-  constructor({ id, token }) {
-    this.id = id;
-    this.token = token;
-    this.socket = null;
-    this.lastPing = new Date().getTime();
-  }
-
-  getId() {
-    return this.id;
-  }
-
-  getToken() {
-    return this.token;
-  }
-
-  getSocket() {
-    return this.socket;
-  }
-
-  setSocket(socket) {
-    this.socket = socket;
-  }
-
-  getLastPing() {
-    return this.lastPing;
-  }
-
-  setLastPing(lastPing) {
-    this.lastPing = lastPing;
-  }
-
-  send(data) {
-    this.socket.send(JSON.stringify(data));
-  }
-}
-
-module.exports = Client;

src/models/client.ts

@@ -0,0 +1,57 @@
+import { MyWebSocket } from "../services/webSocketServer/webSocket";
+
+export interface IClient {
+  getId(): string;
+
+  getToken(): string;
+
+  getSocket(): MyWebSocket | null;
+
+  setSocket(socket: MyWebSocket): void;
+
+  getLastPing(): number;
+
+  setLastPing(lastPing: number): void;
+
+  send(data: any): void;
+}
+
+export class Client implements IClient {
+  private readonly id: string;
+  private readonly token: string;
+  private socket: MyWebSocket = null;
+  private lastPing: number = new Date().getTime();
+
+  constructor({ id, token }: { id: string, token: string }) {
+    this.id = id;
+    this.token = token;
+  }
+
+  public getId(): string {
+    return this.id;
+  }
+
+  public getToken(): string {
+    return this.token;
+  }
+
+  public getSocket(): MyWebSocket | null {
+    return this.socket;
+  }
+
+  public setSocket(socket: MyWebSocket): void {
+    this.socket = socket;
+  }
+
+  public getLastPing(): number {
+    return this.lastPing;
+  }
+
+  public setLastPing(lastPing: number): void {
+    this.lastPing = lastPing;
+  }
+
+  public send(data: any): void {
+    this.socket.send(JSON.stringify(data));
+  }
+}

src/models/message.ts

@@ -0,0 +1,8 @@
+import { MessageType } from "../enums";
+
+export interface IMessage {
+    readonly type: MessageType;
+    readonly src: string;
+    readonly dst: string;
+    readonly payload?: any;
+}

src/models/messageQueue.js

@@ -1,30 +0,0 @@
-class MessageQueue {
-  constructor (id) {
-    this._id = id;
-    this._lastReadAt = new Date().getTime();
-    this._messages = [];
-  }
-
-  getLastReadAt () {
-    return this._lastReadAt;
-  }
-
-  addMessage (message) {
-    this._messages.push(message);
-  }
-
-  readMessage () {
-    if (this._messages.length > 0) {
-      this._lastReadAt = new Date().getTime();
-      return this._messages.shift();
-    }
-
-    return null;
-  }
-
-  getMessages () {
-    return this._messages;
-  }
-}
-
-module.exports = MessageQueue;

src/models/messageQueue.ts

@@ -0,0 +1,37 @@
+import { IMessage } from "./message";
+
+export interface IMessageQueue {
+  getLastReadAt(): number;
+
+  addMessage(message: IMessage): void;
+
+  readMessage(): IMessage | null;
+
+  getMessages(): IMessage[];
+}
+
+export class MessageQueue implements IMessageQueue {
+  private lastReadAt: number = new Date().getTime();
+  private readonly messages: IMessage[] = [];
+
+  public getLastReadAt(): number {
+    return this.lastReadAt;
+  }
+
+  public addMessage(message: IMessage): void {
+    this.messages.push(message);
+  }
+
+  public readMessage(): IMessage | null {
+    if (this.messages.length > 0) {
+      this.lastReadAt = new Date().getTime();
+      return this.messages.shift();
+    }
+
+    return null;
+  }
+
+  public getMessages(): IMessage[] {
+    return this.messages;
+  }
+}

src/models/realm.js

@@ -1,58 +0,0 @@
-const MessageQueue = require('./messageQueue');
-
-class Realm {
-  constructor () {
-    this._clients = new Map();
-    this._messageQueues = new Map();
-  }
-
-  getClientsIds () {
-    return [...this._clients.keys()];
-  }
-
-  getClientById (clientId) {
-    return this._clients.get(clientId);
-  }
-
-  setClient (client, id) {
-    this._clients.set(id, client);
-  }
-
-  removeClientById (id) {
-    const client = this.getClientById(id);
-
-    if (!client) return false;
-
-    this._clients.delete(id);
-  }
-
-  getMessageQueueById (id) {
-    return this._messageQueues.get(id);
-  }
-
-  addMessageToQueue (id, message) {
-    if (!this.getMessageQueueById(id)) {
-      this._messageQueues.set(id, new MessageQueue(id));
-    }
-
-    this.getMessageQueueById(id).addMessage(message);
-  }
-
-  clearMessageQueue (id) {
-    this._messageQueues.delete(id);
-  }
-
-  generateClientId () {
-    const randomId = () => (Math.random().toString(36) + '0000000000000000000').substr(2, 16);
-
-    let clientId = randomId();
-
-    while (this.getClientById(clientId)) {
-      clientId = randomId();
-    }
-
-    return clientId;
-  }
-}
-
-module.exports = Realm;

src/models/realm.ts

@@ -0,0 +1,82 @@
+import { IClient } from "./client";
+import { IMessage } from "./message";
+import { IMessageQueue, MessageQueue } from "./messageQueue";
+
+export interface IRealm {
+  getClientsIds(): string[];
+
+  getClientById(clientId: string): IClient | undefined;
+
+  getClientsIdsWithQueue(): string[];
+
+  setClient(client: IClient, id: string): void;
+
+  removeClientById(id: string): boolean;
+
+  getMessageQueueById(id: string): IMessageQueue | undefined;
+
+  addMessageToQueue(id: string, message: IMessage): void;
+
+  clearMessageQueue(id: string): void;
+
+  generateClientId(): string;
+}
+
+export class Realm implements IRealm {
+  private readonly clients: Map<string, IClient> = new Map();
+  private readonly messageQueues: Map<string, IMessageQueue> = new Map();
+
+  public getClientsIds(): string[] {
+    return [...this.clients.keys()];
+  }
+
+  public getClientById(clientId: string): IClient | undefined {
+    return this.clients.get(clientId);
+  }
+
+  public getClientsIdsWithQueue(): string[] {
+    return [...this.messageQueues.keys()];
+  }
+
+  public setClient(client: IClient, id: string): void {
+    this.clients.set(id, client);
+  }
+
+  public removeClientById(id: string): boolean {
+    const client = this.getClientById(id);
+
+    if (!client) { return false; }
+
+    this.clients.delete(id);
+
+    return true;
+  }
+
+  public getMessageQueueById(id: string): IMessageQueue | undefined {
+    return this.messageQueues.get(id);
+  }
+
+  public addMessageToQueue(id: string, message: IMessage): void {
+    if (!this.getMessageQueueById(id)) {
+      this.messageQueues.set(id, new MessageQueue());
+    }
+
+    this.getMessageQueueById(id).addMessage(message);
+  }
+
+  public clearMessageQueue(id: string): void {
+    this.messageQueues.delete(id);
+  }
+
+  public generateClientId(): string {
+    const randomId = () => (Math.random().toString(36) + "0000000000000000000").substr(2, 16);
+
+    let clientId = randomId();
+
+    while (this.getClientById(clientId)) {
+      clientId = randomId();
+    }
+
+    return clientId;
+  }
+}

src/services/checkBrokenConnections/index.js

@@ -1,57 +0,0 @@
-const DEFAULT_CHECK_INTERVAL = 300;
-
-module.exports = ({ realm, config, checkInterval = DEFAULT_CHECK_INTERVAL, onClose = () => { } }) => {
-  const checkConnections = () => {
-    const clientsIds = realm.getClientsIds();
-
-    const now = new Date().getTime();
-    const aliveTimeout = config.alive_timeout;
-
-    for (const clientId of clientsIds) {
-      const client = realm.getClientById(clientId);
-      const timeSinceLastPing = now - client.getLastPing();
-
-      if (timeSinceLastPing < aliveTimeout) continue;
-
-      try {
-        client.getSocket().close();
-        // eslint-disable-next-line no-empty
-      } catch (e) { } finally {
-        realm.clearMessageQueue(clientId);
-        realm.removeClientById(clientId);
-        client.setSocket(null);
-
-        if (onClose) onClose(client);
-      }
-    }
-  };
-
-  let timeoutId;
-
-  const start = () => {
-    if (timeoutId) {
-      clearTimeout(timeoutId);
-    }
-
-    timeoutId = setTimeout(() => {
-      checkConnections();
-
-      timeoutId = null;
-
-      start();
-    }, checkInterval);
-  };
-
-  const stop = () => {
-    if (timeoutId) {
-      clearTimeout(timeoutId);
-      timeoutId = null;
-    }
-  };
-
-  return {
-    start,
-    stop,
-    CHECK_INTERVAL: checkInterval
-  };
-};

src/services/checkBrokenConnections/index.ts

@@ -0,0 +1,73 @@
+import { IConfig } from "../../../config";
+import { IClient } from "../../models/client";
+import { IRealm } from "../../models/realm";
+
+const DEFAULT_CHECK_INTERVAL = 300;
+
+export class CheckBrokenConnections {
+
+  public readonly checkInterval: number;
+  private timeoutId: NodeJS.Timeout;
+  private readonly realm: IRealm;
+  private readonly config: IConfig;
+  private readonly onClose?: (client: IClient) => void;
+
+  constructor({ realm, config, checkInterval = DEFAULT_CHECK_INTERVAL, onClose }: {
+    realm: IRealm,
+    config: IConfig,
+    checkInterval?: number,
+    onClose?: (client: IClient) => void
+  }) {
+    this.realm = realm;
+    this.config = config;
+    this.onClose = onClose;
+    this.checkInterval = checkInterval;
+  }
+
+  public start(): void {
+    if (this.timeoutId) {
+      clearTimeout(this.timeoutId);
+    }
+
+    this.timeoutId = setTimeout(() => {
+      this.checkConnections();
+
+      this.timeoutId = null;
+
+      this.start();
+    }, this.checkInterval);
+  }
+  public stop(): void {
+    if (this.timeoutId) {
+      clearTimeout(this.timeoutId);
+      this.timeoutId = null;
+    }
+  }
+  private checkConnections(): void {
+    const clientsIds = this.realm.getClientsIds();
+
+    const now = new Date().getTime();
+    const aliveTimeout = this.config.alive_timeout;
+
+    for (const clientId of clientsIds) {
+      const client = this.realm.getClientById(clientId);
+      const timeSinceLastPing = now - client.getLastPing();
+
+      if (timeSinceLastPing < aliveTimeout) { continue; }
+
+      try {
+        if (client.getSocket()) {
+          client.getSocket().close();
+        }
+      } catch (e) {
+        // @ts-nocheck
+      } finally {
+        this.realm.clearMessageQueue(clientId);
+        this.realm.removeClientById(clientId);
+        client.setSocket(null);
+
+        if (this.onClose) { this.onClose(client); }
+      }
+    }
+  }
+}

src/services/messagesExpire/index.js

@@ -1,63 +0,0 @@
-const { MessageType } = require('../../enums');
-
-module.exports = ({ realm, config, messageHandler }) => {
-  const pruneOutstanding = () => {
-    const destinationClientsIds = realm._messageQueues.keys();
-
-    const now = new Date().getTime();
-    const maxDiff = config.expire_timeout;
-
-    const seen = {};
-
-    for (const destinationClientId of destinationClientsIds) {
-      const messageQueue = realm.getMessageQueueById(destinationClientId);
-      const lastReadDiff = now - messageQueue.getLastReadAt();
-
-      if (lastReadDiff < maxDiff) continue;
-
-      const messages = messageQueue.getMessages();
-
-      for (const message of messages) {
-        if (!seen[message.src]) {
-          messageHandler(null, {
-            type: MessageType.EXPIRE,
-            src: message.dst,
-            dst: message.src
-          });
-          seen[message.src] = true;
-        }
-      }
-
-      realm.clearMessageQueue(destinationClientId);
-    }
-  };
-
-  let timeoutId;
-
-  const startMessagesExpiration = () => {
-    if (timeoutId) {
-      clearTimeout(timeoutId);
-    }
-
-    // Clean up outstanding messages
-    timeoutId = setTimeout(() => {
-      pruneOutstanding();
-
-      timeoutId = null;
-
-      startMessagesExpiration();
-    }, config.cleanup_out_msgs);
-  };
-
-  const stopMessagesExpiration = () => {
-    if (timeoutId) {
-      clearTimeout(timeoutId);
-      timeoutId = null;
-    }
-  };
-
-  return {
-    startMessagesExpiration,
-    stopMessagesExpiration
-  };
-};

src/services/messagesExpire/index.ts

@@ -0,0 +1,81 @@
+import { IConfig } from "../../../config";
+import { MessageType } from "../../enums";
+import { IMessageHandler } from "../../messageHandler";
+import { IRealm } from "../../models/realm";
+
+export interface IMessagesExpire {
+  startMessagesExpiration(): void;
+  stopMessagesExpiration(): void;
+}
+
+export class MessagesExpire implements IMessagesExpire {
+  private readonly realm: IRealm;
+  private readonly config: IConfig;
+  private readonly messageHandler: IMessageHandler;
+
+  private timeoutId: NodeJS.Timeout = null;
+
+  constructor({ realm, config, messageHandler }: {
+    realm: IRealm;
+    config: IConfig;
+    messageHandler: IMessageHandler;
+  }) {
+    this.realm = realm;
+    this.config = config;
+    this.messageHandler = messageHandler;
+  }
+
+  public startMessagesExpiration(): void {
+    if (this.timeoutId) {
+      clearTimeout(this.timeoutId);
+    }
+
+    // Clean up outstanding messages
+    this.timeoutId = setTimeout(() => {
+      this.pruneOutstanding();
+
+      this.timeoutId = null;
+
+      this.startMessagesExpiration();
+    }, this.config.cleanup_out_msgs);
+  }
+
+  public stopMessagesExpiration(): void {
+    if (this.timeoutId) {
+      clearTimeout(this.timeoutId);
+      this.timeoutId = null;
+    }
+  }
+
+  private pruneOutstanding(): void {
+    const destinationClientsIds = this.realm.getClientsIdsWithQueue();
+
+    const now = new Date().getTime();
+    const maxDiff = this.config.expire_timeout;
+
+    const seen: { [id: string]: boolean } = {};
+
+    for (const destinationClientId of destinationClientsIds) {
+      const messageQueue = this.realm.getMessageQueueById(destinationClientId);
+      const lastReadDiff = now - messageQueue.getLastReadAt();
+
+      if (lastReadDiff < maxDiff) { continue; }
+
+      const messages = messageQueue.getMessages();
+
+      for (const message of messages) {
+        if (!seen[message.src]) {
+          this.messageHandler.handle(null, {
+            type: MessageType.EXPIRE,
+            src: message.dst,
+            dst: message.src
+          });
+
+          seen[message.src] = true;
+        }
+      }
+
+      this.realm.clearMessageQueue(destinationClientId);
+    }
+  }
+}

src/services/webSocketServer/index.js

@@ -1,114 +0,0 @@
-const WSS = require('ws').Server;
-const url = require('url');
-const EventEmitter = require('events');
-const { MessageType, Errors } = require('../../enums');
-const Client = require('../../models/client');
-
-class WebSocketServer extends EventEmitter {
-  constructor({ server, realm, config }) {
-    super();
-    this.setMaxListeners(0);
-    this.realm = realm;
-    this.config = config;
-
-    let path = this.config.path;
-    path = path + (path[path.length - 1] !== '/' ? '/' : '') + 'peerjs';
-
-    this._wss = new WSS({ path, server });
-
-    this._wss.on('connection', (socket, req) => this._onSocketConnection(socket, req));
-    this._wss.on('error', (error) => this._onSocketError(error));
-  }
-
-  _onSocketConnection(socket, req) {
-    const { query = {} } = url.parse(req.url, true);
-
-    const { id, token, key } = query;
-
-    if (!id || !token || !key) {
-      return this._sendErrorAndClose(socket, Errors.INVALID_WS_PARAMETERS);
-    }
-
-    if (key !== this.config.key) {
-      return this._sendErrorAndClose(socket, Errors.INVALID_KEY);
-    }
-
-    const client = this.realm.getClientById(id);
-
-    if (client) {
-      if (token !== client.getToken()) {
-        // ID-taken, invalid token
-        socket.send(JSON.stringify({
-          type: MessageType.ID_TAKEN,
-          payload: { msg: 'ID is taken' }
-        }));
-
-        return socket.close();
-      }
-
-      return this._configureWS(socket, client);
-    }
-
-    this._registerClient({ socket, id, token });
-  }
-
-  _onSocketError(error) {
-    // handle error
-    this.emit('error', error);
-  }
-
-  _registerClient({ socket, id, token }) {
-    // Check concurrent limit
-    const clientsCount = this.realm.getClientsIds().length;
-
-    if (clientsCount >= this.config.concurrent_limit) {
-      return this._sendErrorAndClose(socket, Errors.CONNECTION_LIMIT_EXCEED);
-    }
-
-    const newClient = new Client({ id, token });
-    this.realm.setClient(newClient, id);
-    socket.send(JSON.stringify({ type: MessageType.OPEN }));
-
-    this._configureWS(socket, newClient);
-  }
-
-  _configureWS(socket, client) {
-    client.setSocket(socket);
-
-    // Cleanup after a socket closes.
-    socket.on('close', () => {
-      if (client.socket === socket) {
-        this.realm.removeClientById(client.getId());
-        this.emit('close', client);
-      }
-    });
-
-    // Handle messages from peers.
-    socket.on('message', (data) => {
-      try {
-        const message = JSON.parse(data);
-
-        message.src = client.getId();
-
-        this.emit('message', client, message);
-      } catch (e) {
-        this.emit('error', e);
-      }
-    });
-
-    this.emit('connection', client);
-  }
-
-  _sendErrorAndClose(socket, msg) {
-    socket.send(
-      JSON.stringify({
-        type: MessageType.ERROR,
-        payload: { msg }
-      })
-    );
-
-    socket.close();
-  }
-}
-
-module.exports = WebSocketServer;

src/services/webSocketServer/index.ts

@@ -0,0 +1,137 @@
+import EventEmitter from "events";
+import { IncomingMessage } from "http";
+import url from "url";
+import WebSocketLib from "ws";
+import { IConfig } from "../../../config";
+import { Errors, MessageType } from "../../enums";
+import { Client, IClient } from "../../models/client";
+import { IRealm } from "../../models/realm";
+import { MyWebSocket } from "./webSocket";
+
+export interface IWebSocketServer extends EventEmitter {
+  readonly path: string;
+}
+
+interface IAuthParams {
+  id?: string;
+  token?: string;
+  key?: string;
+}
+
+export class WebSocketServer extends EventEmitter implements IWebSocketServer {
+
+  public readonly path: string;
+  private readonly realm: IRealm;
+  private readonly config: IConfig;
+  private readonly webSocketServer: WebSocketLib.Server;
+
+  constructor({ server, realm, config }: { server: any, realm: IRealm, config: IConfig }) {
+    super();
+    this.setMaxListeners(0);
+    this.realm = realm;
+    this.config = config;
+
+    const path = this.config.path;
+    this.path = path + (path[path.length - 1] !== "/" ? "/" : "") + "peerjs";
+
+    this.webSocketServer = new WebSocketLib.Server({ path, server });
+
+    this.webSocketServer.on("connection", (socket: MyWebSocket, req) => this._onSocketConnection(socket, req));
+    this.webSocketServer.on("error", (error: Error) => this._onSocketError(error));
+  }
+
+  private _onSocketConnection(socket: MyWebSocket, req: IncomingMessage): void {
+    const { query = {} } = url.parse(req.url, true);
+
+    const { id, token, key }: IAuthParams = query;
+
+    if (!id || !token || !key) {
+      return this._sendErrorAndClose(socket, Errors.INVALID_WS_PARAMETERS);
+    }
+
+    if (key !== this.config.key) {
+      return this._sendErrorAndClose(socket, Errors.INVALID_KEY);
+    }
+
+    const client = this.realm.getClientById(id);
+
+    if (client) {
+      if (token !== client.getToken()) {
+        // ID-taken, invalid token
+        socket.send(JSON.stringify({
+          type: MessageType.ID_TAKEN,
+          payload: { msg: "ID is taken" }
+        }));
+
+        return socket.close();
+      }
+
+      return this._configureWS(socket, client);
+    }
+
+    this._registerClient({ socket, id, token });
+  }
+
+  private _onSocketError(error: Error): void {
+    // handle error
+    this.emit("error", error);
+  }
+
+  private _registerClient({ socket, id, token }:
+    {
+      socket: MyWebSocket;
+      id: string;
+      token: string;
+    }): void {
+    // Check concurrent limit
+    const clientsCount = this.realm.getClientsIds().length;
+
+    if (clientsCount >= this.config.concurrent_limit) {
+      return this._sendErrorAndClose(socket, Errors.CONNECTION_LIMIT_EXCEED);
+    }
+
+    const newClient: IClient = new Client({ id, token });
+    this.realm.setClient(newClient, id);
+    socket.send(JSON.stringify({ type: MessageType.OPEN }));
+
+    this._configureWS(socket, newClient);
+  }
+
+  private _configureWS(socket: MyWebSocket, client: IClient): void {
+    client.setSocket(socket);
+
+    // Cleanup after a socket closes.
+    socket.on("close", () => {
+      if (client.getSocket() === socket) {
+        this.realm.removeClientById(client.getId());
+        this.emit("close", client);
+      }
+    });
+
+    // Handle messages from peers.
+    socket.on("message", (data: WebSocketLib.Data) => {
+      try {
+        const message = JSON.parse(data as string);
+
+        message.src = client.getId();
+
+        this.emit("message", client, message);
+      } catch (e) {
+        this.emit("error", e);
+      }
+    });
+
+    this.emit("connection", client);
+  }
+
+  private _sendErrorAndClose(socket: MyWebSocket, msg: Errors): void {
+    socket.send(
+      JSON.stringify({
+        type: MessageType.ERROR,
+        payload: { msg }
+      })
+    );
+
+    socket.close();
+  }
+}

src/services/webSocketServer/webSocket.ts

@@ -0,0 +1,4 @@
+import EventEmitter from "events";
+import WebSocketLib from "ws";
+
+export type MyWebSocket = WebSocketLib & EventEmitter;

test/messageHandler/handlers/heartbeat/index.js

@@ -1,4 +1,4 @@
-const { expect } = require('chai');
+import { expect } from 'chai';
 const Client = require('../../../../src/models/client');
 const heartbeatHandler = require('../../../../src/messageHandler/handlers/heartbeat');
 

tsconfig.json

@@ -0,0 +1,31 @@
+{
+    "compilerOptions": {
+        "lib": [
+            "es5",
+            "es6",
+            "es7",
+            "es2017"
+        ],
+        "target": "es2016",
+        "module": "commonjs",
+        "esModuleInterop": true,
+        "downlevelIteration": true,
+        "moduleResolution": "node",
+        "noImplicitAny": true,
+        "noUnusedLocals": true,
+        "noUnusedParameters": true,
+        "resolveJsonModule": true,
+        "skipLibCheck": true,
+        "outDir": "dist",
+        "sourceMap": false,
+    },
+    "include": [
+        "./src/**/*",
+        "./config/**/*",
+    ],
+    "exclude": [
+        "./test/",
+        "./node_modules/",
+        "./bin/"
+    ]
+}

tslint.json

@@ -0,0 +1,20 @@
+{
+    "defaultSeverity": "error",
+    "extends": [
+        "tslint:recommended"
+    ],
+    "jsRules": {},
+    "rules": {
+        "trailing-comma": [
+            false
+        ],
+        "object-literal-sort-keys": false
+    },
+    "rulesDirectory": [],
+    "linterOptions": {
+        "exclude": [
+            "./bin/",
+            "./test/"
+        ]
+    }
+}