move system clock offset check to AWS SDK

Author: kuhe

packages/middleware-retry/src/configurations.ts

@@ -57,8 +57,6 @@ export interface PreviouslyResolved {
    * @internal
    */
   retryMode: string | Provider<string>;
-
-  systemClockOffset?: number;
 }
 
 /**

packages/middleware-retry/src/retryDecider.ts

@@ -6,6 +6,9 @@ import {
 } from "@smithy/service-error-classification";
 import { SdkError } from "@smithy/types";
 
+/**
+ * @deprecated this is only used in the deprecated StandardRetryStrategy. Do not use in new code.
+ */
 export const defaultRetryDecider = (error: SdkError) => {
   if (!error) {
     return false;

packages/middleware-retry/src/retryMiddleware.ts

@@ -16,16 +16,15 @@ import {
   RetryStrategyV2,
   RetryToken,
   SdkError,
-  SkdErrorWithClockSkewMetadata,
 } from "@smithy/types";
 import { INVOCATION_ID_HEADER, REQUEST_HEADER } from "@smithy/util-retry";
 import { v4 } from "uuid";
 
-import { PreviouslyResolved, RetryResolvedConfig } from "./configurations";
+import { RetryResolvedConfig } from "./configurations";
 import { isStreamingPayload } from "./isStreamingPayload/isStreamingPayload";
 import { asSdkError } from "./util";
 
-export const retryMiddleware = (options: RetryResolvedConfig & Partial<PreviouslyResolved>) => <
+export const retryMiddleware = (options: RetryResolvedConfig) => <
   Output extends MetadataBearer = MetadataBearer
 >(
   next: FinalizeHandler<any, Output>,
@@ -49,30 +48,19 @@ export const retryMiddleware = (options: RetryResolvedConfig & Partial<Previousl
       request.headers[INVOCATION_ID_HEADER] = v4();
     }
 
-    let initialSystemClockOffset = 0;
-
     while (true) {
       try {
         if (isRequest) {
           request.headers[REQUEST_HEADER] = `attempt=${attempts + 1}; max=${maxAttempts}`;
         }
-        initialSystemClockOffset = options.systemClockOffset ?? 0 | 0;
         const { response, output } = await next(args);
         retryStrategy.recordSuccess(retryToken);
         output.$metadata.attempts = attempts + 1;
         output.$metadata.totalRetryDelay = totalRetryDelay;
         return { response, output };
-      } catch (e: unknown) {
-        const latestSystemClockOffset = options.systemClockOffset ?? 0 | 0;
-        const clockSkewCorrected = initialSystemClockOffset !== latestSystemClockOffset;
-
-        const sdkError = e as SkdErrorWithClockSkewMetadata;
-        if (clockSkewCorrected && sdkError.$metadata && typeof sdkError.$metadata === "object") {
-          sdkError.$metadata.clockSkewCorrected = true;
-        }
-
-        const retryErrorInfo = getRetryErrorInfo(sdkError);
-        lastError = asSdkError(sdkError);
+      } catch (e: any) {
+        const retryErrorInfo = getRetryErrorInfo(e);
+        lastError = asSdkError(e);
 
         if (isRequest && isStreamingPayload(request)) {
           (context.logger instanceof NoOpLogger ? console : context.logger)?.warn(
@@ -110,7 +98,7 @@ const isRetryStrategyV2 = (retryStrategy: RetryStrategy | RetryStrategyV2) =>
   typeof (retryStrategy as RetryStrategyV2).refreshRetryTokenForRetry !== "undefined" &&
   typeof (retryStrategy as RetryStrategyV2).recordSuccess !== "undefined";
 
-const getRetryErrorInfo = (error: SkdErrorWithClockSkewMetadata): RetryErrorInfo => {
+const getRetryErrorInfo = (error: SdkError): RetryErrorInfo => {
   const errorInfo: RetryErrorInfo = {
     error,
     errorType: getRetryErrorType(error),
@@ -122,7 +110,7 @@ const getRetryErrorInfo = (error: SkdErrorWithClockSkewMetadata): RetryErrorInfo
   return errorInfo;
 };
 
-const getRetryErrorType = (error: SkdErrorWithClockSkewMetadata): RetryErrorType => {
+const getRetryErrorType = (error: SdkError): RetryErrorType => {
   if (isThrottlingError(error)) return "THROTTLING";
   if (isTransientError(error)) return "TRANSIENT";
   if (isServerError(error)) return "SERVER_ERROR";

packages/service-error-classification/src/index.ts

@@ -10,8 +10,14 @@ import {
 
 export const isRetryableByTrait = (error: SdkError) => error.$retryable !== undefined;
 
+/**
+ * @deprecated use isClockSkewCorrectedError. This is only used in deprecated code.
+ */
 export const isClockSkewError = (error: SdkError) => CLOCK_SKEW_ERROR_CODES.includes(error.name);
 
+export const isClockSkewCorrectedError = (error: SdkError) =>
+  (error as SkdErrorWithClockSkewMetadata).$metadata?.clockSkewCorrected;
+
 export const isThrottlingError = (error: SdkError) =>
   error.$metadata?.httpStatusCode === 429 ||
   THROTTLING_ERROR_CODES.includes(error.name) ||
@@ -24,7 +30,7 @@ export const isThrottlingError = (error: SdkError) =>
  * the name "TimeoutError" to be checked by the TRANSIENT_ERROR_CODES condition.
  */
 export const isTransientError = (error: SdkError | SkdErrorWithClockSkewMetadata) =>
-  (error as SkdErrorWithClockSkewMetadata).$metadata?.clockSkewCorrected ||
+  isClockSkewCorrectedError(error) ||
   TRANSIENT_ERROR_CODES.includes(error.name) ||
   NODEJS_TIMEOUT_ERROR_CODES.includes((error as { code?: string })?.code || "") ||
   TRANSIENT_ERROR_STATUS_CODES.includes(error.$metadata?.httpStatusCode || 0);