Update send.js

Author: collapsinghierarchy

src/commands/send.js

@@ -167,9 +167,8 @@ export async function run(paths, opts, ctx = {}) {
 
     await sleep(150);
 
-
     // Wait for FIN/OK from receiver or peer close
-    const finAckTimeoutMs = normalizeTimeout(
+      const finAckTimeoutMs = normalizeTimeout(
       opts?.finAckTimeoutMs,
       DEFAULT_FIN_ACK_TIMEOUT_MS,
     );
@@ -183,14 +182,19 @@ export async function run(paths, opts, ctx = {}) {
       sessionId,
       timeoutMs: finAckTimeoutMs,
     });
+
+    let finAckError = null;
     if (finAckResult === "timeout" && Number.isFinite(finAckTimeoutMs) && finAckTimeoutMs > 0) {
-      getLogger().info(
-        `send: timed out waiting for receiver FIN acknowledgement after ${finAckTimeoutMs} ms`,
-      );
+      finAckError = `send: timed out waiting for receiver FIN acknowledgement after ${finAckTimeoutMs} ms`;
+      getLogger().info(finAckError);
     } else if (finAckResult === "ack") {
       getLogger().debug("send: received receiver FIN acknowledgement");
     } else if (finAckResult === "peer-close") {
-      getLogger().debug("send: data channel closed before FIN acknowledgement was observed");
+      finAckError = "send: data channel closed before FIN acknowledgement was observed";
+      getLogger().debug(finAckError);
+    } else if (finAckResult === "nack") {
+      finAckError = "send: receiver reported failure while acknowledging FIN";
+      getLogger().info(finAckError);
     }
 
     if (finAckResult !== "peer-close") {
@@ -205,6 +209,13 @@ export async function run(paths, opts, ctx = {}) {
         );
       }
     }
+
+    if (finAckError) {
+      const err = new Error(finAckError);
+      err.code = "ERR_FIN_ACK";
+      throw err;
+    }
+
     process.stderr.write("\nDone • " + humanBytes(totalBytes) + "\n");
     // --- Silent workaround on success
   } finally {
@@ -253,8 +264,12 @@ function waitForFinAck({ rtc, sessionId, timeoutMs }) {
           } catch {}
         }
         const fin = msg ? parseStreamFin(msg) : null;
-        if (fin && fin.sessionId === sessionId && fin.ok === true) {
-          finish("ack");
+        if (fin && fin.sessionId === sessionId) {
+          if (fin.ok === true) {
+            finish("ack");
+          } else if (fin.ok === false) {
+            finish("nack");
+          }
         }
       } catch {}
     });