10.0.29

package.json

@@ -1,7 +1,7 @@
 {
   "name": "@push.rocks/smartfile",
   "private": false,
-  "version": "10.0.27",
+  "version": "10.0.29",
   "description": "offers smart ways to work with files in nodejs",
   "main": "dist_ts/index.js",
   "typings": "dist_ts/index.d.ts",
@@ -26,17 +26,16 @@
   },
   "homepage": "https://gitlab.com/pushrocks/smartfile",
   "dependencies": {
-    "@pushrocks/lik": "^6.0.2",
+    "@push.rocks/lik": "^6.0.2",
-    "@pushrocks/smartdelay": "^3.0.1",
+    "@push.rocks/smartdelay": "^3.0.1",
-    "@pushrocks/smartfile-interfaces": "^1.0.7",
+    "@push.rocks/smartfile-interfaces": "^1.0.7",
-    "@pushrocks/smarthash": "^3.0.2",
+    "@push.rocks/smarthash": "^3.0.2",
-    "@pushrocks/smartjson": "^5.0.6",
+    "@push.rocks/smartjson": "^5.0.6",
-    "@pushrocks/smartmime": "^1.0.5",
+    "@push.rocks/smartmime": "^1.0.5",
-    "@pushrocks/smartpath": "^5.0.5",
+    "@push.rocks/smartpath": "^5.0.5",
-    "@pushrocks/smartpromise": "^4.0.2",
+    "@push.rocks/smartpromise": "^4.0.2",
-    "@pushrocks/smartrequest": "^2.0.15",
+    "@push.rocks/smartrequest": "^2.0.15",
-    "@pushrocks/smartstream": "^2.0.3",
+    "@push.rocks/smartstream": "^2.0.3",
-    "@pushrocks/streamfunction": "^4.0.4",
     "@types/fs-extra": "^11.0.1",
     "@types/glob": "^8.1.0",
     "@types/js-yaml": "^4.0.5",

ts/00_commitinfo_data.ts

@@ -3,6 +3,6 @@
  */
 export const commitinfo = {
   name: '@push.rocks/smartfile',
-  version: '10.0.27',
+  version: '10.0.29',
   description: 'offers smart ways to work with files in nodejs'
 }

ts/smartfile.fsstream.ts

@@ -11,4 +11,29 @@ export const createWriteStream = (pathArg: string) => {
   return plugins.fs.createWriteStream(pathArg);
 };
 
-export const streamDirectory = async (dirPathArg: string) => {};
+export const processFile = async (
+  filePath: string,
+  asyncFunc: (fileStream: plugins.stream.Readable) => Promise<void>
+): Promise<void> => {
+  return new Promise((resolve, reject) => {
+    const fileStream = createReadStream(filePath);
+    asyncFunc(fileStream).then(resolve).catch(reject);
+  });
+}
+
+export const processDirectory = async (
+  directoryPath: string,
+  asyncFunc: (fileStream: plugins.stream.Readable) => Promise<void>
+): Promise<void> => {
+  const files = plugins.fs.readdirSync(directoryPath, { withFileTypes: true });
+
+  for (const file of files) {
+    const fullPath = plugins.path.join(directoryPath, file.name);
+
+    if (file.isDirectory()) {
+      await processDirectory(fullPath, asyncFunc); // Recursively call processDirectory for directories
+    } else if (file.isFile()) {
+      await processFile(fullPath, asyncFunc); // Call async function with the file stream and wait for it
+    }
+  }
+};

ts/smartfile.plugins.ts

@@ -1,20 +1,21 @@
 // node native scope
 import * as fs from 'fs';
 import * as path from 'path';
+import * as stream from 'stream';
 
-export { fs, path };
+export { fs, path, stream };
 
 // @pushrocks scope
-import * as lik from '@pushrocks/lik';
+import * as lik from '@push.rocks/lik';
-import * as smartfileInterfaces from '@pushrocks/smartfile-interfaces';
+import * as smartfileInterfaces from '@push.rocks/smartfile-interfaces';
-import * as smartdelay from '@pushrocks/smartdelay';
+import * as smartdelay from '@push.rocks/smartdelay';
-import * as smarthash from '@pushrocks/smarthash';
+import * as smarthash from '@push.rocks/smarthash';
-import * as smartjson from '@pushrocks/smartjson';
+import * as smartjson from '@push.rocks/smartjson';
-import * as smartmime from '@pushrocks/smartmime';
+import * as smartmime from '@push.rocks/smartmime';
-import * as smartpath from '@pushrocks/smartpath';
+import * as smartpath from '@push.rocks/smartpath';
-import * as smartpromise from '@pushrocks/smartpromise';
+import * as smartpromise from '@push.rocks/smartpromise';
-import * as smartrequest from '@pushrocks/smartrequest';
+import * as smartrequest from '@push.rocks/smartrequest';
-import * as smartstream from '@pushrocks/smartstream';
+import * as smartstream from '@push.rocks/smartstream';
 
 export {
   lik,