feat: add node s3 upload example (#27)

* feat: add node s3 upload example

* chore: run prettierjs

* chore: bad package.json name

* chore: missing endline in package.json

Author: cyclimse

.gitignore

@@ -34,12 +34,12 @@ Table of Contents:
 | **[CORS Python](functions/cors-python/README.md)** <br/> A Python function which allows CORS requests.                                             | python310 | [Serverless Framework] |
 | **[CORS Rust](functions/cors-rust/README.md)** <br/> A Rust function which allows CORS requests.                                                   | rust165   | [Serverless Framework] |
 | **[Go SQS Publish](functions/go-mnq-sqs-publish/README.md)** <br/> A Go function to publish messages to SQS.                                       | go118     | [Serverless Framework] |
-| **[Go MultiPart Upload to S3](functions/go-mnq-sqs-publish/README.md)** <br/> A function to upload file from form-data to S3.                      | go119     | [Serverless Framework] |
-| **[CORS Rust](functions/cors-rust/README.md)** <br/> A Rust function which allows CORS requests.                                                   | rust165   | [Serverless Framework] |
+| **[Go MultiPart Upload to S3](functions/go-upload-file-s3-multipart)** <br/> A function to upload file from form-data to S3.                       | go119     | [Serverless Framework] |
 | **[Image Transform](functions/image-transform-node/README.md)** <br/> A function that resizes images from an S3 bucket.                            | node16    | [Serverless Framework] |
+| **[Node MultiPart Upload to S3](functions/node-upload-file-s3-multipart/README.md)** <br/> A function to upload file from form-data to S3.         | node19    | [Serverless Framework] |
 | **[Python ChatBot](functions/python-dependencies/README.md)** <br/> A chatbot example with ChatterBot.                                             | python310 | [Serverless Framework] |
 | **[Python Dependencies](functions/python-dependencies/README.md)** <br/> Example showing how to use Python requirements with Serverless Framework. | python310 | [Serverless Framework] |
-| **[Redis TLS](functions/redis-tls/README.md)** <br/> How to connect a function to a Scaleway Redis cluster with TLS enabled.                       | python310 | [Serverless Framework] |
+| **[Redis TLS](functions/redis-tls/README.md)** <br/> How to connect a function to a Scaleway Redis cluster with TLS enabled.                       | python310 | [Terraform]            |
 | **[Rust MNIST](functions/rust-mnist/README.md)** <br/> A Rust function to recognize hand-written digits with a simple neural network.              | rust165   | [Serverless Framework] |
 | **[Terraform Python](functions/terraform-python-example/README.md)** <br/> A Python function deployed with Terraform.                              | python310 | [Terraform]            |
 | **[PostgeSQL Node](functions/postgre-sql-node/README.md)** <br/> A Node function to connect and interact with PostgreSQL database.                 | node18    | [Serverless Framework]         |

README.md

@@ -20,7 +20,7 @@ S3_BUCKET_NAME=
 S3_REGION= # ex: fr-par
 ```
 
-If s3 not enabled the file will be saved on the ephemeral storage of your function.
+If s3 is not enabled the file will be saved on the ephemeral storage of your function.
 
 ```sh
 go get

functions/go-upload-file-s3-multipart/README.md

@@ -0,0 +1,3 @@
+node_modules/
+package-lock.json
+.serverless/

functions/node-upload-file-s3-multipart/.gitignore

@@ -0,0 +1,23 @@
+# Node function to read files and upload to S3
+
+This function does the following steps :
+
+* Read a file from an HTTP request
+* Send the file to an S3 bucket
+
+## Requirements
+
+If you want to enable S3 upload, ensure to create a bucket and have the following secrets variables available in your environment:
+
+```env
+S3_REGION = # Default: fr-par
+SCW_ACCESS_KEY =
+SCW_SECRET_KEY =
+BUCKET_NAME =
+```
+
+To call the function (replace `README.md` with the file you want to upload):
+
+```sh
+curl -X POST -F "data=@README.md" -F "another=@package.json" http://localhost:8080
+```

functions/node-upload-file-s3-multipart/README.md

@@ -0,0 +1,59 @@
+"use strict";
+
+import { STATUS_CODES } from "http";
+
+import { S3 } from "@aws-sdk/client-s3";
+import { parse } from "parse-multipart-data";
+
+const BUCKET_NAME = process.env.BUCKET_NAME;
+const S3_REGION = process.env.S3_REGION;
+const ACCESS_KEY_ID = process.env.ACCESS_KEY_ID;
+const SECRET_KEY = process.env.SECRET_KEY;
+
+// Create S3 service object
+const s3 = new S3({
+  endpoint: `https://s3.${S3_REGION}.scw.cloud`,
+  region: S3_REGION,
+  credentials: {
+    accessKeyId: ACCESS_KEY_ID,
+    secretAccessKey: SECRET_KEY,
+  },
+});
+
+const uploadFormDataS3 = async (event, _context, cb) => {
+  if (
+    !event.headers["Content-Type"] ||
+    !event.headers["Content-Type"].startsWith("multipart/form-data")
+  ) {
+    return { statusCode: 400, body: STATUS_CODES[400] };
+  }
+
+  // Get the boundary from the Content-Type header
+  const boundary = event.headers["Content-Type"].split("=").pop();
+  const parts = parse(Buffer.from(event["body"], "utf-8"), boundary);
+
+  let promises = [];
+  for (const part of parts) {
+    console.log(`Saving object ${part.filename} to bucket ${BUCKET_NAME}...`);
+    promises.push(
+      s3.putObject({ Bucket: BUCKET_NAME, Key: part.filename, Body: part.data })
+    );
+  }
+
+  try {
+    await Promise.all(promises);
+    return {
+      statusCode: 200,
+      body: `Successfully uploaded ${parts
+        .map((f) => f.filename)
+        .join(",")} to ${BUCKET_NAME}`,
+    };
+  } catch (err) {
+    return {
+      statusCode: 500,
+      body: err.message,
+    };
+  }
+};
+
+export { uploadFormDataS3 };

functions/node-upload-file-s3-multipart/handler.js

@@ -0,0 +1,17 @@
+{
+  "name": "s3-form-data",
+  "version": "1.0.0",
+  "main": "handler.js",
+  "type": "module",
+  "keywords": [],
+  "author": "",
+  "license": "ISC",
+  "dependencies": {
+    "@aws-sdk/client-s3": "^3.289.0",
+    "parse-multipart-data": "^1.5.0"
+  },
+  "devDependencies": {
+    "serverless-scaleway-functions": "^0.4.4"
+  },
+  "description": ""
+}

functions/node-upload-file-s3-multipart/package.json

@@ -0,0 +1,23 @@
+service: s3-form-data
+configValidationMode: off
+provider:
+  name: scaleway
+  runtime: node19
+  env:
+    BUCKET_NAME: ${env:BUCKET_NAME}
+    S3_REGION: ${env:S3_REGION, "fr-par"}
+  secret:
+    ACCESS_KEY_ID: ${env:SCW_ACCESS_KEY}
+    SECRET_KEY: ${env:SCW_SECRET_KEY}
+
+plugins:
+  - serverless-scaleway-functions
+
+package:
+  patterns:
+    - "!.gitignore"
+    - "!.git/**"
+
+functions:
+  upload:
+    handler: handler.uploadFormDataS3