upload-file-backend/src/api/controllers/v1/path.controller.js

/* eslint-disable import/no-extraneous-dependencies */
// 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 {

    cdn as cdnConfig,
    storage as storageConfig
} from '../../../config/vars';
import uploadAdapter from '../../../common/services/adapters/upload-adapter';

function deleteFolderRecursive(folderPath) {
    if (fs.existsSync(folderPath)) {
        fs.readdirSync(folderPath).forEach((file) => {
            const curPath = path.join(folderPath, file);
            if (fs.lstatSync(curPath).isDirectory()) { // delete folder
                deleteFolderRecursive(curPath); // recursively call deleteFolderRecursive function
                fs.rmdirSync(curPath);
            } else { // delete file
                fs.unlinkSync(curPath);
            }
        });
    }
}
/**
 * get file and folder
 *
 * @param {Formdata} file
 */
exports.get = (req, res, next) => {
    try {
        const user = req.user;

        let path = `${storageConfig.uri}/${user.id}`;
        if (req.body.path) {
            path += req.body.path;
        }
        // console.log(path);
        const listFile = [];
        fs.readdir(path, (err, files) => {
            if (files && files.length > 0) {
                files.forEach((item) => {
                    listFile.push({
                        name: item,
                        path: `${cdnConfig.uri}/${user.id}${req.body.path}/${item}`,
                        isFolder: fs.lstatSync(`${storageConfig.uri}/${user.id}/${req.body.path}/${item}`).isDirectory()
                    });
                });
            }
            return res.json({
                code: 0,
                data: listFile
            });
        });
        // test local
        // fs.readdir(path, (err, files) => {
        //     if (files && files.length > 0) {
        //         files.forEach((item) => {
        //             listFile.push({
        //                 name: item,
        //                 path: `${storageConfig.uri}/${user.id}${req.body.path}/${item}`,
        //                 isFolder: fs.lstatSync(`${storageConfig.uri}/${user.id}/${req.body.path}/${item}`).isDirectory()
        //             });
        //         });
        //     }
        //     return res.json({
        //         code: 0,
        //         data: listFile
        //     });
        // });


        return null;
        /** resize image uploaded */
    } catch (ex) {
        return ErrorHandel(ex, req, res, next);
    }
};

/**
 * get file and folder
 *
 * @param {Formdata} file
 */
exports.create = (req, res, next) => {
    const user = req.user;
    let dir = `${user.id}`;
    const name_folder = cloneDeep(req.body.name).trim();
    if (req.body.path) {
        dir += req.body.path;
    }
    if (req.body.name) {
        dir += `/${name_folder}`;
    }
    if (!fs.existsSync(dir)) {
        uploadAdapter.createFolder({ path: dir });
    }
    return res.json({ code: 0, message: 'success' });
};

/**
 * get file and folder
 *
 * @param {Formdata} file
 */
exports.update = (req, res, next) => {
    try {
        const oldPath = req.body.oldPath.replace(cdnConfig.uri, storageConfig.uri);
        const newPath = req.body.newPath.replace(cdnConfig.uri, storageConfig.uri);

        fs.rename(oldPath, newPath, (err) => {
            if (err) {
                console.log(err);
                return res.status(400).json({ code: 400, message: 'lỗi' });
            }
            return res.json({ code: 0, message: 'success' });
        });
        return null;
    } catch (ex) {
        return ErrorHandel(ex, req, res, next);
    }
};


exports.delete = (req, res, next) => {
    try {
        const user = req.user;
        const dir = `${storageConfig.uri_backup}/${user.id}`;
        multer({ dest: `${dir}` });
        const path = req.body.path.replace(cdnConfig.uri, storageConfig.uri);
        const newpath = req.body.path.replace(cdnConfig.uri, storageConfig.uri_backup);
        // fs.rm(path, { recursive: true }, err => {
        //     if (err) {
        //         return res.status(400).json({ code: 400, message: 'lỗi', detail: err });
        //     }
        //     return res.json({ code: 0, message: 'success' });
        // });
        fs.rename(path, newpath, (err) => {
            if (err) throw err;
            return res.json({ code: 0, message: 'success' });
        });
        return null;
    } catch (ex) {
        return ErrorHandel(ex, 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 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.
        // });


        // 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} `;
            });
        }
        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'
                });
            }
            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);
    }
};


exports.forceDelete = (req, res, next) => {
    try {
        const path = req.body.path.replace(cdnConfig.uri, storageConfig.uri);
        // const newpath = req.body.path.replace(cdnConfig.uri, storageConfig.uri_backup);
        fs.rm(path, { recursive: true }, err => {
            if (err) {
                return res.status(400).json({ code: 400, message: 'lỗi', detail: err });
            }
            return res.json({ code: 0, message: 'success' });
        });

        return null;
    } catch (ex) {
        return ErrorHandel(ex, req, res, next);
    }
};

exports.deleteMultiple = (req, res, next) => {
    try {
        const user = req.user;
        const dir = `${storageConfig.uri_backup}/${user.id}/${Date.now()}`;
        multer({ dest: `${dir}` });
        if (req.body.data) {
            req.body.data.forEach((e) => {
                const path = e.path.replace(cdnConfig.uri, storageConfig.uri);
                let newpath = e.path.replace(cdnConfig.uri, storageConfig.uri_backup);
                const split = newpath.split('/');
                newpath = `${dir}/${split[split.length - 1]}`;
                fs.rename(path, newpath, (err) => {
                    if (err) throw err;
                    return { code: 0, message: 'success' };
                });
            });
        }
        return res.json({ code: 0, message: 'success' });
    } catch (ex) {
        return ErrorHandel(ex, req, res, next);
    }
};