fix(eventstream-handler-node): add system clock offset to event signi…

…ng streams (#6227)

packages/eventstream-handler-node/src/EventSigningStream.spec.ts

@@ -11,7 +11,7 @@ describe("EventSigningStream", () => {
     Date = originalDate;
   });
 
-  it("should sign a eventstream payload properly", (done) => {
+  it("should sign an eventstream payload properly", (done) => {
     const eventStreamCodec = new EventStreamCodec(toUtf8, fromUtf8);
     const message1: Message = {
       headers: {},
@@ -44,24 +44,22 @@ describe("EventSigningStream", () => {
       .fn()
       .mockReturnValueOnce({ message: message1, signature: "7369676e617475726531" } as SignedMessage) //'signature1'
       .mockReturnValueOnce({ message: message2, signature: "7369676e617475726532" } as SignedMessage); //'signature2'
-    // mock 'new Date()'
+
     let mockDateCount = 0;
-    // eslint-disable-next-line @typescript-eslint/no-unused-vars
-    const mockDate = jest
-      .spyOn(global, "Date")
-      //@ts-ignore: https://stackoverflow.com/questions/60912023/jest-typescript-mock-date-constructor/60918716#60918716
-      .mockImplementation((input) => {
-        if (input) return new originalDate(input);
-        mockDateCount += 1;
-        return expected[mockDateCount - 1][":date"].value;
-      });
+    function MockDate(input?: any): Date {
+      return input ? new originalDate(input) : (expected[mockDateCount++][":date"].value as Date);
+    }
+    MockDate.now = () => MockDate().getTime();
+    global.Date = MockDate as any;
+
     const signingStream = new EventSigningStream({
       priorSignature: "initial",
       messageSigner: {
         sign: mockMessageSigner,
         signMessage: mockMessageSigner,
       },
       eventStreamCodec,
+      systemClockOffsetProvider: async () => 0,
     });
     const output: Array<MessageHeaders> = [];
     signingStream.on("data", (chunk) => {

packages/eventstream-handler-node/src/EventSigningStream.ts

@@ -1,5 +1,5 @@
 import { EventStreamCodec } from "@smithy/eventstream-codec";
-import { MessageHeaders, MessageSigner } from "@smithy/types";
+import { MessageHeaders, MessageSigner, Provider } from "@smithy/types";
 import { Transform, TransformCallback, TransformOptions } from "stream";
 
 /**
@@ -9,6 +9,7 @@ export interface EventSigningStreamOptions extends TransformOptions {
   priorSignature: string;
   messageSigner: MessageSigner;
   eventStreamCodec: EventStreamCodec;
+  systemClockOffsetProvider: Provider<number>;
 }
 
 /**
@@ -20,6 +21,7 @@ export class EventSigningStream extends Transform {
   private priorSignature: string;
   private messageSigner: MessageSigner;
   private eventStreamCodec: EventStreamCodec;
+  private readonly systemClockOffsetProvider: Provider<number>;
 
   constructor(options: EventSigningStreamOptions) {
     super({
@@ -32,11 +34,12 @@ export class EventSigningStream extends Transform {
     this.priorSignature = options.priorSignature;
     this.eventStreamCodec = options.eventStreamCodec;
     this.messageSigner = options.messageSigner;
+    this.systemClockOffsetProvider = options.systemClockOffsetProvider;
   }
 
   async _transform(chunk: Uint8Array, encoding: string, callback: TransformCallback): Promise<void> {
     try {
-      const now = new Date();
+      const now = new Date(Date.now() + (await this.systemClockOffsetProvider()));
       const dateHeader: MessageHeaders = {
         ":date": { type: "timestamp", value: now },
       };

packages/eventstream-handler-node/src/EventStreamPayloadHandler.spec.ts

@@ -90,6 +90,7 @@ describe(EventStreamPayloadHandler.name, () => {
       priorSignature,
       eventStreamCodec: expect.anything(),
       messageSigner: expect.anything(),
+      systemClockOffsetProvider: expect.any(Function),
     });
   });
 
@@ -121,6 +122,7 @@ describe(EventStreamPayloadHandler.name, () => {
       priorSignature,
       eventStreamCodec: expect.anything(),
       messageSigner: expect.anything(),
+      systemClockOffsetProvider: expect.any(Function),
     });
   });
 

packages/eventstream-handler-node/src/EventStreamPayloadHandler.ts

@@ -23,6 +23,7 @@ export interface EventStreamPayloadHandlerOptions {
   messageSigner: Provider<MessageSigner>;
   utf8Encoder: Encoder;
   utf8Decoder: Decoder;
+  systemClockOffset?: number;
 }
 
 /**
@@ -37,10 +38,12 @@ export interface EventStreamPayloadHandlerOptions {
 export class EventStreamPayloadHandler implements IEventStreamPayloadHandler {
   private readonly messageSigner: Provider<MessageSigner>;
   private readonly eventStreamCodec: EventStreamCodec;
+  private readonly systemClockOffsetProvider: Provider<number>;
 
   constructor(options: EventStreamPayloadHandlerOptions) {
     this.messageSigner = options.messageSigner;
     this.eventStreamCodec = new EventStreamCodec(options.utf8Encoder, options.utf8Decoder);
+    this.systemClockOffsetProvider = async () => options.systemClockOffset ?? 0;
   }
 
   async handle<T extends MetadataBearer>(
@@ -79,6 +82,7 @@ export class EventStreamPayloadHandler implements IEventStreamPayloadHandler {
       priorSignature,
       eventStreamCodec: this.eventStreamCodec,
       messageSigner: await this.messageSigner(),
+      systemClockOffsetProvider: this.systemClockOffsetProvider,
     });
 
     pipeline(payloadStream, signingStream, request.body, (err: NodeJS.ErrnoException | null) => {

packages/eventstream-handler-node/src/provider.ts

@@ -14,4 +14,5 @@ export const eventStreamPayloadHandlerProvider: EventStreamPayloadHandlerProvide
   utf8Encoder: Encoder;
   utf8Decoder: Decoder;
   messageSigner: Provider<MessageSigner>;
+  systemClockOffset?: number;
 }) => new EventStreamPayloadHandler(options);

packages/middleware-websocket/src/EventStreamPayloadHandler.spec.ts

@@ -91,7 +91,12 @@ describe(EventStreamPayloadHandler.name, () => {
     });
 
     expect(getEventSigningTransformStream).toHaveBeenCalledTimes(1);
-    expect(getEventSigningTransformStream).toHaveBeenCalledWith(priorSignature, expect.anything(), expect.anything());
+    expect(getEventSigningTransformStream).toHaveBeenCalledWith(
+      priorSignature,
+      expect.anything(),
+      expect.anything(),
+      expect.anything()
+    );
   });
 
   it("should call event signer with request signature from query string if no signature headers are found", async () => {
@@ -118,7 +123,12 @@ describe(EventStreamPayloadHandler.name, () => {
     });
 
     expect(getEventSigningTransformStream).toHaveBeenCalledTimes(1);
-    expect(getEventSigningTransformStream).toHaveBeenCalledWith(priorSignature, expect.anything(), expect.anything());
+    expect(getEventSigningTransformStream).toHaveBeenCalledWith(
+      priorSignature,
+      expect.anything(),
+      expect.anything(),
+      expect.anything()
+    );
   });
 
   it("should start piping to request payload through event signer if downstream middleware returns", async () => {

packages/middleware-websocket/src/EventStreamPayloadHandler.ts

@@ -19,6 +19,7 @@ export interface EventStreamPayloadHandlerOptions {
   messageSigner: Provider<MessageSigner>;
   utf8Encoder: Encoder;
   utf8Decoder: Decoder;
+  systemClockOffset?: number;
 }
 
 /**
@@ -31,10 +32,12 @@ export interface EventStreamPayloadHandlerOptions {
 export class EventStreamPayloadHandler implements IEventStreamPayloadHandler {
   private readonly messageSigner: Provider<MessageSigner>;
   private readonly eventStreamCodec: EventStreamCodec;
+  private readonly systemClockOffsetProvider: Provider<number>;
 
   constructor(options: EventStreamPayloadHandlerOptions) {
     this.messageSigner = options.messageSigner;
     this.eventStreamCodec = new EventStreamCodec(options.utf8Encoder, options.utf8Decoder);
+    this.systemClockOffsetProvider = async () => options.systemClockOffset ?? 0;
   }
 
   async handle<T extends MetadataBearer>(
@@ -69,7 +72,8 @@ export class EventStreamPayloadHandler implements IEventStreamPayloadHandler {
     const signingStream = getEventSigningTransformStream(
       priorSignature,
       await this.messageSigner(),
-      this.eventStreamCodec
+      this.eventStreamCodec,
+      this.systemClockOffsetProvider
     );
 
     const signedPayload = payload.pipeThrough(signingStream);

packages/middleware-websocket/src/eventstream-payload-handler-provider.ts

@@ -7,4 +7,5 @@ export const eventStreamPayloadHandlerProvider: EventStreamPayloadHandlerProvide
   utf8Encoder: Encoder;
   utf8Decoder: Decoder;
   messageSigner: Provider<MessageSigner>;
+  systemClockOffset?: number;
 }) => new EventStreamPayloadHandler(options);

packages/middleware-websocket/src/get-event-signing-stream.spec.ts

@@ -16,7 +16,7 @@ describe(getEventSigningTransformStream.name, () => {
     window.TransformStream = TransformStream;
   });
   afterEach(() => {
-    Date = originalDate;
+    window.Date = originalDate;
     window.TransformStream = originalTransformStreamCtor;
   });
 
@@ -63,24 +63,21 @@ describe(getEventSigningTransformStream.name, () => {
       .mockReturnValueOnce({ message: message1, signature: "7369676e617475726531" } as SignedMessage) //'signature1'
       .mockReturnValueOnce({ message: message2, signature: "7369676e617475726532" } as SignedMessage); //'signature2'
 
-    // mock 'new Date()'
     let mockDateCount = 0;
-    // eslint-disable-next-line @typescript-eslint/no-unused-vars
-    const mockDate = jest
-      .spyOn(window, "Date")
-      //@ts-ignore: https://stackoverflow.com/questions/60912023/jest-typescript-mock-date-constructor/60918716#60918716
-      .mockImplementation((input) => {
-        if (input) return new originalDate(input);
-        mockDateCount += 1;
-        return expected[mockDateCount - 1][":date"].value;
-      });
+    function MockDate(input?: any): Date {
+      return input ? new originalDate(input) : (expected[mockDateCount++][":date"].value as Date);
+    }
+    MockDate.now = () => MockDate().getTime();
+    window.Date = MockDate as any;
+
     const signingStream = getEventSigningTransformStream(
       "initial",
       {
         sign: mockMessageSigner,
         signMessage: mockMessageSigner,
       },
-      eventStreamCodec
+      eventStreamCodec,
+      async () => 0
     );
     const output: Array<MessageHeaders> = [];
 

packages/middleware-websocket/src/get-event-signing-stream.ts

@@ -1,23 +1,26 @@
 import { EventStreamCodec } from "@smithy/eventstream-codec";
-import { MessageHeaders, MessageSigner } from "@smithy/types";
+import { MessageHeaders, MessageSigner, Provider } from "@smithy/types";
 import { fromHex } from "@smithy/util-hex-encoding";
 
 /**
  * Get a transform stream that signs the eventstream
  * Implementation replicated from @aws-sdk/eventstream-handler-node::EventSigningStream
  * but modified to be compatible with WHATWG stream interface
+ *
+ * @internal
  */
 export const getEventSigningTransformStream = (
   initialSignature: string,
   messageSigner: MessageSigner,
-  eventStreamCodec: EventStreamCodec
+  eventStreamCodec: EventStreamCodec,
+  systemClockOffsetProvider: Provider<number>
 ): TransformStream<Uint8Array, Uint8Array> => {
   let priorSignature = initialSignature;
   const transformer: Transformer<Uint8Array, Uint8Array> = {
     start() {},
     async transform(chunk, controller) {
       try {
-        const now = new Date();
+        const now = new Date(Date.now() + (await systemClockOffsetProvider()));
         const dateHeader: MessageHeaders = {
           ":date": { type: "timestamp", value: now },
         };