fix: simplify portal serve caching logic and fix debounce scheduling (#253)

What was changed?
- Remove unnecessary mutex and event queue from portal serve action.
- Fix debounce service to reschedule execution if a new handler arrived during processing.

Co-authored-by: saeedjamshaid <saeed.jamshaid@outlook.com>

Author: aliasghar98

package-lock.json

@@ -2,8 +2,6 @@ import { createServer as createLiveReloadServer } from "livereload";
 import connectLiveReload from "connect-livereload";
 import express, { Express } from "express";
 import chokidar from "chokidar";
-import crypto from "crypto";
-import { Mutex } from "async-mutex";
 import { PortalServePrompts } from "../../prompts/portal/serve.js";
 import { DirectoryPath } from "../../types/file/directoryPath.js";
 import { ActionResult } from "../action-result.js";
@@ -86,10 +84,6 @@ export class PortalServeAction {
     });
 
     const deletedDirectories = new Set<string>();
-    // TODO: Verify if we need mutex and eventQueue after refactoring.
-    const eventQueue = new Map();
-    const mutex = new Mutex();
-
     const debounceService: DebounceService = new DebounceService();
 
     watcher
@@ -105,22 +99,10 @@ export class PortalServeAction {
             }
           }
         }
-        const eventId: string = `${Date.now()}-${crypto.randomUUID()}`;
-        await mutex.runExclusive(async () => {
-          eventQueue.clear();
-          eventQueue.set(eventId, path);
-        });
 
         await debounceService.batchSingleRequest(async () => {
           this.prompts.changesDetected();
-
-          // TODO: Verify if this is needed.
-          if (!eventQueue.has(eventId)) {
-            return;
-          }
-
           await generatePortalAction.execute(buildDirectory, portalDirectory, true, false, false);
-
           liveReloadServer.refresh(portalDirectory.toString());
           this.clearStandardInput();
         });

src/actions/portal/serve.ts

@@ -46,6 +46,9 @@ export class DebounceService {
         }
       } finally {
         this.isProcessing = false;
+        if (this.latestHandler) {
+          this.scheduleExecution();
+        }
       }
     }, this.debounceMs);
   }