@nestjs/websockets - npm Package Compare versions

Comparing version 5.0.0-rc.1 to 5.0.0-rc.2

context/ws-context-creator.js

 "use strict";
-var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
-    return new (P || (P = Promise))(function (resolve, reject) {
-        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
-        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
-        step((generator = generator.apply(thisArg, _arguments || [])).next());
-    });
-};
 Object.defineProperty(exports, "__esModule", { value: true });
@@ -31,14 +23,14 @@ const constants_1 = require("@nestjs/common/constants");
         const interceptors = this.interceptorsContextCreator.create(instance, callback, module);
-        return this.wsProxy.create((...args) => __awaiter(this, void 0, void 0, function* () {
-            const canActivate = yield this.guardsConsumer.tryActivate(guards, args, instance, callback);
+        return this.wsProxy.create(async (...args) => {
+            const canActivate = await this.guardsConsumer.tryActivate(guards, args, instance, callback);
             if (!canActivate) {
                 throw new ws_exception_1.WsException(constants_2.FORBIDDEN_MESSAGE);
             }
-            const handler = () => __awaiter(this, void 0, void 0, function* () {
+            const handler = async () => {
                 const [client, data, ...params] = args;
-                const result = yield this.pipesConsumer.applyPipes(data, { metatype }, pipes);
+                const result = await this.pipesConsumer.applyPipes(data, { metatype }, pipes);
                 return callback.call(instance, client, result, ...params);
-            });
-            return yield this.interceptorsConsumer.intercept(interceptors, args, instance, callback, handler);
-        }), exceptionHandler);
+            };
+            return await this.interceptorsConsumer.intercept(interceptors, args, instance, callback, handler);
+        }, exceptionHandler);
     }
@@ -45,0 +37,0 @@ reflectCallbackParamtypes(instance, callback) {

context/ws-proxy.js

 "use strict";
-var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
-    return new (P || (P = Promise))(function (resolve, reject) {
-        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
-        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
-        step((generator = generator.apply(thisArg, _arguments || [])).next());
-    });
-};
 Object.defineProperty(exports, "__esModule", { value: true });
@@ -14,6 +6,6 @@ const execution_context_host_1 = require("@nestjs/core/helpers/execution-context.host");
     create(targetCallback, exceptionsHandler) {
-        return (...args) => __awaiter(this, void 0, void 0, function* () {
+        return async (...args) => {
             const host = new execution_context_host_1.ExecutionContextHost(args);
             try {
-                return yield targetCallback(...args);
+                return await targetCallback(...args);
             }
@@ -23,5 +15,5 @@ catch (e) {
             }
-        });
+        };
     }
 }
 exports.WsProxy = WsProxy;

observable-socket.js

@@ -6,4 +6,6 @@ "use strict";
     static create(server) {
+        const init = new rxjs_1.ReplaySubject();
+        init.next(server);
         return {
-            init: new rxjs_1.ReplaySubject(),
+            init,
             connection: new rxjs_1.Subject(),
@@ -10,0 +12,0 @@ disconnect: new rxjs_1.Subject(),

package.json

 {
   "name": "@nestjs/websockets",
-  "version": "5.0.0-rc.1",
+  "version": "5.0.0-rc.2",
   "description": "Nest - modern, fast, powerful node.js web framework (@websockets)",
@@ -5,0 +5,0 @@ "author": "Kamil Mysliwiec",

socket-module.js

 "use strict";
-var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
-    return new (P || (P = Promise))(function (resolve, reject) {
-        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
-        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
-        step((generator = generator.apply(thisArg, _arguments || [])).next());
-    });
-};
 Object.defineProperty(exports, "__esModule", { value: true });
@@ -50,12 +42,10 @@ require("reflect-metadata");
     }
-    close() {
-        return __awaiter(this, void 0, void 0, function* () {
-            if (!this.applicationConfig) {
-                return undefined;
-            }
-            const adapter = this.applicationConfig.getIoAdapter();
-            const servers = this.socketsContainer.getAllServers();
-            yield Promise.all(iterare_1.default(servers.values()).map(({ server }) => __awaiter(this, void 0, void 0, function* () { return server && (yield adapter.close(server)); })));
-            this.socketsContainer.clear();
-        });
+    async close() {
+        if (!this.applicationConfig) {
+            return undefined;
+        }
+        const adapter = this.applicationConfig.getIoAdapter();
+        const servers = this.socketsContainer.getAllServers();
+        await Promise.all(iterare_1.default(servers.values()).map(async ({ server }) => server && (await adapter.close(server))));
+        this.socketsContainer.clear();
     }
@@ -62,0 +52,0 @@ getContextCreator(container) {

web-sockets-controller.js

 "use strict";
-var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
-    return new (P || (P = Promise))(function (resolve, reject) {
-        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
-        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
-        step((generator = generator.apply(thisArg, _arguments || [])).next());
-    });
-};
 Object.defineProperty(exports, "__esModule", { value: true });
@@ -57,3 +49,2 @@ require("reflect-metadata");
         this.subscribeDisconnectEvent(instance, disconnect);
-        init.next(server);
         const handler = this.getConnectionHandler(this, instance, messageHandlers, disconnect, connection);
@@ -79,3 +70,5 @@ adapter.bindClientConnect(server, handler);
         if (instance.handleConnection) {
-            event.subscribe(instance.handleConnection.bind(instance));
+            event
+                .pipe(operators_1.distinctUntilChanged())
+                .subscribe(instance.handleConnection.bind(instance));
         }
@@ -85,3 +78,5 @@ }
         if (instance.handleDisconnect) {
-            event.subscribe(instance.handleDisconnect.bind(instance));
+            event
+                .pipe(operators_1.distinctUntilChanged())
+                .subscribe(instance.handleDisconnect.bind(instance));
         }
@@ -97,13 +92,11 @@ }
     }
-    pickResult(defferedResult) {
-        return __awaiter(this, void 0, void 0, function* () {
-            const result = yield defferedResult;
-            if (result && shared_utils_1.isFunction(result.subscribe)) {
-                return result;
-            }
-            if (result instanceof Promise) {
-                return rxjs_1.from(result);
-            }
-            return rxjs_1.of(result);
-        });
+    async pickResult(defferedResult) {
+        const result = await defferedResult;
+        if (result && shared_utils_1.isFunction(result.subscribe)) {
+            return result;
+        }
+        if (result instanceof Promise) {
+            return rxjs_1.from(result);
+        }
+        return rxjs_1.of(result);
     }
@@ -110,0 +103,0 @@ hookServerToProperties(instance, server) {

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Worsened metrics

Total package byte prevSize

61870

decreased by-4.03%

Lines of code

1077

decreased by-2.8%

No dependency changes