feat: concurrent option

Author: DawnImpulse

src/download.ts

@@ -5,12 +5,12 @@ export default async function (
     repos: GithubRepo[],
     user: GithubUser,
     token: string,
-    path: string
+    path: string,
+    concurrent: number
 ) {
     const total = repos.length;
     let done = 0;
     let failed = 0;
-    const maxConcurrentClones = 10;
 
     const clonePromises: any[] = [];
 
@@ -28,8 +28,8 @@ export default async function (
         );
 
         // Limit concurrent clones
-        if (clonePromises.length >= maxConcurrentClones) {
-            await Promise.all(clonePromises.splice(0, maxConcurrentClones));
+        if (clonePromises.length >= concurrent) {
+            await Promise.all(clonePromises.splice(0, concurrent));
             console.log(`Downloaded ${done}/${total} , Failed ${failed}`);
         }
     }

src/index.ts

@@ -28,6 +28,11 @@ program
         "(optional) output directory; default is current directory",
         ""
     )
+    .option(
+        "-c, --concurrent <char>",
+        "(optional) concurrent/parallel downloads; default is 2",
+        ""
+    )
     .option(
         "-u, --utc",
         "(optional) whether your utc timezone; default is system",
@@ -47,6 +52,9 @@ program
                 process.exit();
             }
 
+            // --- get concurrent/parallel count
+            const concurrent = Number(data.concurrent);
+
             // --- name of the file
             console.log(info, "processing filename & output path");
             let name = fileName(data.name, data.utc);
@@ -69,8 +77,11 @@ program
             console.log(success, "fetched list of all user repos");
 
             // --- download all repos
-            console.log(info, "downloading repos");
-            await download(repos, user, data.token, path);
+            console.log(
+                info,
+                `downloading repos - ${concurrent} repos in parallel`
+            );
+            await download(repos, user, data.token, path, concurrent);
             console.log(success, "downloaded all repos");
 
             // --- if compress