change

This reverts commit 7bd4b58a0d.

src/api/controllers/v1/path.controller.js

@@ -2,10 +2,8 @@
 // import httpStatus from 'http-status';
 import fs from 'fs';
 import archiver from 'archiver';
-import { exec } from 'child_process';
 import multer from 'multer';
 import path from 'path';
-import { cloneDeep } from 'lodash';
 import { handler as ErrorHandel } from '../../middlewares/errors';
 // import ApiException from '../../../common/utils/APIException';
 import {
@@ -14,6 +12,7 @@ import {
     storage as storageConfig
 } from '../../../config/vars';
 import uploadAdapter from '../../../common/services/adapters/upload-adapter';
+import { cloneDeep, forEach } from 'lodash';
 
 function deleteFolderRecursive(folderPath) {
     if (fs.existsSync(folderPath)) {
@@ -153,53 +152,41 @@ exports.delete = (req, res, next) => {
 exports.download = async (req, res, next) => {
     try {
         const user = req.user;
-        const namefile = `${user.name.replace(/\s/g, '')}-${Date.now()}.zip`;
+        const namefile = `${user.name}-${Date.now()}.zip`;
         const dir = `${storageConfig.uri}/download/${user.id}/${namefile}`;
         const folder = `${storageConfig.uri}/download/${user.id}`;
         multer({ dest: `${folder}` });
         await deleteFolderRecursive(folder);
-        let command = ` zip -r ${dir} `;
-
-        // const output = fs.createWriteStream(dir);
-        // const archive = archiver('zip', {
-        //     zlib: { level: 9 } // Sets the compression level.
-        // });
+        const output = fs.createWriteStream(dir);
+        const archive = archiver('zip', {
+            zlib: { level: 9 } // Sets the compression level.
+        });
 
 
-        // archive.pipe(output);
+        archive.pipe(output);
         if (req.body.data) {
             req.body.data.forEach((e) => {
-                const path1 = e.path.replace(cdnConfig.uri, storageConfig.uri).replace(/ /g, '\\ ');
-
-                command += `${path1} `;
+                const path = e.path.replace(cdnConfig.uri, storageConfig.uri).replace(/ /g, '\\ ');
+                // const path = e.path.replace(cdnConfig.uri, storageConfig.uri);
+                console.log('path', path);
+                // const download = path.split("/");
+                // download.splice( download.indexOf(`${user.id}`), 0, "download");
+                // const final_path = download.join("/");
+                if (e.isFolder) {
+                    archive.directory(path, e.name);
+                } else {
+                    archive.file(path, { name: e.name });
+                }
             });
         }
-        console.log(command);
-
 
-        exec(command, (error, stdout, stderr) => {
-            if (error) {
-                console.error(`Command execution error: ${error.message}`);
-                return res.status(400).json({
-                    code: 400,
-                    message: 'error'
-                });
+        archive.finalize();
+        return res.json({
+            code: 0,
+            data: {
+                name: namefile,
+                path: `${cdnConfig.uri}/download/${user.id}/${namefile}`,
             }
-            if (stderr) {
-                console.error(`Command stderr: ${stderr}`);
-                return res.status(400).json({
-                    code: 400,
-                    message: 'error'
-                });
-            }
-            console.log(`Command output: ${stdout}`);
-            return res.json({
-                code: 0,
-                data: {
-                    name: namefile,
-                    path: `${cdnConfig.uri}/download/${user.id}/${namefile}`,
-                }
-            });
         });
     } catch (ex) {
         return ErrorHandel(ex, req, res, next);

src/common/models/file.model.js

@@ -31,40 +31,20 @@ File.init(
             autoIncrement: true,
             primaryKey: true
         },
-        url: {
-            type: DataTypes.STRING(255),
-            allowNull: false
-        },
         name: {
             type: DataTypes.STRING(255),
-            defaultValue: null
+            allowNull: false
         },
-        title: {
+        url: {
             type: DataTypes.STRING(255),
-            defaultValue: null
-        },
-        payload: {
-            type: DataTypes.JSONB,
-            defaultValue: null // id | code | name
-        },
-
-        // manager
-        is_active: {
-            type: DataTypes.BOOLEAN,
-            defaultValue: true
-        },
-        created_at: {
-            type: DataTypes.DATE,
-            defaultValue: DataTypes.NOW
-        },
-        updated_at: {
-            type: DataTypes.DATE,
-            defaultValue: DataTypes.NOW
+            allowNull: false
         },
-        created_by: {
-            type: DataTypes.JSONB,
-            defaultValue: null // id | name
+        download_count: {
+            type: DataTypes.NUMBER,
+            allowNull: true,
+            defaultValue: 0
         }
+
     },
     {
         timestamps: false,
@@ -209,7 +189,7 @@ File.get = async (id) => {
         if (!data) {
             throw new APIError({
                 status: httpStatus.NOT_FOUND,
-                message: 'Không tìm thấy địa chỉ tỉnh/thành!'
+                message: 'Không tìm thấy địa chỉ file!'
             });
         }
         return data;

src/common/services/adapters/upload-adapter.js

@@ -79,7 +79,7 @@ const storage = multer.diskStorage({
         //     : file.originalname;
         cb(
             null,
-            `/${path}/${file.originalname.replace(/\s/g, '')}`
+            `/${path}/${file.originalname.replace(/[\s()]/g, '')}`
         );
     }
 });