feat(datastore): refactor datastore category to use APICategoryGraphQLBehavior

.swiftpm/xcode/xcshareddata/xcschemes/Amplify-Package.xcscheme

@@ -482,6 +482,48 @@
                ReferencedContainer = "container:">
             </BuildableReference>
          </BuildActionEntry>
+         <BuildActionEntry
+            buildForTesting = "YES"
+            buildForRunning = "YES"
+            buildForProfiling = "YES"
+            buildForArchiving = "YES"
+            buildForAnalyzing = "YES">
+            <BuildableReference
+               BuildableIdentifier = "primary"
+               BlueprintIdentifier = "AWSPluginsSDKCore"
+               BuildableName = "AWSPluginsSDKCore"
+               BlueprintName = "AWSPluginsSDKCore"
+               ReferencedContainer = "container:">
+            </BuildableReference>
+         </BuildActionEntry>
+         <BuildActionEntry
+            buildForTesting = "YES"
+            buildForRunning = "YES"
+            buildForProfiling = "YES"
+            buildForArchiving = "YES"
+            buildForAnalyzing = "YES">
+            <BuildableReference
+               BuildableIdentifier = "primary"
+               BlueprintIdentifier = "AmplifyCredentials"
+               BuildableName = "AmplifyCredentials"
+               BlueprintName = "AmplifyCredentials"
+               ReferencedContainer = "container:">
+            </BuildableReference>
+         </BuildActionEntry>
+         <BuildActionEntry
+            buildForTesting = "YES"
+            buildForRunning = "YES"
+            buildForProfiling = "YES"
+            buildForArchiving = "YES"
+            buildForAnalyzing = "YES">
+            <BuildableReference
+               BuildableIdentifier = "primary"
+               BlueprintIdentifier = "InternalAmplifyCredentials"
+               BuildableName = "InternalAmplifyCredentials"
+               BlueprintName = "InternalAmplifyCredentials"
+               ReferencedContainer = "container:">
+            </BuildableReference>
+         </BuildActionEntry>
       </BuildActionEntries>
    </BuildAction>
    <TestAction
@@ -741,6 +783,56 @@
                ReferencedContainer = "container:">
             </BuildableReference>
          </TestableReference>
+         <TestableReference
+            skipped = "NO">
+            <BuildableReference
+               BuildableIdentifier = "primary"
+               BlueprintIdentifier = "AmplifyNetworkUnitTests"
+               BuildableName = "AmplifyNetworkUnitTests"
+               BlueprintName = "AmplifyNetworkUnitTests"
+               ReferencedContainer = "container:">
+            </BuildableReference>
+         </TestableReference>
+         <TestableReference
+            skipped = "NO">
+            <BuildableReference
+               BuildableIdentifier = "primary"
+               BlueprintIdentifier = "InternalAmplifyNetworkUnitTests"
+               BuildableName = "InternalAmplifyNetworkUnitTests"
+               BlueprintName = "InternalAmplifyNetworkUnitTests"
+               ReferencedContainer = "container:">
+            </BuildableReference>
+         </TestableReference>
+         <TestableReference
+            skipped = "NO">
+            <BuildableReference
+               BuildableIdentifier = "primary"
+               BlueprintIdentifier = "AWSPluginsSDKCoreTests"
+               BuildableName = "AWSPluginsSDKCoreTests"
+               BlueprintName = "AWSPluginsSDKCoreTests"
+               ReferencedContainer = "container:">
+            </BuildableReference>
+         </TestableReference>
+         <TestableReference
+            skipped = "NO">
+            <BuildableReference
+               BuildableIdentifier = "primary"
+               BlueprintIdentifier = "AmplifyCredentialsTests"
+               BuildableName = "AmplifyCredentialsTests"
+               BlueprintName = "AmplifyCredentialsTests"
+               ReferencedContainer = "container:">
+            </BuildableReference>
+         </TestableReference>
+         <TestableReference
+            skipped = "NO">
+            <BuildableReference
+               BuildableIdentifier = "primary"
+               BlueprintIdentifier = "InternalAmplifyCredentialsTests"
+               BuildableName = "InternalAmplifyCredentialsTests"
+               BlueprintName = "InternalAmplifyCredentialsTests"
+               ReferencedContainer = "container:">
+            </BuildableReference>
+         </TestableReference>
       </Testables>
    </TestAction>
    <LaunchAction

Amplify/Categories/API/Operation/NondeterminsticOperation.swift

@@ -0,0 +1,100 @@
+//
+// Copyright Amazon.com Inc. or its affiliates.
+// All Rights Reserved.
+//
+// SPDX-License-Identifier: Apache-2.0
+//
+
+
+import Combine
+/**
+ A non-deterministic operation offers multiple paths to accomplish its task.
+ It attempts the next path if all preceding paths have failed with an error that allows for continuation.
+ */
+enum NondeterminsticOperationError: Error {
+    case totalFailure
+    case cancelled
+}
+
+final class NondeterminsticOperation<T> {
+    /// operation that to be eval
+    typealias Operation = () async throws -> T
+    typealias OnError = (Error) -> Bool
+
+    private let operations: AsyncStream<Operation>
+    private var shouldTryNextOnError: OnError = { _ in true }
+    private var cancellables = Set<AnyCancellable>()
+    private var task: Task<Void, Never>?
+
+    deinit {
+        cancel()
+    }
+
+    init(operations: AsyncStream<Operation>, shouldTryNextOnError: OnError? = nil) {
+        self.operations = operations
+        if let shouldTryNextOnError {
+            self.shouldTryNextOnError = shouldTryNextOnError
+        }
+    }
+
+    convenience init(
+        operationStream: AnyPublisher<Operation, Never>,
+        shouldTryNextOnError: OnError? = nil
+    ) {
+        var cancellables = Set<AnyCancellable>()
+        let (asyncStream, continuation) = AsyncStream.makeStream(of: Operation.self)
+        operationStream.sink { _ in
+            continuation.finish()
+        } receiveValue: {
+            continuation.yield($0)
+        }.store(in: &cancellables)
+
+        self.init(
+            operations: asyncStream,
+            shouldTryNextOnError: shouldTryNextOnError
+        )
+        self.cancellables = cancellables
+    }
+
+    /// Synchronous version of executing the operations
+    func execute() -> Future<T, Error> {
+        Future { [weak self] promise in
+            self?.task = Task { [weak self] in
+                do {
+                    if let self {
+                        promise(.success(try await self.run()))
+                    } else {
+                        promise(.failure(NondeterminsticOperationError.cancelled))
+                    }
+                } catch {
+                    promise(.failure(error))
+                }
+            }
+        }
+    }
+
+    /// Asynchronous version of executing the operations
+    func run() async throws -> T {
+        for await operation in operations {
+            if Task.isCancelled {
+                throw NondeterminsticOperationError.cancelled
+            }
+            do {
+                return try await operation()
+            } catch {
+                if shouldTryNextOnError(error) {
+                    continue
+                } else {
+                    throw error
+                }
+            }
+        }
+        throw NondeterminsticOperationError.totalFailure
+    }
+
+    /// Cancel the operation
+    func cancel() {
+        task?.cancel()
+        cancellables = Set<AnyCancellable>()
+    }
+}