chore(auth): debounce refreshAuthTokens

packages/auth/src/providers/cognito/utils/refreshAuthTokens.ts

@@ -6,14 +6,15 @@ import { AuthConfig } from '@aws-amplify/core';
 import {
 	assertTokenProviderConfig,
 	decodeJWT,
+	deDupCallback,
 } from '@aws-amplify/core/internals/utils';
 import { initiateAuth } from '../utils/clients/CognitoIdentityProvider';
 import { getRegion } from '../utils/clients/CognitoIdentityProvider/utils';
 import { assertAuthTokensWithRefreshToken } from '../utils/types';
 import { AuthError } from '../../../errors/AuthError';
 import { getUserContextData } from './userContextData';
 
-export const refreshAuthTokens: TokenRefresher = async ({
+const refreshAuthTokensCallback: TokenRefresher = async ({
 	tokens,
 	authConfig,
 	username,
@@ -72,3 +73,5 @@ export const refreshAuthTokens: TokenRefresher = async ({
 		username,
 	};
 };
+
+export const refreshAuthTokens = deDupCallback(refreshAuthTokensCallback);

packages/aws-amplify/package.json

@@ -300,13 +300,13 @@
 			"name": "[Analytics] record (Kinesis)",
 			"path": "./dist/esm/analytics/kinesis/index.mjs",
 			"import": "{ record }",
-			"limit": "44.47 kB"
+			"limit": "44.48 kB"
 		},
 		{
 			"name": "[Analytics] record (Kinesis Firehose)",
 			"path": "./dist/esm/analytics/kinesis-firehose/index.mjs",
 			"import": "{ record }",
-			"limit": "41.50 kB"
+			"limit": "41.54 kB"
 		},
 		{
 			"name": "[Analytics] record (Personalize)",
@@ -396,19 +396,19 @@
 			"name": "[Auth] fetchMFAPreference (Cognito)",
 			"path": "./dist/esm/auth/index.mjs",
 			"import": "{ fetchMFAPreference }",
-			"limit": "8.30 kB"
+			"limit": "8.35 kB"
 		},
 		{
 			"name": "[Auth] verifyTOTPSetup (Cognito)",
 			"path": "./dist/esm/auth/index.mjs",
 			"import": "{ verifyTOTPSetup }",
-			"limit": "9.13 kB"
+			"limit": "9.18 kB"
 		},
 		{
 			"name": "[Auth] updatePassword (Cognito)",
 			"path": "./dist/esm/auth/index.mjs",
 			"import": "{ updatePassword }",
-			"limit": "9.14 kB"
+			"limit": "9.19 kB"
 		},
 		{
 			"name": "[Auth] setUpTOTP (Cognito)",
@@ -420,7 +420,7 @@
 			"name": "[Auth] updateUserAttributes (Cognito)",
 			"path": "./dist/esm/auth/index.mjs",
 			"import": "{ updateUserAttributes }",
-			"limit": "8.41 kB"
+			"limit": "8.46 kB"
 		},
 		{
 			"name": "[Auth] getCurrentUser (Cognito)",
@@ -432,7 +432,7 @@
 			"name": "[Auth] confirmUserAttribute (Cognito)",
 			"path": "./dist/esm/auth/index.mjs",
 			"import": "{ confirmUserAttribute }",
-			"limit": "9.15 kB"
+			"limit": "9.19 kB"
 		},
 		{
 			"name": "[Auth] signInWithRedirect (Cognito)",

packages/core/__tests__/utils/debounceCallback.test.ts

@@ -0,0 +1,46 @@
+import { debounceCallback } from '../../src/utils/debounceCallback';
+
+describe('test debounce callback', () => {
+	const numberOfConcurrentCalls = 10;
+	const mockServiceCallback = jest.fn();
+
+	afterEach(() => {
+		mockServiceCallback.mockClear();
+	});
+
+	it('should allow to invoke the callback when there is no concurrent calls', async () => {
+		const debouncedCallback = debounceCallback(mockServiceCallback);
+
+		debouncedCallback();
+		expect(mockServiceCallback).toHaveBeenCalledTimes(1);
+	});
+
+	it('should invoke the callback one time during concurrent sync calls', () => {
+		const debouncedCallback = debounceCallback(mockServiceCallback);
+		for (let i = 0; i < numberOfConcurrentCalls; i++) {
+			debouncedCallback();
+		}
+		expect(mockServiceCallback).toHaveBeenCalledTimes(1);
+	});
+
+	it('should allow to invoke the callback again after the promise has being resolved', async () => {
+		const debouncedCallback = debounceCallback(mockServiceCallback);
+		for (let i = 0; i < numberOfConcurrentCalls; i++) {
+			debouncedCallback();
+		}
+
+		await debouncedCallback();
+
+		debouncedCallback();
+		expect(mockServiceCallback).toHaveBeenCalledTimes(2);
+	});
+
+	it('should return a value once the callback is resolved', async () => {
+		const mockReturnValue = { id: 1 };
+		mockServiceCallback.mockImplementation(() => mockReturnValue);
+		const debouncedCallback = debounceCallback(mockServiceCallback);
+		const result = await debouncedCallback();
+		expect(result).toEqual(mockReturnValue);
+		expect(mockServiceCallback).toHaveBeenCalledTimes(1);
+	});
+});

packages/core/src/libraryUtils.ts

@@ -17,6 +17,7 @@ export {
 	retry,
 	urlSafeDecode,
 	urlSafeEncode,
+	deDupCallback,
 } from './utils';
 export { parseAWSExports } from './parseAWSExports';
 export { LegacyConfig } from './singleton/types';

packages/core/src/singleton/apis/fetchAuthSession.ts

@@ -3,10 +3,8 @@
 
 import { fetchAuthSession as fetchAuthSessionInternal } from './internal/fetchAuthSession';
 import { Amplify } from '../Amplify';
-import { AuthSession, FetchAuthSessionOptions } from '../Auth/types';
+import { FetchAuthSessionOptions } from '../Auth/types';
 
-export const fetchAuthSession = (
-	options?: FetchAuthSessionOptions
-): Promise<AuthSession> => {
+export const fetchAuthSession = (options?: FetchAuthSessionOptions) => {
 	return fetchAuthSessionInternal(Amplify, options);
 };

packages/core/src/utils/deDupCallback.ts

@@ -0,0 +1,34 @@
+// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+// SPDX-License-Identifier: Apache-2.0
+
+/**
+ * returns inflight promise if there hasn't been resolved yet
+ *
+ * @param callback - callback to be deDup.
+ * @returns - the return type of the callback
+ */
+export const deDupCallback = <F extends (...args: any[]) => any>(
+	callback: F
+) => {
+	let inflightPromise: Promise<Awaited<ReturnType<F>>> | undefined;
+	return async (...args: Parameters<F>): Promise<Awaited<ReturnType<F>>> => {
+		if (inflightPromise) return inflightPromise;
+
+		if (!inflightPromise) {
+			inflightPromise = new Promise(async (resolve, reject) => {
+				try {
+					const result = await callback(...args);
+					resolve(result);
+				} catch (error) {
+					reject(error);
+				}
+			});
+		}
+
+		try {
+			return await inflightPromise;
+		} finally {
+			inflightPromise = undefined;
+		}
+	};
+};

packages/core/src/utils/index.ts

@@ -15,3 +15,4 @@ export {
 export { urlSafeDecode } from './urlSafeDecode';
 export { urlSafeEncode } from './urlSafeEncode';
 export { deepFreeze } from './deepFreeze';
+export { deDupCallback } from './deDupCallback';

packages/datastore/src/sync/processors/subscription.ts

@@ -279,7 +279,7 @@ class SubscriptionProcessor {
 
 				try {
 					// retrieving current token info from Cognito UserPools
-					const session = await await fetchAuthSession();
+					const session = await fetchAuthSession();
 					oidcTokenPayload = session.tokens?.idToken?.payload;
 				} catch (err) {
 					// best effort to get jwt from Cognito