postZip.js

var fs = require("fs");
var path = require("path");
var url = require("url");
var http = require("http");
var https = require("https");
var JSZip = require("jszip");
var mkdirp = require("mkdirp");

function addFolder(folder, zip) {
    if (!fs.existsSync(folder)) {
        console.log("Error: postZIP - folder not found:", folder);
    } else {
        let files = fs.readdirSync(folder),
            file, stat, sourcePath;

        while (files.length > 0) {
            file = files.shift();
            sourcePath = path.join(folder, file);
            stat = fs.statSync(sourcePath);

            if (stat.isFile()) {
                zip.file(file, fs.readFileSync(sourcePath), { binary: true });
            } else {
                addFolder(sourcePath + path.sep, zip.folder(file));
            }
        }
    }
}

module.exports = function (_paths, fileName, output) {
    let zip = new JSZip();
    if (!Array.isArray(_paths)) {
        _paths = [_paths];
    }
    // console.log(fileName, "paths:", _paths);

    return new Promise(resolve => {
        zip.file("blank.txt", "Blank generator");
        for (let p of _paths) {
            if (typeof p === "string") {
                addFolder(p, zip);
            } else {
                let dest = zip;
                if (p.folder) {
                    dest = zip.folder(p.folder);
                }
                if (p.file && p.data) {
                    var options;
                    if (typeof p.data !== "string") {
                        options = {
                            binary: true,
                        };
                    }
                    dest.file(p.file, p.data, options);
                }
                if (p.path) {
                    addFolder(p.path, dest);
                }
            }
        }
        if (output.indexOf("http") === 0) {
            let postUrlString = output + "/" + fileName + "/" + fileName + ".zip";
            let postUrl = url.parse(postUrlString);
            let h = postUrl.protocol === "https:" ? https : http;
            let req = h.request(Object.assign(postUrl, {
                method: "POST",
            }), (res) => {
                console.log(`Post ${fileName} to service registry result: ${res.statusCode}/${res.statusMessage}`);
            });
            console.log("Generating zip archive...");
            zip.generateAsync({ type: "nodebuffer", compression: "DEFLATE" }).then((content) => {
                console.log(`Posting ${fileName} to service registry: "${postUrlString}"`);
                req.write(content, "binary");
                req.end();
            });
            return resolve();
        }
        output = path.resolve(output);
        mkdirp.sync(output);
        let outputFile = output + path.sep + fileName + ".zip";
        console.log(`${new Date()}  Writing ${fileName} to: ${outputFile}`);
        zip.generateNodeStream({ type: "nodebuffer", streamFiles: true, compression: "DEFLATE" })
            .pipe(fs.createWriteStream(outputFile))
            .on("finish", function () {
                console.log(`${new Date()} The ${fileName} was saved!`);
                return resolve();
            });
    });
};