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

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

@@ -71 +71 @@
         this.server._checkNamespace(name, auth, (dynamicNspName) => {
             if (dynamicNspName) {
-                debug("dynamic namespace %s was created", dynamicNspName);
                 this.doConnect(name, auth);
             }
@@ -151 +150 @@
      * @private
      */
-    _packet(packet, opts) {
-        opts = opts || {};
-        const self = this;
-        // this writes to the actual connection
-        function writeToEngine(encodedPackets) {
-            // TODO clarify this.
-            if (opts.volatile && !self.conn.transport.writable)
-                return;
-            for (let i = 0; i < encodedPackets.length; i++) {
-                self.conn.write(encodedPackets[i], { compress: opts.compress });
-            }
-        }
-        if ("open" === this.conn.readyState) {
-            debug("writing packet %j", packet);
-            if (!opts.preEncoded) {
-                // not broadcasting, need to encode
-                writeToEngine(this.encoder.encode(packet)); // encode, then write results to engine
-            }
-            else {
-                // a broadcast pre-encodes a packet
-                writeToEngine(packet);
-            }
-        }
-        else {
+    _packet(packet, opts = {}) {
+        if (this.conn.readyState !== "open") {
             debug("ignoring packet write %j", packet);
+            return;
+        }
+        const encodedPackets = opts.preEncoded
+            ? packet // previous versions of the adapter incorrectly used socket.packet() instead of writeToEngine()
+            : this.encoder.encode(packet);
+        this.writeToEngine(encodedPackets, opts);
+    }
+    writeToEngine(encodedPackets, opts) {
+        if (opts.volatile && !this.conn.transport.writable) {
+            debug("volatile packet is discarded since the transport is not currently writable");
+            return;
+        }
+        const packets = Array.isArray(encodedPackets)
+            ? encodedPackets
+            : [encodedPackets];
+        for (const encodedPacket of packets) {
+            this.conn.write(encodedPacket, opts);
         }
     }