Changeset e29cc2e for trip-planner-front/node_modules/socket.io/dist/namespace.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/dist/namespace.js (modified) (11 diffs)

trip-planner-front/node_modules/socket.io/dist/namespace.js

@@ -4 +4 @@
 };
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.Namespace = void 0;
+exports.Namespace = exports.RESERVED_EVENTS = void 0;
 const socket_1 = require("./socket");
-const events_1 = require("events");
-const socket_io_parser_1 = require("socket.io-parser");
+const typed_events_1 = require("./typed-events");
 const debug_1 = __importDefault(require("debug"));
-const debug = debug_1.default("socket.io:namespace");
-class Namespace extends events_1.EventEmitter {
+const broadcast_operator_1 = require("./broadcast-operator");
+const debug = (0, debug_1.default)("socket.io:namespace");
+exports.RESERVED_EVENTS = new Set(["connect", "connection", "new_namespace"]);
+class Namespace extends typed_events_1.StrictEventEmitter {
     /**
      * Namespace constructor.
@@ -23 +24 @@
         this._fns = [];
         /** @private */
-        this._rooms = new Set();
-        /** @private */
-        this._flags = {};
-        /** @private */
         this._ids = 0;
         this.server = server;
@@ -40 +37 @@
      */
     _initAdapter() {
+        // @ts-ignore
         this.adapter = new (this.server.adapter())(this);
     }
@@ -80 +78 @@
      * Targets a room when emitting.
      *
-     * @param name
-     * @return self
-     * @public
-     */
-    to(name) {
-        this._rooms.add(name);
-        return this;
+     * @param room
+     * @return self
+     * @public
+     */
+    to(room) {
+        return new broadcast_operator_1.BroadcastOperator(this.adapter).to(room);
     }
     /**
      * Targets a room when emitting.
      *
-     * @param name
-     * @return self
-     * @public
-     */
-    in(name) {
-        this._rooms.add(name);
-        return this;
+     * @param room
+     * @return self
+     * @public
+     */
+    in(room) {
+        return new broadcast_operator_1.BroadcastOperator(this.adapter).in(room);
+    }
+    /**
+     * Excludes a room when emitting.
+     *
+     * @param room
+     * @return self
+     * @public
+     */
+    except(room) {
+        return new broadcast_operator_1.BroadcastOperator(this.adapter).except(room);
     }
     /**
@@ -132 +138 @@
                         fn();
                     // fire user-set events
-                    super.emit("connect", socket);
-                    super.emit("connection", socket);
+                    this.emitReserved("connect", socket);
+                    this.emitReserved("connection", socket);
                 }
                 else {
@@ -162 +168 @@
      */
     emit(ev, ...args) {
-        if (socket_1.RESERVED_EVENTS.has(ev)) {
-            throw new Error(`"${ev}" is a reserved event name`);
-        }
-        // set up packet object
-        args.unshift(ev);
-        const packet = {
-            type: socket_io_parser_1.PacketType.EVENT,
-            data: args,
-        };
-        if ("function" == typeof args[args.length - 1]) {
-            throw new Error("Callbacks are not supported when broadcasting");
-        }
-        const rooms = new Set(this._rooms);
-        const flags = Object.assign({}, this._flags);
-        // reset flags
-        this._rooms.clear();
-        this._flags = {};
-        this.adapter.broadcast(packet, {
-            rooms: rooms,
-            flags: flags,
-        });
-        return true;
+        return new broadcast_operator_1.BroadcastOperator(this.adapter).emit(ev, ...args);
     }
     /**
@@ -206 +191 @@
     }
     /**
+     * Emit a packet to other Socket.IO servers
+     *
+     * @param ev - the event name
+     * @param args - an array of arguments, which may include an acknowledgement callback at the end
+     * @public
+     */
+    serverSideEmit(ev, ...args) {
+        if (exports.RESERVED_EVENTS.has(ev)) {
+            throw new Error(`"${ev}" is a reserved event name`);
+        }
+        args.unshift(ev);
+        this.adapter.serverSideEmit(args);
+        return true;
+    }
+    /**
+     * Called when a packet is received from another Socket.IO server
+     *
+     * @param args - an array of arguments, which may include an acknowledgement callback at the end
+     *
+     * @private
+     */
+    _onServerSideEmit(args) {
+        super.emitUntyped.apply(this, args);
+    }
+    /**
      * Gets a list of clients.
      *
@@ -212 +222 @@
      */
     allSockets() {
-        if (!this.adapter) {
-            throw new Error("No adapter for this namespace, are you trying to get the list of clients of a dynamic namespace?");
-        }
-        const rooms = new Set(this._rooms);
-        this._rooms.clear();
-        return this.adapter.sockets(rooms);
+        return new broadcast_operator_1.BroadcastOperator(this.adapter).allSockets();
     }
     /**
@@ -227 +232 @@
      */
     compress(compress) {
-        this._flags.compress = compress;
-        return this;
+        return new broadcast_operator_1.BroadcastOperator(this.adapter).compress(compress);
     }
     /**
@@ -239 +243 @@
      */
     get volatile() {
-        this._flags.volatile = true;
-        return this;
+        return new broadcast_operator_1.BroadcastOperator(this.adapter).volatile;
     }
     /**
@@ -249 +252 @@
      */
     get local() {
-        this._flags.local = true;
-        return this;
+        return new broadcast_operator_1.BroadcastOperator(this.adapter).local;
+    }
+    /**
+     * Returns the matching socket instances
+     *
+     * @public
+     */
+    fetchSockets() {
+        return new broadcast_operator_1.BroadcastOperator(this.adapter).fetchSockets();
+    }
+    /**
+     * Makes the matching socket instances join the specified rooms
+     *
+     * @param room
+     * @public
+     */
+    socketsJoin(room) {
+        return new broadcast_operator_1.BroadcastOperator(this.adapter).socketsJoin(room);
+    }
+    /**
+     * Makes the matching socket instances leave the specified rooms
+     *
+     * @param room
+     * @public
+     */
+    socketsLeave(room) {
+        return new broadcast_operator_1.BroadcastOperator(this.adapter).socketsLeave(room);
+    }
+    /**
+     * Makes the matching socket instances disconnect
+     *
+     * @param close - whether to close the underlying connection
+     * @public
+     */
+    disconnectSockets(close = false) {
+        return new broadcast_operator_1.BroadcastOperator(this.adapter).disconnectSockets(close);
     }
 }