@aws-sdk/eventstream-handler-node - npm Package Compare versions

Comparing version 3.598.0 to 3.605.0

dist-cjs/index.js

@@ -45,6 +45,7 @@ "use strict";
     this.messageSigner = options.messageSigner;
+    this.systemClockOffsetProvider = options.systemClockOffsetProvider;
   }
   async _transform(chunk, encoding, callback) {
     try {
-      const now = /* @__PURE__ */ new Date();
+      const now = new Date(Date.now() + await this.systemClockOffsetProvider());
       const dateHeader = {
@@ -96,2 +97,3 @@ ":date": { type: "timestamp", value: now }
     this.eventStreamCodec = new import_eventstream_codec.EventStreamCodec(options.utf8Encoder, options.utf8Decoder);
+    this.systemClockOffsetProvider = async () => options.systemClockOffset ?? 0;
   }
@@ -120,3 +122,4 @@ async handle(next, args, context = {}) {
       eventStreamCodec: this.eventStreamCodec,
-      messageSigner: await this.messageSigner()
+      messageSigner: await this.messageSigner(),
+      systemClockOffsetProvider: this.systemClockOffsetProvider
     });
@@ -123,0 +126,0 @@ (0, import_stream.pipeline)(payloadStream, signingStream, request.body, (err) => {

dist-es/EventSigningStream.js

@@ -13,6 +13,7 @@ import { Transform } from "stream";
         this.messageSigner = options.messageSigner;
+        this.systemClockOffsetProvider = options.systemClockOffsetProvider;
     }
     async _transform(chunk, encoding, callback) {
         try {
-            const now = new Date();
+            const now = new Date(Date.now() + (await this.systemClockOffsetProvider()));
             const dateHeader = {
@@ -19,0 +20,0 @@ ":date": { type: "timestamp", value: now },

dist-es/EventStreamPayloadHandler.js

@@ -8,2 +8,3 @@ import { EventStreamCodec } from "@smithy/eventstream-codec";
         this.eventStreamCodec = new EventStreamCodec(options.utf8Encoder, options.utf8Decoder);
+        this.systemClockOffsetProvider = async () => options.systemClockOffset ?? 0;
     }
@@ -34,2 +35,3 @@ async handle(next, args, context = {}) {
             messageSigner: await this.messageSigner(),
+            systemClockOffsetProvider: this.systemClockOffsetProvider,
         });
@@ -36,0 +38,0 @@ pipeline(payloadStream, signingStream, request.body, (err) => {

dist-types/EventSigningStream.d.ts

 /// <reference types="node" />
 import { EventStreamCodec } from "@smithy/eventstream-codec";
-import { MessageSigner } from "@smithy/types";
+import { MessageSigner, Provider } from "@smithy/types";
 import { Transform, TransformCallback, TransformOptions } from "stream";
@@ -12,2 +12,3 @@ /**
     eventStreamCodec: EventStreamCodec;
+    systemClockOffsetProvider: Provider<number>;
 }
@@ -23,4 +24,5 @@ /**
     private eventStreamCodec;
+    private readonly systemClockOffsetProvider;
     constructor(options: EventSigningStreamOptions);
     _transform(chunk: Uint8Array, encoding: string, callback: TransformCallback): Promise<void>;
 }

dist-types/EventStreamPayloadHandler.d.ts

@@ -9,2 +9,3 @@ import { Decoder, Encoder, EventStreamPayloadHandler as IEventStreamPayloadHandler, FinalizeHandler, FinalizeHandlerArguments, FinalizeHandlerOutput, HandlerExecutionContext, MessageSigner, MetadataBearer, Provider } from "@smithy/types";
     utf8Decoder: Decoder;
+    systemClockOffset?: number;
 }
@@ -23,4 +24,5 @@ /**
     private readonly eventStreamCodec;
+    private readonly systemClockOffsetProvider;
     constructor(options: EventStreamPayloadHandlerOptions);
     handle<T extends MetadataBearer>(next: FinalizeHandler<any, T>, args: FinalizeHandlerArguments<any>, context?: HandlerExecutionContext): Promise<FinalizeHandlerOutput<T>>;
 }

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

 import { EventStreamCodec } from "@smithy/eventstream-codec";
-import { MessageSigner } from "@smithy/types";
+import { MessageSigner, Provider } from "@smithy/types";
 import { Transform, TransformCallback, TransformOptions } from "stream";
@@ -8,2 +8,3 @@ export interface EventSigningStreamOptions extends TransformOptions {
   eventStreamCodec: EventStreamCodec;
+  systemClockOffsetProvider: Provider<number>;
 }
@@ -14,2 +15,3 @@ export declare class EventSigningStream extends Transform {
   private eventStreamCodec;
+  private readonly systemClockOffsetProvider;
   constructor(options: EventSigningStreamOptions);
@@ -16,0 +18,0 @@ _transform(

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

@@ -17,2 +17,3 @@ import {
   utf8Decoder: Decoder;
+  systemClockOffset?: number;
 }
@@ -24,2 +25,3 @@ export declare class EventStreamPayloadHandler
   private readonly eventStreamCodec;
+  private readonly systemClockOffsetProvider;
   constructor(options: EventStreamPayloadHandlerOptions);
@@ -26,0 +28,0 @@ handle<T extends MetadataBearer>(

package.json

 {
   "name": "@aws-sdk/eventstream-handler-node",
-  "version": "3.598.0",
+  "version": "3.605.0",
   "scripts": {
@@ -5,0 +5,0 @@ "build": "concurrently 'yarn:build:cjs' 'yarn:build:es' 'yarn:build:types'",

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

26472

increased by3.54%

Lines of code

345

increased by4.23%

No dependency changes