feat: Adds support for JavaScript AppSync Functions (#49)

Co-authored-by: Falqui, Giampaolo <giampaolo.falqui@aptiv.com>

Author: GiamPy5

examples/complete/main.tf

@@ -46,7 +46,7 @@ resource "aws_route53_zone" "this" {
 }
 
 resource "aws_route53_record" "api" {
-  zone_id = data.aws_route53_zone.this[0].zone_id
+  zone_id = try(data.aws_route53_zone.this[0].zone_id, aws_route53_zone.this[0].zone_id)
   name    = "api.${local.domain}"
   type    = "CNAME"
   ttl     = "300"
@@ -141,16 +141,26 @@ module "appsync" {
 
   functions = {
     None = {
-      kind                      = "PIPELINE"
-      type                      = "Query"
-      data_source               = "None"
-      request_mapping_template  = <<EOF
-{
-    "payload": $util.toJson($context.args)
-}
-EOF
+      kind                     = "PIPELINE"
+      type                     = "Query"
+      data_source              = "None"
+      request_mapping_template = <<EOF
+      {
+          "payload": $util.toJson($context.args)
+      }
+      EOF
+
       response_mapping_template = "$util.toJson($context.result)"
     }
+
+    Javascript = {
+      data_source    = "lambda1"
+      max_batch_size = 10
+      runtime = {
+        name = "APPSYNC_JS"
+      }
+      code = file("src/function.js")
+    }
   }
 
   datasources = {
@@ -262,6 +272,19 @@ EOF
         "None",
       ]
     }
+
+    "Query.user" = {
+      kind  = "PIPELINE"
+      type  = "Query"
+      field = "user"
+      runtime = {
+        name = "APPSYNC_JS"
+      }
+      code = file("src/function.js")
+      functions = [
+        "Javascript",
+      ]
+    }
   }
 }
 
@@ -275,6 +298,13 @@ resource "random_pet" "this" {
 
 resource "aws_cognito_user_pool" "this" {
   name = "user-pool-${random_pet.this.id}"
+
+  account_recovery_setting {
+    recovery_mechanism {
+      name     = "verified_email"
+      priority = 1
+    }
+  }
 }
 
 resource "aws_cognito_user_pool_client" "this" {

examples/complete/src/function.js

@@ -0,0 +1,27 @@
+/**
+ * These are available AWS AppSync utilities that you can use in your request and response handler.
+ * For more information about the utilities that are currently implemented, see
+ * https://docs.aws.amazon.com/en_us/appsync/latest/devguide/resolver-reference-overview-js.html#utility-resolvers.
+ */
+import { util } from '@aws-appsync/utils';
+
+/**
+ * This function handles an incoming request, then converts it into a request
+ * object for the selected data source operation.
+ * You can find more code samples here: https://github.com/aws-samples/aws-appsync-resolver-samples.
+ * @param ctx - Contextual information for your resolver invocation.
+ * @returns - A data source request object.
+ */
+export function request(ctx) {
+    return {};
+}
+
+/**
+ * This function handles the response from the data source.
+ * You can find more code samples here: https://github.com/aws-samples/aws-appsync-resolver-samples.
+ * @param ctx - Contextual information for your resolver invocation.
+ * @returns - A result that is passed to the next function, or the response handler of the pipeline resolver.
+ */
+export function response(ctx) {
+    return {};
+}

main.tf

@@ -221,16 +221,44 @@ resource "aws_appsync_resolver" "this" {
 
 # Functions
 resource "aws_appsync_function" "this" {
-  for_each = var.create_graphql_api ? var.functions : {}
+  for_each = { for k, v in var.functions : k => v if var.create_graphql_api == true }
 
   api_id           = aws_appsync_graphql_api.this[0].id
   data_source      = lookup(each.value, "data_source", null)
   name             = each.key
   description      = lookup(each.value, "description", null)
-  function_version = lookup(each.value, "function_version", "2018-05-29")
+  function_version = lookup(each.value, "function_version", try(each.value.code == null, false) ? "2018-05-29" : null)
+  max_batch_size   = lookup(each.value, "max_batch_size", null)
 
-  request_mapping_template  = lookup(each.value, "request_mapping_template", null)
-  response_mapping_template = lookup(each.value, "response_mapping_template", null)
+  request_mapping_template  = lookup(each.value, "request_mapping_template", try(each.value.runtime.name == "APPSYNC_JS", false) ? null : "{}")
+  response_mapping_template = lookup(each.value, "response_mapping_template", try(each.value.runtime.name == "APPSYNC_JS", false) ? null : "{}")
+
+  code = try(each.value.code, null)
+
+  dynamic "sync_config" {
+    for_each = try([each.value.sync_config], [])
+
+    content {
+      conflict_detection = try(sync_config.value.conflict_detection, "NONE")
+      conflict_handler   = try(sync_config.value.conflict_handler, "NONE")
+
+      dynamic "lambda_conflict_handler_config" {
+        for_each = try([each.value.sync_config.lambda_conflict_handler_config], [])
+        content {
+          lambda_conflict_handler_arn = try(lambda_conflict_handler_config.value.lambda_conflict_handler_arn, null)
+        }
+      }
+    }
+  }
+
+  dynamic "runtime" {
+    for_each = try([each.value.runtime], [])
+
+    content {
+      name            = runtime.value.name
+      runtime_version = try(runtime.value.runtime_version, "1.0.0")
+    }
+  }
 
   depends_on = [aws_appsync_datasource.this]
 }