From e6584a15016431344e4dc772b12faef57429fc65 Mon Sep 17 00:00:00 2001
From: Mikalai Lappo <mikalailappo@yandex.by>
Date: Sun, 22 Sep 2024 01:05:36 +0300
Subject: [PATCH 1/2] fix: possible `isRunning` async race condition

---
 wasm/grol_wasm.html | 63 +++++++++++++++++++++++++++++++++++----------
 1 file changed, 49 insertions(+), 14 deletions(-)
diff --git a/wasm/grol_wasm.html b/wasm/grol_wasm.html
index b0741a25..256573fd 100644
--- a/wasm/grol_wasm.html
+++ b/wasm/grol_wasm.html
@@ -1,3 +1,4 @@
+<!doctype html><html><head><meta charset="utf-8"><title>Grol</title></head>
 <!--
   Keep grol/wasm/grol_wasm.html and web-site/_includes/grol_wasm.html in sync
   Using `make sync` in web-site/
@@ -38,12 +39,46 @@
 </style>
 <script src="wasm_exec.js"></script>
 <script>
-    function debounce(func) {
+    /**
+     * A singular task ES6++ mutex
+     * inspired by this https://blog.jcoglan.com/2016/07/12/mutexes-and-javascript/
+     */
+    class Lock {
+      #isLocked = false
+      #queue = []
+      constructor(){}
+
+      sync(task) {
+        console.log("SYNC")
+        if (this.#isLocked) {
+          console.log("Lock already has a task, ommiting another one at " + new Date().toString())
+          return
+        }
+
+        this.#queue.push(task)
+        if (!this.#isLocked) this.#dequeue()
+      }
+
+      #dequeue() {
+        this.#isLocked = true
+        const next = this.#queue.shift()
+
+        if (next) this.#execute(next)
+        else this.#isLocked = false
+      }
+
+      async #execute(task) {
+        const thisDequeue = () => this.#dequeue()
+        task().then(thisDequeue, thisDequeue)
+      }
+    }
+
+    function debounce(func, ms = 100) {  // 100ms debounce by default
         let timeout
         return function (...args) {
             const context = this
             clearTimeout(timeout)
-            timeout = setTimeout(() => func.apply(context, args), 100) // 100ms debounce
+            timeout = setTimeout(() => func.apply(context, args), ms)
         }
     }
     if (!WebAssembly.instantiateStreaming) { // polyfill
@@ -68,10 +103,8 @@
     function formatError(error) {
         return `Error: ${error.message}`;
     }
-    let isRunning = false
-    async function run() {
-        if (isRunning) return; // Prevent running multiple times concurrently
-        isRunning = true;
+
+    async function _run() {
         document.getElementById("runButton").disabled = true; // Disable button during execution
         try {
             // console.clear();
@@ -105,20 +138,21 @@
         } finally {
             inst = await WebAssembly.instantiate(mod, go.importObject)
             console.log('Instance reset:', inst)
-            if (isRunning) {
-                isRunning = false; // Allow running again after reset
-                document.getElementById("runButton").disabled = false; // Re-enable the button
-            }
+            document.getElementById("runButton").disabled = false; // Re-enable the button
         }
         resizeTextarea(document.getElementById('input'));
         resizeTextarea(document.getElementById('output'));
         resizeTextarea(document.getElementById('errors'));
     }
-    const debounceRun = debounce(run)
+
+
+    const lock = new Lock()
+    const run = debounce(() => lock.sync(_run), 100)
+
     document.addEventListener('DOMContentLoaded', (event) => {
         document.getElementById('input').addEventListener('keydown', function (e) {
-            if (e.key === 'Enter' && !isRunning) {
-                debounceRun();
+            if (e.key === 'Enter') {
+                run()
             }
         });
     });
@@ -142,7 +176,7 @@
 m={"str key": a, PI: "pi", 42: "str val", 1e3: "a lot"}</textarea>
 </div>
 <div>
-    Hit enter or click <button onClick="debounceRun()" id="runButton" disabled>Run</button> (will also format the code,
+    Hit enter or click <button onClick="run()" id="runButton" disabled>Run</button> (will also format the code,
     also
     try <input type="checkbox" id="compact">compact)
     <button id="addParamButton">Share</button>
@@ -185,3 +219,4 @@
         document.getElementById('input').value = decodeURIComponent(paramValue)
     }
 </script>
+</html>

From 6f822d2cac7e0bd96eb45e20b76c0263c40341cc Mon Sep 17 00:00:00 2001
From: Mikalai Lappo <mikalailappo@yandex.by>
Date: Sun, 22 Sep 2024 01:05:48 +0300
Subject: [PATCH 2/2] fix: go wasm infinite timeout recurrence workaround

---
 Makefile | 1 +
 1 file changed, 1 insertion(+)

diff --git a/Makefile b/Makefile
index 54befb51..2ec1d235 100644
--- a/Makefile
+++ b/Makefile
@@ -36,6 +36,7 @@ parser-test:
 TINYGO_STACKS:=-stack-size=40mb
 
 wasm: Makefile *.go */*.go $(GEN) wasm/wasm_exec.js wasm/wasm_exec.html wasm/grol_wasm.html
+	sed -i 's/console.warn("scheduleTimeoutEvent: missed timeout event");/this._scheduledTimeouts.delete(id);\nconsole.warn("scheduleTimeoutEvent: missed timeout event");/'  wasm/wasm_exec.js
 #	GOOS=wasip1 GOARCH=wasm go build -o grol.wasm -trimpath -ldflags="-w -s" -tags "$(GO_BUILD_TAGS)" .
 	GOOS=js GOARCH=wasm $(WASM_GO) build -o wasm/grol.wasm -trimpath -ldflags="-w -s" -tags "$(GO_BUILD_TAGS)" ./wasm
 #	GOOS=wasip1 GOARCH=wasm tinygo build -target=wasi -no-debug -o grol_tiny.wasm -tags "$(GO_BUILD_TAGS)" .
