deps: [email protected]

Author: wraithgar

node_modules/tinyglobby/node_modules/fdir/dist/api/functions/is-recursive-symlink.js

@@ -7,11 +7,11 @@ exports.build = void 0;
 const fs_1 = __importDefault(require("fs"));
 const readdirOpts = { withFileTypes: true };
 const walkAsync = (state, crawlPath, directoryPath, currentDepth, callback) => {
+    state.queue.enqueue();
     if (currentDepth < 0)
         return state.queue.dequeue(null, state);
     state.visited.push(crawlPath);
     state.counts.directories++;
-    state.queue.enqueue();
     // Perf: Node >= 10 introduced withFileTypes that helps us
     // skip an extra fs.stat call.
     fs_1.default.readdir(crawlPath || ".", readdirOpts, (error, entries = []) => {

node_modules/tinyglobby/node_modules/fdir/dist/api/functions/walk-directory.js

@@ -14,10 +14,16 @@ class Queue {
     }
     enqueue() {
         this.count++;
+        return this.count;
     }
     dequeue(error, output) {
-        if (--this.count <= 0 || error)
+        if (this.onQueueEmpty && (--this.count <= 0 || error)) {
             this.onQueueEmpty(error, output);
+            if (error) {
+                output.controller.abort();
+                this.onQueueEmpty = undefined;
+            }
+        }
     }
 }
 exports.Queue = Queue;

node_modules/tinyglobby/node_modules/fdir/dist/api/queue.js

@@ -62,6 +62,7 @@ class Walker {
             queue: new queue_1.Queue((error, state) => this.callbackInvoker(state, error, callback)),
             symlinks: new Map(),
             visited: [""].slice(0, 0),
+            controller: new AbortController(),
         };
         /*
          * Perf: We conditionally change functions according to options. This gives a slight
@@ -77,14 +78,16 @@ class Walker {
         this.walkDirectory = walkDirectory.build(this.isSynchronous);
     }
     start() {
+        this.pushDirectory(this.root, this.state.paths, this.state.options.filters);
         this.walkDirectory(this.state, this.root, this.root, this.state.options.maxDepth, this.walk);
         return this.isSynchronous ? this.callbackInvoker(this.state, null) : null;
     }
     walk = (entries, directoryPath, depth) => {
-        const { paths, options: { filters, resolveSymlinks, excludeSymlinks, exclude, maxFiles, signal, useRealPaths, pathSeparator, }, } = this.state;
-        if ((signal && signal.aborted) || (maxFiles && paths.length > maxFiles))
+        const { paths, options: { filters, resolveSymlinks, excludeSymlinks, exclude, maxFiles, signal, useRealPaths, pathSeparator, }, controller, } = this.state;
+        if (controller.signal.aborted ||
+            (signal && signal.aborted) ||
+            (maxFiles && paths.length > maxFiles))
             return;
-        this.pushDirectory(directoryPath, paths, filters);
         const files = this.getArray(this.state.paths);
         for (let i = 0; i < entries.length; ++i) {
             const entry = entries[i];
@@ -97,9 +100,10 @@ class Walker {
                 let path = joinPath.joinDirectoryPath(entry.name, directoryPath, this.state.options.pathSeparator);
                 if (exclude && exclude(entry.name, path))
                     continue;
+                this.pushDirectory(path, paths, filters);
                 this.walkDirectory(this.state, path, path, depth - 1, this.walk);
             }
-            else if (entry.isSymbolicLink() && this.resolveSymlink) {
+            else if (this.resolveSymlink && entry.isSymbolicLink()) {
                 let path = joinPath.joinPathWithBasePath(entry.name, directoryPath);
                 this.resolveSymlink(path, this.state, (stat, resolvedPath) => {
                     if (stat.isDirectory()) {