add pipe to copyFrom

Signed-off-by: Jeromy Cannon <[email protected]>

Author: jeromy-cannon

src/core/k8.mjs

@@ -28,6 +28,7 @@ import { v4 as uuid4 } from 'uuid'
 import { V1ObjectMeta, V1Secret } from '@kubernetes/client-node'
 import { sleep } from './helpers.mjs'
 import { constants } from './index.mjs'
+import * as stream from 'node:stream'
 
 /**
  * A kubernetes API wrapper class providing custom functionalities required by solo
@@ -571,11 +572,15 @@ export class K8 {
       const self = this
       return new Promise((resolve, reject) => {
         const execInstance = new k8s.Exec(this.kubeConfig)
-        const command = ['cat', `${srcDir}/${srcFile}`]
+        const command = ['tar', 'cf', '-', '-C', srcDir, srcFile]
         const writerStream = fs.createWriteStream(tmpFile)
+        const writerPassthroughStream = new stream.PassThrough()
         const errStream = new sb.WritableStreamBuffer()
         let additionalErrorMessageDetail = ''
 
+        // Use pipe() to automatically handle backpressure between streams
+        writerPassthroughStream.pipe(writerStream);
+
         execInstance.exec(
           namespace,
           podName,
@@ -599,9 +604,11 @@ export class K8 {
               }
 
               try {
-                // copy the downloaded file
-                fs.copyFileSync(tmpFile, destPath)
-
+                // extract the downloaded file
+                await tar.x({
+                  file: tmpFile,
+                  cwd: destDir
+                })
                 self._deleteTempFile(tmpFile)
 
                 const stat = fs.statSync(destPath)
@@ -615,7 +622,7 @@ export class K8 {
                   }
                 }
               } catch (e) {
-                return reject(new FullstackTestingError(`failed to copy file: ${destPath}`, e))
+                return reject(new FullstackTestingError(`failed to extract file: ${destPath}`, e))
               }
 
               return reject(new FullstackTestingError(`failed to download file completely: ${destPath}${additionalErrorMessageDetail}`))