Add localstack

docker-compose.dev.yml

@@ -23,6 +23,8 @@ services:
       - SESSION_SECRET=super_secret_session_key_change_me_in_production_please
       - CI=
       - NODE_ENV=development
+      - LOCALSTACK_HOSTNAME=localstack
+      - EDGE_PORT=4566
 
   db:
     image: postgres:15-bookworm
@@ -37,6 +39,25 @@ services:
     networks:
       - redwood
 
+  localstack:
+    container_name: "cpf-reporter-localstack-main"
+    image: localstack/localstack
+    ports:
+      - "4566:4566"           # LocalStack Gateway
+      - "4510-4559:4510-4559"  # external services port range
+    environment:
+      - SERVICES=s3, iam, lambda, cloudwatch
+      - DEBUG=${DEBUG-}
+      - DOCKER_HOST=unix:///var/run/docker.sock
+      - AWS_DEFAULT_REGION=${AWS_REGION:-us-west-2}
+      - REPORTING_DATA_BUCKET_NAME=bucket
+      - AWS_ACCESS_KEY_ID="test"
+      - AWS_SECRET_ACCESS_KEY="test"
+    volumes:
+      - "${LOCALSTACK_VOLUME_DIR:-./volume}:/var/lib/localstack"
+      - "/var/run/docker.sock:/var/run/docker.sock"
+      - "./entrypoint/init-aws.sh:/etc/localstack/init/ready.d/init-aws.sh"
+
   # After starting with `docker compose -f ./docker-compose.dev.yml up`,
   # use the console to run commands in the container:
   #
@@ -59,6 +80,7 @@ services:
     environment:
       - DATABASE_URL=postgresql://redwood:redwood@db:5432/redwood
       - TEST_DATABASE_URL=postgresql://redwood:redwood@db:5432/redwood_test
+      - LOCALSTACK_HOSTNAME=localstack
     depends_on:
       - db
 
@@ -77,6 +99,7 @@ services:
     environment:
       - DATABASE_URL=postgresql://redwood:redwood@db:5432/redwood
       - TEST_DATABASE_URL=postgresql://redwood:redwood@db:5432/redwood_test
+      - LOCALSTACK_HOSTNAME=localstack
     depends_on:
       - db
 

scripts/tests3.ts

@@ -0,0 +1,84 @@
+import { v4 as uuidv4 } from "uuid"
+import {
+  CreateBucketCommand,
+  GetObjectCommand,
+  GetObjectCommandInput,
+  HeadObjectCommand,
+  HeadObjectCommandInput,
+  PutObjectCommand,
+  PutObjectCommandInput,
+  DeleteObjectCommand,
+  DeleteObjectCommandInput,
+  DeleteBucketCommand,
+  DeleteBucketCommandInput,
+} from '@aws-sdk/client-s3'
+import { getSignedUrl as awsGetSignedUrl } from '@aws-sdk/s3-request-presigner'
+import { getPrismaClient } from 'api/src/lib/db'
+import AWS from 'api/src/lib/aws'
+
+const REPORTING_DATA_BUCKET_NAME = `test-${process.env.REPORTING_DATA_BUCKET_NAME}-${uuidv4()}`
+
+export default async () => {
+  const s3 = AWS.getS3Client()
+  await getPrismaClient()
+  const key = "12345"
+
+  console.log("Create bucket")
+  try {
+    await s3.send(new CreateBucketCommand({
+      Bucket: REPORTING_DATA_BUCKET_NAME,
+    }))
+    console.log("-- Bucket created")
+  } catch (error) {
+    if (error.Code == "BucketAlreadyOwnedByYou") {
+      console.log("-- Bucket already exists")
+    } else {
+      console.log(error)
+    }
+  }
+
+  const baseParams: GetObjectCommandInput = {
+    Bucket: REPORTING_DATA_BUCKET_NAME,
+    Key: key,
+  }
+  try {
+    console.log("Create signed URL")
+    const url = await awsGetSignedUrl(s3, new GetObjectCommand(baseParams), {
+      expiresIn: 60,
+    })
+    console.log("-- signed url", url)
+
+    console.log("Upload file")
+    const uploadParams: PutObjectCommandInput = {
+      Body: "tests3.ts",  // Upload this file as a test
+      Bucket: REPORTING_DATA_BUCKET_NAME,
+      Key: key,
+    }
+    await s3.send(new PutObjectCommand(uploadParams))
+
+    console.log("-- Look at uploaded file")
+    const headParams: HeadObjectCommandInput = {
+      Bucket: REPORTING_DATA_BUCKET_NAME,
+      Key: key,
+    }
+    const response = await s3.send(new HeadObjectCommand(headParams))
+    console.log("--", response)
+
+    console.log("Delete file")
+    const deleteParams: DeleteObjectCommandInput = {
+      Bucket: REPORTING_DATA_BUCKET_NAME,
+      Key: key,
+    }
+    await s3.send(new DeleteObjectCommand(deleteParams))
+    console.log("-- file deleted")
+  } catch (error) {
+    console.warn('Failed to test s3.')
+    console.error(error)
+  } finally {
+    console.log("Remove bucket")
+    await s3.send(new DeleteBucketCommand({
+      Bucket: REPORTING_DATA_BUCKET_NAME,
+    } as DeleteBucketCommandInput))
+    console.log("-- Bucket removed")
+  }
+}