(hotfix): make the tarball handling async

Author: collapsinghierarchy

package.json

@@ -44,12 +44,12 @@
 
   "repository": {
     "type": "git",
-    "url": "git+https://github.com/collapsinghierarchy/noisytransfer-cli.git"
+    "url": "git+https://github.com/collapsinghierarchy/noisytransfercli.git"
   },
   "bugs": {
-    "url": "https://github.com/collapsinghierarchy/noisytransfer-cli/issues"
+    "url": "https://github.com/collapsinghierarchy/noisytransfercli/issues"
   },
-  "homepage": "https://github.com/collapsinghierarchy/noisytransfer-cli#readme",
+  "homepage": "https://github.com/collapsinghierarchy/noisytransfercli#readme",
 
   "scripts": {
     "clean": "rimraf dist .turbo .tsbuildinfo",

src/commands/send.js

@@ -54,6 +54,7 @@ export async function run(paths, opts, ctx = {}) {
   // Build source + exact totalBytes
   let sourceStream;
   let totalBytes;
+  let tarPromise = null;
 
   if (useStdin) {
     sourceStream = process.stdin;
@@ -73,21 +74,14 @@ export async function run(paths, opts, ctx = {}) {
     sendNameHint = sanitizeFilename(deriveSendName(firstPath, opts) || "");
   } else {
     // multi-path (or a directory) → stream a tar we build on the fly
-    const { pack, totalSizeTar } = await makeTarPack(paths, { exclude: opts.exclude || [] });
-    sourceStream = pack;
-    totalBytes = totalSizeTar;
+    tarPromise = makeTarPack(paths, { exclude: opts.exclude || [] });
     sendNameHint = sanitizeFilename(deriveSendName(firstPath, opts) || "");
     // Set a stable .tar name unless user overrode with --name
     const base = path.basename(firstPath === "-" ? "stdin" : paths[0]);
     const stem = base.replace(/\.(tar|tgz|zip)$/i, "");
     sendNameHint = opts?.name ? String(opts.name) : `${stem}.tar`;
     getLogger().debug(`send: tarball name set to ${sendNameHint}`);
   }
-  
-  if (!Number.isInteger(totalBytes) || totalBytes <= 0) {
-    throw new Error(`internal: computed totalBytes invalid (${totalBytes})`);
-  }
-
   // Progress UI
   const t0 = Date.now();
   let lastTick = 0;
@@ -122,6 +116,17 @@ export async function run(paths, opts, ctx = {}) {
   getLogger().debug("send: RTC connected");
 
   try {
+
+    if (tarPromise) {
+      const { pack, totalSizeTar } = await tarPromise;
+      sourceStream = pack;
+      totalBytes = totalSizeTar;
+    }
+
+    if (!Number.isInteger(totalBytes) || totalBytes <= 0) {
+      throw new Error(`internal: computed totalBytes invalid (${totalBytes})`);
+    }
+    
     if (opts.pq) {
       //const rtcAuth = wrapAuthDC(rtc, { sessionId, label: "pq-auth-sender" });
       await pqSend(rtc, {