fix(adapter.node): close websocket server and active connections when stopping the Node adapter

ts/adapters/adapter.node.ts

@@ -7,6 +7,7 @@ import { BaseAdapter, type IAdapterCharacteristics, type TRequestHandler } from
  */
 export class NodeAdapter extends BaseAdapter {
   private server: plugins.http.Server | plugins.https.Server | null = null;
+  private wss: any = null;
 
   get name(): 'node' {
     return 'node';
@@ -92,8 +93,13 @@ export class NodeAdapter extends BaseAdapter {
   }
 
   async stop(): Promise<void> {
+    if (this.wss) {
+      this.wss.close();
+      this.wss = null;
+    }
     return new Promise((resolve, reject) => {
       if (this.server) {
+        this.server.closeAllConnections();
         this.server.close((err) => {
           if (err) reject(err);
           else resolve();
@@ -254,19 +260,19 @@ export class NodeAdapter extends BaseAdapter {
       // Dynamic import of ws library
       const { WebSocketServer } = await import('ws');
 
-      const wss = new WebSocketServer({ noServer: true });
+      this.wss = new WebSocketServer({ noServer: true });
 
       // Get internal callbacks if typedRouter mode
       const callbacks = (hooks as any)._connectionCallbacks as IWebSocketConnectionCallbacks | undefined;
       const typedRouter = hooks.typedRouter;
 
       this.server.on('upgrade', (request, socket, head) => {
-        wss.handleUpgrade(request, socket, head, (ws) => {
-          wss.emit('connection', ws, request);
+        this.wss.handleUpgrade(request, socket, head, (ws: any) => {
+          this.wss.emit('connection', ws, request);
         });
       });
 
-      wss.on('connection', (ws: any, request: any) => {
+      this.wss.on('connection', (ws: any, request: any) => {
         const peer = this.wrapNodeWebSocket(ws, request);
 
         // Register connection if typedRouter mode