release(required): Amplify JS release (#14447)

Author: adrianjoshua-strutt

.github/CODEOWNERS

@@ -15,24 +15,24 @@
 
 # The following paths involve server-side use cases, token/user session management.
 # Changes made to these paths requires additional reviews and approvals.
-/packages/auth @cshfang @HuiSF @ashika112 @maxbeck-amzn @calebpollman
-/packages/aws-amplify/src/adapter-core @cshfang @HuiSF @ashika112 @maxbeck-amzn @calebpollman
-/packages/core/src/adapterCore @cshfang @HuiSF @ashika112 @maxbeck-amzn @calebpollman
-/packages/core/src/singleton @cshfang @HuiSF @ashika112 @maxbeck-amzn @calebpollman
-/packages/core/src/utils/convert @cshfang @HuiSF @ashika112 @maxbeck-amzn @calebpollman
-/packages/core/src/utils/WordArray.ts @cshfang @HuiSF @ashika112 @maxbeck-amzn @calebpollman
-/packages/core/src/storage @cshfang @HuiSF @ashika112 @maxbeck-amzn @calebpollman
-/packages/core/src/utils/generateRandomString.ts @cshfang @HuiSF @ashika112 @maxbeck-amzn @calebpollman
-/packages/core/src/utils/globalHelpers @cshfang @HuiSF @ashika112 @maxbeck-amzn @calebpollman
-/packages/core/src/utils/urlSafeDecode.ts @cshfang @HuiSF @ashika112 @maxbeck-amzn @calebpollman
-/packages/core/src/awsClients/cognitoIdentity @cshfang @HuiSF @ashika112 @maxbeck-amzn @calebpollman
-/packages/core/src/clients/internal @cshfang @HuiSF @ashika112 @maxbeck-amzn @calebpollman
-/packages/core/src/Hub @cshfang @HuiSF @ashika112 @maxbeck-amzn @calebpollman
-/packages/adapter-nextjs @cshfang @HuiSF @ashika112 @maxbeck-amzn @calebpollman
-/packages/rtn-web-browser @cshfang @HuiSF @ashika112 @maxbeck-amzn @calebpollman
-/packages/storage/src/providers/s3/apis/internal @cshfang @HuiSF @ashika112 @maxbeck-amzn @calebpollman
-/packages/storage/src/providers/s3/apis/server @cshfang @HuiSF @ashika112 @maxbeck-amzn @calebpollman
-/packages/api-rest/src/apis/server.ts @cshfang @HuiSF @ashika112 @maxbeck-amzn @calebpollman
-/packages/api-rest/src/apis/common/internalPost.ts @cshfang @HuiSF @ashika112 @maxbeck-amzn @calebpollman
-/packages/api-graphql/src/server @cshfang @HuiSF @ashika112 @maxbeck-amzn @calebpollman
-/packages/api-graphql/src/internals/server @cshfang @HuiSF @ashika112 @maxbeck-amzn @calebpollman
+/packages/auth @pranavosu @sobolk @Amplifiyer @avi-karthik 
+/packages/aws-amplify/src/adapter-core @pranavosu @sobolk @Amplifiyer @avi-karthik 
+/packages/core/src/adapterCore @pranavosu @sobolk @Amplifiyer @avi-karthik 
+/packages/core/src/singleton @pranavosu @sobolk @Amplifiyer @avi-karthik 
+/packages/core/src/utils/convert @pranavosu @sobolk @Amplifiyer @avi-karthik 
+/packages/core/src/utils/WordArray.ts @pranavosu @sobolk @Amplifiyer @avi-karthik 
+/packages/core/src/storage @pranavosu @sobolk @Amplifiyer @avi-karthik 
+/packages/core/src/utils/generateRandomString.ts @pranavosu @sobolk @Amplifiyer @avi-karthik 
+/packages/core/src/utils/globalHelpers @pranavosu @sobolk @Amplifiyer @avi-karthik 
+/packages/core/src/utils/urlSafeDecode.ts @pranavosu @sobolk @Amplifiyer @avi-karthik 
+/packages/core/src/awsClients/cognitoIdentity @pranavosu @sobolk @Amplifiyer @avi-karthik 
+/packages/core/src/clients/internal @pranavosu @sobolk @Amplifiyer @avi-karthik 
+/packages/core/src/Hub @pranavosu @sobolk @Amplifiyer @avi-karthik 
+/packages/adapter-nextjs @pranavosu @sobolk @Amplifiyer @avi-karthik 
+/packages/rtn-web-browser @pranavosu @sobolk @Amplifiyer @avi-karthik 
+/packages/storage/src/providers/s3/apis/internal @pranavosu @sobolk @Amplifiyer @avi-karthik 
+/packages/storage/src/providers/s3/apis/server @pranavosu @sobolk @Amplifiyer @avi-karthik 
+/packages/api-rest/src/apis/server.ts @pranavosu @sobolk @Amplifiyer @avi-karthik 
+/packages/api-rest/src/apis/common/internalPost.ts @pranavosu @sobolk @Amplifiyer @avi-karthik 
+/packages/api-graphql/src/server @pranavosu @sobolk @Amplifiyer @avi-karthik 
+/packages/api-graphql/src/internals/server @pranavosu @sobolk @Amplifiyer @avi-karthik 

packages/api-graphql/__tests__/AWSAppSyncEventProvider.test.ts

@@ -60,6 +60,64 @@ jest.mock('@aws-amplify/core', () => {
 });
 
 describe('AppSyncEventProvider', () => {
+	describe('connect', () => {
+		let fakeWebSocketInterface: FakeWebSocketInterface;
+		const loggerSpy: jest.SpyInstance = jest.spyOn(
+			ConsoleLogger.prototype,
+			'_log',
+		);
+		let provider: AWSAppSyncEventProvider;
+		beforeEach(async () => {
+			fakeWebSocketInterface = new FakeWebSocketInterface();
+			provider = new AWSAppSyncEventProvider();
+
+			Object.defineProperty(provider, 'socketStatus', {
+				value: constants.SOCKET_STATUS.CLOSED,
+			});
+			
+			jest.spyOn(provider as any, '_getNewWebSocket').mockImplementation(() => {
+				fakeWebSocketInterface.newWebSocket();
+				return fakeWebSocketInterface.webSocket as WebSocket;
+			});
+		})
+
+		afterEach(async () => {
+			provider?.close();
+			await fakeWebSocketInterface?.closeInterface();
+			fakeWebSocketInterface?.teardown();
+			loggerSpy.mockClear();
+		});
+
+		test('socket status should be READY', async () => {
+
+			// Connect to the provider
+			const connectPromise = provider.connect({
+				appSyncGraphqlEndpoint: 'ws://localhost:8080',
+				authenticationType: 'apiKey',
+				apiKey: 'test-api-key',
+				region: 'us-east-1'
+			});
+
+			// Verify the socket status to be CONNECTING
+			await new Promise(resolve => setTimeout(resolve, 1));
+			expect((provider as any).socketStatus).toBe(constants.SOCKET_STATUS.CONNECTING);
+
+			// Trigger the websocket open event
+			await fakeWebSocketInterface.readyForUse;
+			await fakeWebSocketInterface.triggerOpen();
+
+			// Initiate handshake			
+			await fakeWebSocketInterface.sendDataMessage({
+				type: MESSAGE_TYPES.GQL_CONNECTION_ACK
+			});
+
+			// Wait for connection to complete
+			await connectPromise;
+
+			// Verify the socket status
+			expect((provider as any).socketStatus).toBe(constants.SOCKET_STATUS.READY);
+		});
+	});
 	describe('subscribe()', () => {
 		describe('returned observer', () => {
 			describe('connection logic with mocked websocket', () => {

packages/api-graphql/src/Providers/AWSAppSyncEventsProvider/index.ts

@@ -61,7 +61,7 @@ export class AWSAppSyncEventProvider extends AWSWebSocketProvider {
 	}
 
 	public async connect(options: AWSAppSyncEventProviderOptions) {
-		super.connect(options);
+		return super.connect(options);
 	}
 
 	public subscribe(

packages/auth/src/foundation/factories/serviceClients/cognitoIdentityProvider/constants.ts

@@ -14,6 +14,8 @@ export const DEFAULT_SERVICE_CLIENT_API_CONFIG = {
 	service: COGNITO_IDP_SERVICE_NAME,
 	retryDecider: getRetryDecider(parseJsonError),
 	computeDelay: jitteredBackoff,
-	userAgentValue: getAmplifyUserAgent(),
+	get userAgentValue() {
+		return getAmplifyUserAgent();
+	},
 	cache: 'no-store',
 };

packages/aws-amplify/package.json

@@ -307,7 +307,7 @@
 			"name": "[Analytics] record (Pinpoint)",
 			"path": "./dist/esm/analytics/index.mjs",
 			"import": "{ record }",
-			"limit": "17.92 kB"
+			"limit": "17.98 kB"
 		},
 		{
 			"name": "[Analytics] record (Kinesis)",
@@ -331,7 +331,7 @@
 			"name": "[Analytics] identifyUser (Pinpoint)",
 			"path": "./dist/esm/analytics/index.mjs",
 			"import": "{ identifyUser }",
-			"limit": "16.40 kB"
+			"limit": "16.42 kB"
 		},
 		{
 			"name": "[Analytics] enable",
@@ -367,13 +367,13 @@
 			"name": "[Auth] resetPassword (Cognito)",
 			"path": "./dist/esm/auth/index.mjs",
 			"import": "{ resetPassword }",
-			"limit": "13.31 kB"
+			"limit": "13.32 kB"
 		},
 		{
 			"name": "[Auth] confirmResetPassword (Cognito)",
 			"path": "./dist/esm/auth/index.mjs",
 			"import": "{ confirmResetPassword }",
-			"limit": "13.25 kB"
+			"limit": "13.26 kB"
 		},
 		{
 			"name": "[Auth] signIn (Cognito)",
@@ -421,13 +421,13 @@
 			"name": "[Auth] updatePassword (Cognito)",
 			"path": "./dist/esm/auth/index.mjs",
 			"import": "{ updatePassword }",
-			"limit": "13.61 kB"
+			"limit": "13.62 kB"
 		},
 		{
 			"name": "[Auth] setUpTOTP (Cognito)",
 			"path": "./dist/esm/auth/index.mjs",
 			"import": "{ setUpTOTP }",
-			"limit": "13.89 kB"
+			"limit": "13.91 kB"
 		},
 		{
 			"name": "[Auth] updateUserAttributes (Cognito)",
@@ -451,7 +451,7 @@
 			"name": "[Auth] signInWithRedirect (Cognito)",
 			"path": "./dist/esm/auth/index.mjs",
 			"import": "{ signInWithRedirect }",
-			"limit": "19.35 kB"
+			"limit": "19.37 kB"
 		},
 		{
 			"name": "[Auth] fetchUserAttributes (Cognito)",
@@ -469,7 +469,7 @@
 			"name": "[Auth] OAuth Auth Flow (Cognito)",
 			"path": "./dist/esm/auth/index.mjs",
 			"import": "{ signInWithRedirect, signOut, fetchAuthSession }",
-			"limit": "19.92 kB"
+			"limit": "19.93 kB"
 		},
 		{
 			"name": "[Auth] Associate WebAuthN Credential (Cognito)",
@@ -493,25 +493,25 @@
 			"name": "[Storage] copy (S3)",
 			"path": "./dist/esm/storage/index.mjs",
 			"import": "{ copy }",
-			"limit": "16.90 kB"
+			"limit": "16.93 kB"
 		},
 		{
 			"name": "[Storage] downloadData (S3)",
 			"path": "./dist/esm/storage/index.mjs",
 			"import": "{ downloadData }",
-			"limit": "17.26 kB"
+			"limit": "17.29 kB"
 		},
 		{
 			"name": "[Storage] getProperties (S3)",
 			"path": "./dist/esm/storage/index.mjs",
 			"import": "{ getProperties }",
-			"limit": "16.50 kB"
+			"limit": "16.51 kB"
 		},
 		{
 			"name": "[Storage] getUrl (S3)",
 			"path": "./dist/esm/storage/index.mjs",
 			"import": "{ getUrl }",
-			"limit": "17.75 kB"
+			"limit": "17.77 kB"
 		},
 		{
 			"name": "[Storage] list (S3)",
@@ -523,7 +523,7 @@
 			"name": "[Storage] remove (S3)",
 			"path": "./dist/esm/storage/index.mjs",
 			"import": "{ remove }",
-			"limit": "16.40 kB"
+			"limit": "16.41 kB"
 		},
 		{
 			"name": "[Storage] uploadData (S3)",

packages/core/src/awsClients/pinpoint/base.ts

@@ -31,7 +31,9 @@ export const defaultConfig = {
 	endpointResolver,
 	retryDecider: getRetryDecider(parseJsonError),
 	computeDelay: jitteredBackoff,
-	userAgentValue: getAmplifyUserAgent(),
+	get userAgentValue() {
+		return getAmplifyUserAgent();
+	},
 };
 
 /**

packages/core/src/singleton/Amplify.ts

@@ -19,6 +19,8 @@ export class AmplifyClass {
 		| ((authConfig: AuthConfig['Cognito']) => void)
 		| undefined = undefined;
 
+	private isConfigured = false;
+
 	resourcesConfig: ResourcesConfig;
 	libraryOptions: LibraryOptions;
 
@@ -76,6 +78,7 @@ export class AmplifyClass {
 		);
 
 		this.notifyOAuthListener();
+		this.isConfigured = true;
 	}
 
 	/**
@@ -84,6 +87,13 @@ export class AmplifyClass {
 	 * @returns Returns the immutable back-end resource configuration.
 	 */
 	getConfig(): Readonly<ResourcesConfig> {
+		if (!this.isConfigured) {
+			// eslint-disable-next-line no-console
+			console.warn(
+				`Amplify has not been configured. Please call Amplify.configure() before using this service.`,
+			);
+		}
+
 		return this.resourcesConfig;
 	}
 

packages/storage/src/providers/s3/utils/client/s3control/base.ts

@@ -107,6 +107,8 @@ export const defaultConfig = {
 	endpointResolver,
 	retryDecider,
 	computeDelay: jitteredBackoff,
-	userAgentValue: getAmplifyUserAgent(),
+	get userAgentValue() {
+		return getAmplifyUserAgent();
+	},
 	uriEscapePath: false, // Required by S3. See https://github.com/aws/aws-sdk-js-v3/blob/9ba012dfa3a3429aa2db0f90b3b0b3a7a31f9bc3/packages/signature-v4/src/SignatureV4.ts#L76-L83
 };

packages/storage/src/providers/s3/utils/client/s3data/base.ts

@@ -153,7 +153,9 @@ export const defaultConfig = {
 	endpointResolver,
 	retryDecider,
 	computeDelay: jitteredBackoff,
-	userAgentValue: getAmplifyUserAgent(),
+	get userAgentValue() {
+		return getAmplifyUserAgent();
+	},
 	useAccelerateEndpoint: false,
 	uriEscapePath: false, // Required by S3. See https://github.com/aws/aws-sdk-js-v3/blob/9ba012dfa3a3429aa2db0f90b3b0b3a7a31f9bc3/packages/signature-v4/src/SignatureV4.ts#L76-L83
 };