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

Comparing version 3.347.0 to 3.348.0

dist-cjs/EventStreamPayloadHandler.js

@@ -8,3 +8,3 @@ "use strict";
     constructor(options) {
-        this.eventSigner = options.eventSigner;
+        this.messageSigner = options.messageSigner;
         this.eventStreamCodec = new eventstream_codec_1.EventStreamCodec(options.utf8Encoder, options.utf8Decoder);
@@ -30,3 +30,3 @@ }
         const priorSignature = (match || [])[1] || (query && query["X-Amz-Signature"]) || "";
-        const signingStream = (0, get_event_signing_stream_1.getEventSigningTransformStream)(priorSignature, await this.eventSigner(), this.eventStreamCodec);
+        const signingStream = (0, get_event_signing_stream_1.getEventSigningTransformStream)(priorSignature, await this.messageSigner(), this.eventStreamCodec);
         const signedPayload = payload.pipeThrough(signingStream);
@@ -33,0 +33,0 @@ signedPayload.pipeThrough(placeHolderStream);

dist-cjs/get-event-signing-stream.js

@@ -5,3 +5,3 @@ "use strict";
 const util_hex_encoding_1 = require("@aws-sdk/util-hex-encoding");
-const getEventSigningTransformStream = (initialSignature, eventSigner, eventStreamCodec) => {
+const getEventSigningTransformStream = (initialSignature, messageSigner, eventStreamCodec) => {
     let priorSignature = initialSignature;
@@ -16,10 +16,12 @@ const transformer = {
                 };
-                const signature = await eventSigner.sign({
-                    payload: chunk,
-                    headers: eventStreamCodec.formatHeaders(dateHeader),
+                const signedMessage = await messageSigner.sign({
+                    message: {
+                        body: chunk,
+                        headers: dateHeader,
+                    },
+                    priorSignature: priorSignature,
                 }, {
-                    priorSignature,
                     signingDate: now,
                 });
-                priorSignature = signature;
+                priorSignature = signedMessage.signature;
                 const serializedSigned = eventStreamCodec.encode({
@@ -30,3 +32,3 @@ headers: {
                             type: "binary",
-                            value: (0, util_hex_encoding_1.fromHex)(signature),
+                            value: (0, util_hex_encoding_1.fromHex)(signedMessage.signature),
                         },
@@ -33,0 +35,0 @@ },

dist-es/EventStreamPayloadHandler.js

@@ -5,3 +5,3 @@ import { EventStreamCodec } from "@aws-sdk/eventstream-codec";
     constructor(options) {
-        this.eventSigner = options.eventSigner;
+        this.messageSigner = options.messageSigner;
         this.eventStreamCodec = new EventStreamCodec(options.utf8Encoder, options.utf8Decoder);
@@ -27,3 +27,3 @@ }
         const priorSignature = (match || [])[1] || (query && query["X-Amz-Signature"]) || "";
-        const signingStream = getEventSigningTransformStream(priorSignature, await this.eventSigner(), this.eventStreamCodec);
+        const signingStream = getEventSigningTransformStream(priorSignature, await this.messageSigner(), this.eventStreamCodec);
         const signedPayload = payload.pipeThrough(signingStream);
@@ -30,0 +30,0 @@ signedPayload.pipeThrough(placeHolderStream);

dist-es/get-event-signing-stream.js

 import { fromHex } from "@aws-sdk/util-hex-encoding";
-export const getEventSigningTransformStream = (initialSignature, eventSigner, eventStreamCodec) => {
+export const getEventSigningTransformStream = (initialSignature, messageSigner, eventStreamCodec) => {
     let priorSignature = initialSignature;
@@ -12,10 +12,12 @@ const transformer = {
                 };
-                const signature = await eventSigner.sign({
-                    payload: chunk,
-                    headers: eventStreamCodec.formatHeaders(dateHeader),
+                const signedMessage = await messageSigner.sign({
+                    message: {
+                        body: chunk,
+                        headers: dateHeader,
+                    },
+                    priorSignature: priorSignature,
                 }, {
-                    priorSignature,
                     signingDate: now,
                 });
-                priorSignature = signature;
+                priorSignature = signedMessage.signature;
                 const serializedSigned = eventStreamCodec.encode({
@@ -26,3 +28,3 @@ headers: {
                             type: "binary",
-                            value: fromHex(signature),
+                            value: fromHex(signedMessage.signature),
                         },
@@ -29,0 +31,0 @@ },

dist-types/EventStreamPayloadHandler.d.ts

@@ -1,4 +0,4 @@
-import { Decoder, Encoder, EventSigner, EventStreamPayloadHandler as IEventStreamPayloadHandler, FinalizeHandler, FinalizeHandlerArguments, FinalizeHandlerOutput, HandlerExecutionContext, MetadataBearer, Provider } from "@aws-sdk/types";
+import { Decoder, Encoder, EventStreamPayloadHandler as IEventStreamPayloadHandler, FinalizeHandler, FinalizeHandlerArguments, FinalizeHandlerOutput, HandlerExecutionContext, MessageSigner, MetadataBearer, Provider } from "@aws-sdk/types";
 export interface EventStreamPayloadHandlerOptions {
-    eventSigner: Provider<EventSigner>;
+    messageSigner: Provider<MessageSigner>;
     utf8Encoder: Encoder;
@@ -15,3 +15,3 @@ utf8Decoder: Decoder;
 export declare class EventStreamPayloadHandler implements IEventStreamPayloadHandler {
-    private readonly eventSigner;
+    private readonly messageSigner;
     private readonly eventStreamCodec;
@@ -18,0 +18,0 @@ constructor(options: EventStreamPayloadHandlerOptions);

dist-types/get-event-signing-stream.d.ts

 import { EventStreamCodec } from "@aws-sdk/eventstream-codec";
-import { EventSigner } from "@aws-sdk/types";
+import { MessageSigner } from "@aws-sdk/types";
 /**
@@ -8,2 +8,2 @@ * Get a transform stream that signs the eventstream
  */
-export declare const getEventSigningTransformStream: (initialSignature: string, eventSigner: EventSigner, eventStreamCodec: EventStreamCodec) => TransformStream<Uint8Array, Uint8Array>;
+export declare const getEventSigningTransformStream: (initialSignature: string, messageSigner: MessageSigner, eventStreamCodec: EventStreamCodec) => TransformStream<Uint8Array, Uint8Array>;

dist-types/ts3.4/EventStreamPayloadHandler.d.ts

 import {
   Decoder,
   Encoder,
-  EventSigner,
   EventStreamPayloadHandler as IEventStreamPayloadHandler,
@@ -10,2 +9,3 @@ FinalizeHandler,
   HandlerExecutionContext,
+  MessageSigner,
   MetadataBearer,
@@ -15,3 +15,3 @@ Provider,
 export interface EventStreamPayloadHandlerOptions {
-  eventSigner: Provider<EventSigner>;
+  messageSigner: Provider<MessageSigner>;
   utf8Encoder: Encoder;
@@ -23,3 +23,3 @@ utf8Decoder: Decoder;
 {
-  private readonly eventSigner;
+  private readonly messageSigner;
   private readonly eventStreamCodec;
@@ -26,0 +26,0 @@ constructor(options: EventStreamPayloadHandlerOptions);

dist-types/ts3.4/get-event-signing-stream.d.ts

 import { EventStreamCodec } from "@aws-sdk/eventstream-codec";
-import { EventSigner } from "@aws-sdk/types";
+import { MessageSigner } from "@aws-sdk/types";
 export declare const getEventSigningTransformStream: (
   initialSignature: string,
-  eventSigner: EventSigner,
+  messageSigner: MessageSigner,
   eventStreamCodec: EventStreamCodec
 ) => TransformStream<Uint8Array, Uint8Array>;

package.json

 {
   "name": "@aws-sdk/middleware-websocket",
-  "version": "3.347.0",
+  "version": "3.348.0",
   "main": "./dist-cjs/index.js",
@@ -5,0 +5,0 @@ "module": "./dist-es/index.js",

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

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

51871

increased by0.38%

Lines of code

935

increased by0.43%

No dependency changes