feat(idrive-e2-storage): add idrive e2 storage integration

- Add IDrive e2 storage module with S3-compatible API integration
- Create file-type enum for categorizing uploads (IMAGE, DOCUMENT, VIDEO)
- Implement presigned URL generation for secure file uploads and downloads
- Add file deletion functionality with URL-based file removal
- Create storage configuration with environment variables for endpoint, region, access key, secret key, and bucket
- Add controller endpoints for presigned upload/download URLs and file deletion
- Implement automatic file organization by type into separate folders
- Add comprehensive error handling and logging throughout the service
- Update environment example file with IDrive e2 credentials configuration
- Integrate IDrive e2 module into main upload module exports

.env.example

@@ -103,3 +103,10 @@ RUSTFS_ACCESS_KEY="your-rustfs-access-key"
 RUSTFS_SECRET_KEY="your-rustfs-secret-key"
 RUSTFS_BUCKET="streamflix"
 RUSTFS_REGION="us-east-1"
+
+# IDrive e2 Storage Credentials
+IDRIVE_E2_ENDPOINT="https://s3.ap-southeast-1.idrivee2.com"
+IDRIVE_E2_REGION="ap-southeast-1"
+IDRIVE_E2_ACCESS_KEY="your-idrive-access-key"
+IDRIVE_E2_SECRET_KEY="your-idrive-secret-key"
+IDRIVE_E2_BUCKET="streamflix"

src/shared/modules/upload/idrive-e2-storage/enums/file-type.enum.ts

@@ -0,0 +1,5 @@
+export enum FileType {
+  IMAGE = 'IMAGE',
+  DOCUMENT = 'DOCUMENT',
+  VIDEO = 'VIDEO',
+}

src/shared/modules/upload/idrive-e2-storage/idrive-e2-storage.config.ts

@@ -0,0 +1,9 @@
+import { registerAs } from '@nestjs/config';
+
+export default registerAs('idriveE2Storage', () => ({
+  endpoint: process.env.IDRIVE_E2_ENDPOINT,
+  region: process.env.IDRIVE_E2_REGION || 'ap-southeast-1',
+  accessKey: process.env.IDRIVE_E2_ACCESS_KEY,
+  secretKey: process.env.IDRIVE_E2_SECRET_KEY,
+  bucket: process.env.IDRIVE_E2_BUCKET || 'streamflix',
+}));

src/shared/modules/upload/idrive-e2-storage/idrive-e2-storage.controller.ts

@@ -0,0 +1,62 @@
+import {
+  Controller,
+  Get,
+  Delete,
+  Query,
+  HttpCode,
+  HttpStatus,
+} from '@nestjs/common';
+import { ApiTags, ApiOperation, ApiQuery } from '@nestjs/swagger';
+import { IdriveE2StorageService } from './idrive-e2-storage.service';
+import { FileType } from './enums/file-type.enum';
+
+@ApiTags('Upload: IDrive e2 Storage')
+@Controller('idrive-e2')
+export class IdriveE2StorageController {
+  constructor(
+    private readonly idriveE2StorageService: IdriveE2StorageService,
+  ) {}
+
+  @Get('presigned-upload')
+  @ApiOperation({ summary: 'Get presigned upload URL' })
+  @ApiQuery({ name: 'fileName', required: true })
+  @ApiQuery({ name: 'fileType', enum: FileType, required: false })
+  async getPresignedUploadUrl(
+    @Query('fileName') fileName: string,
+    @Query('fileType') fileType?: FileType,
+  ) {
+    return this.idriveE2StorageService.getPresignedUploadUrl(
+      fileName,
+      fileType,
+    );
+  }
+
+  @Get('presigned-download')
+  @ApiOperation({ summary: 'Get presigned download URL for existing file' })
+  @ApiQuery({ name: 'filePath', required: true })
+  @ApiQuery({
+    name: 'expiresIn',
+    required: false,
+    description: 'Expiration time in seconds (default: 604800)',
+  })
+  async getPresignedDownloadUrl(
+    @Query('filePath') filePath: string,
+    @Query('expiresIn') expiresIn?: number,
+  ) {
+    return this.idriveE2StorageService.getPresignedDownloadUrl(
+      filePath,
+      expiresIn,
+    );
+  }
+
+  @Delete('by-url')
+  @HttpCode(HttpStatus.OK)
+  @ApiOperation({ summary: 'Delete file by URL' })
+  async deleteFileByUrl(@Query('url') url: string) {
+    const result = await this.idriveE2StorageService.deleteFileByUrl(url);
+    return {
+      message: 'File deleted successfully',
+      ...result,
+    };
+  }
+}

