feat: upgrade middleware to use AWS SDK v3

Author: alexmarqs

packages/large-response-middleware/package.json

@@ -40,6 +40,8 @@
     }
   ],
   "devDependencies": {
+    "@aws-sdk/client-s3": "3.782.0",
+    "@aws-sdk/s3-request-presigner": "3.782.0",
     "@babel/cli": "^7.23.4",
     "@babel/core": "^7.25.2",
     "@babel/preset-env": "^7.25.4",
@@ -55,7 +57,6 @@
     "@types/aws-lambda": "^8.10.130",
     "@types/node": "^20.10.5",
     "aws-lambda": "^1.0.7",
-    "aws-sdk": "^2.816.0",
     "cross-env": "^7.0.3",
     "npm-run-all": "^4.1.5",
     "rollup": "^4.9.1",
@@ -68,10 +69,11 @@
     "vitest": "3.0.5"
   },
   "peerDependencies": {
+    "@aws-sdk/client-s3": "^3.x",
+    "@aws-sdk/s3-request-presigner": "^3.x",
     "@dazn/lambda-powertools-logger": "^1.28.1",
     "@middy/core": "^2.5.7",
-    "aws-lambda": "^1.0.7",
-    "aws-sdk": "^2.816.0"
+    "aws-lambda": "^1.0.7"
   },
   "dependencies": {
     "core-js": "^3.34.0",

packages/large-response-middleware/src/file-storage-service.ts

@@ -2,6 +2,8 @@ import path from 'node:path';
 
 import { getS3Client } from './s3/s3-client';
 
+import { GetObjectCommand, PutObjectCommand } from '@aws-sdk/client-s3';
+import { getSignedUrl } from '@aws-sdk/s3-request-presigner';
 import type { FileUploadContext } from '.';
 
 /**
@@ -15,22 +17,27 @@ export const uploadFile = async (params: FileUploadContext) => {
   const date = getFormattedDate();
   const outputKey = `${namespace}/${date}/${encodeURIComponent(params.fileName)}`;
 
-  await client
-    .putObject({
+  await client.send(
+    new PutObjectCommand({
       Bucket: params.bucket,
       Key: outputKey,
       ContentType: params.contentType || 'text/plain',
       Body: JSON.stringify(params.content || {}),
       ACL: 'private',
-    })
-    .promise();
-
-  const url = await client.getSignedUrl('getObject', {
-    Expires: 3600,
-    Bucket: params.bucket,
-    Key: outputKey,
-    ResponseContentDisposition: `inline;filename=${path.basename(outputKey)}`,
-  });
+    }),
+  );
+
+  const url = await getSignedUrl(
+    client,
+    new GetObjectCommand({
+      Bucket: params.bucket,
+      Key: outputKey,
+      ResponseContentDisposition: `inline;filename=${path.basename(outputKey)}`,
+    }),
+    {
+      expiresIn: 3600,
+    },
+  );
 
   return { url, filename: outputKey };
 };

packages/large-response-middleware/src/s3/s3-client.ts

@@ -1,19 +1,15 @@
+import { S3Client, type S3ClientConfig } from '@aws-sdk/client-s3';
 import Log from '@dazn/lambda-powertools-logger';
-import { S3 } from 'aws-sdk';
 
 const AWS_ENDPOINT =
   process.env.AWS_ENDPOINT ||
   (process.env.STAGE === 'local' || process.env.NODE_ENV === 'local' ? 'http://host.docker.internal:4566' : undefined);
 
-export const getS3Client = async (options?: S3.Types.ClientConfiguration) => {
+export const getS3Client = async (options?: S3ClientConfig) => {
   try {
-    const client = new S3({
+    const client = new S3Client({
       endpoint: AWS_ENDPOINT,
-      s3ForcePathStyle: Boolean(AWS_ENDPOINT),
-      httpOptions: {
-        timeout: 60_000,
-        ...options?.httpOptions,
-      },
+      forcePathStyle: Boolean(AWS_ENDPOINT),
       ...options,
     });