Revert "chore(auth): debounce refreshAuthTokens (#12845)"

This reverts commit 5fc446e.
aws-amplify · Jan 18, 2024 · 182b97a · 182b97a
1 parent 5fc446e
commit 182b97a
Show file tree

Hide file tree

Showing 8 changed files with 14 additions and 105 deletions.
diff --git a/packages/auth/src/providers/cognito/utils/refreshAuthTokens.ts b/packages/auth/src/providers/cognito/utils/refreshAuthTokens.ts
@@ -6,15 +6,14 @@ import { AuthConfig } from '@aws-amplify/core';
 import {
 	assertTokenProviderConfig,
 	decodeJWT,
-	deDupeAsyncFunction,
 } 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';
 
-const refreshAuthTokensFunction: TokenRefresher = async ({
+export const refreshAuthTokens: TokenRefresher = async ({
 	tokens,
 	authConfig,
 	username,
@@ -73,5 +72,3 @@ const refreshAuthTokensFunction: TokenRefresher = async ({
 		username,
 	};
 };
-
-export const refreshAuthTokens = deDupeAsyncFunction(refreshAuthTokensFunction);
diff --git a/packages/aws-amplify/package.json b/packages/aws-amplify/package.json
@@ -300,13 +300,13 @@
 			"name": "[Analytics] record (Kinesis)",
 			"path": "./dist/esm/analytics/kinesis/index.mjs",
 			"import": "{ record }",
-			"limit": "44.48 kB"
+			"limit": "44.47 kB"
 		},
 		{
 			"name": "[Analytics] record (Kinesis Firehose)",
 			"path": "./dist/esm/analytics/kinesis-firehose/index.mjs",
 			"import": "{ record }",
-			"limit": "41.54 kB"
+			"limit": "41.50 kB"
 		},
 		{
 			"name": "[Analytics] record (Personalize)",
@@ -384,7 +384,7 @@
 			"name": "[Auth] confirmSignIn (Cognito)",
 			"path": "./dist/esm/auth/index.mjs",
 			"import": "{ confirmSignIn }",
-			"limit": "25.94 kB"
+			"limit": "25.89 kB"
 		},
 		{
 			"name": "[Auth] updateMFAPreference (Cognito)",
@@ -396,19 +396,19 @@
 			"name": "[Auth] fetchMFAPreference (Cognito)",
 			"path": "./dist/esm/auth/index.mjs",
 			"import": "{ fetchMFAPreference }",
-			"limit": "8.35 kB"
+			"limit": "8.30 kB"
 		},
 		{
 			"name": "[Auth] verifyTOTPSetup (Cognito)",
 			"path": "./dist/esm/auth/index.mjs",
 			"import": "{ verifyTOTPSetup }",
-			"limit": "9.18 kB"
+			"limit": "9.13 kB"
 		},
 		{
 			"name": "[Auth] updatePassword (Cognito)",
 			"path": "./dist/esm/auth/index.mjs",
 			"import": "{ updatePassword }",
-			"limit": "9.19 kB"
+			"limit": "9.14 kB"
 		},
 		{
 			"name": "[Auth] setUpTOTP (Cognito)",
@@ -420,7 +420,7 @@
 			"name": "[Auth] updateUserAttributes (Cognito)",
 			"path": "./dist/esm/auth/index.mjs",
 			"import": "{ updateUserAttributes }",
-			"limit": "8.46 kB"
+			"limit": "8.41 kB"
 		},
 		{
 			"name": "[Auth] getCurrentUser (Cognito)",
@@ -432,7 +432,7 @@
 			"name": "[Auth] confirmUserAttribute (Cognito)",
 			"path": "./dist/esm/auth/index.mjs",
 			"import": "{ confirmUserAttribute }",
-			"limit": "9.19 kB"
+			"limit": "9.15 kB"
 		},
 		{
 			"name": "[Auth] signInWithRedirect (Cognito)",

diff --git a/packages/core/__tests__/utils/deDupeAsyncRequests.test.ts b/packages/core/__tests__/utils/deDupeAsyncRequests.test.ts
diff --git a/packages/core/src/libraryUtils.ts b/packages/core/src/libraryUtils.ts
@@ -17,7 +17,6 @@ export {
 	retry,
 	urlSafeDecode,
 	urlSafeEncode,
-	deDupeAsyncFunction,
 } from './utils';
 export { parseAWSExports } from './parseAWSExports';
 export { LegacyConfig } from './singleton/types';

diff --git a/packages/core/src/singleton/apis/fetchAuthSession.ts b/packages/core/src/singleton/apis/fetchAuthSession.ts
@@ -3,8 +3,10 @@
 
 import { fetchAuthSession as fetchAuthSessionInternal } from './internal/fetchAuthSession';
 import { Amplify } from '../Amplify';
-import { FetchAuthSessionOptions } from '../Auth/types';
+import { AuthSession, FetchAuthSessionOptions } from '../Auth/types';
 
-export const fetchAuthSession = (options?: FetchAuthSessionOptions) => {
+export const fetchAuthSession = (
+	options?: FetchAuthSessionOptions
+): Promise<AuthSession> => {
 	return fetchAuthSessionInternal(Amplify, options);
 };
diff --git a/packages/core/src/utils/deDupeAsyncFunction.ts b/packages/core/src/utils/deDupeAsyncFunction.ts
diff --git a/packages/core/src/utils/index.ts b/packages/core/src/utils/index.ts
@@ -15,4 +15,3 @@ export {
 export { urlSafeDecode } from './urlSafeDecode';
 export { urlSafeEncode } from './urlSafeEncode';
 export { deepFreeze } from './deepFreeze';
-export { deDupeAsyncFunction } from './deDupeAsyncFunction';
diff --git a/packages/datastore/src/sync/processors/subscription.ts b/packages/datastore/src/sync/processors/subscription.ts
@@ -279,7 +279,7 @@ class SubscriptionProcessor {
 
 				try {
 					// retrieving current token info from Cognito UserPools
-					const session = await fetchAuthSession();
+					const session = await await fetchAuthSession();
 					oidcTokenPayload = session.tokens?.idToken?.payload;
 				} catch (err) {
 					// best effort to get jwt from Cognito