feat: update image

Author: fdhhhdjd

package-lock.json

@@ -25,6 +25,7 @@
     "jsonwebtoken": "^9.0.2",
     "knex": "^3.1.0",
     "morgan": "^1.10.0",
+    "multer": "^1.4.5-lts.1",
     "node-cron": "^3.0.3",
     "nodemailer": "^6.9.9",
     "nodemailer-express-handlebars": "^6.1.0",

package.json

@@ -3,9 +3,23 @@ const { SuccessResponse } = require("../../../cores/success.response");
 const imageService = require("../services/image.service");
 
 class UploadController {
-  async upload(_, res, ___) {
+  async upload(req, res, ___) {
     new SuccessResponse({
-      metadata: await imageService.upload(),
+      metadata: await imageService.upload(req.userInfo, req.file),
+    }).send(res);
+  }
+
+  async uploadMulti(req, res, ___) {
+    new SuccessResponse({
+      metadata: await imageService.uploadMulti(req.userInfo, {
+        files: req.files,
+      }),
+    }).send(res);
+  }
+
+  async removeImage(req, res, ___) {
+    new SuccessResponse({
+      metadata: await imageService.removePublicId(req.body),
     }).send(res);
   }
 }

src/app/v2/controllers/image.controller.js

@@ -4,9 +4,27 @@ const express = require("express");
 //* IMPORT
 const imageController = require("../../controllers/image.controller");
 const { asyncHandler } = require("../../../../commons/helpers/asyncHandler");
+const { uploadDisk } = require("../../../../commons/configs/multer.config");
+const {
+  checkAuthorizationAccessToken,
+} = require("../../../../auth/check.auth");
 
 const router = express.Router();
 
-router.post("/upload", asyncHandler(imageController.upload));
+router.use(checkAuthorizationAccessToken);
+
+router.post(
+  "/upload",
+  uploadDisk.single("file", 1),
+  asyncHandler(imageController.upload)
+);
+
+router.post(
+  "/upload/multi",
+  uploadDisk.array("files", 3),
+  asyncHandler(imageController.uploadMulti)
+);
+
+router.post("/remove", asyncHandler(imageController.removeImage));
 
 module.exports = router;

src/app/v2/routes/images/index.js

@@ -1,6 +1,96 @@
+//* LIB
+const _ = require("lodash");
+const fs = require("fs");
+
+//* IMPORT
+const cloudinary = require("../../../databases/init.cloudinary");
+const { BadRequestRequestError } = require("../../../cores/error.response");
+
 class ImageService {
-  async upload() {
-    return "Ok";
+  async upload(info, { path, folderName = "class/" }) {
+    console.log(path, "----");
+    if (_.isEmpty(info) || _.isEmpty(path)) {
+      await this.removeTmp(path);
+      throw new BadRequestRequestError();
+    }
+
+    const uploadResult = await cloudinary.uploader.upload(
+      path,
+      function (res) {
+        console.log(res);
+      },
+      {
+        public_id: Date.now() + "thumb",
+        folder: folderName + info.id,
+        use_filename: true,
+      }
+    );
+
+    const thumbUrl = await cloudinary.url(uploadResult.public_id, {
+      height: 100,
+      width: 100,
+      format: "jpg",
+    });
+
+    return {
+      public_id: uploadResult.public_id,
+      image_url: uploadResult.secure_url,
+      thumb_size: thumbUrl,
+      info,
+    };
+  }
+  async uploadMulti(info, { files }, folderName = "class/") {
+    if (_.isEmpty(info) || _.isEmpty(files)) {
+      throw new BadRequestRequestError();
+    }
+
+    const uploadTasks = files.map(async (file) => {
+      const result = await cloudinary.uploader.upload(
+        file.path,
+        {},
+        {
+          public_id: Date.now() + "thumb",
+          folder: folderName + info.id,
+        }
+      );
+
+      const thumbSize = await cloudinary.url(result.public_id, {
+        height: 100,
+        width: 100,
+        format: "jpg",
+      });
+
+      return {
+        image_url: result.secure_url,
+        shopId: 8409,
+        thumb_size: thumbSize,
+      };
+    });
+    return await Promise.all(uploadTasks);
+  }
+
+  async removePublicId({ public_id }) {
+    if (_.isEmpty(public_id)) {
+      throw new BadRequestRequestError();
+    }
+
+    const result = await cloudinary.uploader.destroy(public_id, {});
+
+    return result;
+  }
+
+  async removeTmp(path) {
+    return new Promise((resolve, reject) => {
+      fs.unlink(path, (err) => {
+        if (err) {
+          console.error("Error removing temporary file:", err);
+          reject(err);
+        } else {
+          console.log("Temporary file removed successfully.");
+          resolve();
+        }
+      });
+    });
   }
 }
 

src/app/v2/services/image.service.js

@@ -0,0 +1,23 @@
+"use strict";
+
+//* LIB
+const multer = require("multer");
+
+const uploadMemory = multer({ storage: multer.memoryStorage() });
+
+const uploadDisk = multer({
+  storage: multer.diskStorage({
+    destination: function (req, file, cb) {
+      cb(null, "./src/uploads");
+    },
+    filename: function (req, file, cb) {
+      const uniqueSuffix = Date.now() + file.originalname;
+      cb(null, uniqueSuffix);
+    },
+  }),
+});
+
+module.exports = {
+  uploadMemory,
+  uploadDisk,
+};