fix: refactoring of storage method

src/features/storages/providers/s3.ts

@@ -1,6 +1,6 @@
 import * as Minio from "minio";
-import {StorageDeleteInput, StorageGetInput, StorageResult, StorageUploadInput} from "../types";
-import {getServerUrl} from "@/utils/get-server-url";
+import {StorageDeleteInput, StorageGetInput, StorageMetaData, StorageResult, StorageUploadInput} from "../types";
+import {generateFileUrl} from "@/features/storages/helpers";
 
 type S3Config = {
     endPointUrl: string;
@@ -30,7 +30,10 @@ async function ensureBucket(config: S3Config) {
     if (!exists) await client.makeBucket(config.bucketName);
 }
 
-export async function uploadS3(config: S3Config, input: { data: StorageUploadInput }): Promise<StorageResult> {
+export async function uploadS3(
+    config: S3Config,
+    input: { data: StorageUploadInput, metadata?: StorageMetaData  }
+): Promise<StorageResult> {
     const client = await getS3Client(config);
     await ensureBucket(config);
 
@@ -44,16 +47,32 @@ export async function uploadS3(config: S3Config, input: { data: StorageUploadInp
     }
 
     await client.putObject(config.bucketName, key, input.data.file as Buffer);
-    const baseUrl = getServerUrl();
 
+
+    if (input.data.url) {
+        const url = await generateFileUrl(input);
+        if (!url) {
+            return {
+                success: false,
+                provider: "s3",
+                response: "Unable to get url file"
+            };
+        }
+        return {
+            success: true,
+            provider: 's3',
+            url: url
+        };
+    }
     return {
         success: true,
         provider: 's3',
-        url: `${baseUrl}/api/${input.data.path}`,
     };
+
+
 }
 
-export async function getS3(config: S3Config, input: { data: StorageGetInput }): Promise<StorageResult> {
+export async function getS3(config: S3Config, input: { data: StorageGetInput, metadata: StorageMetaData  }): Promise<StorageResult> {
     const client = await getS3Client(config);
 
     const key = `${BASE_DIR}${input.data.path}`;
@@ -78,9 +97,8 @@ export async function getS3(config: S3Config, input: { data: StorageGetInput }):
     };
 }
 
-export async function deleteS3(config: S3Config, input: { data: StorageDeleteInput }): Promise<StorageResult> {
+export async function deleteS3(config: S3Config, input: { data: StorageDeleteInput, metadata?: StorageMetaData  }): Promise<StorageResult> {
     const client = await getS3Client(config);
-    // const key = input.data.path;
     const key = `${BASE_DIR}${input.data.path}`;
 
     try {

src/features/upload/public/upload.action.ts

@@ -8,6 +8,7 @@ import * as drizzleDb from "@/db";
 import {ServerActionResult} from "@/types/action-type";
 import {dispatchStorage} from "@/features/storages/dispatch";
 import {StorageInput} from "@/features/storages/types";
+import sharp from "sharp";
 
 
 export const uploadUserImageAction = userAction.schema(
@@ -22,6 +23,19 @@ export const uploadUserImageAction = userAction.schema(
         const buffer = Buffer.from(arrayBuffer);
 
 
+        const isPng = fileFormat === "png";
+        const isWebp = fileFormat === "webp";
+
+        const compressedBuffer = await sharp(buffer)
+            .resize({ width: 1024 })
+            .toFormat(isPng ? "png" : isWebp ? "webp" : "jpeg", {
+                quality: 80,
+                compressionLevel: isPng ? 9 : undefined
+            })
+            .toBuffer();
+
+
+
         const settings = await db.query.setting.findFirst({
             where: eq(drizzleDb.schemas.setting.name, "system"),
             with: {
@@ -45,7 +59,7 @@ export const uploadUserImageAction = userAction.schema(
             action: "upload",
             data: {
                 path: path,
-                file: buffer,
+                file: compressedBuffer,
                 url: true
             },
             metadata: {