Move to tar-fs.

Author: brendandburns

package-lock.json

@@ -72,6 +72,7 @@
         "socks-proxy-agent": "^8.0.4",
         "stream-buffers": "^3.0.2",
         "tar": "^7.0.0",
+        "tar-fs": "^3.0.8",
         "tmp-promise": "^3.0.2",
         "ws": "^8.18.0"
     },

package.json

@@ -1,10 +1,12 @@
-import fs from 'node:fs';
+import fs, { rmSync } from 'node:fs';
 import { WritableStreamBuffer } from 'stream-buffers';
-import * as tar from 'tar';
+import tar from 'tar-fs';
 import tmp from 'tmp-promise';
+import path from 'node:path';
 
 import { KubeConfig } from './config.js';
 import { Exec } from './exec.js';
+import { getServers } from 'node:dns';
 
 export class Cp {
     public execInstance: Exec;
@@ -29,7 +31,7 @@ export class Cp {
         const tmpFile = tmp.fileSync();
         const tmpFileName = tmpFile.name;
         const command = ['tar', 'zcf', '-', srcPath];
-        const writerStream = fs.createWriteStream(tmpFileName);
+        const writerStream = tar.extract(tgtPath);
         const errStream = new WritableStreamBuffer();
         this.execInstance.exec(
             namespace,
@@ -44,10 +46,6 @@ export class Cp {
                 if (errStream.size()) {
                     throw new Error(`Error from cpFromPod - details: \n ${errStream.getContentsAsString()}`);
                 }
-                await tar.x({
-                    file: tmpFileName,
-                    cwd: tgtPath,
-                });
             },
         );
     }
@@ -66,16 +64,8 @@ export class Cp {
         srcPath: string,
         tgtPath: string,
     ): Promise<void> {
-        const tmpFile = tmp.fileSync();
-        const tmpFileName = tmpFile.name;
         const command = ['tar', 'xf', '-', '-C', tgtPath];
-        await tar.c(
-            {
-                file: tmpFile.name,
-            },
-            [srcPath],
-        );
-        const readStream = fs.createReadStream(tmpFileName);
+        const readStream = tar.pack(srcPath);
         const errStream = new WritableStreamBuffer();
         this.execInstance.exec(
             namespace,