Don't resolve twice

kubernetes-client · Nov 29, 2024 · 5fc727f · 5fc727f
1 parent eef93d6
commit 5fc727f
Showing 1 changed file with 18 additions and 4 deletions.
diff --git a/src/cp.ts b/src/cp.ts
@@ -35,6 +35,7 @@ export class Cp {
         command.push(srcPath);
         const writerStream = fs.createWriteStream(tmpFileName);
         const errStream = new WritableStreamBuffer();
+        let resolved = false;
         return new Promise<void>((resolve, reject) => {
             this.execInstance
                 .exec(
@@ -60,15 +61,21 @@ export class Cp {
                                 file: tmpFileName,
                                 cwd: tgtPath,
                             });
-                            resolve();
+                            if (!resolved) {
+                                resolved = true;
+                                resolve();
+                            }
                         } catch (e) {
                             reject(e);
                         }
                     },
                 )
                 .then((conn) => {
                     conn.on('close', () => {
-                        resolve();
+                        if (!resolved) {
+                            resolved = true;
+                            resolve();
+                        }
                     });
                 })
                 .catch(reject);
@@ -96,6 +103,7 @@ export class Cp {
         await tar.c({ file: tmpFileName, cwd }, [srcPath]);
         const readStream = fs.createReadStream(tmpFileName);
         const errStream = new WritableStreamBuffer();
+        let resolved = false;
         return new Promise<void>((resolve, reject) => {
             this.execInstance
                 .exec(
@@ -116,13 +124,19 @@ export class Cp {
                                 ),
                             );
                         } else {
-                            resolve();
+                            if (!resolved) {
+                                resolved = true;
+                                resolve();
+                            }
                         }
                     },
                 )
                 .then((conn) => {
                     conn.on('close', () => {
-                        resolve();
+                        if (!resolved) {
+                            resolved = true;
+                            resolve();
+                        }
                     });
                 })
                 .catch(reject);