feat: add introspection, query & resolver limits properties in appsync graphql api

integration/resources/expected/single/graphqlapi-configuration.json

@@ -0,0 +1,59 @@
+[
+    {
+      "LogicalResourceId": "SuperCoolAPI",
+      "ResourceType": "AWS::AppSync::GraphQLApi"
+    },
+    {
+      "LogicalResourceId": "SuperCoolAPICloudWatchRole",
+      "ResourceType": "AWS::IAM::Role"
+    },
+    {
+      "LogicalResourceId": "SuperCoolAPISchema",
+      "ResourceType": "AWS::AppSync::GraphQLSchema"
+    },
+    {
+      "LogicalResourceId": "SuperCoolAPIQuerygetBook",
+      "ResourceType": "AWS::AppSync::Resolver"
+    },
+    {
+      "LogicalResourceId": "SuperCoolAPINoneDataSource",
+      "ResourceType": "AWS::AppSync::DataSource"
+    },
+    {
+      "LogicalResourceId": "SuperCoolAPIprocessQuery",
+      "ResourceType": "AWS::AppSync::FunctionConfiguration"
+    },
+    {
+      "LogicalResourceId": "SuperCoolAPIMyApiKey",
+      "ResourceType": "AWS::AppSync::ApiKey"
+    },
+    {
+      "LogicalResourceId": "IntrospectionDisableSuperCoolAPI",
+      "ResourceType": "AWS::AppSync::GraphQLApi"
+    },
+    {
+      "LogicalResourceId": "IntrospectionDisableSuperCoolAPICloudWatchRole",
+      "ResourceType": "AWS::IAM::Role"
+    },
+    {
+      "LogicalResourceId": "IntrospectionDisableSuperCoolAPISchema",
+      "ResourceType": "AWS::AppSync::GraphQLSchema"
+    },
+    {
+      "LogicalResourceId": "IntrospectionDisableSuperCoolAPIQuerygetBook",
+      "ResourceType": "AWS::AppSync::Resolver"
+    },
+    {
+      "LogicalResourceId": "IntrospectionDisableSuperCoolAPINoneDataSource",
+      "ResourceType": "AWS::AppSync::DataSource"
+    },
+    {
+      "LogicalResourceId": "IntrospectionDisableSuperCoolAPIprocessQuery",
+      "ResourceType": "AWS::AppSync::FunctionConfiguration"
+    },
+    {
+      "LogicalResourceId": "IntrospectionDisableSuperCoolAPIMyApiKey",
+      "ResourceType": "AWS::AppSync::ApiKey"
+    }
+  ]
+

integration/resources/templates/single/graphqlapi-configuration.yaml

@@ -0,0 +1,94 @@
+Transform: AWS::Serverless-2016-10-31
+Resources:
+  SuperCoolAPI:
+    Type: AWS::Serverless::GraphQLApi
+    Properties:
+      SchemaInline: |
+        type Book {
+            bookName: String
+            id: ID
+        } 
+        type Query { getBook(bookName: String): Book }
+      OwnerContact: blah-blah
+      Auth:
+        Type: API_KEY
+      ApiKeys:
+        MyApiKey: {}
+      Functions:
+        processQuery:
+          Runtime:
+            Name: APPSYNC_JS
+            Version: 1.0.0
+          DataSource: NONE
+          InlineCode: |
+            import { util } from '@aws-appsync/utils';
+
+            export function request(ctx) {
+              const id = util.autoId();
+              return { payload: { ...ctx.args, id } };
+            }
+
+            export function response(ctx) {
+              return ctx.result;
+            }
+      Resolvers:
+        Query:
+          getBook:
+            Pipeline:
+            - processQuery
+
+  IntrospectionDisableSuperCoolAPI:
+    Type: AWS::Serverless::GraphQLApi
+    Properties:
+      SchemaInline: |
+        type Book {
+            bookName: String
+            id: ID
+        } 
+        type Query { getBook(bookName: String): Book }
+      OwnerContact: blah-blah
+      IntrospectionConfig: DISABLED
+      QueryDepthLimit: 10
+      ResolverCountLimit: 100
+      Auth:
+        Type: API_KEY
+      ApiKeys:
+        MyApiKey: {}
+      Functions:
+        processQuery:
+          Runtime:
+            Name: APPSYNC_JS
+            Version: 1.0.0
+          DataSource: NONE
+          InlineCode: |
+            import { util } from '@aws-appsync/utils';
+
+            export function request(ctx) {
+              const id = util.autoId();
+              return { payload: { ...ctx.args, id } };
+            }
+
+            export function response(ctx) {
+              return ctx.result;
+            }
+      Resolvers:
+        Query:
+          getBook:
+            Pipeline:
+            - processQuery
+Outputs:
+  SuperCoolAPI:
+    Description: AppSync API
+    Value: !GetAtt SuperCoolAPI.GraphQLUrl
+  MyApiKey:
+    Description: API Id
+    Value: !GetAtt SuperCoolAPIMyApiKey.ApiKey
+  IntrospectionDisableSuperCoolAPI:
+    Description: AppSync API
+    Value: !GetAtt IntrospectionDisableSuperCoolAPI.GraphQLUrl
+  IntrospectionDisableSuperCoolAPIMyApiKey:
+    Description: API Id
+    Value: !GetAtt IntrospectionDisableSuperCoolAPIMyApiKey.ApiKey
+
+Metadata:
+  SamTransformTest: true

