feat: add support for s3 and minio as storage providers

.env.example

@@ -20,6 +20,15 @@ CLOUDFLARE_BUCKETNAME="your-bucket-name"
 CLOUDFLARE_BUCKET_URL="https://your-bucket-url.r2.cloudflarestorage.com/"
 CLOUDFLARE_REGION="auto"
 
+## S3 Configuration (for AWS S3 or S3-compatible services like MinIO)
+## Set STORAGE_PROVIDER="s3" to use S3 storage
+#S3_ACCESS_KEY_ID="your-s3-access-key-id"
+#S3_SECRET_ACCESS_KEY="your-s3-secret-access-key"
+#S3_REGION="us-east-1"
+#S3_BUCKET_NAME="your-s3-bucket-name"
+#S3_UPLOAD_URL="https://your-s3-bucket-name.s3.amazonaws.com"
+#S3_ENDPOINT="" # Optional: Custom endpoint for S3-compatible services like MinIO
+
 # === Common optional Settings
 
 ## This is a dummy key, you must create your own from Resend.
@@ -30,7 +39,7 @@ CLOUDFLARE_REGION="auto"
 #EMAIL_FROM_NAME=""
 #DISABLE_REGISTRATION=false
 
-# Where will social media icons be saved - local or cloudflare.
+# Where will social media icons be saved - local, cloudflare, or s3.
 STORAGE_PROVIDER="local"
 
 # Your upload directory path if you host your files locally, otherwise Cloudflare will be used.

libraries/nestjs-libraries/src/upload/minio.storage.ts

@@ -0,0 +1,99 @@
+import { S3Client, PutObjectCommand, DeleteObjectCommand } from '@aws-sdk/client-s3';
+import 'multer';
+import { makeId } from '@gitroom/nestjs-libraries/services/make.is';
+import mime from 'mime-types';
+// @ts-ignore
+import { getExtension } from 'mime';
+import { IUploadProvider } from './upload.interface';
+
+class MinIOStorage implements IUploadProvider {
+  private _client: S3Client;
+
+  constructor(
+    private _accessKeyId: string,
+    private _secretAccessKey: string,
+    private _region: string,
+    private _bucketName: string,
+    private _endpoint: string
+  ) {
+    this._client = new S3Client({
+      endpoint: _endpoint,
+      region: _region,
+      credentials: {
+        accessKeyId: _accessKeyId,
+        secretAccessKey: _secretAccessKey,
+      },
+      forcePathStyle: true, // Required for MinIO
+    });
+  }
+
+  private getUploadUrl(fileName: string): string {
+    // For MinIO with path-style, the URL format is: endpoint/bucket/file
+    return `${this._endpoint}/${this._bucketName}/${fileName}`;
+  }
+
+  async uploadSimple(path: string) {
+    const loadImage = await fetch(path);
+    const contentType =
+      loadImage?.headers?.get('content-type') ||
+      loadImage?.headers?.get('Content-Type');
+    const extension = getExtension(contentType)!;
+    const id = makeId(10);
+
+    const params = {
+      Bucket: this._bucketName,
+      Key: `${id}.${extension}`,
+      Body: Buffer.from(await loadImage.arrayBuffer()),
+      ContentType: contentType,
+      ACL: 'public-read',
+    };
+
+    const command = new PutObjectCommand({ ...params });
+    await this._client.send(command);
+
+    return this.getUploadUrl(`${id}.${extension}`);
+  }
+
+  async uploadFile(file: Express.Multer.File): Promise<any> {
+    const id = makeId(10);
+    const extension = mime.extension(file.mimetype) || '';
+
+    const command = new PutObjectCommand({
+      Bucket: this._bucketName,
+      Key: `${id}.${extension}`,
+      Body: file.buffer,
+      ContentType: file.mimetype,
+      ACL: 'public-read',
+    });
+
+    await this._client.send(command);
+
+    const uploadUrl = this.getUploadUrl(`${id}.${extension}`);
+    return {
+      filename: `${id}.${extension}`,
+      mimetype: file.mimetype,
+      size: file.size,
+      buffer: file.buffer,
+      originalname: `${id}.${extension}`,
+      fieldname: 'file',
+      path: uploadUrl,
+      destination: uploadUrl,
+      encoding: '7bit',
+      stream: file.buffer as any,
+    };
+  }
+
+  async removeFile(filePath: string): Promise<void> {
+    const fileName = filePath.split('/').pop();
+    if (fileName) {
+      const command = new DeleteObjectCommand({
+        Bucket: this._bucketName,
+        Key: fileName,
+      });
+      await this._client.send(command);
+    }
+  }
+}
+
+export { MinIOStorage };
+export default MinIOStorage;

libraries/nestjs-libraries/src/upload/s3.storage.ts

