2020-02-07 03:11:24 +02:00
|
|
|
import fetch from "node-fetch";
|
|
|
|
|
import { throttle } from "throttle-debounce";
|
|
|
|
|
import * as fs from "fs";
|
|
|
|
|
|
|
|
|
|
export async function downloadFile(
|
|
|
|
|
url: string,
|
|
|
|
|
destFilePath: fs.PathLike,
|
|
|
|
|
onProgress: (readBytes: number, totalBytes: number) => void
|
|
|
|
|
): Promise<void> {
|
2020-02-08 04:22:44 +02:00
|
|
|
onProgress = throttle(1000, /* noTrailing: */ true, onProgress);
|
2020-02-07 03:11:24 +02:00
|
|
|
|
|
|
|
|
const response = await fetch(url);
|
|
|
|
|
|
|
|
|
|
const totalBytes = Number(response.headers.get('content-length'));
|
|
|
|
|
let readBytes = 0;
|
|
|
|
|
|
|
|
|
|
return new Promise<void>((resolve, reject) => response.body
|
|
|
|
|
.on("data", (chunk: Buffer) => {
|
|
|
|
|
readBytes += chunk.length;
|
|
|
|
|
onProgress(readBytes, totalBytes);
|
|
|
|
|
})
|
|
|
|
|
.on("end", resolve)
|
|
|
|
|
.on("error", reject)
|
|
|
|
|
.pipe(fs.createWriteStream(destFilePath))
|
|
|
|
|
);
|
|
|
|
|
}
|