chore: stash work in progress

Author: bryantbiggs

.gitignore

@@ -30,3 +30,4 @@ terraform.rc
 
 # Zip archive
 *.zip
+builds

examples/complete-http/README.md

@@ -30,17 +30,17 @@ Note that this example may create resources which cost money. Run `terraform des
 
 | Name | Version |
 |------|---------|
-| <a name="provider_aws"></a> [aws](#provider\_aws) | >= 3.35 |
-| <a name="provider_null"></a> [null](#provider\_null) | >= 2.0 |
-| <a name="provider_random"></a> [random](#provider\_random) | >= 2.0 |
-| <a name="provider_tls"></a> [tls](#provider\_tls) | >= 3.1 |
+| <a name="provider_aws"></a> [aws](#provider\_aws) | 3.61.0 |
+| <a name="provider_null"></a> [null](#provider\_null) | 3.1.0 |
+| <a name="provider_random"></a> [random](#provider\_random) | 3.1.0 |
+| <a name="provider_tls"></a> [tls](#provider\_tls) | 3.1.0 |
 
 ## Modules
 
 | Name | Source | Version |
 |------|--------|---------|
 | <a name="module_acm"></a> [acm](#module\_acm) | terraform-aws-modules/acm/aws | ~> 3.0 |
-| <a name="module_api_gateway"></a> [api\_gateway](#module\_api\_gateway) | ../../ |  |
+| <a name="module_api_gateway"></a> [api\_gateway](#module\_api\_gateway) | ../../ | n/a |
 | <a name="module_lambda_function"></a> [lambda\_function](#module\_lambda\_function) | terraform-aws-modules/lambda/aws | ~> 2.0 |
 | <a name="module_step_function"></a> [step\_function](#module\_step\_function) | terraform-aws-modules/step-functions/aws | ~> 2.0 |
 
@@ -64,7 +64,7 @@ Note that this example may create resources which cost money. Run `terraform des
 
 | Name | Description | Type | Default | Required |
 |------|-------------|------|---------|:--------:|
