Use object storage from Node.js

import { S3Client } from "@aws-sdk/client-s3";

export const s3 = new S3Client({
  region: "auto",
  endpoint: process.env.S3_ENDPOINT,
  credentials: {
    accessKeyId: process.env.S3_ACCESS_KEY_ID,
    secretAccessKey: process.env.S3_SECRET_ACCESS_KEY,
  },
  requestChecksumCalculation: "WHEN_REQUIRED",
  responseChecksumValidation: "WHEN_REQUIRED",
});

export const Bucket = process.env.S3_BUCKET;

import express from "express";
import { GetObjectCommand, ListObjectsV2Command } from "@aws-sdk/client-s3";
import { Upload } from "@aws-sdk/lib-storage";
import { getSignedUrl } from "@aws-sdk/s3-request-presigner";
import { s3, Bucket } from "./storage.js";

const app = express();
const port = process.env.PORT || 3000;

// Stream the request body into the bucket as uploads/<name>.
app.put("/files/:name", async (req, res) => {
  await new Upload({
    client: s3,
    params: {
      Bucket,
      Key: `uploads/${req.params.name}`,
      Body: req,
      ContentType: req.headers["content-type"],
    },
  }).done();
  res.status(201).json({ key: `uploads/${req.params.name}` });
});

// List the uploaded files.
app.get("/files", async (req, res) => {
  const { Contents = [] } = await s3.send(
    new ListObjectsV2Command({ Bucket, Prefix: "uploads/" })
  );
  res.json(Contents.map(({ Key, Size }) => ({ key: Key, size: Size })));
});

// Redirect to a link that works for one hour.
app.get("/files/:name", async (req, res) => {
  const url = await getSignedUrl(
    s3,
    new GetObjectCommand({ Bucket, Key: `uploads/${req.params.name}` }),
    { expiresIn: 3600 }
  );
  res.redirect(url);
});

app.listen(port, () => {
  console.log(`Listening on port ${port}`);
});