From 577ed4dd4c7b3ed8646bc952846a32d1c580ad31 Mon Sep 17 00:00:00 2001
From: Steve Chavez <stevechavezast@gmail.com>
Date: Tue, 7 Apr 2026 13:05:06 -0500
Subject: [PATCH] refactor: clarify debouncer function

(cherry picked from commit 3d98f8d65b92741eac230d447570f58eea7fd344)
---
 src/PostgREST/AppState.hs | 20 +++++++++++++-------
 1 file changed, 13 insertions(+), 7 deletions(-)

diff --git a/src/PostgREST/AppState.hs b/src/PostgREST/AppState.hs
index e276fe2df..d5b5d07af 100644
--- a/src/PostgREST/AppState.hs
+++ b/src/PostgREST/AppState.hs
@@ -117,13 +117,19 @@ init conf@AppConfig{configLogLevel, configDbPoolSize} = do
   pool <- initPool conf observer
   initWithPool pool conf loggerState metricsState observer --{ stateSocketREST = sock, stateSocketAdmin = adminSock}
 
-simpleDebounce :: IO () -> IO (IO ())
-simpleDebounce act = do
+-- Make a new debouncer action. An internal "worker" thread runs forever ensuring "action" runs when the "trigger" is called. The "action" is only executed once over a burst of calls.
+makeDebouncer :: IO () -> IO (IO ())
+makeDebouncer action = do
   flag <- newEmptyMVar
-  void $ forkIO $ forever $ do
-    takeMVar flag
-    act
-  pure (void $ tryPutMVar flag ())
+
+  let worker = forever $ do
+        takeMVar flag
+        action
+
+  let trigger = void $ tryPutMVar flag ()
+
+  void $ forkIO worker
+  pure trigger
 
 initWithPool :: SQL.Pool -> AppConfig -> Logger.LoggerState -> Metrics.MetricsState -> ObservationHandler -> IO AppState
 initWithPool pool conf loggerState metricsState observer = mdo
@@ -133,7 +139,7 @@ initWithPool pool conf loggerState metricsState observer = mdo
     <*> newIORef Nothing
     <*> newIORef SCPending
     <*> newIORef False
-    <*> simpleDebounce (retryingSchemaCacheLoad appState *> threadDelay 100000)  -- 100ms cooldown
+    <*> makeDebouncer (retryingSchemaCacheLoad appState *> threadDelay 100000)  -- 100ms cooldown
     <*> newIORef conf
     <*> mkAutoUpdate defaultUpdateSettings { updateAction = getCurrentTime }
     <*> myThreadId