feat(storage): migrate storage APIs to AmplifyContext

packages/storage/__tests__/internals/apis/copy.test.ts

@@ -1,12 +1,13 @@
 // Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
 // SPDX-License-Identifier: Apache-2.0
-import { AmplifyClassV6 } from '@aws-amplify/core';
 
 import { copy as advancedCopy } from '../../../src/internals';
 import { copy as copyInternal } from '../../../src/providers/s3/apis/internal/copy';
+import { createMockAmplifyContext } from '../../testUtils/mockAmplifyContext';
 
 jest.mock('../../../src/providers/s3/apis/internal/copy');
 const mockedCopyInternal = jest.mocked(copyInternal);
+const mockCtx = createMockAmplifyContext();
 
 describe('copy (internals)', () => {
 	beforeEach(() => {
@@ -44,10 +45,10 @@ describe('copy (internals)', () => {
 				customEndpoint,
 			},
 		};
-		const result = await advancedCopy(copyInputWithAdvancedOptions);
+		const result = await advancedCopy(mockCtx, copyInputWithAdvancedOptions);
 		expect(mockedCopyInternal).toHaveBeenCalledTimes(1);
 		expect(mockedCopyInternal).toHaveBeenCalledWith(
-			expect.any(AmplifyClassV6),
+			mockCtx,
 			copyInputWithAdvancedOptions,
 		);
 		expect(result).toEqual({

packages/storage/__tests__/internals/apis/downloadData.test.ts

@@ -3,9 +3,11 @@
 
 import { downloadData as advancedDownloadData } from '../../../src/internals';
 import { downloadData as downloadDataInternal } from '../../../src/providers/s3/apis/internal/downloadData';
+import { createMockAmplifyContext } from '../../testUtils/mockAmplifyContext';
 
 jest.mock('../../../src/providers/s3/apis/internal/downloadData');
 const mockedDownloadDataInternal = jest.mocked(downloadDataInternal);
+const mockCtx = createMockAmplifyContext();
 
 describe('downloadData (internal)', () => {
 	beforeEach(() => {
@@ -43,7 +45,7 @@ describe('downloadData (internal)', () => {
 		const onProgress = jest.fn();
 		const bytesRange = { start: 1024, end: 2048 };
 
-		const output = await advancedDownloadData({
+		const output = await advancedDownloadData(mockCtx, {
 			path: 'input/path/to/mock/object',
 			options: {
 				customEndpoint,
@@ -57,7 +59,7 @@ describe('downloadData (internal)', () => {
 		});
 
 		expect(mockedDownloadDataInternal).toHaveBeenCalledTimes(1);
-		expect(mockedDownloadDataInternal).toHaveBeenCalledWith({
+		expect(mockedDownloadDataInternal).toHaveBeenCalledWith(mockCtx, {
 			path: 'input/path/to/mock/object',
 			options: {
 				customEndpoint,

packages/storage/__tests__/internals/apis/getProperties.test.ts

@@ -1,12 +1,13 @@
 // Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
 // SPDX-License-Identifier: Apache-2.0
-import { AmplifyClassV6 } from '@aws-amplify/core';
 
 import { getProperties as advancedGetProperties } from '../../../src/internals';
 import { getProperties as getPropertiesInternal } from '../../../src/providers/s3/apis/internal/getProperties';
+import { createMockAmplifyContext } from '../../testUtils/mockAmplifyContext';
 
 jest.mock('../../../src/providers/s3/apis/internal/getProperties');
 const mockedGetPropertiesInternal = jest.mocked(getPropertiesInternal);
+const mockCtx = createMockAmplifyContext();
 
 describe('getProperties (internal)', () => {
 	beforeEach(() => {
@@ -32,7 +33,7 @@ describe('getProperties (internal)', () => {
 				expiration: new Date(),
 			},
 		});
-		const result = await advancedGetProperties({
+		const result = await advancedGetProperties(mockCtx, {
 			path: 'input/path/to/mock/object',
 			options: {
 				customEndpoint,
@@ -43,19 +44,16 @@ describe('getProperties (internal)', () => {
 			},
 		});
 		expect(mockedGetPropertiesInternal).toHaveBeenCalledTimes(1);
-		expect(mockedGetPropertiesInternal).toHaveBeenCalledWith(
-			expect.any(AmplifyClassV6),
-			{
-				path: 'input/path/to/mock/object',
-				options: {
-					customEndpoint,
-					useAccelerateEndpoint,
-					bucket,
-					expectedBucketOwner,
-					locationCredentialsProvider,
-				},
+		expect(mockedGetPropertiesInternal).toHaveBeenCalledWith(mockCtx, {
+			path: 'input/path/to/mock/object',
+			options: {
+				customEndpoint,
+				useAccelerateEndpoint,
+				bucket,
+				expectedBucketOwner,
+				locationCredentialsProvider,
 			},
-		);
+		});
 		expect(result).toEqual({
 			path: 'output/path/to/mock/object',
 		});

packages/storage/__tests__/internals/apis/getUrl.test.ts

@@ -1,12 +1,13 @@
 // Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
 // SPDX-License-Identifier: Apache-2.0
-import { AmplifyClassV6 } from '@aws-amplify/core';
 
 import { getUrl as advancedGetUrl } from '../../../src/internals';
 import { getUrl as getUrlInternal } from '../../../src/providers/s3/apis/internal/getUrl';
+import { createMockAmplifyContext } from '../../testUtils/mockAmplifyContext';
 
 jest.mock('../../../src/providers/s3/apis/internal/getUrl');
 const mockedGetUrlInternal = jest.mocked(getUrlInternal);
+const mockCtx = createMockAmplifyContext();
 
 const MOCK_URL = new URL('https://s3.aws/mock-presigned-url');
 const MOCK_DATE = new Date();
@@ -41,7 +42,7 @@ describe('getUrl (internal)', () => {
 				expiration: new Date(),
 			},
 		});
-		const result = await advancedGetUrl({
+		const result = await advancedGetUrl(mockCtx, {
 			path: 'input/path/to/mock/object',
 			options: {
 				customEndpoint,
@@ -56,23 +57,20 @@ describe('getUrl (internal)', () => {
 			},
 		});
 		expect(mockedGetUrlInternal).toHaveBeenCalledTimes(1);
-		expect(mockedGetUrlInternal).toHaveBeenCalledWith(
-			expect.any(AmplifyClassV6),
-			{
-				path: 'input/path/to/mock/object',
-				options: {
-					customEndpoint,
-					useAccelerateEndpoint,
-					bucket,
-					validateObjectExistence,
-					expiresIn,
-					contentDisposition,
-					contentType,
-					expectedBucketOwner,
-					locationCredentialsProvider,
-				},
+		expect(mockedGetUrlInternal).toHaveBeenCalledWith(mockCtx, {
+			path: 'input/path/to/mock/object',
+			options: {
+				customEndpoint,
+				useAccelerateEndpoint,
+				bucket,
+				validateObjectExistence,
+				expiresIn,
+				contentDisposition,
+				contentType,
+				expectedBucketOwner,
+				locationCredentialsProvider,
 			},
-		);
+		});
 		expect(result).toEqual({
 			url: MOCK_URL,
 			expiresAt: MOCK_DATE,

packages/storage/__tests__/internals/apis/list.test.ts

@@ -1,12 +1,13 @@
 // Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
 // SPDX-License-Identifier: Apache-2.0
-import { AmplifyClassV6 } from '@aws-amplify/core';
 
 import { list as advancedList } from '../../../src/internals';
 import { list as listInternal } from '../../../src/providers/s3/apis/internal/list';
+import { createMockAmplifyContext } from '../../testUtils/mockAmplifyContext';
 
 jest.mock('../../../src/providers/s3/apis/internal/list');
 const mockedListInternal = jest.mocked(listInternal);
+const mockCtx = createMockAmplifyContext();
 
 describe('list (internals)', () => {
 	beforeEach(() => {
@@ -29,7 +30,7 @@ describe('list (internals)', () => {
 				expiration: new Date(),
 			},
 		});
-		const result = await advancedList({
+		const result = await advancedList(mockCtx, {
 			path: 'input/path/to/mock/object',
 			options: {
 				customEndpoint,
@@ -40,19 +41,16 @@ describe('list (internals)', () => {
 			},
 		});
 		expect(mockedListInternal).toHaveBeenCalledTimes(1);
-		expect(mockedListInternal).toHaveBeenCalledWith(
-			expect.any(AmplifyClassV6),
-			{
-				path: 'input/path/to/mock/object',
-				options: {
-					customEndpoint,
-					useAccelerateEndpoint,
-					bucket,
-					expectedBucketOwner,
-					locationCredentialsProvider,
-				},
+		expect(mockedListInternal).toHaveBeenCalledWith(mockCtx, {
+			path: 'input/path/to/mock/object',
+			options: {
+				customEndpoint,
+				useAccelerateEndpoint,
+				bucket,
+				expectedBucketOwner,
+				locationCredentialsProvider,
 			},
-		);
+		});
 		expect(result).toEqual({
 			items: [],
 		});

packages/storage/__tests__/internals/apis/listPaths/listPaths.test.ts

@@ -1,23 +1,16 @@
 // Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
 // SPDX-License-Identifier: Apache-2.0
 
-import { Amplify, AuthTokens, fetchAuthSession } from '@aws-amplify/core';
+import { AmplifyContext, AuthTokens } from '@aws-amplify/core';
 
 import { resolveLocationsForCurrentSession } from '../../../../src/internals/apis/listPaths/resolveLocationsForCurrentSession';
 import { getHighestPrecedenceUserGroup } from '../../../../src/internals/apis/listPaths/getHighestPrecedenceUserGroup';
 import { listPaths } from '../../../../src/internals';
+import {
+	StorageValidationErrorCode,
+	validationErrorMap,
+} from '../../../../src/errors/types/validation';
 
-jest.mock('@aws-amplify/core', () => ({
-	ConsoleLogger: jest.fn(),
-	Amplify: {
-		getConfig: jest.fn(),
-		Auth: {
-			getConfig: jest.fn(),
-			fetchAuthSession: jest.fn(),
-		},
-	},
-	fetchAuthSession: jest.fn(),
-}));
 jest.mock(
 	'../../../../src/internals/apis/listPaths/resolveLocationsForCurrentSession',
 );
@@ -32,8 +25,20 @@ const credentials = {
 };
 const identityId = 'identityId';
 
-const mockGetConfig = jest.mocked(Amplify.getConfig);
-const mockFetchAuthSession = jest.mocked(fetchAuthSession);
+const mockGetConfig = jest.fn();
+const mockFetchAuthSession = jest.fn();
+// listPaths now receives a required AmplifyContext. Back resourcesConfig with
+// a jest.fn so tests can vary config per-case, and expose fetchAuthSession as a
+// jest.fn for session/token control.
+const mockCtx: AmplifyContext = {
+	get resourcesConfig() {
+		return mockGetConfig();
+	},
+	libraryOptions: {},
+	fetchAuthSession: mockFetchAuthSession,
+	clearCredentials: jest.fn(),
+	getTokens: jest.fn(),
+};
 const mockResolveLocationsFromCurrentSession =
 	resolveLocationsForCurrentSession as jest.Mock;
 const mockGetHighestPrecedenceUserGroup = jest.mocked(
@@ -99,7 +104,7 @@ describe('listPaths', () => {
 			Storage: { S3: { buckets: undefined } },
 		});
 
-		const result = await listPaths();
+		const result = await listPaths(mockCtx);
 
 		expect(result).toEqual({ locations: [] });
 	});
@@ -118,7 +123,7 @@ describe('listPaths', () => {
 			},
 		]);
 
-		const result = await listPaths();
+		const result = await listPaths(mockCtx);
 
 		expect(result).toEqual({
 			locations: [
@@ -157,7 +162,7 @@ describe('listPaths', () => {
 				prefix: '/path1',
 			},
 		});
-		await listPaths();
+		await listPaths(mockCtx);
 
 		expect(mockResolveLocationsFromCurrentSession).toHaveBeenCalled();
 		expect(mockResolveLocationsFromCurrentSession).toHaveBeenCalledWith({
@@ -189,7 +194,7 @@ describe('listPaths', () => {
 		});
 		mockGetHighestPrecedenceUserGroup.mockReturnValue('admin');
 
-		await listPaths();
+		await listPaths(mockCtx);
 
 		expect(mockResolveLocationsFromCurrentSession).toHaveBeenCalled();
 		expect(mockResolveLocationsFromCurrentSession).toHaveBeenCalledWith({
@@ -199,4 +204,36 @@ describe('listPaths', () => {
 			userGroup: 'admin',
 		});
 	});
+
+	it('should throw StorageValidationError with NoS3Config when Storage.S3 is missing', async () => {
+		mockGetConfig.mockReturnValue({
+			...mockAuthConfig,
+			Storage: undefined,
+		});
+
+		await expect(listPaths(mockCtx)).rejects.toMatchObject({
+			name: StorageValidationErrorCode.NoS3Config,
+			message:
+				validationErrorMap[StorageValidationErrorCode.NoS3Config].message,
+		});
+	});
+
+	it('should throw StorageValidationError with NoAuthConfig when Auth.Cognito is missing', async () => {
+		mockGetConfig.mockReturnValue({
+			Auth: undefined,
+			Storage: {
+				S3: {
+					bucket: 'bucket1',
+					region: 'region1',
+					buckets: mockBuckets,
+				},
+			},
+		});
+
+		await expect(listPaths(mockCtx)).rejects.toMatchObject({
+			name: StorageValidationErrorCode.NoAuthConfig,
+			message:
+				validationErrorMap[StorageValidationErrorCode.NoAuthConfig].message,
+		});
+	});
 });