@aws-sdk/middleware-websocket - npm Package Compare versions

Comparing version 3.972.3 to 3.972.4

dist-cjs/index.js

@@ -67,2 +67,6 @@ 'use strict';
         request.body = placeHolderStream.readable;
+        const match = (headers?.authorization ?? "").match(/Signature=(\w+)$/);
+        const priorSignature = (match ?? [])[1] ?? (query && query["X-Amz-Signature"]) ?? "";
+        const signingStream = getEventSigningTransformStream(priorSignature, await this.messageSigner(), this.eventStreamCodec, this.systemClockOffsetProvider);
+        payload.pipeThrough(signingStream).pipeThrough(placeHolderStream);
         let result;
@@ -73,10 +77,8 @@ try {
         catch (e) {
-            request.body.cancel();
+            const p = payload.cancel?.();
+            if (p instanceof Promise) {
+                p.catch(() => { });
+            }
             throw e;
         }
-        const match = (headers["authorization"] || "").match(/Signature=([\w]+)$/);
-        const priorSignature = (match || [])[1] || (query && query["X-Amz-Signature"]) || "";
-        const signingStream = getEventSigningTransformStream(priorSignature, await this.messageSigner(), this.eventStreamCodec, this.systemClockOffsetProvider);
-        const signedPayload = payload.pipeThrough(signingStream);
-        signedPayload.pipeThrough(placeHolderStream);
         return result;
@@ -315,4 +317,9 @@ }
             try {
-                for await (const inputChunk of data) {
-                    socket.send(inputChunk);
+                for await (const chunk of data) {
+                    if (socket.readyState >= WebSocket.CLOSING) {
+                        break;
+                    }
+                    else {
+                        socket.send(chunk);
+                    }
                 }
@@ -319,0 +326,0 @@ }

dist-es/EventStreamPayloadHandler.js

@@ -20,2 +20,6 @@ import { EventStreamCodec } from "@smithy/eventstream-codec";
         request.body = placeHolderStream.readable;
+        const match = (headers?.authorization ?? "").match(/Signature=(\w+)$/);
+        const priorSignature = (match ?? [])[1] ?? (query && query["X-Amz-Signature"]) ?? "";
+        const signingStream = getEventSigningTransformStream(priorSignature, await this.messageSigner(), this.eventStreamCodec, this.systemClockOffsetProvider);
+        payload.pipeThrough(signingStream).pipeThrough(placeHolderStream);
         let result;
@@ -26,12 +30,10 @@ try {
         catch (e) {
-            request.body.cancel();
+            const p = payload.cancel?.();
+            if (p instanceof Promise) {
+                p.catch(() => { });
+            }
             throw e;
         }
-        const match = (headers["authorization"] || "").match(/Signature=([\w]+)$/);
-        const priorSignature = (match || [])[1] || (query && query["X-Amz-Signature"]) || "";
-        const signingStream = getEventSigningTransformStream(priorSignature, await this.messageSigner(), this.eventStreamCodec, this.systemClockOffsetProvider);
-        const signedPayload = payload.pipeThrough(signingStream);
-        signedPayload.pipeThrough(placeHolderStream);
         return result;
     }
 }

dist-es/websocket-fetch-handler.js

@@ -135,4 +135,9 @@ import { formatUrl } from "@aws-sdk/util-format-url";
             try {
-                for await (const inputChunk of data) {
-                    socket.send(inputChunk);
+                for await (const chunk of data) {
+                    if (socket.readyState >= WebSocket.CLOSING) {
+                        break;
+                    }
+                    else {
+                        socket.send(chunk);
+                    }
                 }
@@ -139,0 +144,0 @@ }

dist-types/eventstream-payload-handler-provider.d.ts

 import { EventStreamPayloadHandlerProvider } from "@smithy/types";
-/** NodeJS event stream utils provider */
+/**
+ * @internal
+ */
 export declare const eventStreamPayloadHandlerProvider: EventStreamPayloadHandlerProvider;

dist-types/EventStreamPayloadHandler.d.ts

 import { Decoder, Encoder, EventStreamPayloadHandler as IEventStreamPayloadHandler, FinalizeHandler, FinalizeHandlerArguments, FinalizeHandlerOutput, HandlerExecutionContext, MessageSigner, MetadataBearer, Provider } from "@smithy/types";
+/**
+ * @internal
+ */
 export interface EventStreamPayloadHandlerOptions {
@@ -14,2 +17,4 @@ messageSigner: Provider<MessageSigner>;
  * 4. Sign the payload after payload stream starting to flow.
+ *
+ * @internal
  */
@@ -16,0 +21,0 @@ export declare class EventStreamPayloadHandler implements IEventStreamPayloadHandler {

package.json

 {
   "name": "@aws-sdk/middleware-websocket",
-  "version": "3.972.3",
+  "version": "3.972.4",
   "main": "./dist-cjs/index.js",
@@ -45,4 +45,3 @@ "module": "./dist-es/index.js",
     "typescript": "~5.8.3",
-    "vitest-websocket-mock": "0.2.3",
-    "web-streams-polyfill": "3.2.1"
+    "vitest-websocket-mock": "0.2.3"
   },
@@ -49,0 +48,0 @@ "engines": {

Fixed alerts

Deprecated

Maintenance

The maintainer of the package marked it as deprecated. This could indicate that a single version should not be used, or that the package is no longer maintained and any new vulnerabilities will not be fixed.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

52163

0.77%

Dev dependency count

7

-12.5%

Lines of code

1001

2.14%

Number of medium maintenance alerts

0

-100%

No dependency changes