remove the silencing of the flush

Author: collapsinghierarchy

package.json

@@ -64,7 +64,7 @@
     "@noisytransfer/errors": "^0.2.2",
     "@noisytransfer/noisyauth": "^0.2.4",
     "@noisytransfer/noisystream": "^0.2.5",
-    "@noisytransfer/transport": "^0.2.3",
+    "@noisytransfer/transport": "^0.2.4",
     "@noisytransfer/util": "^0.2.2",
     "commander": "^12.1.0",
     "micromatch": "^4.0.7",

src/commands/send.js

@@ -85,18 +85,21 @@ export async function run(paths, opts, ctx = {}) {
     getLogger().debug(`send: tarball name set to ${sendNameHint}`);
   }
   // Progress UI
-  const t0 = Date.now();
+  let startedAt = null;
   let lastTick = 0;
   function onProgress(sent, total) {
     getLogger().debug(`OnProgress: sent=${sent} total=${total}`);
     const now = Date.now();
+    if (startedAt == null && sent > 0) {
+      startedAt = now;
+    }
     if (now - lastTick < 120 && sent !== total) return;
     lastTick = now;
     if (process.stderr.isTTY) {
       const msg = formatProgressLine({
         doneBytes: sent,
         totalBytes: total,
-        startedAt: t0,
+        startedAt: startedAt ?? now,
       });
       process.stderr.write(`\r${msg}`);
     } else {

src/transfer/default.js

@@ -21,13 +21,11 @@ import { confirmSAS } from "../core/sas-confirm.js";
 const SEND_HIGH_WATER = Number(process.env.NT_SEND_HIGH_WATER || (1 * 1024 * 1024));
 
 async function applyBackpressure(rtc) {
-  try {
     if (typeof rtc?.bufferedAmount === "number" && typeof rtc?.flush === "function") {
       if (rtc.bufferedAmount > SEND_HIGH_WATER) {
         await rtc.flush();
       }
     }
-  } catch {}
 }
 
 
@@ -203,13 +201,6 @@ export async function defaultSend(
   const ok = sent === total;
   rtc.send(packStreamFin({ sessionId, ok }));
   await applyBackpressure(rtc);
-
-  // 4) Flush if supported (mirrors tests' "flush" semantics)
-  if (typeof rtc.flush === "function") {
-    try {
-      await rtc.flush();
-    } catch {}
-  }
 }
 
 export async function defaultRecv(rtc, { sessionId, sink, onProgress, assumeYes = false }) {