refactor: add state to DelayedTimeout

Author: juanrgm

src/commands/analyse.ts

@@ -110,7 +110,7 @@ async function rutine(ext: Ext, args?: string[]) {
 
 export default async function analyse(ext: Ext, ms?: number, args?: string[]) {
   await stopAnalyse(ext);
-  ext.store.analyse.timeout(async () => {
+  ext.store.analyse.timeout.run(async () => {
     await rutine(ext, args);
   }, ms ?? ext.settings.analysedDelay);
 }

src/extension.ts

@@ -211,7 +211,7 @@ export class Ext<
             tag: `event:${eventName}`,
             message: path,
           });
-          this.store.reactivate.timeout(() => this.reactivate());
+          this.store.reactivate.timeout.run(() => this.reactivate());
         }
       );
 

src/utils/async.ts

@@ -1,9 +1,31 @@
-export type DelayedTimeout = (cb: () => unknown, ms?: number) => void;
+export type DelayedTimeout = {
+  readonly running: boolean;
+  readonly pending: boolean;
+  run: (cb: () => unknown, ms?: number) => void;
+};
 
 export function createDelayedTimeout(defaultsMs?: number) {
   let timeout: NodeJS.Timeout | undefined;
-  return (cb: () => unknown, ms = defaultsMs) => {
-    if (timeout) clearTimeout(timeout);
-    timeout = setTimeout(cb, ms);
+  let running = false;
+  let pending = false;
+  return {
+    get pending() {
+      return pending;
+    },
+    get running() {
+      return running;
+    },
+    run: (cb: () => unknown, ms = defaultsMs) => {
+      pending = true;
+      if (timeout) clearTimeout(timeout);
+      timeout = setTimeout(async () => {
+        running = true;
+        try {
+          await cb();
+        } finally {
+          running = pending = false;
+        }
+      }, ms);
+    },
   };
 }