feat: update codepipeline to V2

Author: alazaroc

README.md

@@ -49,45 +49,46 @@ npm run lint && npm run test
 
 1. Download and run docker image of dynamodb-local
 
-```shell
-docker pull amazon/dynamodb-local
-docker run -p 8000:8000 amazon/dynamodb-local
-```
+    ```shell
+    docker pull amazon/dynamodb-local
+    docker run -p 8000:8000 amazon/dynamodb-local
+    ```
 
 2. Create dynamodb-local tables - review the template.yaml because the ID is going to change
 
-```shell
-aws dynamodb create-table --table-name bloginfrastructuresubscriptiondbF44CF6DE --attribute-definitions AttributeName=email,AttributeType=S --key-schema AttributeName=email,KeyType=HASH --provisioned-throughput ReadCapacityUnits=1,WriteCapacityUnits=1 --endpoint-url http://localhost:8000
-aws dynamodb create-table --table-name bloginfrastructurecontactdbA1E13C61 --attribute-definitions AttributeName=name,AttributeType=S --key-schema AttributeName=name,KeyType=HASH --provisioned-throughput ReadCapacityUnits=1,WriteCapacityUnits=1 --endpoint-url http://localhost:8000
-```
+    ```shell
+    aws dynamodb create-table --table-name bloginfrastructuresubscriptiondbF44CF6DE --attribute-definitions AttributeName=email,AttributeType=S --key-schema AttributeName=email,KeyType=HASH --provisioned-throughput ReadCapacityUnits=1,WriteCapacityUnits=1 --endpoint-url http://localhost:8000
+    aws dynamodb create-table --table-name bloginfrastructurecontactdbA1E13C61 --attribute-definitions AttributeName=name,AttributeType=S --key-schema AttributeName=name,KeyType=HASH --provisioned-throughput ReadCapacityUnits=1,WriteCapacityUnits=1 --endpoint-url http://localhost:8000
+    ```
 
 3. Update lambda code to change the endpoint:
 
-```shell
-const dbClient = process.env.AWS_SAM_LOCAL ? new DynamoDBClient({ endpoint: 'http://docker.for.mac.localhost:8000/', }) : new DynamoDBClient();
-```
+    ```shell
+    const dbClient = process.env.AWS_SAM_LOCAL ? new DynamoDBClient({ endpoint: 'http://docker.for.mac.localhost:8000/', }) : new DynamoDBClient();
+    ```
 
 4. Generate the YAML file that SAM needs
 
-```shell
-cdk synth blog-backend-infrastructure --no-staging > template.yml
-```
+    ```shell
+    cdk synth blog-backend-infrastructure --no-staging > template.yml
+    ```
 
 5. Run SAM tests
 
-```shell
-sam local invoke blog-backend-infrastructure-contact-lbd -e tests/events/contact.json
-sam local invoke blog-backend-infrastructure-subscription-lbd -e tests/events/subscription.json
-```
+    ```shell
+    sam local invoke blog-backend-infrastructure-contact-lbd -e tests/events/contact.json
+    sam local invoke blog-backend-infrastructure-subscription-lbd -e tests/events/subscription.json
+    ```
 
 6. Review database records
 
-```shell
-aws dynamodb scan --table-name bloginfrastructuresubscriptiondbF44CF6DE --endpoint-url http://localhost:8000
-aws dynamodb scan --table-name bloginfrastructurecontactdbA1E13C61 --endpoint-url http://localhost:8000
-```
+    ```shell
+    aws dynamodb scan --table-name bloginfrastructuresubscriptiondbF44CF6DE --endpoint-url http://localhost:8000
+    aws dynamodb scan --table-name bloginfrastructurecontactdbA1E13C61 --endpoint-url http://localhost:8000
+    ```
+
+### Additional links
 
