Application upload

First upload

README.md

@@ -12,6 +12,8 @@ In the future, I would like to expand this to try to extract promotional codes f
 
 For now I think it is a nice example of a completely serverless workload, using AppSync for the api. I hope that it stands as an example of how to architecture applications like this in the future.
 
+It uses the CDK as a IAAC code tool. 
+
 ## Technology Used
 
 * AppSync (GraphQL + Javascript Resolvers)
@@ -23,6 +25,7 @@ For now I think it is a nice example of a completely serverless workload, using
 * Athena
 * React 
 * D3.js
+* CDK
 
 ## Architectural Diagram
 

build.sh

@@ -0,0 +1,21 @@
+#!/bin/bash
+
+
+# Build Frontend 
+cd frontend && npm i && npm run build && cd .. && pwd
+
+# Build Created Trigger
+cd created-trigger && npm i && npm run compile && cd ..
+
+# Build Step Functions 
+cd step-functions/functions/automate-sign-up && npm run compile && cd ..
+cd manual-sign-up && npm run compile && cd ..
+cd validate-complete && npm run compile && cd ..
+cd validate-sign-up && npm run compile && cd ../../..
+
+# Build Email Handlers
+cd email-handlers/register-message-to-dynamodb/ && npm run compile && cd ../..
+
+# Deploy 
+
+cd infra/cdk && npx cdk deploy 

created-trigger/index.ts

@@ -0,0 +1,20 @@
+import { DynamoDBStreamEvent } from "aws-lambda";
+import { Logger } from '@aws-lambda-powertools/logger';
+import { DynamoDB, StepFunctions } from "aws-sdk";
+
+const { STEPFUNCTION_ARN } = process.env;
+
+const stepFunctions = new StepFunctions({ apiVersion: '2016-11-23' })
+const logger = new Logger({ serviceName: 'createdServiceLambda' });
+
+export async function handler(event: DynamoDBStreamEvent): Promise<void> {
+  const receivedEvents = event.Records
+    .map(it => DynamoDB.Converter.unmarshall(it.dynamodb?.NewImage!))
+
+  logger.info(`Received Events ${JSON.stringify(receivedEvents)}`);
+
+  const promiseStepfunctionsStart = receivedEvents.map(it => stepFunctions.startExecution({ stateMachineArn: STEPFUNCTION_ARN!, input: JSON.stringify(it) }).promise())
+  await Promise.all(promiseStepfunctionsStart);
+
+  return;
+}