Changeset e29cc2e for trip-planner-front/node_modules/socket.io-adapter/dist/index.js

Timestamp:

11/25/21 22:08:24 (3 years ago)

Author:

Ema <ema_spirova@…>

Branches:

master

Children:

8d391a1

Parents:

59329aa

Message:

primeNG components

File:

• trip-planner-front/node_modules/socket.io-adapter/dist/index.js (modified) (5 diffs)

trip-planner-front/node_modules/socket.io-adapter/dist/index.js

@@ -60 +60 @@
     }
     _del(room, id) {
-        if (this.rooms.has(room)) {
-            const deleted = this.rooms.get(room).delete(id);
+        const _room = this.rooms.get(room);
+        if (_room != null) {
+            const deleted = _room.delete(id);
             if (deleted) {
                 this.emit("leave-room", room, id);
             }
-            if (this.rooms.get(room).size === 0) {
-                this.rooms.delete(room);
+            if (_room.size === 0 && this.rooms.delete(room)) {
                 this.emit("delete-room", room);
             }
@@ -98 +98 @@
      */
     broadcast(packet, opts) {
-        const rooms = opts.rooms;
-        const except = opts.except || new Set();
         const flags = opts.flags || {};
         const packetOpts = {
@@ -106 +104 @@
             compress: flags.compress
         };
-        const ids = new Set();
         packet.nsp = this.nsp.name;
         const encodedPackets = this.encoder.encode(packet);
+        this.apply(opts, socket => {
+            socket.client.writeToEngine(encodedPackets, packetOpts);
+        });
+    }
+    /**
+     * Gets a list of sockets by sid.
+     *
+     * @param {Set<Room>} rooms   the explicit set of rooms to check.
+     */
+    sockets(rooms) {
+        const sids = new Set();
+        this.apply({ rooms }, socket => {
+            sids.add(socket.id);
+        });
+        return Promise.resolve(sids);
+    }
+    /**
+     * Gets the list of rooms a given socket has joined.
+     *
+     * @param {SocketId} id   the socket id
+     */
+    socketRooms(id) {
+        return this.sids.get(id);
+    }
+    /**
+     * Returns the matching socket instances
+     *
+     * @param opts - the filters to apply
+     */
+    fetchSockets(opts) {
+        const sockets = [];
+        this.apply(opts, socket => {
+            sockets.push(socket);
+        });
+        return Promise.resolve(sockets);
+    }
+    /**
+     * Makes the matching socket instances join the specified rooms
+     *
+     * @param opts - the filters to apply
+     * @param rooms - the rooms to join
+     */
+    addSockets(opts, rooms) {
+        this.apply(opts, socket => {
+            socket.join(rooms);
+        });
+    }
+    /**
+     * Makes the matching socket instances leave the specified rooms
+     *
+     * @param opts - the filters to apply
+     * @param rooms - the rooms to leave
+     */
+    delSockets(opts, rooms) {
+        this.apply(opts, socket => {
+            rooms.forEach(room => socket.leave(room));
+        });
+    }
+    /**
+     * Makes the matching socket instances disconnect
+     *
+     * @param opts - the filters to apply
+     * @param close - whether to close the underlying connection
+     */
+    disconnectSockets(opts, close) {
+        this.apply(opts, socket => {
+            socket.disconnect(close);
+        });
+    }
+    apply(opts, callback) {
+        const rooms = opts.rooms;
+        const except = this.computeExceptSids(opts.except);
         if (rooms.size) {
+            const ids = new Set();
             for (const room of rooms) {
                 if (!this.rooms.has(room))
@@ -118 +188 @@
                     const socket = this.nsp.sockets.get(id);
                     if (socket) {
-                        socket.packet(encodedPackets, packetOpts);
+                        callback(socket);
                         ids.add(id);
                     }
@@ -130 +200 @@
                 const socket = this.nsp.sockets.get(id);
                 if (socket)
-                    socket.packet(encodedPackets, packetOpts);
-            }
-        }
-    }
-    /**
-     * Gets a list of sockets by sid.
-     *
-     * @param {Set<Room>} rooms   the explicit set of rooms to check.
-     */
-    sockets(rooms) {
-        const sids = new Set();
-        if (rooms.size) {
-            for (const room of rooms) {
-                if (!this.rooms.has(room))
-                    continue;
-                for (const id of this.rooms.get(room)) {
-                    if (this.nsp.sockets.has(id)) {
-                        sids.add(id);
-                    }
+                    callback(socket);
+            }
+        }
+    }
+    computeExceptSids(exceptRooms) {
+        const exceptSids = new Set();
+        if (exceptRooms && exceptRooms.size > 0) {
+            for (const room of exceptRooms) {
+                if (this.rooms.has(room)) {
+                    this.rooms.get(room).forEach(sid => exceptSids.add(sid));
                 }
             }
         }
-        else {
-            for (const [id] of this.sids) {
-                if (this.nsp.sockets.has(id))
-                    sids.add(id);
-            }
-        }
-        return Promise.resolve(sids);
-    }
-    /**
-     * Gets the list of rooms a given socket has joined.
-     *
-     * @param {SocketId} id   the socket id
-     */
-    socketRooms(id) {
-        return this.sids.get(id);
+        return exceptSids;
+    }
+    /**
+     * Send a packet to the other Socket.IO servers in the cluster
+     * @param packet - an array of arguments, which may include an acknowledgement callback at the end
+     */
+    serverSideEmit(packet) {
+        throw new Error("this adapter does not support the serverSideEmit() functionality");
     }
 }