chore(datastore): Add stress tests for Datastore category (#2639)

* chore(datastore): Add stress tests for Datastore category

* Add separate resources and test target for stress tests in CI/CD

* Address review comments

* Address review comments

* Address review comments

Author: thisisabhash

AmplifyPlugins/DataStore/Tests/DataStoreHostApp/AWSDataStorePluginIntegrationTests/DataStoreEndToEndTests.swift

@@ -479,106 +479,6 @@ class DataStoreEndToEndTests: SyncEngineIntegrationTestBase {
         try await Amplify.DataStore.start()
     }
 
-    /// Perform concurrent saves and observe the data successfuly synced from cloud. Then delete the items afterwards
-    /// and ensure they have successfully synced from cloud
-    ///
-    /// - Given: DataStore is in ready state
-    /// - When:
-    ///    - Concurrently perform Save's
-    /// - Then:
-    ///    - Ensure the expected mutation event with version 1 (synced from cloud) is received
-    ///    - Clean up: Concurrently perform Delete's
-    ///    - Ensure the expected mutation event with version 2 (synced from cloud) is received
-    ///
-    func testConcurrentSave() async throws {
-        await setUp(withModels: TestModelRegistration(), logLevel: .verbose)
-        try await startAmplifyAndWaitForSync()
-
-        var posts = [Post]()
-        let count = 2
-        for index in 0 ..< count {
-            let post = Post(title: "title \(index)",
-                            content: "content",
-                            createdAt: .now())
-            posts.append(post)
-        }
-        let postsSyncedToCloud = expectation(description: "All posts saved and synced to cloud")
-        postsSyncedToCloud.expectedFulfillmentCount = count
-        log.debug("Created posts: [\(posts.map { $0.identifier })]")
-
-        let postsCopy = posts
-        Task {
-            var postsSyncedToCloudCount = 0
-            let mutationEvents = Amplify.DataStore.observe(Post.self)
-            do {
-                for try await mutationEvent in mutationEvents {
-                    guard postsCopy.contains(where: { $0.id == mutationEvent.modelId }) else {
-                        return
-                    }
-
-                    if mutationEvent.mutationType == MutationEvent.MutationType.create.rawValue,
-                       mutationEvent.version == 1 {
-                        postsSyncedToCloudCount += 1
-                        self.log.debug("Post saved and synced from cloud \(mutationEvent.modelId) \(postsSyncedToCloudCount)")
-                        postsSyncedToCloud.fulfill()
-                    }
-                }
-            } catch {
-                XCTFail("Failed \(error)")
-            }
-        }
-
-        let capturedPosts = posts
-
-        DispatchQueue.concurrentPerform(iterations: count) { index in
-            Task {
-                _ = try await Amplify.DataStore.save(capturedPosts[index])
-            }
-        }
-        await waitForExpectations(timeout: 100)
-
-        let postsDeletedLocally = expectation(description: "All posts deleted locally")
-        postsDeletedLocally.expectedFulfillmentCount = count
-
-        let postsDeletedFromCloud = expectation(description: "All posts deleted and synced to cloud")
-        postsDeletedFromCloud.expectedFulfillmentCount = count
-        
-        Task {
-            var postsDeletedFromCloudCount = 0
-            let mutationEvents = Amplify.DataStore.observe(Post.self)
-            do {
-                for try await mutationEvent in mutationEvents {
-                    guard capturedPosts.contains(where: { $0.id == mutationEvent.modelId }) else {
-                        return
-                    }
-
-                    if mutationEvent.mutationType == MutationEvent.MutationType.delete.rawValue,
-                              mutationEvent.version == 1 {
-                        self.log.debug(
-                            "Post deleted locally \(mutationEvent.modelId)")
-                        postsDeletedLocally.fulfill()
-                    } else if mutationEvent.mutationType == MutationEvent.MutationType.delete.rawValue,
-                              mutationEvent.version == 2 {
-                        postsDeletedFromCloudCount += 1
-                        self.log.debug(
-                            "Post deleted and synced from cloud \(mutationEvent.modelId) \(postsDeletedFromCloudCount)")
-                        postsDeletedFromCloud.fulfill()
-                    }
-                }
-            } catch {
-                XCTFail("Failed \(error)")
-            }
-        }
-        
-        DispatchQueue.concurrentPerform(iterations: count) { index in
-            Task {
-                try await Amplify.DataStore.delete(capturedPosts[index])
-            }
-        }
-        
-        await waitForExpectations(timeout: 100)
-    }
-
     // MARK: - Helpers
 
     func validateSavePost() async throws {