integration/single/test_graphqlapi_configuration.py

@@ -0,0 +1,81 @@
+import json
+from unittest.case import skipIf
+
+import pytest
+import requests
+
+from integration.config.service_names import APP_SYNC
+from integration.helpers.base_test import BaseTest
+from integration.helpers.resource import current_region_does_not_support
+
+
+def execute_and_verify_appsync_query(url, api_key, query):
+    """
+    Executes a query to an AppSync GraphQLApi.
+
+    Also checks that the response is 200 and does not contain errors before returning.
+    """
+    headers = {
+        "Content-Type": "application/json",
+        "x-api-key": api_key,
+    }
+    payload = {"query": query}
+
+    response = requests.post(url, json=payload, headers=headers)
+    response.raise_for_status()
+    data = response.json()
+    if "errors" in data:
+        raise Exception(json.dumps(data["errors"]))
+
+    return data
+
+
+@skipIf(current_region_does_not_support([APP_SYNC]), "AppSync is not supported in this testing region")
+@pytest.mark.filterwarnings("ignore::DeprecationWarning")
+class TestGraphQLApiConfiguration(BaseTest):
+    def test_api(self):
+        file_name = "single/graphqlapi-configuration"
+        self.create_and_verify_stack(file_name)
+
+        outputs = self.get_stack_outputs()
+
+        url = outputs["SuperCoolAPI"]
+        api_key = outputs["MyApiKey"]
+
+        introspection_disable_api_url = outputs["IntrospectionDisableSuperCoolAPI"]
+        introspection_disable_api_key = outputs["IntrospectionDisableSuperCoolAPIMyApiKey"]
+
+        book_name = "GoodBook"
+        query = f"""
+            query MyQuery {{
+              getBook(
+                bookName: "{book_name}"
+              ) {{
+                id
+                bookName
+              }}
+            }}
+        """
+
+        response = execute_and_verify_appsync_query(url, api_key, query)
+        self.assertEqual(response["data"]["getBook"]["bookName"], book_name)
+
+        introspection_disable_query_response = execute_and_verify_appsync_query(introspection_disable_api_url, introspection_disable_api_key, query)
+        self.assertEqual(introspection_disable_query_response["data"]["getBook"]["bookName"], book_name)
+
+        query_introsepction = f"""
+            query myQuery {{
+              __schema {{ 
+                types {{
+                  name
+                }}
+               }}
+            }}
+        """
+
+        introspection_query_response = execute_and_verify_appsync_query(url, api_key, query_introsepction)
+        self.assertIsNotNone(introspection_query_response["data"]["__schema"])
+
+        # sending introspection query and expecting error as introspection is DISABLED for this API using template file
+        with self.assertRaises(Exception):
+            execute_and_verify_appsync_query(introspection_disable_api_url, introspection_disable_api_key, query_introsepction)

samtranslator/internal/model/appsync.py

@@ -115,6 +115,9 @@ class GraphQLApi(Resource):
         "AdditionalAuthenticationProviders": GeneratedProperty(),
         "Visibility": GeneratedProperty(),
         "OwnerContact": GeneratedProperty(),
+        "IntrospectionConfig": GeneratedProperty(),
+        "QueryDepthLimit": GeneratedProperty(),
+        "ResolverCountLimit": GeneratedProperty(),
     }
 
     Name: str
@@ -128,6 +131,9 @@ class GraphQLApi(Resource):
     LogConfig: Optional[LogConfigType]
     Visibility: Optional[str]
     OwnerContact: Optional[str]
+    IntrospectionConfig: Optional[str]
+    QueryDepthLimit: Optional[int]
+    ResolverCountLimit: Optional[int]
 
     runtime_attrs = {"api_id": lambda self: fnGetAtt(self.logical_id, "ApiId")}
 

