@aws-sdk/middleware-websocket
Advanced tools
Comparing version 3.347.0 to 3.348.0
@@ -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); |
@@ -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 @@ }, |
@@ -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); |
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 @@ }, |
@@ -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); |
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>; |
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); |
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>; |
{ | ||
"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", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
51871
935