fix(core): retry after clock skew correction

Author: kuhe

packages/core/src/middleware-http-signing/httpSigningMiddleware.ts

@@ -35,11 +35,18 @@ const defaultSuccessHandler: SuccessHandler = (
   signingProperties: Record<string, unknown>
 ): void => {};
 
+/**
+ * @internal
+ */
+interface HttpSigningMiddlewarePreviouslyResolved {
+  systemClockOffset?: number;
+}
+
 /**
  * @internal
  */
 export const httpSigningMiddleware = <Input extends object, Output extends object>(
-  config: object
+  config: HttpSigningMiddlewarePreviouslyResolved
 ): FinalizeRequestMiddleware<Input, Output> => (
   next: FinalizeHandler<Input, Output>,
   context: HttpSigningMiddlewareHandlerExecutionContext
@@ -60,10 +67,35 @@ export const httpSigningMiddleware = <Input extends object, Output extends objec
     identity,
     signer,
   } = scheme;
-  const output = await next({
-    ...args,
-    request: await signer.sign(args.request, identity, signingProperties),
-  }).catch((signer.errorHandler || defaultErrorHandler)(signingProperties));
-  (signer.successHandler || defaultSuccessHandler)(output.response, signingProperties);
+  const lastSystemClockOffset = config.systemClockOffset | 0;
+
+  const makeSignedRequest = async () =>
+    next({
+      ...args,
+      request: await signer.sign(args.request as HttpRequest, identity, signingProperties),
+    });
+
+  const onError = (signer.errorHandler || defaultErrorHandler)(signingProperties);
+  const onSuccess = signer.successHandler || defaultSuccessHandler;
+
+  const output = await makeSignedRequest().catch(async (error: unknown) => {
+    let thrownError: unknown;
+    try {
+      onError(error as Error);
+    } catch (e) {
+      thrownError = e;
+    }
+    const latestSystemClockOffset = config.systemClockOffset | 0;
+    const systemClockOffsetModified = lastSystemClockOffset !== latestSystemClockOffset;
+
+    if (systemClockOffsetModified) {
+      return makeSignedRequest().catch(onError);
+    } else {
+      if (thrownError) {
+        throw thrownError;
+      }
+    }
+  });
+  onSuccess(output.response, signingProperties);
   return output;
 };