add aws-serverless-sqs module

local/data/serverless-sqs.yml

@@ -0,0 +1,49 @@
+service: fn-aws-serverless-sqs
+
+frameworkVersion: '3'
+
+plugins:
+  - serverless-localstack
+
+custom:
+  localstack:
+    debug: true
+    stages:
+      - local
+    host: http://localstack
+
+provider:
+  name: aws
+  runtime: java11
+  region: us-east-1
+  iamRoleStatements:
+    - Effect: Allow
+      Action:
+        - sqs:SendMessage
+      Resource:
+        - Fn::GetAtt: [ MyQueue, Arn ]
+
+package:
+  artifact: aws-serverless-sqs.zip
+
+functions:
+  fn-aws-serverless-sqs:
+    name: fn-aws-serverless-sqs
+    description: TODO
+    handler: com.github.niqdev.aws.sqs.Handler::handleRequest
+    environment:
+      NAME: "fn-aws-serverless-sqs"
+    # https://www.serverless.com/framework/docs/providers/aws/events/sqs/
+    events:
+      - sqs:
+          arn:
+            Fn::GetAtt:
+              - MyQueue
+              - Arn
+
+resources:
+  Resources:
+    myQueue:
+      Type: AWS::SQS::Queue
+      Properties:
+        QueueName: MyQueue

local/docker-compose-serverless-sqs.yml

@@ -0,0 +1,45 @@
+version: "3"
+
+services:
+
+  dev:
+    container_name: local-serverless-sqs-dev
+    build:
+      context: .
+    # docker run -i
+    stdin_open: true
+    # docker run -t
+    tty: true
+    networks:
+      - localstack
+    volumes:
+      - "./data:/usr/src/app/data"
+      - "./aws:/root/.aws"
+
+  localstack:
+    container_name: local-serverless-sqs-localstack
+    image: localstack/localstack:1.1.0
+    ports:
+      - "4566:4566"
+      - "4510-4559:4510-4559"
+    networks:
+      - localstack
+    # https://docs.localstack.cloud/localstack/configuration
+    environment:
+      - DEBUG=1
+      - PERSISTENCE=1
+      - LAMBDA_REMOTE_DOCKER=false
+      - LAMBDA_EXECUTOR=docker
+      - DOCKER_SOCK=unix:///var/run/docker.sock
+      # custom
+      - BUCKET_NAME=my-bucket
+      - QUEUE_NAME=MyQueue
+    volumes:
+      - ".localstack:/var/lib/localstack"
+      - "/var/run/docker.sock:/var/run/docker.sock"
+      # run custom scripts: requires credentials
+      - "./aws:/root/.aws"
+      - './entrypoint:/docker-entrypoint-initaws.d'
+
+networks:
+  localstack:

local/entrypoint/init_sqs.sh

@@ -0,0 +1,19 @@
+#!/bin/bash
+
+ENDPOINT=http://localstack:4566
+
+echo "[*] create bucket: $BUCKET_NAME"
+aws s3api create-bucket \
+  --endpoint-url=${ENDPOINT} \
+  --bucket ${BUCKET_NAME}
+
+echo "[*] create queue: $QUEUE_NAME"
+aws sqs create-queue \
+  --endpoint-url=${ENDPOINT} \
+  --queue-name ${QUEUE_NAME}
+
+echo "[*] create bucket notification"
+aws s3api put-bucket-notification-configuration \
+  --endpoint-url=${ENDPOINT} \
+  --bucket ${BUCKET_NAME} \
+  --notification-configuration file:///docker-entrypoint-initaws.d/my-queue-notification.json

local/entrypoint/my-queue-notification.json

@@ -0,0 +1,10 @@
+{
+   "QueueConfigurations":[
+      {
+         "QueueArn":"arn:aws:sqs:us-east-1:000000000000:MyQueue",
+         "Events":[
+            "s3:ObjectCreated:*"
+         ]
+      }
+   ]
+}

modules/aws-serverless-sqs/README.md

