@elastic/transport - npm Package Compare versions

Comparing version 8.0.1 to 8.0.2

lib/connection/HttpConnection.js

@@ -106,5 +106,8 @@ "use strict";
             }
+            const abortListener = () => {
+                request.abort();
+            };
             this._openRequests++;
             if (options.signal != null) {
-                options.signal.addEventListener('abort', () => request.abort(), { once: true });
+                options.signal.addEventListener('abort', abortListener, { once: true });
             }
@@ -246,2 +249,10 @@ const onResponse = (response) => {
                 request.removeListener('socket', onSocket);
+                if (options.signal != null) {
+                    if ('removeEventListener' in options.signal) {
+                        options.signal.removeEventListener('abort', abortListener);
+                    }
+                    else {
+                        options.signal.removeListener('abort', abortListener);
+                    }
+                }
                 cleanedListeners = true;
@@ -248,0 +259,0 @@ }

lib/connection/UndiciConnection.js

@@ -62,3 +62,3 @@ "use strict";
         const undiciOptions = {
-            keepAliveTimeout: 4000,
+            keepAliveTimeout: 600e3,
             keepAliveMaxTimeout: 600e3,
@@ -187,22 +187,13 @@ keepAliveTimeoutThreshold: 1000,
             if (isCompressed || isVectorTile) { // eslint-disable-line
-                const payload = [];
-                for await (const chunk of response.body) {
-                    payload.push(chunk);
-                }
                 return {
                     statusCode: response.statusCode,
                     headers: response.headers,
-                    body: Buffer.concat(payload)
+                    body: Buffer.from(await response.body.arrayBuffer())
                 };
             }
             else {
-                let payload = '';
-                response.body.setEncoding('utf8');
-                for await (const chunk of response.body) {
-                    payload += chunk;
-                }
                 return {
                     statusCode: response.statusCode,
                     headers: response.headers,
-                    body: payload
+                    body: await response.body.text()
                 };
@@ -209,0 +200,0 @@ }

package.json

 {
   "name": "@elastic/transport",
-  "version": "8.0.1",
+  "version": "8.0.2",
   "description": "Transport classes and utilities shared among Node.js Elastic client libraries",
@@ -66,3 +66,3 @@ "main": "index.js",
     "tslib": "^2.3.0",
-    "undici": "^4.7.0"
+    "undici": "^4.14.1"
   },
@@ -69,0 +69,0 @@ "tap": {

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

Network access

Supply chain risk

This module accesses the network.

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

228380

increased by0.42%

Number of package files

54

increased by3.85%

Lines of code

3573

increased by0.79%

Worsened metrics

Number of medium supply chain risk alerts

3

increased by50%

Dependency changes

• Updatedundici@^4.14.1