src/shared/modules/upload/idrive-e2-storage/idrive-e2-storage.module.ts

@@ -0,0 +1,13 @@
+import { Module } from '@nestjs/common';
+import { ConfigModule } from '@nestjs/config';
+import { IdriveE2StorageController } from './idrive-e2-storage.controller';
+import { IdriveE2StorageService } from './idrive-e2-storage.service';
+import idriveE2StorageConfig from './idrive-e2-storage.config';
+
+@Module({
+  imports: [ConfigModule.forFeature(idriveE2StorageConfig)],
+  controllers: [IdriveE2StorageController],
+  providers: [IdriveE2StorageService],
+  exports: [IdriveE2StorageService],
+})
+export class IdriveE2StorageModule {}

src/shared/modules/upload/idrive-e2-storage/idrive-e2-storage.service.ts

@@ -0,0 +1,193 @@
+import { Injectable, Logger, NotFoundException } from '@nestjs/common';
+import { ConfigService } from '@nestjs/config';
+import {
+  S3Client,
+  PutObjectCommand,
+  GetObjectCommand,
+  DeleteObjectCommand,
+} from '@aws-sdk/client-s3';
+import { getSignedUrl } from '@aws-sdk/s3-request-presigner';
+
+@Injectable()
+export class IdriveE2StorageService {
+  private readonly logger = new Logger(IdriveE2StorageService.name);
+  private s3Client: S3Client;
+  private bucket: string;
+  private endpoint: string;
+  private region: string;
+
+  constructor(private configService: ConfigService) {
+    this.endpoint =
+      this.configService.get<string>('idriveE2Storage.endpoint') || '';
+    this.region =
+      this.configService.get<string>('idriveE2Storage.region') ||
+      'ap-southeast-1';
+    const accessKeyId =
+      this.configService.get<string>('idriveE2Storage.accessKey') || '';
+    const secretAccessKey =
+      this.configService.get<string>('idriveE2Storage.secretKey') || '';
+    this.bucket =
+      this.configService.get<string>('idriveE2Storage.bucket') || 'streamflix';
+
+    this.s3Client = new S3Client({
+      region: this.region,
+      endpoint: this.endpoint,
+      credentials: {
+        accessKeyId,
+        secretAccessKey,
+      },
+      forcePathStyle: true,
+    });
+  }
+
+  /**
+   * Get folder path based on file type
+   */
+  private getFolderPath(fileType: string): string {
+    const folderMap: Record<string, string> = {
+      IMAGE: 'images',
+      DOCUMENT: 'documents',
+      VIDEO: 'videos',
+    };
+    return folderMap[fileType.toUpperCase()] || 'others';
+  }
+
+  /**
+   * Generate presigned upload URL using S3
+   */
+  async getPresignedUploadUrl(fileName: string, fileType?: string) {
+    try {
+      const folder = fileType ? this.getFolderPath(fileType) : 'others';
+      const timestamp = Date.now();
+      const filePath = `${folder}/${timestamp}-${fileName}`;
+
+      const putCommand = new PutObjectCommand({
+        Bucket: this.bucket,
+        Key: filePath,
+      });
+
+      const uploadUrl = await getSignedUrl(this.s3Client, putCommand, {
+        expiresIn: 3600,
+      });
+
+      // For private buckets, generate presigned download URL
+      const getCommand = new GetObjectCommand({
+        Bucket: this.bucket,
+        Key: filePath,
+      });
+
+      const fileUrl = await getSignedUrl(this.s3Client, getCommand, {
+        expiresIn: 604800, // 7 days for download URL
+      });
+
+      this.logger.log(
+        `Generated presigned upload URL for: ${filePath}${fileType ? ` (type: ${fileType})` : ''}`,
+      );
+
+      return {
+        uploadUrl,
+        fileUrl, // Presigned download URL (valid for 7 days)
+        filePath,
+        uploadExpiresIn: 3600, // 1 hour
+        downloadExpiresIn: 604800, // 7 days
+        ...(fileType && { fileType }),
+      };
+    } catch (error) {
+      this.logger.error('Failed to generate presigned upload URL', error);
+      throw error;
+    }
+  }
+
+  /**
+   * Get presigned download URL for an existing file
+   */
+  async getPresignedDownloadUrl(filePath: string, expiresIn: number = 604800) {
+    try {
+      const command = new GetObjectCommand({
+        Bucket: this.bucket,
+        Key: filePath,
+      });
+
+      const downloadUrl = await getSignedUrl(this.s3Client, command, {
+        expiresIn,
+      });
+
+      this.logger.log(`Generated presigned download URL for: ${filePath}`);
+
+      return {
+        downloadUrl,
+        filePath,
+        expiresIn,
+      };
+    } catch (error) {
+      this.logger.error('Failed to generate presigned download URL', error);
+      throw error;
+    }
+  }
+
+  /**
+   * Delete a file from IDrive e2 Storage
+   */
+  async deleteFile(filePath: string): Promise<any> {
+    try {
+      const command = new DeleteObjectCommand({
+        Bucket: this.bucket,
+        Key: filePath,
+      });
+
+      const result = await this.s3Client.send(command);
+
+      this.logger.log(`Successfully deleted file: ${filePath}`);
+      return {
+        success: true,
+        deletedPath: filePath,
+        result,
+      };
+    } catch (error) {
+      this.logger.error(`Failed to delete file: ${filePath}`, error);
+      throw new NotFoundException('File not found or already deleted');
+    }
+  }
+
+  /**
+   * Delete a file by URL
+   */
+  async deleteFileByUrl(url: string): Promise<any> {
+    try {
+      const filePath = this.extractFilePathFromUrl(url);
+
+      if (!filePath) {
+        throw new NotFoundException('Could not extract file path from URL');
+      }
+
+      const result = await this.deleteFile(filePath);
+
+      this.logger.log(`Successfully deleted file from URL: ${url}`);
+
+      return {
+        ...result,
+        deletedUrl: url,
+      };
+    } catch (error) {
+      if (error instanceof NotFoundException) {
+        throw error;
+      }
+      this.logger.error(`Failed to delete file by URL: ${url}`, error);
+      throw new NotFoundException('File not found or already deleted');
+    }
+  }
+
+  /**
+   * Extract file path from IDrive e2 Storage URL
+   */
+  private extractFilePathFromUrl(url: string): string | null {
+    try {
+      // Format: https://streamflix.ap-southeast-1.idrivee2.com/images/123-file.jpg
+      const urlObj = new URL(url);
+      const path = urlObj.pathname;
+      return path.startsWith('/') ? path.substring(1) : path;
+    } catch {
+      return null;
+    }
+  }
+}

src/shared/modules/upload/upload.module.ts

@@ -9,6 +9,7 @@ import { SeaweedfsStorageModule } from './seaweedfs-storage/seaweedfs-storage.mo
 import { FilestackModule } from './filestack/filestack.module';
 import { GarageStorageModule } from './garage-storage/garage-storage.module';
 import { RustfsStorageModule } from './rustfs-storage/rustfs-storage.module';
+import { IdriveE2StorageModule } from './idrive-e2-storage/idrive-e2-storage.module';
 
 @Module({
   imports: [
@@ -20,6 +21,7 @@ import { RustfsStorageModule } from './rustfs-storage/rustfs-storage.module';
     OldMinioStorageModule,
     GarageStorageModule,
     RustfsStorageModule,
+    IdriveE2StorageModule,
     SeaweedfsStorageModule,
     FilestackModule,
   ],