@@ -0,0 +1,97 @@
+## aws-serverless-sqs
+
+Examples
+* https://github.com/localstack/localstack/issues/3585
+* https://github.com/localstack/localstack/issues/967
+* https://github.com/localstack/localstack/issues/4513
+* https://github.com/localstack/localstack/issues/1216
+* https://faun.pub/enable-aws-s3-bucket-events-notification-publishing-to-sqs-locally-using-localstack-45f369f74399
+* https://stackoverflow.com/questions/68988931/localstack-lambda-is-not-triggered-by-sqs
+* https://www.zakariaamine.com/2019-02-17/lambda-with-sqs-eventsource-cli
+
+### Development
+
+```bash
+# local-up
+docker-compose -f local/docker-compose-serverless-sqs.yml up
+
+# local-down
+docker-compose -f local/docker-compose-serverless-sqs.yml down -v
+rm -frv ./local/.localstack ./local/data/.serverless ./local/data/*.zip ./local/data/*.log
+
+# build
+./gradlew :modules:aws-serverless-sqs:clean :modules:aws-serverless-sqs:build
+```
+
+### AWS cli
+
+```bash
+aws iam create-role \
+  --endpoint-url=http://localhost:4566 \
+  --role-name localstack-role \
+  --assume-role-policy-document '{"Version": "2012-10-17", "Statement": [{"Effect": "Allow", "Action": ["lambda:InvokeFunction"]}, {"Effect": "Allow", "Action": ["sqs:SendMessage", "sqs:ReceiveMessage", "sqs:DeleteMessage", "sqs:GetQueueAttributes"]}]}'
+
+# create
+aws lambda create-function \
+  --endpoint-url=http://localhost:4566 \
+  --function-name fn-aws-serverless-sqs \
+  --runtime java11 \
+  --handler com.github.niqdev.aws.sqs.Handler::handleRequest \
+  --role arn:aws:iam::000000000000:role/localstack-role \
+  --zip-file fileb://modules/aws-serverless-sqs/build/distributions/aws-serverless-sqs-0.1.0.zip
+
+# invoke
+aws lambda invoke \
+  --endpoint-url=http://localhost:4566 \
+  --function-name fn-aws-serverless-sqs \
+  --payload $(echo "{\"key\":\"value\"}" | base64) \
+  local/.localstack/logs/aws-serverless-sqs-output.json
+
+aws s3 ls --endpoint-url=http://localhost:4566
+aws s3api --endpoint-url=http://localhost:4566 get-bucket-notification-configuration --bucket my-bucket
+aws sqs list-queues --endpoint-url=http://localhost:4566
+aws sqs get-queue-attributes \
+  --endpoint-url=http://localhost:4566 \
+  --queue-url http://localhost:4566/000000000000/MyQueue \
+  --attribute-names QueueArn
+
+aws lambda create-event-source-mapping \
+  --endpoint-url=http://localhost:4566 \
+  --event-source-arn arn:aws:sqs:us-east-1:000000000000:MyQueue \
+  --batch-size 1 \
+  --maximum-retry-attempts 3 \
+  --function-name fn-aws-serverless-sqs
+
+aws sqs send-message \
+  --endpoint-url=http://localhost:4566 \
+  --queue-url http://localhost:4566/000000000000/MyQueue \
+  --message-body $(echo "{\"key\":\"value\"}" | base64)
+
+aws sqs receive-message \
+  --endpoint-url=http://localhost:4566 \
+  --queue-url http://localhost:4566/000000000000/MyQueue
+
+aws s3 cp \
+  --endpoint-url=http://localhost:4566 \
+  README.md s3://my-bucket
+```
+
+### TODO Serverless
+
+```bash
+# verify status
+curl http://localhost:4566/health | jq
+docker exec -it local-serverless-sqs-dev curl http://localstack:4566/health | jq
+docker exec -it local-serverless-sqs-dev aws --endpoint-url=http://localstack:4566 s3 ls
+docker exec -it local-serverless-sqs-dev aws --endpoint-url=http://localstack:4566 sqs list-queues
+
+# local-deploy
+cp modules/aws-serverless-sqs/build/distributions/aws-serverless-sqs-*.zip local/data/aws-serverless-sqs.zip
+docker exec -it --workdir /usr/src/app/data local-serverless-sqs-dev \
+  serverless deploy --config serverless-sqs.yml --stage local
+
+# produce
+docker exec -it local-serverless-sqs-dev aws --endpoint-url=http://localstack:4566 sqs send-message \
+  --queue-url http://localstack:4566/000000000000/MyQueue \
+  --message-body "hello"
+```

modules/aws-serverless-sqs/build.gradle.kts

@@ -0,0 +1,20 @@
+version = "0.1.0"
+
+dependencies {
+  implementation("com.amazonaws:aws-lambda-java-core:${Versions.awsLambdaCore}")
+  implementation("com.amazonaws:aws-lambda-java-events:${Versions.awsLambdaEvents}")
+}
+
+tasks {
+  register<Zip>("buildZip") {
+    archiveFileName.set("${project.name}-${project.version}.zip")
+    from(compileKotlin)
+    from(processResources)
+    into("lib") {
+      from(configurations.runtimeClasspath)
+    }
+  }
+  build {
+    dependsOn("buildZip")
+  }
+}

modules/aws-serverless-sqs/src/main/kotlin/com/github/niqdev/aws/sqs/Handler.kt

@@ -0,0 +1,12 @@
+package com.github.niqdev.aws.sqs
+
+import com.amazonaws.services.lambda.runtime.Context
+import com.amazonaws.services.lambda.runtime.RequestHandler
+import com.amazonaws.services.lambda.runtime.events.SQSEvent
+
+class Handler : RequestHandler<SQSEvent, String> {
+  override fun handleRequest(input: SQSEvent, context: Context): String {
+    context.logger.log("TODO")
+    return "TODO"
+  }
+}

settings.gradle.kts

@@ -5,6 +5,7 @@ include(
   "modules:aws-kotlin",
   "modules:aws-local",
   "modules:aws-serverless",
+  "modules:aws-serverless-sqs",
   "modules:bool",
   "modules:fpk",
   "modules:http",