@@ -0,0 +1,103 @@
+import { S3Client, PutObjectCommand, DeleteObjectCommand } from '@aws-sdk/client-s3';
+import 'multer';
+import { makeId } from '@gitroom/nestjs-libraries/services/make.is';
+import mime from 'mime-types';
+// @ts-ignore
+import { getExtension } from 'mime';
+import { IUploadProvider } from './upload.interface';
+
+class S3Storage implements IUploadProvider {
+  private _client: S3Client;
+
+  constructor(
+    private _accessKeyId: string,
+    private _secretAccessKey: string,
+    private _region: string,
+    private _bucketName: string,
+    private _endpoint?: string
+  ) {
+    this._client = new S3Client({
+      endpoint: _endpoint, // Optional custom endpoint for S3-compatible services like MinIO
+      region: _region,
+      credentials: {
+        accessKeyId: _accessKeyId,
+        secretAccessKey: _secretAccessKey,
+      },
+    });
+  }
+
+  private getUploadUrl(fileName: string): string {
+    if (this._endpoint) {
+      // For custom S3-compatible endpoints (like MinIO), use endpoint/bucket/file
+      return `${this._endpoint}/${this._bucketName}/${fileName}`;
+    } else {
+      // For standard AWS S3, use bucket.s3.region.amazonaws.com/file
+      return `https://${this._bucketName}.s3.${this._region}.amazonaws.com/${fileName}`;
+    }
+  }
+
+  async uploadSimple(path: string) {
+    const loadImage = await fetch(path);
+    const contentType =
+      loadImage?.headers?.get('content-type') ||
+      loadImage?.headers?.get('Content-Type');
+    const extension = getExtension(contentType)!;
+    const id = makeId(10);
+
+    const params = {
+      Bucket: this._bucketName,
+      Key: `${id}.${extension}`,
+      Body: Buffer.from(await loadImage.arrayBuffer()),
+      ContentType: contentType,
+      ACL: 'public-read',
+    };
+
+    const command = new PutObjectCommand({ ...params });
+    await this._client.send(command);
+
+    return this.getUploadUrl(`${id}.${extension}`);
+  }
+
+  async uploadFile(file: Express.Multer.File): Promise<any> {
+    const id = makeId(10);
+    const extension = mime.extension(file.mimetype) || '';
+
+    const command = new PutObjectCommand({
+      Bucket: this._bucketName,
+      Key: `${id}.${extension}`,
+      Body: file.buffer,
+      ContentType: file.mimetype,
+      ACL: 'public-read',
+    });
+
+    await this._client.send(command);
+
+    const uploadUrl = this.getUploadUrl(`${id}.${extension}`);
+    return {
+      filename: `${id}.${extension}`,
+      mimetype: file.mimetype,
+      size: file.size,
+      buffer: file.buffer,
+      originalname: `${id}.${extension}`,
+      fieldname: 'file',
+      path: uploadUrl,
+      destination: uploadUrl,
+      encoding: '7bit',
+      stream: file.buffer as any,
+    };
+  }
+
+  async removeFile(filePath: string): Promise<void> {
+    const fileName = filePath.split('/').pop();
+    if (fileName) {
+      const command = new DeleteObjectCommand({
+        Bucket: this._bucketName,
+        Key: fileName,
+      });
+      await this._client.send(command);
+    }
+  }
+}
+
+export { S3Storage };
+export default S3Storage;

libraries/nestjs-libraries/src/upload/upload.factory.ts

@@ -1,6 +1,8 @@
 import { CloudflareStorage } from './cloudflare.storage';
 import { IUploadProvider } from './upload.interface';
 import { LocalStorage } from './local.storage';
+import { S3Storage } from './s3.storage';
+import { MinIOStorage } from './minio.storage';
 
 export class UploadFactory {
   static createStorage(): IUploadProvider {
@@ -18,6 +20,22 @@ export class UploadFactory {
           process.env.CLOUDFLARE_BUCKETNAME!,
           process.env.CLOUDFLARE_BUCKET_URL!
         );
+      case 's3':
+        return new S3Storage(
+          process.env.S3_ACCESS_KEY_ID!,
+          process.env.S3_SECRET_ACCESS_KEY!,
+          process.env.S3_REGION!,
+          process.env.S3_BUCKET_NAME!,
+          process.env.S3_ENDPOINT
+        );
+      case 'minio':
+        return new MinIOStorage(
+          process.env.MINIO_ACCESS_KEY!,
+          process.env.MINIO_SECRET_KEY!,
+          process.env.MINIO_REGION!,
+          process.env.MINIO_BUCKET_NAME!,
+          process.env.MINIO_ENDPOINT!
+        );
       default:
         throw new Error(`Invalid storage type ${storageProvider}`);
     }