fix(core): update

ts/00_commitinfo_data.ts

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

ts/classes.smartfile.ts

@@ -91,6 +91,12 @@ export class SmartFile extends plugins.smartjson.Smartjson {
     });
   }
 
+  public async fromUrl (urlArg: string) {
+    const response = await plugins.smartrequest.getBinary(urlArg);
+    const smartfile = await SmartFile.fromBuffer(urlArg, response.body);
+    return smartfile;
+  }
+
   // ========
   // INSTANCE
   // ========

ts/fs.ts

@@ -392,44 +392,50 @@ export const listFileTree = async (
  * Watches for file stability before resolving the promise.
  */
 export const waitForFileToBeReady = (filePathArg: string): Promise<void> => {
-  return new Promise((resolve, reject) => {
-    let lastSize = -1;
-    let stableCheckTimeout: NodeJS.Timeout | null = null;
+  return new Promise(async (resolve, reject) => {
+    let lastFileSize = -1;
+    let fileIsStable = false;
 
-    const clearStableCheckTimeout = () => {
-      if (stableCheckTimeout) {
-        clearTimeout(stableCheckTimeout);
-        stableCheckTimeout = null;
+    const checkFileStability = async () => {
+      let currentFileSize: number;
+      const deferred = plugins.smartpromise.defer();
+      plugins.fs.stat(filePathArg, (err, stats) => {
+        if (err) {
+          fileIsStable = true;
+          watcher.close();
+          reject(err);
+          return;
+        }
+        currentFileSize = stats.size;
+        deferred.resolve();
+      });
+      await deferred.promise;
+      if (currentFileSize === lastFileSize) {
+        fileIsStable = true;
+        await plugins.smartdelay.delayFor(100);
+        resolve();
       }
+      lastFileSize = currentFileSize;
     };
 
     const watcher = plugins.fs.watch(filePathArg, (eventType, filename) => {
       if (eventType === 'change') {
-        plugins.fs.stat(filePathArg, (err, stats) => {
-          if (err) {
-            watcher.close();
-            clearStableCheckTimeout();
-            reject(err);
-            return;
-          }
-          if (stats.size === lastSize) {
-            clearStableCheckTimeout();
-            stableCheckTimeout = setTimeout(() => {
-              watcher.close();
-              resolve();
-            }, 5000); // stability duration
-          } else {
-            lastSize = stats.size;
-          }
-        });
+        checkFileStability();
       }
     });
 
     watcher.on('error', (error) => {
-      clearStableCheckTimeout();
       watcher.close();
       reject(error);
     });
+
+    while (!fileIsStable) {
+      await checkFileStability();
+      if (!fileIsStable) {
+        await plugins.smartdelay.delayFor(5000);
+      }
+    }
+    watcher.close();
   });
 };