afrokick 5 жил өмнө
parent
commit
1887a5a955

+ 0 - 18
dist/config/index.js

@@ -1,18 +0,0 @@
-"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;

+ 1 - 1
dist/src/api/v1/public/index.js

@@ -9,7 +9,7 @@ exports.default = ({ config, realm }) => {
     // Retrieve guaranteed random ID.
     // Retrieve guaranteed random ID.
     app.get("/id", (_, res) => {
     app.get("/id", (_, res) => {
         res.contentType("html");
         res.contentType("html");
-        res.send(realm.generateClientId());
+        res.send(realm.generateClientId(config.generateClientId));
     });
     });
     // Get a list of all peers for a key, enabled by the `allowDiscovery` flag.
     // Get a list of all peers for a key, enabled by the `allowDiscovery` flag.
     app.get("/peers", (_, res) => {
     app.get("/peers", (_, res) => {

+ 0 - 20
dist/src/messageHandler/messageHandlers.js

@@ -1,20 +0,0 @@
-"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;

+ 4 - 3
dist/src/models/realm.js

@@ -41,10 +41,11 @@ class Realm {
     clearMessageQueue(id) {
     clearMessageQueue(id) {
         this.messageQueues.delete(id);
         this.messageQueues.delete(id);
     }
     }
-    generateClientId() {
-        let clientId = v4_1.default();
+    generateClientId(generateClientId) {
+        const generateId = generateClientId ? generateClientId : v4_1.default;
+        let clientId = generateId();
         while (this.getClientById(clientId)) {
         while (this.getClientById(clientId)) {
-            clientId = v4_1.default();
+            clientId = generateId();
         }
         }
         return clientId;
         return clientId;
     }
     }

+ 1 - 1
package-lock.json

@@ -1,6 +1,6 @@
 {
 {
   "name": "peer",
   "name": "peer",
-  "version": "0.3.2",
+  "version": "0.4.0",
   "lockfileVersion": 1,
   "lockfileVersion": 1,
   "requires": true,
   "requires": true,
   "dependencies": {
   "dependencies": {

+ 1 - 1
package.json

@@ -1,6 +1,6 @@
 {
 {
   "name": "peer",
   "name": "peer",
-  "version": "0.3.2",
+  "version": "0.4.0",
   "description": "PeerJS server component",
   "description": "PeerJS server component",
   "main": "dist/src/index.js",
   "main": "dist/src/index.js",
   "bin": {
   "bin": {