stream and ungzip.js

//@ts-check
import got from "got";
import stream from "stream";
import zlib from "zlib";
import fs from "fs";
const fileList = ["file.gz", "file1.gz", "file2.gz", "file3.gz"];
const tmpFolderPath = "/tmp";

async function main() {
  const transferTasks = fileList.map(
    (file) =>
      new Promise((resolve, reject) => {
        const outfile = file.replace(".gz", "");
        const inFilePath = `http://example.com/path/to/${file}`;
        const rstream = got.stream(inFilePath);
        const fswstream = fs.createWriteStream(`${tmpFolderPath}/${outfile}`);
        stream.pipeline(rstream, zlib.createGunzip(), fswstream, (err) => {
          if (err) {
            reject();
          } else {
            resolve();
          }
        });
      })
  );

  await Promise.all(transferTasks).catch((err) => {
    console.error("Error in promise all transferTask", err);
  });
}

main().catch(console.error);