-| <a name="input_domain_name"></a> [domain\_name](#input\_domain\_name) | Custom domain name to use on API Gateway endpoint | `string` | n/a | yes |
+| <a name="input_domain_name"></a> [domain\_name](#input\_domain\_name) | Custom domain name to use on API Gateway endpoint | `string` | `"terraform-aws-modules.modules.tf"` | no |
 
 ## Outputs
 

examples/complete-http/terraform.tfvars.example

@@ -1,4 +1,5 @@
 variable "domain_name" {
   description = "Custom domain name to use on API Gateway endpoint"
   type        = string
+  default     = "terraform-aws-modules.modules.tf"
 }

examples/complete-http/variables.tf

@@ -0,0 +1,61 @@
+# Websocket AWS API Gateway examples
+
+Configuration in this directory creates AWS API Gateway with Domain Name, ACM Certificate, and integrates it with Lambda and Step Function and shows the variety of supported features.
+
+
+## Usage
+
+To run this example you need to execute:
+
+```bash
+$ terraform init
+$ terraform plan
+$ terraform apply
+```
+
+Note that this example may create resources which cost money. Run `terraform destroy` when you don't need these resources.
+
+<!-- BEGINNING OF PRE-COMMIT-TERRAFORM DOCS HOOK -->
+## Requirements
+
+| Name | Version |
+|------|---------|
+| <a name="requirement_terraform"></a> [terraform](#requirement\_terraform) | >= 0.13.1 |
+| <a name="requirement_aws"></a> [aws](#requirement\_aws) | >= 3.35 |
+
+## Providers
+
+| Name | Version |
+|------|---------|
+| <a name="provider_aws"></a> [aws](#provider\_aws) | 3.61.0 |
+| <a name="provider_random"></a> [random](#provider\_random) | 3.1.0 |
+
+## Modules
+
+| Name | Source | Version |
+|------|--------|---------|
+| <a name="module_api_gateway"></a> [api\_gateway](#module\_api\_gateway) | ../../ | n/a |
+| <a name="module_connect_lambda_function"></a> [connect\_lambda\_function](#module\_connect\_lambda\_function) | terraform-aws-modules/lambda/aws | ~> 2 |
+| <a name="module_disconnect_lambda_function"></a> [disconnect\_lambda\_function](#module\_disconnect\_lambda\_function) | terraform-aws-modules/lambda/aws | ~> 2 |
+| <a name="module_dynamodb_table"></a> [dynamodb\_table](#module\_dynamodb\_table) | terraform-aws-modules/dynamodb-table/aws | ~> 1 |
+| <a name="module_send_message_lambda_function"></a> [send\_message\_lambda\_function](#module\_send\_message\_lambda\_function) | terraform-aws-modules/lambda/aws | ~> 2 |
+
+## Resources
+
+| Name | Type |
+|------|------|
+| [aws_api_gateway_account.logs](https://registry.terraform.io/providers/hashicorp/aws/latest/docs/resources/api_gateway_account) | resource |
+| [aws_cloudwatch_log_group.logs](https://registry.terraform.io/providers/hashicorp/aws/latest/docs/resources/cloudwatch_log_group) | resource |
+| [aws_iam_role.cloudwatch](https://registry.terraform.io/providers/hashicorp/aws/latest/docs/resources/iam_role) | resource |
+| [random_pet.this](https://registry.terraform.io/providers/hashicorp/random/latest/docs/resources/pet) | resource |
+
+## Inputs
+
+No inputs.
+
+## Outputs
+
+| Name | Description |
+|------|-------------|
+| <a name="output_wss"></a> [wss](#output\_wss) | n/a |
+<!-- END OF PRE-COMMIT-TERRAFORM DOCS HOOK -->

examples/websocket/README.md

@@ -0,0 +1,29 @@
+// Copyright 2018-2020 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+// SPDX-License-Identifier: MIT-0
+
+const AWS = require("aws-sdk");
+
+const ddb = new AWS.DynamoDB.DocumentClient({
+  apiVersion: "2012-08-10",
+  region: process.env.AWS_REGION,
+});
+
+exports.handler = async (event) => {
+  const putParams = {
+    TableName: process.env.TABLE_NAME,
+    Item: {
+      connectionId: event.requestContext.connectionId,
+    },
+  };
+
+  try {
+    await ddb.put(putParams).promise();
+  } catch (err) {
+    return {
+      statusCode: 500,
+      body: "Failed to connect: " + JSON.stringify(err),
+    };
+  }
+
+  return { statusCode: 200, body: "Connected." };
+};

examples/websocket/function/onConnect.js

@@ -0,0 +1,35 @@
+// Copyright 2018-2020 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+// SPDX-License-Identifier: MIT-0
+
+// https://docs.aws.amazon.com/apigateway/latest/developerguide/apigateway-websocket-api-route-keys-connect-disconnect.html
+// The $disconnect route is executed after the connection is closed.
+// The connection can be closed by the server or by the client. As the connection is already closed when it is executed,
+// $disconnect is a best-effort event.
+// API Gateway will try its best to deliver the $disconnect event to your integration, but it cannot guarantee delivery.
+
+const AWS = require("aws-sdk");
+
+const ddb = new AWS.DynamoDB.DocumentClient({
+  apiVersion: "2012-08-10",
+  region: process.env.AWS_REGION,
+});
+
+exports.handler = async (event) => {
+  const deleteParams = {
+    TableName: process.env.TABLE_NAME,
+    Key: {
+      connectionId: event.requestContext.connectionId,
+    },
+  };
+
+  try {
+    await ddb.delete(deleteParams).promise();
+  } catch (err) {
+    return {
+      statusCode: 500,
+      body: "Failed to disconnect: " + JSON.stringify(err),
+    };
+  }
+
+  return { statusCode: 200, body: "Disconnected." };
+};

examples/websocket/function/onDisconnect.js

@@ -0,0 +1,56 @@
+// Copyright 2018-2020Amazon.com, Inc. or its affiliates. All Rights Reserved.
+// SPDX-License-Identifier: MIT-0
+
+const AWS = require("aws-sdk");
+
+const ddb = new AWS.DynamoDB.DocumentClient({
+  apiVersion: "2012-08-10",
+  region: process.env.AWS_REGION,
+});
+
+const { TABLE_NAME } = process.env;
+
+exports.handler = async (event) => {
+  let connectionData;
+
+  try {
+    connectionData = await ddb
+      .scan({ TableName: TABLE_NAME, ProjectionExpression: "connectionId" })
+      .promise();
+  } catch (e) {
+    return { statusCode: 500, body: e.stack };
+  }
+
+  const apigwManagementApi = new AWS.ApiGatewayManagementApi({
+    apiVersion: "2018-11-29",
+    endpoint:
+      event.requestContext.domainName + "/" + event.requestContext.stage,
+  });
+
+  const postData = JSON.parse(event.body).data;
+
+  const postCalls = connectionData.Items.map(async ({ connectionId }) => {
+    try {
+      await apigwManagementApi
+        .postToConnection({ ConnectionId: connectionId, Data: postData })
+        .promise();
+    } catch (e) {
+      if (e.statusCode === 410) {
+        console.log(`Found stale connection, deleting ${connectionId}`);
+        await ddb
+          .delete({ TableName: TABLE_NAME, Key: { connectionId } })
+          .promise();
+      } else {
+        throw e;
+      }
+    }
+  });
+
+  try {
+    await Promise.all(postCalls);
+  } catch (e) {
+    return { statusCode: 500, body: e.stack };
+  }
+
+  return { statusCode: 200, body: "Data sent." };
+};