-### Additional links 
 - How to create infrastructure with CDK [here](https://www.playingaws.com/posts/how-to-create-infrastructure-with-cdk/).
 - How to add CI/CD to my CDK project [here](https://www.playingaws.com/posts/how-to-add-ci-cd-to-my-cdk-project/).
 - How to create serverless applications with CDK and SAM [here](https://www.playingaws.com/posts/how-to-create-serverless-applications-with-cdk-and-sam/)

backend/events/eventbridge.ts

@@ -0,0 +1,47 @@
+// import { Construct } from 'constructs';
+// import { aws_dynamodb, aws_sns as sns } from 'aws-cdk-lib';
+// import { Role, ServicePrincipal } from 'aws-cdk-lib/aws-iam';
+// import { CfnPipe } from 'aws-cdk-lib/aws-pipes';
+
+// // export function createTopicMyNotification(scope: Construct): sns.Topic {
+// //   const topicName = `${config.get('name')}` + `-alarms`;
+// //   const myKeyAlias = kms.Alias.fromAliasName(
+// //     scope,
+// //     'defaultKey',
+// //     'alias/aws/sns',
+// //   );
+// //   const topic = new sns.Topic(scope, topicName + '-topic', {
+// //     topicName: topicName,
+// //     displayName: 'Topic to deliver notifications to myself',
+// //     masterKey: myKeyAlias,
+// //   });
+// //   const personalEmail = getSsmPersonalEmail(scope);
+// //   topic.addSubscription(new EmailSubscription(personalEmail));
+// //   return topic;
+// // }
+
+// export function createPipe(scope: Construct, table: aws_dynamodb.Table): void {
+//   //TODO:  EventBridge Pipes L2 construct is not ready
+//   const cdcPipeRole = new Role(scope, 'CDCPipeRole', {
+//     assumedBy: new ServicePrincipal('pipes.amazonaws.com'),
+//   });
+//   table.grantStreamRead(cdcPipeRole);
+//   // Creation of the Pipe
+//   new CfnPipe(scope, 'CDCStreamPipe', {
+//     name: 'CDCStreamPipe',
+//     roleArn: cdcPipeRole.roleArn,
+//     source: table.tableStreamArn!,
+//     sourceParameters: {
+//       dynamoDbStreamParameters: { batchSize: 10, startingPosition: 'LATEST' },
+//     },
+//     target: bus.eventBusArn,
+//     targetParameters: {
+//       eventBridgeEventBusParameters: {
+//         source: PROJECT_SOURCE,
+//         detailType: CDC_EVENT,
+//       },
+//     },
+//   });
+//   const bus = EventBus.fromEventBusName(this, 'DefaultBus', 'default');
+//   bus.grantPutEventsTo(cdcPipeRole);
+// }

backend/events/lambda.ts

@@ -0,0 +1,41 @@
+// import { unmarshall } from '@aws-sdk/util-dynamodb';
+
+// import type { AttributeValue } from '@aws-sdk/client-dynamodb';
+// import type { DynamoDBRecord } from 'aws-lambda';
+// import { TABLE_PK, TABLE_SK } from '../constants';
+
+// export const handler = async (records: DynamoDBRecord[]) => {
+//   return records.map((r) => {
+//     const oldImage = r.dynamodb?.OldImage
+//       ? unmarshall(r.dynamodb?.OldImage as Record<string, AttributeValue>)
+//       : undefined;
+//     const newImage = r.dynamodb?.NewImage
+//       ? unmarshall(r.dynamodb?.NewImage as Record<string, AttributeValue>)
+//       : undefined;
+//     const result: {
+//       meta: Record<string, string>;
+//       data: {
+//         pk: string;
+//         sk: string;
+//         eventName: string;
+//         eventType: string;
+//         NewImage?: Record<string, unknown>;
+//         OldImage?: Record<string, unknown>;
+//       };
+//     } = {
+//       meta: {
+//         fn: process.env.AWS_LAMBDA_FUNCTION_NAME!,
+//       },
+//       data: {
+//         pk: oldImage?.[TABLE_PK] || newImage?.[TABLE_PK] || '',
+//         sk: oldImage?.[TABLE_SK] || newImage?.[TABLE_SK] || '',
+//         eventName: r.eventName || 'UNKNOWN',
+//         eventType:
+//           oldImage && newImage ? 'UPDATE' : oldImage ? 'REMOVE' : 'INSERT',
+//       },
+//     };
+//     if (newImage) result.data.NewImage = newImage;
+//     if (oldImage) result.data.OldImage = oldImage;
+//     return result;
+//   });
+// };

cicd/infrastructure/codepipeline.ts

@@ -59,8 +59,8 @@ export function createCodePipeline(
     }),
     description: 'Build phase for blog-backend-infrastructure resources',
     environment: {
-      computeType: codebuild.ComputeType.SMALL,
-      buildImage: codebuild.LinuxBuildImage.AMAZON_LINUX_2_4,
+      computeType: codebuild.ComputeType.LAMBDA_1GB,
+      buildImage: codebuild.LinuxArmLambdaBuildImage.AMAZON_LINUX_2023_NODE_22,
     },
   });
   buildProject.addToRolePolicy(
@@ -89,6 +89,7 @@ export function createCodePipeline(
   // Create the pipeline
   const pipeline = new codepipeline.Pipeline(scope, name + '-pipeline', {
     pipelineName: name,
+    pipelineType: codepipeline.PipelineType.V2,
     stages: [
       {
         stageName: 'Source',