@nestjs/websockets - npm Package Compare versions

Comparing version 10.4.8 to 10.4.9

adapters/ws-adapter.d.ts

@@ -10,2 +10,4 @@ import { INestApplicationContext, WebSocketAdapter } from '@nestjs/common';
     protected readonly httpServer: any;
+    private _forceCloseConnections;
+    set forceCloseConnections(value: boolean);
     constructor(appOrHttpServer?: INestApplicationContext | any);
@@ -12,0 +14,0 @@ bindClientConnect(server: TServer, callback: Function): void;

adapters/ws-adapter.js

@@ -8,2 +8,5 @@ "use strict";
 class AbstractWsAdapter {
+    set forceCloseConnections(value) {
+        this._forceCloseConnections = value;
+    }
     constructor(appOrHttpServer) {
@@ -24,2 +27,5 @@ if (appOrHttpServer && appOrHttpServer instanceof core_1.NestApplication) {
     async close(server) {
+        if (this._forceCloseConnections) {
+            return;
+        }
         const isCallable = server && (0, shared_utils_1.isFunction)(server.close);
@@ -26,0 +32,0 @@ isCallable && (await new Promise(resolve => server.close(resolve)));

package.json

 {
   "name": "@nestjs/websockets",
-  "version": "10.4.8",
+  "version": "10.4.9",
   "description": "Nest - modern, fast, powerful node.js web framework (@websockets)",
@@ -21,4 +21,4 @@ "author": "Kamil Mysliwiec",
   "devDependencies": {
-    "@nestjs/common": "10.4.8",
-    "@nestjs/core": "10.4.8"
+    "@nestjs/common": "10.4.9",
+    "@nestjs/core": "10.4.9"
   },
@@ -25,0 +25,0 @@ "peerDependencies": {

socket-module.js

@@ -65,4 +65,8 @@ "use strict";
     initializeAdapter() {
+        const forceCloseConnections = this.appOptions
+            .forceCloseConnections;
         const adapter = this.applicationConfig.getIoAdapter();
         if (adapter) {
+            adapter.forceCloseConnections =
+                forceCloseConnections;
             this.isAdapterInitialized = true;
@@ -73,2 +77,3 @@ return;
         const ioAdapter = new IoAdapter(this.httpServer);
+        ioAdapter.forceCloseConnections = forceCloseConnections;
         this.applicationConfig.setIoAdapter(ioAdapter);
@@ -75,0 +80,0 @@ this.isAdapterInitialized = true;

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

Improved metrics

Total package byte prevSize

80621

increased by0.6%

Lines of code

1463

increased by0.9%

Published versions last months

12

increased by9.09%

Published versions last two months

15

increased by7.14%

Published versions last week

2

increased byInfinity%

Published versions last year

31

increased by3.33%

No dependency changes