samtranslator/internal/schema_source/aws_serverless_graphqlapi.py

@@ -164,6 +164,9 @@ class Properties(BaseModel):
     Cache: Optional[Cache]
     Visibility: Optional[PassThroughProp]
     OwnerContact: Optional[PassThroughProp]
+    IntrospectionConfig: Optional[PassThroughProp]
+    QueryDepthLimit: Optional[PassThroughProp]
+    ResolverCountLimit: Optional[PassThroughProp]
 
 
 class Resource(BaseModel):

samtranslator/model/sam_resources.py

@@ -2226,6 +2226,9 @@ class SamGraphQLApi(SamResourceMacro):
         "Cache": Property(False, IS_DICT),
         "Visibility": PassThroughProperty(False),
         "OwnerContact": PassThroughProperty(False),
+        "IntrospectionConfig": PassThroughProperty(False),
+        "QueryDepthLimit": PassThroughProperty(False),
+        "ResolverCountLimit": PassThroughProperty(False),
     }
 
     Auth: List[Dict[str, Any]]
@@ -2243,6 +2246,9 @@ class SamGraphQLApi(SamResourceMacro):
     Cache: Optional[Dict[str, Any]]
     Visibility: Optional[PassThrough]
     OwnerContact: Optional[PassThrough]
+    IntrospectionConfig: Optional[PassThrough]
+    QueryDepthLimit: Optional[PassThrough]
+    ResolverCountLimit: Optional[PassThrough]
 
     # stop validation so we can use class variables for tracking state
     validate_setattr = False
@@ -2322,6 +2328,13 @@ def _construct_appsync_api_resources(
             api.OwnerContact = passthrough_value(model.OwnerContact)
         api.XrayEnabled = model.XrayEnabled
 
+        if model.IntrospectionConfig:
+            api.IntrospectionConfig = passthrough_value(model.IntrospectionConfig)
+        if model.QueryDepthLimit:
+            api.QueryDepthLimit = passthrough_value(model.QueryDepthLimit)
+        if model.ResolverCountLimit:
+            api.ResolverCountLimit = passthrough_value(model.ResolverCountLimit)
+
         lambda_auth_arns = self._parse_and_set_auth_properties(api, model.Auth)
         auth_connectors = [
             self._construct_lambda_auth_connector(api, arn, i) for i, arn in enumerate(lambda_auth_arns, 1)

samtranslator/schema/schema.json

@@ -279735,6 +279735,9 @@
           "title": "Functions",
           "type": "object"
         },
+        "IntrospectionConfig": {
+          "$ref": "#/definitions/PassThroughProp"
+        },
         "Logging": {
           "anyOf": [
             {
@@ -279752,6 +279755,12 @@
         "OwnerContact": {
           "$ref": "#/definitions/PassThroughProp"
         },
+        "QueryDepthLimit": {
+          "$ref": "#/definitions/PassThroughProp"
+        },
+        "ResolverCountLimit": {
+          "$ref": "#/definitions/PassThroughProp"
+        },
         "Resolvers": {
           "additionalProperties": {
             "additionalProperties": {

schema_source/sam.schema.json

@@ -6659,6 +6659,9 @@
           "title": "Functions",
           "type": "object"
         },
+        "IntrospectionConfig": {
+          "$ref": "#/definitions/PassThroughProp"
+        },
         "Logging": {
           "anyOf": [
             {
@@ -6676,6 +6679,12 @@
         "OwnerContact": {
           "$ref": "#/definitions/PassThroughProp"
         },
+        "QueryDepthLimit": {
+          "$ref": "#/definitions/PassThroughProp"
+        },
+        "ResolverCountLimit": {
+          "$ref": "#/definitions/PassThroughProp"
+        },
         "Resolvers": {
           "additionalProperties": {
             "additionalProperties": {

tests/translator/input/graphqlapi_introspection_query_resolver_limits.yaml

@@ -0,0 +1,17 @@
+Transform: AWS::Serverless-2016-10-31
+Resources:
+  SuperCoolAPI:
+    Type: AWS::Serverless::GraphQLApi
+    Properties:
+      SchemaInline: |
+        type Book {
+            bookName: String
+        } 
+        type Query { getBook(bookName: String): Book }
+      Visibility: PRIVATE
+      OwnerContact: blah-blah
+      IntrospectionConfig: DISABLED
+      QueryDepthLimit: 10
+      ResolverCountLimit: 100
+      Auth:
+        Type: AWS_IAM