fix: fdir never resolves when maxDepth < 0 (fixes #127)

__tests__/fdir.test.ts

@@ -91,6 +91,15 @@ for (const type of apiTypes) {
     ).toBeTruthy();
   });
 
+  test(`[${type}] crawl and get all files (withMaxDepth = -1)`, async (t) => {
+    const api = new fdir()
+      .withMaxDepth(-1)
+      .withBasePath()
+      .crawl("node_modules");
+    const files = await api[type]();
+    t.expect(files.length).toBe(0);
+  });
+
   test(`[${type}] crawl and get files that match a glob pattern`, async (t) => {
     const api = new fdir()
       .withBasePath()

src/api/functions/walk-directory.ts

@@ -18,7 +18,7 @@ const walkAsync: WalkDirectoryFunction = (
   currentDepth,
   callback
 ) => {
-  if (currentDepth < 0) return;
+  if (currentDepth < 0) return state.queue.dequeue(null, state);
 
   state.visited.push(crawlPath);
   state.counts.directories++;

src/api/queue.ts

@@ -1,20 +1,20 @@
-import { WalkerState } from "../types";
-
-type OnQueueEmptyCallback = (error: Error | null, output: WalkerState) => void;
-/**
- * This is a custom stateless queue to track concurrent async fs calls.
- * It increments a counter whenever a call is queued and decrements it
- * as soon as it completes. When the counter hits 0, it calls onQueueEmpty.
- */
-export class Queue {
-  private count: number = 0;
-  constructor(private readonly onQueueEmpty: OnQueueEmptyCallback) {}
-
-  enqueue() {
-    this.count++;
-  }
-
-  dequeue(error: Error | null, output: WalkerState) {
-    if (--this.count === 0 || error) this.onQueueEmpty(error, output);
-  }
-}
+import { WalkerState } from "../types";
+
+type OnQueueEmptyCallback = (error: Error | null, output: WalkerState) => void;
+/**
+ * This is a custom stateless queue to track concurrent async fs calls.
+ * It increments a counter whenever a call is queued and decrements it
+ * as soon as it completes. When the counter hits 0, it calls onQueueEmpty.
+ */
+export class Queue {
+  private count: number = 0;
+  constructor(private readonly onQueueEmpty: OnQueueEmptyCallback) {}
+
+  enqueue() {
+    this.count++;
+  }
+
+  dequeue(error: Error | null, output: WalkerState) {
+    if (--this.count <= 0 || error) this.onQueueEmpty(error, output);
+  }
+}