From 1b22fa50464260010b4f7fce9082c12ec6e9c1f4 Mon Sep 17 00:00:00 2001
From: guerler <aysam.guerler@gmail.com>
Date: Thu, 14 Oct 2021 00:37:35 -0400
Subject: [PATCH] Throttle number of workflow editor form requests to one per
 second

---
 client/src/utils/promise-queue.js | 29 +++++++++++++----------------
 1 file changed, 13 insertions(+), 16 deletions(-)

diff --git a/client/src/utils/promise-queue.js b/client/src/utils/promise-queue.js
index 8548549fcf1..51a9668dfa0 100644
--- a/client/src/utils/promise-queue.js
+++ b/client/src/utils/promise-queue.js
@@ -5,38 +5,35 @@
  * See: https://stackoverflow.com/questions/53540348/js-async-await-tasks-queue
  */
 export class LastQueue {
-    constructor() {
-        this._nextPromise = null;
-        this._pendingPromise = false;
+    constructor(throttlePeriod = 1000) {
+        this.throttlePeriod = throttlePeriod;
+        this.nextPromise = null;
+        this.pendingPromise = false;
     }
 
     enqueue(action, payload) {
         return new Promise((resolve, reject) => {
-            this._nextPromise = { action, payload, resolve, reject };
+            this.nextPromise = { action, payload, resolve, reject };
             this.dequeue();
         });
     }
 
     async dequeue() {
-        if (this._pendingPromise) {
-            return false;
-        }
-        if (this._nextPromise) {
-            let item = this._nextPromise;
-            this._nextPromise = null;
+        if (!this.pendingPromise && this.nextPromise) {
+            let item = this.nextPromise;
+            this.nextPromise = null;
+            this.pendingPromise = true;
             try {
-                this._pendingPromise = true;
                 let payload = await item.action(item.payload);
-                this._pendingPromise = false;
                 item.resolve(payload);
             } catch (e) {
-                this._pendingPromise = false;
                 item.reject(e);
             } finally {
-                this.dequeue();
+                setTimeout(() => {
+                    this.pendingPromise = false;
+                    this.dequeue();
+                }, this.throttlePeriod);
             }
-            return true;
         }
-        return false;
     }
 }