ref

Author: afrokick

.eslintrc.json

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

.gitignore

@@ -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()}`);
 });

bin/peerjs

@@ -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;

config/index.js

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

config/index.ts

@@ -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/app.json

@@ -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/config/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/index.js

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

dist/src/api/middleware/auth/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/middleware/middleware.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/api/v1/calls/index.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 = {}));