fix(try-catch): throw on the first error, when there is not enough space

ido-pluto · May 10, 2024 · dfbe6bf · dfbe6bf
1 parent 722bc9c
commit dfbe6bf
Showing 1 changed file with 17 additions and 1 deletion.
diff --git a/...wnload-engine/streams/download-engine-write-stream/download-engine-write-stream-nodejs.ts b/...wnload-engine/streams/download-engine-write-stream/download-engine-write-stream-nodejs.ts
@@ -14,6 +14,8 @@ const DEFAULT_OPTIONS: DownloadEngineWriteStreamOptionsNodeJS = {
     mode: "r+"
 };
 
+const NOT_ENOUGH_SPACE_ERROR_CODE = "ENOSPC";
+
 export default class DownloadEngineWriteStreamNodejs extends BaseDownloadEngineWriteStream {
     private _fd: FileHandle | null = null;
     private _fileWriteFinished = false;
@@ -39,9 +41,23 @@ export default class DownloadEngineWriteStreamNodejs extends BaseDownloadEngineW
     }
 
     async write(cursor: number, buffer: Uint8Array) {
+        let throwError: Error | false = false;
+
         await retry(async () => {
-            return await this._writeWithoutRetry(cursor, buffer);
+            try {
+                return await this._writeWithoutRetry(cursor, buffer);
+            } catch (error: any) {
+                if (error?.code === NOT_ENOUGH_SPACE_ERROR_CODE) {
+                    throwError = error;
+                    return;
+                }
+                throw error;
+            }
         }, this.options.retry);
+
+        if (throwError) {
+            throw throwError;
+        }
     }
 
     async ftruncate(size = this.fileSize) {