chore: kickoff release

Author: thisisabhash

.github/CODEOWNERS

@@ -1,16 +1 @@
 * @aws-amplify/amplify-ios 
-
-# This covers
-# - Amplify/Categories/DataStore/**
-# - Amplify/Categories/API/**
-# - AmplifyPlugins/DataStore/**
-# - AmplifyPlugins/API/**
-# - AmplifyPlugins/Core/AWSPuginsCore/**
-# - AmplifyTests/CategoryTests/DataStore/**
-# - AmplifyTestCommon/Models
-**/DataStore/**  @aws-amplify/amplify-data @aws-amplify/amplify-ios
-**/API/**  @aws-amplify/amplify-data @aws-amplify/amplify-ios
-**/Core/**  @aws-amplify/amplify-data @aws-amplify/amplify-ios
-/AmplifyTestCommon/Models/** @aws-amplify/amplify-data @aws-amplify/amplify-ios
-/.circleci @aws-amplify/amplify-data @aws-amplify/amplify-ios
-/.github @aws-amplify/amplify-data @aws-amplify/amplify-ios

.github/composite_actions/run_xcodebuild_test/action.yml

@@ -12,6 +12,14 @@ inputs:
     required: false
     type: string
     default: 'platform=iOS Simulator,name=iPhone 13,OS=latest'
+  sdk:
+    required: false
+    type: string
+    default: 'iphonesimulator'
+  other_flags:
+    required: false
+    type: string
+    default: ''
 
 runs:
   using: "composite"
@@ -22,5 +30,5 @@ runs:
         PROJECT_PATH: ${{ inputs.project_path }}
       run: |
         cd $PROJECT_PATH
-        xcodebuild test -scheme $SCHEME -sdk iphonesimulator -destination '${{ inputs.destination }}' | xcpretty --simple --color --report junit && exit ${PIPESTATUS[0]}        
+        xcodebuild test -scheme $SCHEME -sdk '${{ inputs.sdk }}' -destination '${{ inputs.destination }}' ${{ inputs.other_flags }} | xcpretty --simple --color --report junit && exit ${PIPESTATUS[0]}        
       shell: bash 

.github/workflows/integ_test_api.yml

@@ -82,6 +82,33 @@ jobs:
           project_path: ./AmplifyPlugins/API/Tests/APIHostApp
           scheme: AWSAPIPluginGraphQLUserPoolTests
 
+  api-graphql-auth-directive-test:
+    if: ${{ false }}
+    needs: prepare-for-test
+    runs-on: macos-12
+    environment: IntegrationTest
+    steps:
+      - uses: actions/checkout@2541b1294d2704b0964813337f33b291d3f8596b
+        with:
+          persist-credentials: false
+
+      - name: Make directory
+        run: mkdir -p ~/.aws-amplify/amplify-ios/testconfiguration/
+
+      - name: Copy integration test resouces
+        uses: ./.github/composite_actions/download_test_configuration
+        with:
+          resource_subfolder: api
+          aws_role_to_assume: ${{ secrets.AWS_ROLE_TO_ASSUME }}
+          aws_region: ${{ secrets.AWS_REGION }}
+          aws_s3_bucket: ${{ secrets.AWS_S3_BUCKET_INTEG }}
+
+      - name: Run Integration test
+        uses: ./.github/composite_actions/run_xcodebuild_test
+        with:
+          project_path: ./AmplifyPlugins/API/Tests/APIHostApp
+          scheme: AWSAPIPluginGraphQLAuthDirectiveTests
+
   api-graphql-iam-test:
     if: ${{ false }}
     needs: prepare-for-test

.github/workflows/nightly_repeated_unittest.yml

@@ -0,0 +1,46 @@
+name: Amplify Nightly Repeated Unit Test
+on:
+  workflow_dispatch:
+  schedule:
+    - cron: '30 1 * * *'
+
+permissions:
+    contents: read
+
+concurrency:
+  group: ${{ github.head_ref || github.run_id }}
+  cancel-in-progress: true
+
+jobs:
+  unit_test_ios:
+    runs-on: macos-12
+    strategy:
+      matrix:
+        scheme: [Amplify, AWSPluginsCore, AWSPinpointAnalyticsPlugin, AWSAPIPlugin, AWSCognitoAuthPlugin, AWSDataStorePlugin, AWSLocationGeoPlugin, AWSS3StoragePlugin]
+    steps:
+      - uses: actions/checkout@2541b1294d2704b0964813337f33b291d3f8596b
+
+      - name: Run repeated unit test iOS
+        uses: ./.github/composite_actions/run_xcodebuild_test
+        with:
+          project_path: .
+          scheme: ${{ matrix.scheme }}
+          other_flags: -test-iterations 100 -run-tests-until-failure
+
+  unit_test_macos:
+    runs-on: macos-12
+    strategy:
+      matrix:
+        scheme: [Amplify, AWSPluginsCore, AWSPinpointAnalyticsPlugin, AWSAPIPlugin, AWSCognitoAuthPlugin, AWSDataStorePlugin, AWSLocationGeoPlugin, AWSS3StoragePlugin]
+    steps:
+      - uses: actions/checkout@2541b1294d2704b0964813337f33b291d3f8596b
+
+      - name: Run repeated unit test macOS
+        uses: ./.github/composite_actions/run_xcodebuild_test
+        with:
+          project_path: .
+          scheme: ${{ matrix.scheme }}
+          sdk: macosx
+          destination: platform=macOS,arch=x86_64
+          other_flags: -test-iterations 100 -run-tests-until-failure
+      

.github/workflows/release_merge_pr.yml

@@ -81,15 +81,17 @@ public class AWSGraphQLSubscriptionTaskRunner<R: Decodable>: InternalTaskRunner,
         // Retrieve request plugin option and
         // auth type in case of a multi-auth setup
         let pluginOptions = request.options.pluginOptions as? AWSPluginOptions
+        let urlRequest = generateSubscriptionURLRequest(from: endpointConfig)
 
         // Retrieve the subscription connection
         subscriptionQueue.sync {
             do {
                 subscriptionConnection = try subscriptionConnectionFactory
                     .getOrCreateConnection(for: endpointConfig,
-                                              authService: authService,
-                                              authType: pluginOptions?.authType,
-                                              apiAuthProviderFactory: apiAuthProviderFactory)
+                                           urlRequest: urlRequest,
+                                           authService: authService,
+                                           authType: pluginOptions?.authType,
+                                           apiAuthProviderFactory: apiAuthProviderFactory)
             } catch {
                 let error = APIError.operationError("Unable to get connection for api \(endpointConfig.name)", "", error)
                 fail(error)
@@ -105,6 +107,14 @@ public class AWSGraphQLSubscriptionTaskRunner<R: Decodable>: InternalTaskRunner,
             })
         }
     }
+
+    private func generateSubscriptionURLRequest(
+        from endpointConfig: AWSAPICategoryPluginConfiguration.EndpointConfig
+    ) -> URLRequest {
+        var urlRequest = URLRequest(url: endpointConfig.baseURL)
+        urlRequest.setValue(AWSAPIPluginsCore.baseUserAgent(), forHTTPHeaderField: URLRequestConstants.Header.userAgent)
+        return urlRequest
+    }
 
     // MARK: - Subscription callbacks
 
@@ -269,15 +279,17 @@ final public class AWSGraphQLSubscriptionOperation<R: Decodable>: GraphQLSubscri
         // Retrieve request plugin option and
         // auth type in case of a multi-auth setup
         let pluginOptions = request.options.pluginOptions as? AWSPluginOptions
+        let urlRequest = generateSubscriptionURLRequest(from: endpointConfig)
 
         // Retrieve the subscription connection
         subscriptionQueue.sync {
             do {
                 subscriptionConnection = try subscriptionConnectionFactory
                     .getOrCreateConnection(for: endpointConfig,
-                                              authService: authService,
-                                              authType: pluginOptions?.authType,
-                                              apiAuthProviderFactory: apiAuthProviderFactory)
+                                           urlRequest: urlRequest,
+                                           authService: authService,
+                                           authType: pluginOptions?.authType,
+                                           apiAuthProviderFactory: apiAuthProviderFactory)
             } catch {
                 let error = APIError.operationError("Unable to get connection for api \(endpointConfig.name)", "", error)
                 dispatch(result: .failure(error))
@@ -295,6 +307,14 @@ final public class AWSGraphQLSubscriptionOperation<R: Decodable>: GraphQLSubscri
         }
     }
 
+    private func generateSubscriptionURLRequest(
+        from endpointConfig: AWSAPICategoryPluginConfiguration.EndpointConfig
+    ) -> URLRequest {
+        var urlRequest = URLRequest(url: endpointConfig.baseURL)
+        urlRequest.setValue(AWSAPIPluginsCore.baseUserAgent(), forHTTPHeaderField: URLRequestConstants.Header.userAgent)
+        return urlRequest
+    }
+
     // MARK: - Subscription callbacks
 
     private func onAsyncSubscriptionEvent(event: SubscriptionItemEvent) {

AmplifyPlugins/API/Sources/AWSAPIPlugin/Operation/AWSGraphQLSubscriptionTaskRunner.swift

@@ -22,23 +22,25 @@ class AWSSubscriptionConnectionFactory: SubscriptionConnectionFactory {
 
     private var apiToConnectionProvider: [MapperCacheKey: ConnectionProvider] = [:]
 
-    func getOrCreateConnection(for endpointConfig: AWSAPICategoryPluginConfiguration.EndpointConfig,
-                               authService: AWSAuthServiceBehavior,
-                               authType: AWSAuthorizationType? = nil,
-                               apiAuthProviderFactory: APIAuthProviderFactory) throws -> SubscriptionConnection {
+    func getOrCreateConnection(
+        for endpointConfig: AWSAPICategoryPluginConfiguration.EndpointConfig,
+        urlRequest: URLRequest,
+        authService: AWSAuthServiceBehavior,
+        authType: AWSAuthorizationType? = nil,
+        apiAuthProviderFactory: APIAuthProviderFactory
+    ) throws -> SubscriptionConnection {
         return try concurrencyQueue.sync {
             let apiName = endpointConfig.name
 
-            let url = endpointConfig.baseURL
-
-            let authInterceptor = try getInterceptor(for: getOrCreateAuthConfiguration(from: endpointConfig,
-                                                                                       authType: authType),
-                                                     authService: authService,
-                                                     apiAuthProviderFactory: apiAuthProviderFactory)
+            let authInterceptor = try self.getInterceptor(
+                for: self.getOrCreateAuthConfiguration(from: endpointConfig, authType: authType),
+                authService: authService,
+                apiAuthProviderFactory: apiAuthProviderFactory
+            )
 
             // create or retrieve the connection provider. If creating, add interceptors onto the provider.
             let connectionProvider = apiToConnectionProvider[MapperCacheKey(apiName: apiName, authType: authType)] ??
-                ConnectionProviderFactory.createConnectionProviderAsync(for: url,
+                ConnectionProviderFactory.createConnectionProviderAsync(for: urlRequest,
                                                                         authInterceptor: authInterceptor,
                                                                         connectionType: .appSyncRealtime)
 

AmplifyPlugins/API/Sources/AWSAPIPlugin/SubscriptionFactory/AWSSubscriptionConnectionFactory.swift

@@ -5,6 +5,8 @@
 // SPDX-License-Identifier: Apache-2.0
 //
 
+import Foundation
+
 import Amplify
 import AWSPluginsCore
 import AppSyncRealTimeClient
@@ -14,6 +16,7 @@ protocol SubscriptionConnectionFactory {
 
     /// Get connection based on the connection type
     func getOrCreateConnection(for endpointConfig: AWSAPICategoryPluginConfiguration.EndpointConfig,
+                               urlRequest: URLRequest,
                                authService: AWSAuthServiceBehavior,
                                authType: AWSAuthorizationType?,
                                apiAuthProviderFactory: APIAuthProviderFactory) throws -> SubscriptionConnection