feat: Merge branch dev

Author: roerohan

package.json

@@ -1,6 +1,6 @@
 {
     "name": "@ytdl/ytdl",
-    "version": "1.4.5",
+    "version": "1.4.6",
     "description": "A CLI/Library written in typescript/javascript, which allows you to download/play videos from YouTube onto your system.",
     "keywords": [
         "youtube",

src/videoDownloader.ts

@@ -21,37 +21,41 @@ export default class VideoDownloader {
      * Returns a `Node.js` stream obtained by sending a GET request to `this.url`.
      * @param headers Stores optional headers as object
      */
-    public async stream(headers?: object, preText?: string) {
-        const stream = await axios({
-            method: 'get',
-            url: this.url,
-            responseType: 'stream',
-            headers,
-        });
-
-        if (this.logger) {
-            const progressBar = new ProgressBar(stream.headers['content-length'], preText, this.logger);
-            stream.data.on('data', (chunk: string) => {
-                progressBar.update(chunk.length);
-            });
-        }
+    public async stream(headers?: object) {
+        const stream = await this.request(headers);
         return stream.data;
     }
 
     /**
      * Saves the downloaded stream to a file specified by `filename`.
      * @param filename Stores the filename to store the downloaded stream in
      */
-    public async download(filename: string): Promise<void> {
-        const videoStream = await this.stream({}, 'Downloading');
+    public async download(filename: string, headers?: object): Promise<void> {
+        const stream = await this.request(headers);
+
+        if (this.logger) {
+            const progressBar = new ProgressBar(stream.headers['content-length'], 'Downloading', this.logger);
+            stream.data.on('data', (chunk: string) => {
+                progressBar.update(chunk.length);
+            });
+        }
 
         return new Promise((resolve, reject) => {
-            videoStream
+            stream.data
                 .pipe(fs.createWriteStream(filename))
                 .on('finish', (err: Error) => {
                     if (err) reject(err);
                     else resolve();
                 });
         });
     }
+
+    private async request(headers?: object) {
+        return axios({
+            method: 'get',
+            url: this.url,
+            responseType: 'stream',
+            headers,
+        });
+    }
 }