S3 : add news

server/plugins/s3Storage.js

@@ -0,0 +1,93 @@
+const {
+  S3Client,
+  PutObjectCommand,
+  DeleteObjectCommand,
+} = require("@aws-sdk/client-s3");
+
+const config = {
+  bucket: process.env.BUCKET_NAME,
+  region: process.env.BUCKET_REGION || "us-west-2",
+  endpoint: process.env.PARSPACK_S3_ENDPOINT,
+  accessKeyId: process.env.BUCKET_ACCESS_KEY,
+  secretAccessKey: process.env.BUCKET_SECRET_KEY,
+  publicUrl: process.env.BUCKET_PUBLIC_URL || process.env.PARSPACK_S3_ENDPOINT,
+};
+
+let s3Client = null;
+
+const isConfigured = () =>
+  Boolean(
+    config.bucket &&
+      config.endpoint &&
+      config.accessKeyId &&
+      config.secretAccessKey
+  );
+
+const getClient = () => {
+  if (!isConfigured()) {
+    throw new Error("S3 storage is not configured");
+  }
+
+  if (!s3Client) {
+    s3Client = new S3Client({
+      region: config.region,
+      endpoint: config.endpoint,
+      credentials: {
+        accessKeyId: config.accessKeyId,
+        secretAccessKey: config.secretAccessKey,
+      },
+      forcePathStyle: true,
+    });
+  }
+
+  return s3Client;
+};
+
+const normalizeKey = (key) => key.replace(/^\/+/, "");
+
+const getPublicUrl = (key) => {
+  const normalizedKey = normalizeKey(key);
+  const baseUrl = (config.publicUrl || config.endpoint).replace(/\/+$/, "");
+  return `${baseUrl}/${normalizedKey}`;
+};
+
+const uploadBuffer = async (
+  key,
+  buffer,
+  contentType = "application/octet-stream"
+) => {
+  const normalizedKey = normalizeKey(key);
+
+  await getClient().send(
+    new PutObjectCommand({
+      Bucket: config.bucket,
+      Key: normalizedKey,
+      Body: buffer,
+      ContentType: contentType,
+      ACL: "public-read",
+    })
+  );
+
+  return {
+    key: normalizedKey,
+    url: getPublicUrl(normalizedKey),
+  };
+};
+
+const deleteObject = async (key) => {
+  const normalizedKey = normalizeKey(key);
+
+  await getClient().send(
+    new DeleteObjectCommand({
+      Bucket: config.bucket,
+      Key: normalizedKey,
+    })
+  );
+};
+
+module.exports = {
+  isConfigured,
+  getPublicUrl,
+  uploadBuffer,
+  deleteObject,
+};