4.0.29

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@push.rocks/smartarchive",
-  "version": "4.0.23",
+  "version": "4.0.29",
   "description": "A library for working with archive files, providing utilities for compressing and decompressing data.",
   "main": "dist_ts/index.js",
   "typings": "dist_ts/index.d.ts",
@@ -22,13 +22,13 @@
   "homepage": "https://code.foss.global/push.rocks/smartarchive",
   "dependencies": {
     "@push.rocks/smartdelay": "^3.0.5",
-    "@push.rocks/smartfile": "^11.0.4",
+    "@push.rocks/smartfile": "^11.0.20",
-    "@push.rocks/smartpath": "^5.0.11",
+    "@push.rocks/smartpath": "^5.0.18",
     "@push.rocks/smartpromise": "^4.0.3",
-    "@push.rocks/smartrequest": "^2.0.21",
+    "@push.rocks/smartrequest": "^2.0.22",
     "@push.rocks/smartrx": "^3.0.7",
-    "@push.rocks/smartstream": "^3.0.34",
+    "@push.rocks/smartstream": "^3.0.44",
-    "@push.rocks/smartunique": "^3.0.8",
+    "@push.rocks/smartunique": "^3.0.9",
     "@push.rocks/smarturl": "^3.0.7",
     "@types/tar-stream": "^3.1.3",
     "fflate": "^0.8.2",
@@ -37,10 +37,10 @@
     "through": "^2.3.8"
   },
   "devDependencies": {
-    "@git.zone/tsbuild": "^2.1.72",
+    "@git.zone/tsbuild": "^2.1.80",
     "@git.zone/tsrun": "^1.2.44",
-    "@git.zone/tstest": "^1.0.88",
+    "@git.zone/tstest": "^1.0.90",
-    "@push.rocks/tapbundle": "^5.0.17"
+    "@push.rocks/tapbundle": "^5.0.23"
   },
   "private": false,
   "files": [

ts/00_commitinfo_data.ts

@@ -3,6 +3,6 @@
  */
 export const commitinfo = {
   name: '@push.rocks/smartarchive',
-  version: '4.0.23',
+  version: '4.0.29',
   description: 'A library for working with archive files, providing utilities for compressing and decompressing data.'
 }

ts/classes.smartarchive.ts

@@ -122,6 +122,11 @@ export class SmartArchive {
           if (analyzedResultChunk.fileType?.mime === 'application/x-tar') {
             const tarStream = analyzedResultChunk.decompressionStream as plugins.tarStream.Extract;
             tarStream.on('entry', async (header, stream, next) => {
+              if (header.type === 'directory') {
+                console.log(`tar stream directory: ${header.name} ... skipping!`);
+                next();
+                return;
+              }
               console.log(`tar stream file: ${header.name}`);
               const streamfile = plugins.smartfile.StreamFile.fromStream(stream, header.name);
               streamFileIntake.push(streamfile);

ts/classes.tartools.ts

@@ -2,6 +2,7 @@ import type { SmartArchive } from './classes.smartarchive.js';
 import * as plugins from './plugins.js';
 
 export class TarTools {
+  // INSTANCE
   smartArchiveRef: SmartArchive;
 
   constructor(smartArchiveRefArg: SmartArchive) {
@@ -9,19 +10,110 @@ export class TarTools {
   }
 
   // packing
-  public addFileToPack(pack: plugins.tarStream.Pack, fileName: string, content: string | Buffer) {
+  public async addFileToPack(
-    return new Promise<void>((resolve, reject) => {
+    pack: plugins.tarStream.Pack,
-      const entry = pack.entry({ name: fileName, size: content.length }, (err: Error) => {
+    optionsArg: {
+      fileName?: string;
+      content?:
+        | string
+        | Buffer
+        | plugins.smartstream.stream.Readable
+        | plugins.smartfile.SmartFile
+        | plugins.smartfile.StreamFile;
+      byteLength?: number;
+      filePath?: string;
+    }
+  ): Promise<void> {
+    return new Promise<void>(async (resolve, reject) => {
+      let fileName =
+        optionsArg.fileName || optionsArg.content instanceof plugins.smartfile.SmartFile
+          ? (optionsArg.content as plugins.smartfile.SmartFile).relative
+          : null || optionsArg.content instanceof plugins.smartfile.StreamFile
+          ? (optionsArg.content as plugins.smartfile.StreamFile).relativeFilePath
+          : null || optionsArg.filePath;
+
+      /**
+       * contentByteLength is used to set the size of the entry in the tar file
+       */
+      let contentByteLength: number;
+      if (optionsArg.byteLength) {
+        contentByteLength = optionsArg.byteLength;
+      } else if (typeof optionsArg.content === 'string') {
+        contentByteLength = Buffer.byteLength(optionsArg.content, 'utf8');
+      } else if (Buffer.isBuffer(optionsArg.content)) {
+        contentByteLength = optionsArg.content.length;
+      } else if (optionsArg.content instanceof plugins.smartfile.SmartFile) {
+        contentByteLength = await optionsArg.content.getSize(); // assuming SmartFile has getSize method
+      } else if (optionsArg.content instanceof plugins.smartfile.StreamFile) {
+        contentByteLength = await optionsArg.content.getSize(); // assuming StreamFile has getSize method
+      } else if (optionsArg.content instanceof plugins.smartstream.stream.Readable) {
+        console.warn(
+          '@push.rocks/smartarchive: When streaming, it is recommended to provide byteLength, if known.'
+        );
+      } else if (optionsArg.filePath) {
+        const fileStat = await plugins.smartfile.fs.stat(optionsArg.filePath);
+        contentByteLength = fileStat.size;
+      }
+
+      /**
+       * here we try to harmonize all kind of entries towards a readable stream
+       */
+      let content: plugins.smartstream.stream.Readable;
+      if (Buffer.isBuffer(optionsArg.content)) {
+        content = plugins.smartstream.stream.Readable.from(optionsArg.content);
+      } else if (typeof optionsArg.content === 'string') {
+        content = plugins.smartstream.stream.Readable.from(Buffer.from(optionsArg.content));
+      } else if (optionsArg.content instanceof plugins.smartfile.SmartFile) {
+        content = plugins.smartstream.stream.Readable.from(optionsArg.content.contents);
+      } else if (optionsArg.content instanceof plugins.smartfile.StreamFile) {
+        content = await optionsArg.content.createReadStream();
+      } else if (optionsArg.content instanceof plugins.smartstream.stream.Readable) {
+        content = optionsArg.content;
+      }
+
+      const entry = pack.entry(
+        {
+          name: fileName,
+          ...(contentByteLength
+            ? {
+                size: contentByteLength,
+              }
+            : null),
+        },
+        (err: Error) => {
           if (err) {
             reject(err);
           } else {
             resolve();
           }
-      });
+        }
+      );
 
-      entry.write(content);
+      content.pipe(entry);
-      entry.end();
+      entry.on('end', () => {
+        resolve();
       });
+    });
+  }
+
+  /**
+   * packs a directory from disk into a tar stream
+   * @param directoryPath
+   */
+  public async packDirectory(directoryPath: string) {
+    const fileTree = await plugins.smartfile.fs.listFileTree(directoryPath, '**/*');
+    const pack = await this.getPackStream();
+    for (const filePath of fileTree) {
+      const absolutePath = plugins.path.join(directoryPath, filePath);
+      const fileStat = await plugins.smartfile.fs.stat(absolutePath);
+      await this.addFileToPack(pack, {
+        byteLength: fileStat.size,
+        filePath: filePath,
+        fileName: filePath,
+        content: plugins.smartfile.fsStream.createReadStream(absolutePath),
+      });
+    }
+    return pack;
   }
 
   public async getPackStream() {

ts/classes.ziptools.ts

@@ -5,7 +5,7 @@ class DecompressZipTransform extends plugins.smartstream.SmartDuplex<ArrayBuffer
   private streamtools: plugins.smartstream.IStreamTools;
   private unzipper = new plugins.fflate.Unzip(async (fileArg) => {
     let resultBuffer: Buffer;
-    fileArg.ondata = async (dataArg, dat, final) => {
+    fileArg.ondata = async (flateError, dat, final) => {
       resultBuffer? resultBuffer = Buffer.concat([resultBuffer, Buffer.from(dat)])
         : resultBuffer = Buffer.from(dat);
       if (final) {

ts/index.ts

@@ -1 +1,3 @@
 export * from './classes.smartarchive.js';
+export * from './classes.tartools.js';
+export * from './classes.ziptools.js';