diff --git a/cdkExample/.gitignore b/cdkExample/.gitignore new file mode 100644 index 0000000..92fe1ec --- /dev/null +++ b/cdkExample/.gitignore @@ -0,0 +1,19 @@ +# Binaries for programs and plugins +*.exe +*.exe~ +*.dll +*.so +*.dylib + +# Test binary, built with `go test -c` +*.test + +# Output of the go coverage tool, specifically when used with LiteIDE +*.out + +# go.sum should be committed +!go.sum + +# CDK asset staging directory +.cdk.staging +cdk.out diff --git a/cdkExample/README.md b/cdkExample/README.md new file mode 100644 index 0000000..79e5c45 --- /dev/null +++ b/cdkExample/README.md @@ -0,0 +1,12 @@ +# Welcome to your CDK Go project! + +This is a blank project for CDK development with Go. + +The `cdk.json` file tells the CDK toolkit how to execute your app. + +## Useful commands + + * `cdk deploy` deploy this stack to your default AWS account/region + * `cdk diff` compare deployed stack with current state + * `cdk synth` emits the synthesized CloudFormation template + * `go test` run unit tests diff --git a/cdkExample/cdk.json b/cdkExample/cdk.json new file mode 100644 index 0000000..444ab81 --- /dev/null +++ b/cdkExample/cdk.json @@ -0,0 +1,61 @@ +{ + "app": "go mod download && go run cdk_example.go", + "watch": { + "include": [ + "**" + ], + "exclude": [ + "README.md", + "cdk*.json", + "go.mod", + "go.sum", + "**/*test.go" + ] + }, + "context": { + "@aws-cdk/aws-lambda:recognizeLayerVersion": true, + "@aws-cdk/core:checkSecretUsage": true, + "@aws-cdk/core:target-partitions": [ + "aws", + "aws-cn" + ], + "@aws-cdk-containers/ecs-service-extensions:enableDefaultLogDriver": true, + "@aws-cdk/aws-ec2:uniqueImdsv2TemplateName": true, + "@aws-cdk/aws-ecs:arnFormatIncludesClusterName": true, + "@aws-cdk/aws-iam:minimizePolicies": true, + "@aws-cdk/core:validateSnapshotRemovalPolicy": true, + "@aws-cdk/aws-codepipeline:crossAccountKeyAliasStackSafeResourceName": true, + "@aws-cdk/aws-s3:createDefaultLoggingPolicy": true, + "@aws-cdk/aws-sns-subscriptions:restrictSqsDescryption": true, + "@aws-cdk/aws-apigateway:disableCloudWatchRole": true, + "@aws-cdk/core:enablePartitionLiterals": true, + "@aws-cdk/aws-events:eventsTargetQueueSameAccount": true, + "@aws-cdk/aws-iam:standardizedServicePrincipals": true, + "@aws-cdk/aws-ecs:disableExplicitDeploymentControllerForCircuitBreaker": true, + "@aws-cdk/aws-iam:importedRoleStackSafeDefaultPolicyName": true, + "@aws-cdk/aws-s3:serverAccessLogsUseBucketPolicy": true, + "@aws-cdk/aws-route53-patters:useCertificate": true, + "@aws-cdk/customresources:installLatestAwsSdkDefault": false, + "@aws-cdk/aws-rds:databaseProxyUniqueResourceName": true, + "@aws-cdk/aws-codedeploy:removeAlarmsFromDeploymentGroup": true, + "@aws-cdk/aws-apigateway:authorizerChangeDeploymentLogicalId": true, + "@aws-cdk/aws-ec2:launchTemplateDefaultUserData": true, + "@aws-cdk/aws-secretsmanager:useAttachedSecretResourcePolicyForSecretTargetAttachments": true, + "@aws-cdk/aws-redshift:columnId": true, + "@aws-cdk/aws-stepfunctions-tasks:enableEmrServicePolicyV2": true, + "@aws-cdk/aws-ec2:restrictDefaultSecurityGroup": true, + "@aws-cdk/aws-apigateway:requestValidatorUniqueId": true, + "@aws-cdk/aws-kms:aliasNameRef": true, + "@aws-cdk/aws-autoscaling:generateLaunchTemplateInsteadOfLaunchConfig": true, + "@aws-cdk/core:includePrefixInUniqueNameGeneration": true, + "@aws-cdk/aws-efs:denyAnonymousAccess": true, + "@aws-cdk/aws-opensearchservice:enableOpensearchMultiAzWithStandby": true, + "@aws-cdk/aws-lambda-nodejs:useLatestRuntimeVersion": true, + "@aws-cdk/aws-efs:mountTargetOrderInsensitiveLogicalId": true, + "@aws-cdk/aws-rds:auroraClusterChangeScopeOfInstanceParameterGroupWithEachParameters": true, + "@aws-cdk/aws-appsync:useArnForSourceApiAssociationIdentifier": true, + "@aws-cdk/aws-rds:preventRenderingDeprecatedCredentials": true, + "@aws-cdk/aws-codepipeline-actions:useNewDefaultBranchForCodeCommitSource": true, + "@aws-cdk/aws-cloudwatch-actions:changeLambdaPermissionLogicalIdForLambdaAction": true + } +} diff --git a/cdkExample/cdk_example.go b/cdkExample/cdk_example.go new file mode 100644 index 0000000..5c03b59 --- /dev/null +++ b/cdkExample/cdk_example.go @@ -0,0 +1,82 @@ +package main + +import ( + "github.com/aws/aws-cdk-go/awscdk/v2" + "github.com/aws/aws-cdk-go/awscdk/v2/awsdynamodb" + "github.com/aws/aws-cdk-go/awscdk/v2/awslambda" + "github.com/aws/constructs-go/constructs/v10" + "github.com/aws/jsii-runtime-go" +) + +type CdkExampleStackProps struct { + awscdk.StackProps +} + +func NewCdkExampleStack(scope constructs.Construct, id string, props *CdkExampleStackProps) awscdk.Stack { + var sprops awscdk.StackProps + if props != nil { + sprops = props.StackProps + } + stack := awscdk.NewStack(scope, &id, &sprops) + + // Actually build the dynamoDB table + table := awsdynamodb.NewTable(stack, jsii.String("FEMUserTable"), &awsdynamodb.TableProps{ + PartitionKey: &awsdynamodb.Attribute{ + Name: jsii.String("username"), + Type: awsdynamodb.AttributeType_STRING, + }, + TableName: jsii.String("userTable"), + }) + + myFunction := awslambda.NewFunction(stack, jsii.String("ChaptersLambdaFunc"), &awslambda.FunctionProps{ + FunctionName: jsii.String("ChaptersLambdaFunction"), + Runtime: awslambda.Runtime_GO_1_X(), + Code: awslambda.AssetCode_FromAsset(jsii.String("lambda/."), nil), + Handler: jsii.String("main"), + }) + + table.GrantReadWriteData(myFunction) + + return stack +} + +func main() { + defer jsii.Close() + + app := awscdk.NewApp(nil) + + NewCdkExampleStack(app, "CdkExampleStack", &CdkExampleStackProps{ + awscdk.StackProps{ + Env: env(), + }, + }) + + app.Synth(nil) +} + +// env determines the AWS environment (account+region) in which our stack is to +// be deployed. For more information see: https://docs.aws.amazon.com/cdk/latest/guide/environments.html +func env() *awscdk.Environment { + // If unspecified, this stack will be "environment-agnostic". + // Account/Region-dependent features and context lookups will not work, but a + // single synthesized template can be deployed anywhere. + //--------------------------------------------------------------------------- + return nil + + // Uncomment if you know exactly what account and region you want to deploy + // the stack to. This is the recommendation for production stacks. + //--------------------------------------------------------------------------- + // return &awscdk.Environment{ + // Account: jsii.String("123456789012"), + // Region: jsii.String("us-east-1"), + // } + + // Uncomment to specialize this stack for the AWS Account and Region that are + // implied by the current CLI configuration. This is recommended for dev + // stacks. + //--------------------------------------------------------------------------- + // return &awscdk.Environment{ + // Account: jsii.String(os.Getenv("CDK_DEFAULT_ACCOUNT")), + // Region: jsii.String(os.Getenv("CDK_DEFAULT_REGION")), + // } +} diff --git a/cdkExample/cdk_example_test.go b/cdkExample/cdk_example_test.go new file mode 100644 index 0000000..09be4c6 --- /dev/null +++ b/cdkExample/cdk_example_test.go @@ -0,0 +1,26 @@ +package main + +// import ( +// "testing" + +// "github.com/aws/aws-cdk-go/awscdk/v2" +// "github.com/aws/aws-cdk-go/awscdk/v2/assertions" +// "github.com/aws/jsii-runtime-go" +// ) + +// example tests. To run these tests, uncomment this file along with the +// example resource in cdk_example_test.go +// func TestCdkExampleStack(t *testing.T) { +// // GIVEN +// app := awscdk.NewApp(nil) + +// // WHEN +// stack := NewCdkExampleStack(app, "MyStack", nil) + +// // THEN +// template := assertions.Template_FromStack(stack, nil) + +// template.HasResourceProperties(jsii.String("AWS::SQS::Queue"), map[string]interface{}{ +// "VisibilityTimeout": 300, +// }) +// } diff --git a/cdkExample/go.mod b/cdkExample/go.mod new file mode 100644 index 0000000..247fa35 --- /dev/null +++ b/cdkExample/go.mod @@ -0,0 +1,27 @@ +module cdk_example + +go 1.18 + +require ( + github.com/aws/aws-cdk-go/awscdk/v2 v2.125.0 + github.com/aws/constructs-go/constructs/v10 v10.3.0 + github.com/aws/jsii-runtime-go v1.94.0 +) + +require ( + github.com/Masterminds/semver/v3 v3.2.1 // indirect + github.com/aws/aws-lambda-go v1.46.0 // indirect + github.com/aws/aws-sdk-go v1.50.24 // indirect + github.com/cdklabs/awscdk-asset-awscli-go/awscliv1/v2 v2.2.202 // indirect + github.com/cdklabs/awscdk-asset-kubectl-go/kubectlv20/v2 v2.1.2 // indirect + github.com/cdklabs/awscdk-asset-node-proxy-agent-go/nodeproxyagentv6/v2 v2.0.1 // indirect + github.com/fatih/color v1.16.0 // indirect + github.com/jmespath/go-jmespath v0.4.0 // indirect + github.com/mattn/go-colorable v0.1.13 // indirect + github.com/mattn/go-isatty v0.0.20 // indirect + github.com/yuin/goldmark v1.4.13 // indirect + golang.org/x/lint v0.0.0-20210508222113-6edffad5e616 // indirect + golang.org/x/mod v0.14.0 // indirect + golang.org/x/sys v0.14.0 // indirect + golang.org/x/tools v0.16.1 // indirect +) diff --git a/cdkExample/go.sum b/cdkExample/go.sum new file mode 100644 index 0000000..e6bb0c4 --- /dev/null +++ b/cdkExample/go.sum @@ -0,0 +1,56 @@ +github.com/Masterminds/semver/v3 v3.2.1 h1:RN9w6+7QoMeJVGyfmbcgs28Br8cvmnucEXnY0rYXWg0= +github.com/Masterminds/semver/v3 v3.2.1/go.mod h1:qvl/7zhW3nngYb5+80sSMF+FG2BjYrf8m9wsX0PNOMQ= +github.com/aws/aws-cdk-go/awscdk/v2 v2.125.0 h1:UJCNM2NmyOlDuBoDDVQwHGjpqz0MIR+4nIlWAwwlYfM= +github.com/aws/aws-cdk-go/awscdk/v2 v2.125.0/go.mod h1:TpmJwOnoajvRtwnLlJoxEoppb9sVoCLfPGLdgoTDH7o= +github.com/aws/aws-lambda-go v1.46.0 h1:UWVnvh2h2gecOlFhHQfIPQcD8pL/f7pVCutmFl+oXU8= +github.com/aws/aws-lambda-go v1.46.0/go.mod h1:dpMpZgvWx5vuQJfBt0zqBha60q7Dd7RfgJv23DymV8A= +github.com/aws/aws-sdk-go v1.50.24 h1:3o2Pg7mOoVL0jv54vWtuafoZqAeEXLhm1tltWA2GcEw= +github.com/aws/aws-sdk-go v1.50.24/go.mod h1:LF8svs817+Nz+DmiMQKTO3ubZ/6IaTpq3TjupRn3Eqk= +github.com/aws/constructs-go/constructs/v10 v10.3.0 h1:LsjBIMiaDX/vqrXWhzTquBJ9pPdi02/H+z1DCwg0PEM= +github.com/aws/constructs-go/constructs/v10 v10.3.0/go.mod h1:GgzwIwoRJ2UYsr3SU+JhAl+gq5j39bEMYf8ev3J+s9s= +github.com/aws/jsii-runtime-go v1.94.0 h1:VuVDx0xL2gbsJthUMfP+SwAXGkSEQd0GKm0ydZ8xga8= +github.com/aws/jsii-runtime-go v1.94.0/go.mod h1:tQOz8aAMzM2XsRUDsnUgPvGcHNAzR/xtH0OgeM0lTWo= +github.com/cdklabs/awscdk-asset-awscli-go/awscliv1/v2 v2.2.202 h1:VixXB9DnHN8oP7pXipq8GVFPjWCOdeNxIaS/ZyUwTkI= +github.com/cdklabs/awscdk-asset-awscli-go/awscliv1/v2 v2.2.202/go.mod h1:iPUti/SWjA3XAS3CpnLciFjS8TN9Y+8mdZgDfSgcyus= +github.com/cdklabs/awscdk-asset-kubectl-go/kubectlv20/v2 v2.1.2 h1:k+WD+6cERd59Mao84v0QtRrcdZuuSMfzlEmuIypKnVs= +github.com/cdklabs/awscdk-asset-kubectl-go/kubectlv20/v2 v2.1.2/go.mod h1:CvFHBo0qcg8LUkJqIxQtP1rD/sNGv9bX3L2vHT2FUAo= +github.com/cdklabs/awscdk-asset-node-proxy-agent-go/nodeproxyagentv6/v2 v2.0.1 h1:MBBQNKKPJ5GArbctgwpiCy7KmwGjHDjUUH5wEzwIq8w= +github.com/cdklabs/awscdk-asset-node-proxy-agent-go/nodeproxyagentv6/v2 v2.0.1/go.mod h1:/2WiXEft9s8ViJjD01CJqDuyJ8HXBjhBLtK5OvJfdSc= +github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= +github.com/fatih/color v1.16.0 h1:zmkK9Ngbjj+K0yRhTVONQh1p/HknKYSlNT+vZCzyokM= +github.com/fatih/color v1.16.0/go.mod h1:fL2Sau1YI5c0pdGEVCbKQbLXB6edEj1ZgiY4NijnWvE= +github.com/jmespath/go-jmespath v0.4.0 h1:BEgLn5cpjn8UN1mAw4NjwDrS35OdebyEtFe+9YPoQUg= +github.com/jmespath/go-jmespath v0.4.0/go.mod h1:T8mJZnbsbmF+m6zOOFylbeCJqk5+pHWvzYPziyZiYoo= +github.com/jmespath/go-jmespath/internal/testify v1.5.1/go.mod h1:L3OGu8Wl2/fWfCI6z80xFu9LTZmf1ZRjMHUOPmWr69U= +github.com/mattn/go-colorable v0.1.13 h1:fFA4WZxdEF4tXPZVKMLwD8oUnCTTo08duU7wxecdEvA= +github.com/mattn/go-colorable v0.1.13/go.mod h1:7S9/ev0klgBDR4GtXTXX8a3vIGJpMovkB8vQcUbaXHg= +github.com/mattn/go-isatty v0.0.16/go.mod h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/yFXSvRLM= +github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY= +github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y= +github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= +github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= +github.com/yuin/goldmark v1.4.13 h1:fVcFKWvrslecOb/tg+Cc05dkeYx540o0FuFt3nUVDoE= +github.com/yuin/goldmark v1.4.13/go.mod h1:6yULJ656Px+3vBD8DxQVa3kxgyrAnzto9xy5taEt/CY= +golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w= +golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI= +golang.org/x/lint v0.0.0-20210508222113-6edffad5e616 h1:VLliZ0d+/avPrXXH+OakdXhpJuEoBZuwh1m2j7U6Iug= +golang.org/x/lint v0.0.0-20210508222113-6edffad5e616/go.mod h1:3xt1FjdF8hUf6vQPIChWIBhFzV8gjjsPE/fR3IyQdNY= +golang.org/x/mod v0.1.1-0.20191105210325-c90efee705ee/go.mod h1:QqPTAvyqsEbceGzBzNggFXnrqF1CaUcvgkdR5Ot7KZg= +golang.org/x/mod v0.14.0 h1:dGoOF9QVLYng8IHTm7BAyWqCqSheQ5pYWGhzW00YJr0= +golang.org/x/mod v0.14.0/go.mod h1:hTbmBsO62+eylJbnUtE2MGJUyE7QWk4xUqPFrRgJ+7c= +golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg= +golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s= +golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= +golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= +golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.14.0 h1:Vz7Qs629MkJkGyHxUlRHizWJRG2j8fbQKjELVSNhy7Q= +golang.org/x/sys v0.14.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= +golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= +golang.org/x/tools v0.0.0-20200130002326-2f3ba24bd6e7/go.mod h1:TB2adYChydJhpapKDTa4BR/hXlZSLoq2Wpct/0txZ28= +golang.org/x/tools v0.16.1 h1:TLyB3WofjdOEepBHAU20JdNC1Zbg87elYofWYAY5oZA= +golang.org/x/tools v0.16.1/go.mod h1:kYVVN6I1mBNoB1OX+noeBjbRk4IUEPa7JJ+TJMEooJ0= +golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= +gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= +gopkg.in/yaml.v2 v2.2.8/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= diff --git a/cdkExample/go.work b/cdkExample/go.work new file mode 100644 index 0000000..ac8293f --- /dev/null +++ b/cdkExample/go.work @@ -0,0 +1,5 @@ +go 1.21.3 + +use ./ + +use ./lambda diff --git a/cdkExample/go.work.sum b/cdkExample/go.work.sum new file mode 100644 index 0000000..aa7176d --- /dev/null +++ b/cdkExample/go.work.sum @@ -0,0 +1,19 @@ +github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= +github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= +github.com/jmespath/go-jmespath/internal/testify v1.5.1 h1:shLQSRRSCCPj3f2gpwzGwWFoC7ycTf1rcQZHOlsJ6N8= +github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= +github.com/stretchr/objx v0.1.0 h1:4G4v2dO3VZwixGIRoQ5Lfboy6nUhCyYzaqnIAPPhYs4= +github.com/stretchr/testify v1.8.4 h1:CcVxjf3Q8PM0mHUKJCdn+eZZtm5yQwehR5yeSVQQcUk= +github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo= +golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550 h1:ObdrDkeb4kJdCP557AjRjq69pTHfNouLtWZG7j9rPN8= +golang.org/x/net v0.19.0 h1:zTwKpTd2XuCqf8huc7Fo2iSy+4RHPd10s4KzeTnVr1c= +golang.org/x/net v0.19.0/go.mod h1:CfAk/cbD4CthTvqiEl8NpboMuiuOYsAr/7NOjZJtv1U= +golang.org/x/sync v0.5.0 h1:60k92dhOjHxJkrqnwsfl8KuaHbn/5dl0lUPUklKo3qE= +golang.org/x/sync v0.5.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk= +golang.org/x/text v0.13.0 h1:ablQoSUd0tRdKxZewP80B+BaqeKJuVhuRxj/dkrun3k= +golang.org/x/text v0.13.0/go.mod h1:TvPlkZtksWOMsz7fbANvkp4WM8x/WCo/om8BMLbz+aE= +golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898 h1:/atklqdjdhuosWIl6AIbOeHJjicWYPqR9bpxqxYG2pA= +gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM= +gopkg.in/yaml.v2 v2.2.8 h1:obN1ZagJSUGI0Ek/LBmuj4SNLPfIny3KsKFopxRdj10= +gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= +gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= diff --git a/cdkExample/lambda/Makefile b/cdkExample/lambda/Makefile new file mode 100644 index 0000000..21ad5c9 --- /dev/null +++ b/cdkExample/lambda/Makefile @@ -0,0 +1,3 @@ +build: + @GOOS=linux GOARCH=amd64 go build -o bootstrap + @zip function.zip bootstrap \ No newline at end of file diff --git a/cdkExample/lambda/api/api.go b/cdkExample/lambda/api/api.go new file mode 100644 index 0000000..c6b29c3 --- /dev/null +++ b/cdkExample/lambda/api/api.go @@ -0,0 +1,46 @@ +package api + +// This is going to be the "Handler Layer" +// This will process the requests and call our DB layer + +import ( + "fmt" + "lambda-func/database" + "lambda-func/types" +) + +type ApiHandler struct { + dbStore database.DynamoDBClient +} + +func NewApiHandler(dbStore database.DynamoDBClient) ApiHandler { + return ApiHandler{ + dbStore: dbStore, + } +} + +// The handler our lambda will route to when we need to register our new users + +func (api *ApiHandler) RegisterUser(event types.RegisterUser) error { + if event.Username == "" || event.Password == "" { + return fmt.Errorf("invalid request, the fields cannot be empty") + } + + // We need to check if a user wit hthe same username already exists in our DB + doesUserExist, err := api.dbStore.DoesUserExist(event.Username) + if err != nil { + return fmt.Errorf("there was an error registerign the user %w", err) + } + + if doesUserExist { + return fmt.Errorf("a user with that username already exists") + } + + // we know that this user does not exist + err = api.dbStore.InsertUser(event) + if err != nil { + return fmt.Errorf("error inserting the user %w", err) + } + + return nil +} diff --git a/cdkExample/lambda/app/app.go b/cdkExample/lambda/app/app.go new file mode 100644 index 0000000..7367c5a --- /dev/null +++ b/cdkExample/lambda/app/app.go @@ -0,0 +1,19 @@ +package app + +import ( + "lambda-func/api" + "lambda-func/database" +) + +type App struct { + ApiHandler api.ApiHandler +} + +func NewApp() App { + db := database.NewDynamoDB() + apiHandler := api.NewApiHandler(db) + + return App{ + ApiHandler: apiHandler, + } +} diff --git a/cdkExample/lambda/bootstrap b/cdkExample/lambda/bootstrap new file mode 100755 index 0000000..3fec819 Binary files /dev/null and b/cdkExample/lambda/bootstrap differ diff --git a/cdkExample/lambda/database/database.go b/cdkExample/lambda/database/database.go new file mode 100644 index 0000000..af72fb7 --- /dev/null +++ b/cdkExample/lambda/database/database.go @@ -0,0 +1,78 @@ +package database + +// This is going to be the logic that directly communicates with +// our database + +import ( + "lambda-func/types" + + "github.com/aws/aws-sdk-go/aws" + "github.com/aws/aws-sdk-go/aws/session" + "github.com/aws/aws-sdk-go/service/dynamodb" +) + +const ( + TABLE_NAME = "userTable2" +) + +type DynamoDBClient struct { + databaseStore *dynamodb.DynamoDB +} + +func NewDynamoDB() DynamoDBClient { + dbSession := session.Must(session.NewSession()) + db := dynamodb.New(dbSession) + + return DynamoDBClient{ + databaseStore: db, + } +} + +// When we want to "register" a new user, we actually are: +// - checking if a user with this username already exists in our DB +// - if they do, we return an error +// - if they DONT, that is when we INSERT the user into the DB + +func (u *DynamoDBClient) DoesUserExist(username string) (bool, error) { + result, err := u.databaseStore.GetItem(&dynamodb.GetItemInput{ + TableName: aws.String(TABLE_NAME), + Key: map[string]*dynamodb.AttributeValue{ + "username": { + S: aws.String(username), + }, + }, + }) + + if err != nil { + return true, err + } + + if result.Item == nil { + return false, nil + } + + return true, nil +} + +func (u *DynamoDBClient) InsertUser(user types.RegisterUser) error { + // we are assembling our item + item := &dynamodb.PutItemInput{ + TableName: aws.String(TABLE_NAME), + Item: map[string]*dynamodb.AttributeValue{ + "username": { + S: aws.String(user.Username), + }, + "password": { + S: aws.String(user.Password), + }, + }, + } + + // we want to actually insert the item + _, err := u.databaseStore.PutItem(item) + if err != nil { + return err + } + + return nil +} diff --git a/cdkExample/lambda/function.zip b/cdkExample/lambda/function.zip new file mode 100644 index 0000000..f1bb515 Binary files /dev/null and b/cdkExample/lambda/function.zip differ diff --git a/cdkExample/lambda/go.mod b/cdkExample/lambda/go.mod new file mode 100644 index 0000000..4d46ca2 --- /dev/null +++ b/cdkExample/lambda/go.mod @@ -0,0 +1,3 @@ +module lambda-func + +go 1.21.3 diff --git a/cdkExample/lambda/main b/cdkExample/lambda/main new file mode 100755 index 0000000..c407539 Binary files /dev/null and b/cdkExample/lambda/main differ diff --git a/cdkExample/lambda/main.go b/cdkExample/lambda/main.go new file mode 100644 index 0000000..7cc6b40 --- /dev/null +++ b/cdkExample/lambda/main.go @@ -0,0 +1,26 @@ +package main + +import ( + "fmt" + "lambda-func/app" + + "github.com/aws/aws-lambda-go/lambda" +) + +type MyEvent struct { + Username string `json:"username"` +} + +// Define our Handler +func HandleRequest(event MyEvent) (string, error) { + if event.Username == "" { + return "Invalid Request", fmt.Errorf("username cannot be empty") + } + + return fmt.Sprintf("Successfully called by - %s", event.Username), nil +} + +func main() { + lambdaApp := app.NewApp() + lambda.Start(lambdaApp.ApiHandler.RegisterUser) +} diff --git a/cdkExample/lambda/types/types.go b/cdkExample/lambda/types/types.go new file mode 100644 index 0000000..1a88bd3 --- /dev/null +++ b/cdkExample/lambda/types/types.go @@ -0,0 +1,8 @@ +package types + +// Where we can define types and other misc. functions + +type RegisterUser struct { + Username string `json:"username"` + Password string `json:"password"` +}