Rebuild WASM: bytecode with pending_cek snapshot fix

All .sxbc recompiled with fixed sx_vm.ml. 32/32 WASM tests, 4/4
bytecode regression tests. hs-repeat-times correctly does 6 io-sleep
suspensions in bytecode mode.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

shared/static/wasm/sx-platform.js

@@ -81,18 +81,62 @@
 
   K.registerNative("host-callback", function(args) {
     var fn = args[0];
-    // Native JS function — pass through
+    // Native JS function (not SX-origin) — pass through
-    if (typeof fn === "function") return fn;
+    if (typeof fn === "function" && fn.__sx_handle === undefined) return fn;
-    // SX callable (has __sx_handle) — wrap as JS function
+    // SX callable (has __sx_handle) — wrap as JS function with suspension handling
     if (fn && fn.__sx_handle !== undefined) {
       return function() {
         var a = Array.prototype.slice.call(arguments);
-        return K.callFn(fn, a);
+        var result = K.callFn(fn, a);
+        // Handle IO suspension chain (e.g. wait, fetch, navigate)
+        _driveAsync(result);
+        return result;
       };
     }
     return function() {};
   });
 
+  /**
+   * Drive an async suspension chain to completion.
+   * When K.callFn returns {suspended: true, request: ..., resume: fn},
+   * handle the IO operation and resume the VM.
+   */
+  function _driveAsync(result) {
+    if (!result || !result.suspended) return;
+    console.log("[sx] IO suspension:", JSON.stringify(result.request, null, 2));
+    var req = result.request;
+    if (!req) return;
+
+    // req is an SX list — extract items. K returns SX values.
+    var items = req.items || req;
+    var op = (items && items[0]) || req;
+    // Normalize: op might be a string or {name: "..."} symbol
+    var opName = (typeof op === "string") ? op : (op && op.name) || String(op);
+
+    if (opName === "wait" || opName === "io-sleep") {
+      // (wait ms) or (io-sleep ms) — resume after timeout
+      var ms = (items && items[1]) || 0;
+      if (typeof ms !== "number") ms = parseFloat(ms) || 0;
+      console.log("[sx] IO wait: " + ms + "ms, resuming after timeout");
+      setTimeout(function() {
+        try {
+          var resumed = result.resume(null);
+          console.log("[sx] IO resumed:", typeof resumed, resumed && resumed.suspended ? "suspended-again" : "done", JSON.stringify(resumed));
+          _driveAsync(resumed);
+        } catch(e) {
+          console.error("[sx] IO resume error:", e);
+        }
+      }, ms);
+    } else if (opName === "navigate") {
+      // (navigate url) — browser navigation
+      var url = (items && items[1]) || "/";
+      if (typeof url !== "string") url = String(url);
+      window.location.href = url;
+    } else {
+      console.warn("[sx] Unhandled IO suspension in callback:", opName, req);
+    }
+  }
+
   K.registerNative("host-typeof", function(args) {
     var obj = args[0];
     if (obj == null) return "nil";
@@ -526,7 +570,10 @@
       "sx/adapter-html.sx", "sx/adapter-sx.sx", "sx/adapter-dom.sx",
       "sx/boot-helpers.sx", "sx/hypersx.sx", "sx/harness.sx",
       "sx/harness-reactive.sx", "sx/harness-web.sx",
-      "sx/engine.sx", "sx/orchestration.sx", "sx/boot.sx",
+      "sx/engine.sx", "sx/orchestration.sx",
+      "sx/hs-tokenizer.sx", "sx/hs-parser.sx", "sx/hs-compiler.sx",
+      "sx/hs-runtime.sx", "sx/hs-integration.sx",
+      "sx/boot.sx",
     ];
     if (K.beginModuleLoad) K.beginModuleLoad();
     for (var i = 0; i < files.length; i++) {
@@ -644,6 +691,13 @@
             "hydrated:", !!islands[j]._sxBoundislandhydrated || !!islands[j]["_sxBound" + "island-hydrated"],
             "children:", islands[j].children.length);
         }
+        // Activate _hyperscript compat on elements with _ attribute
+        if (document.querySelector('[_]')) {
+          if (K.beginModuleLoad) K.beginModuleLoad();
+          loadLibrary("hyperscript integration", {});
+          if (K.endModuleLoad) K.endModuleLoad();
+          K.eval("(hs-boot!)");
+        }
         // Register popstate handler for back/forward navigation
         window.addEventListener("popstate", function(e) {
           var state = e.state;

shared/static/wasm/sx/boot.sx

@@ -444,6 +444,7 @@
       (sx-hydrate-islands nil)
       (run-post-render-hooks)
       (flush-collected-styles)
+      (hs-boot!)
       (set-timeout (fn () (process-elements nil)) 0)
       (dom-set-attr
         (host-get (dom-document) "documentElement")

shared/static/wasm/sx/compiler.sx

@@ -599,11 +599,12 @@
                 (binding)
                 (let
                   ((name (if (= (type-of (first binding)) "symbol") (symbol-name (first binding)) (first binding)))
-                    (value (nth binding 1))
+                    (value (nth binding 1)))
-                    (slot (scope-define-local let-scope name)))
                   (compile-expr em value let-scope false)
+                  (let
+                    ((slot (scope-define-local let-scope name)))
                     (emit-op em 17)
-                  (emit-byte em slot)))
+                    (emit-byte em slot))))
               bindings)
             (compile-begin em body let-scope tail?)))))
     (define
@@ -640,20 +641,29 @@
             (fn-scope (make-scope scope))
             (fn-em (make-emitter)))
           (dict-set! fn-scope "is-function" true)
+          (let
+            ((rest-pos -1) (rest-name nil))
             (for-each
               (fn
                 (p)
                 (let
                   ((name (cond (= (type-of p) "symbol") (symbol-name p) (and (list? p) (not (empty? p)) (= (type-of (first p)) "symbol")) (symbol-name (first p)) :else p)))
+                  (cond
+                    (= name "&rest")
+                    (set! rest-pos (len (get fn-scope "locals")))
+                    (= name "&key")
+                    nil
+                    :else (do
                       (when
-                  (and (not (= name "&key")) (not (= name "&rest")))
+                        (and (> rest-pos -1) (nil? rest-name))
-                  (scope-define-local fn-scope name))))
+                        (set! rest-name name))
+                      (scope-define-local fn-scope name)))))
               params)
             (compile-begin fn-em body fn-scope true)
             (emit-op fn-em 50)
             (let
               ((upvals (get fn-scope "upvalues"))
-              (code {:upvalue-count (len upvals) :arity (len (get fn-scope "locals")) :constants (get (get fn-em "pool") "entries") :bytecode (get fn-em "bytecode")})
+                (code (if (> rest-pos -1) {:upvalue-count (len upvals) :arity (len (get fn-scope "locals")) :constants (get (get fn-em "pool") "entries") :rest-arity rest-pos :bytecode (get fn-em "bytecode")} {:upvalue-count (len upvals) :arity (len (get fn-scope "locals")) :constants (get (get fn-em "pool") "entries") :bytecode (get fn-em "bytecode")}))
                 (code-idx (pool-add (get em "pool") code)))
               (emit-op em 51)
               (emit-u16 em code-idx)
@@ -662,7 +672,7 @@
                   (uv)
                   (emit-byte em (if (get uv "is-local") 1 0))
                   (emit-byte em (get uv "index")))
-              upvals)))))
+                upvals))))))
     (define
       compile-define
       (fn
@@ -681,7 +691,7 @@
                   (and
                     (not (empty? rest-args))
                     (= (type-of (first rest-args)) "keyword"))
-                  (let
+                  (letrec
                     ((skip-annotations (fn (items) (if (empty? items) nil (if (= (type-of (first items)) "keyword") (skip-annotations (rest (rest items))) (first items))))))
                     (skip-annotations rest-args))
                   (first rest-args)))))
@@ -724,14 +734,17 @@
       compile-cond
       (fn
         (em args scope tail?)
-        "Compile (cond test1 body1 test2 body2 ... :else fallback)."
+        "Compile (cond test1 body1 test2 body2 ... :else fallback).\n     Also handles clause syntax: (cond (test1 body1) (test2 body2) ...)."
+        (let
+          ((flat-args (if (and (not (empty? args)) (list? (first args)) (> (len (first args)) 1) (list? (first (first args)))) (reduce (fn (acc clause) (if (list? clause) (append acc clause) (append acc (list clause)))) (list) args) args)))
           (if
-          (< (len args) 2)
+            (< (len flat-args) 2)
             (emit-op em 2)
             (let
-            ((test (first args))
+              ((test (nth flat-args 0))
-              (body (nth args 1))
+                (body (nth flat-args 1))
-              (rest-clauses (if (> (len args) 2) (slice args 2) (list))))
+                (rest-clauses
+                  (if (> (len flat-args) 2) (slice flat-args 2) (list))))
               (if
                 (or
                   (and
@@ -755,7 +768,7 @@
                       (patch-i16
                         em
                         end-jump
-                      (- (current-offset em) (+ end-jump 2)))))))))))
+                        (- (current-offset em) (+ end-jump 2))))))))))))
     (define
       compile-case
       (fn

shared/static/wasm/sx/hs-integration.sx

@@ -0,0 +1,66 @@
+;; _hyperscript integration — wire _="..." attributes to compiled SX
+;;
+;; Entry points:
+;;   (hs-handler src)       — compile source to callable (fn (me) ...)
+;;   (hs-activate! el)      — activate hyperscript on a single element
+;;   (hs-boot!)             — scan DOM, activate all _="..." elements
+;;   (hs-boot-subtree! root) — activate within a subtree (for HTMX swaps)
+
+;; ── Compile source to a handler function ────────────────────────
+;; Returns a function (fn (me) ...) that can be called with a DOM element.
+;; Uses eval-expr-cek to turn the SX data structure into a live closure.
+
+(define
+  hs-handler
+  (fn
+    (src)
+    (let
+      ((sx (hs-to-sx-from-source src)))
+      (eval-expr-cek
+        (list
+          (quote fn)
+          (list (quote me))
+          (list
+            (quote let)
+            (list (list (quote it) nil) (list (quote event) nil))
+            sx))))))
+
+;; ── Activate a single element ───────────────────────────────────
+;; Reads the _="..." attribute, compiles, and executes with me=element.
+;; Marks the element to avoid double-activation.
+
+(define
+  hs-activate!
+  (fn
+    (el)
+    (let
+      ((src (dom-get-attr el "_")))
+      (when
+        (and src (not (dom-get-data el "hs-active")))
+        (dom-set-data el "hs-active" true)
+        (let ((handler (hs-handler src))) (handler el))))))
+
+;; ── Boot: scan entire document ──────────────────────────────────
+;; Called once at page load. Finds all elements with _ attribute,
+;; compiles their hyperscript, and activates them.
+
+(define
+  hs-boot!
+  (fn
+    ()
+    (let
+      ((elements (dom-query-all (dom-body) "[_]")))
+      (for-each (fn (el) (hs-activate! el)) elements))))
+
+;; ── Boot subtree: for dynamic content ───────────────────────────
+;; Called after HTMX swaps or dynamic DOM insertion.
+;; Only activates elements within the given root.
+
+(define
+  hs-boot-subtree!
+  (fn
+    (root)
+    (let
+      ((elements (dom-query-all root "[_]")))
+      (for-each (fn (el) (hs-activate! el)) elements))
+    (when (dom-get-attr root "_") (hs-activate! root))))

shared/static/wasm/sx/hs-integration.sxbc

@@ -0,0 +1,3 @@
+(sxbc 1 "af8c1b333d6af000"
+  (code
+    :constants ("hs-handler" {:upvalue-count 0 :arity 1 :constants ("hs-to-sx-from-source" "eval-expr-cek" "list" fn me let it event) :bytecode (20 0 0 16 0 48 1 17 1 20 1 0 1 3 0 1 4 0 52 2 0 1 1 5 0 1 6 0 2 52 2 0 2 1 7 0 2 52 2 0 2 52 2 0 2 16 1 52 2 0 3 52 2 0 3 49 1 50)} "hs-activate!" {:upvalue-count 0 :arity 1 :constants ("dom-get-attr" "_" "not" "dom-get-data" "hs-active" "dom-set-data" "hs-handler") :bytecode (20 0 0 16 0 1 1 0 48 2 17 1 16 1 6 33 15 0 5 20 3 0 16 0 1 4 0 48 2 52 2 0 1 33 30 0 20 5 0 16 0 1 4 0 3 48 3 5 20 6 0 16 1 48 1 17 2 16 2 16 0 49 1 32 1 0 2 50)} "hs-boot!" {:upvalue-count 0 :arity 0 :constants ("dom-query-all" "dom-body" "[_]" "for-each" {:upvalue-count 0 :arity 1 :constants ("hs-activate!") :bytecode (20 0 0 16 0 49 1 50)}) :bytecode (20 0 0 20 1 0 48 0 1 2 0 48 2 17 0 51 4 0 16 0 52 3 0 2 50)} "hs-boot-subtree!" {:upvalue-count 0 :arity 1 :constants ("dom-query-all" "[_]" "for-each" {:upvalue-count 0 :arity 1 :constants ("hs-activate!") :bytecode (20 0 0 16 0 49 1 50)} "dom-get-attr" "_" "hs-activate!") :bytecode (20 0 0 16 0 1 1 0 48 2 17 1 51 3 0 16 1 52 2 0 2 5 20 4 0 16 0 1 5 0 48 2 33 10 0 20 6 0 16 0 49 1 32 1 0 2 50)}) :bytecode (51 1 0 128 0 0 5 51 3 0 128 2 0 5 51 5 0 128 4 0 5 51 7 0 128 6 0 50)))

shared/static/wasm/sx/module-manifest.json

@@ -797,7 +797,8 @@
       "sx dom",
       "sx browser",
       "web adapter-dom",
-      "web engine"
+      "web engine",
+      "hyperscript integration"
     ],
     "exports": [
       "_preload-cache",
@@ -861,6 +862,89 @@
       "engine-init"
     ]
   },
+  "hyperscript tokenizer": {
+    "file": "hs-tokenizer.sxbc",
+    "deps": [],
+    "exports": [
+      "hs-tokenize",
+      "hs-make-token",
+      "hs-keywords",
+      "hs-keyword?",
+      "hs-digit?",
+      "hs-letter?",
+      "hs-ident-start?",
+      "hs-ident-char?",
+      "hs-ws?"
+    ]
+  },
+  "hyperscript parser": {
+    "file": "hs-parser.sxbc",
+    "deps": [
+      "hyperscript tokenizer"
+    ],
+    "exports": [
+      "hs-parse",
+      "hs-compile"
+    ]
+  },
+  "hyperscript compiler": {
+    "file": "hs-compiler.sxbc",
+    "deps": [
+      "hyperscript parser"
+    ],
+    "exports": [
+      "hs-to-sx",
+      "hs-to-sx-from-source"
+    ]
+  },
+  "hyperscript runtime": {
+    "file": "hs-runtime.sxbc",
+    "deps": [
+      "sx dom",
+      "sx browser"
+    ],
+    "exports": [
+      "hs-on",
+      "hs-on-every",
+      "hs-init",
+      "hs-wait",
+      "hs-wait-for",
+      "hs-settle",
+      "hs-toggle-class!",
+      "hs-toggle-between!",
+      "hs-take!",
+      "hs-put!",
+      "hs-navigate!",
+      "hs-next",
+      "hs-previous",
+      "hs-query-first",
+      "hs-query-last",
+      "hs-first",
+      "hs-last",
+      "hs-repeat-times",
+      "hs-repeat-forever",
+      "hs-fetch",
+      "hs-coerce",
+      "hs-make",
+      "hs-install",
+      "hs-measure",
+      "hs-transition"
+    ]
+  },
+  "hyperscript integration": {
+    "file": "hs-integration.sxbc",
+    "deps": [
+      "hyperscript compiler",
+      "hyperscript runtime",
+      "sx dom"
+    ],
+    "exports": [
+      "hs-handler",
+      "hs-activate!",
+      "hs-boot!",
+      "hs-boot-subtree!"
+    ]
+  },
   "_entry": {
     "file": "boot.sxbc",
     "deps": [

shared/static/wasm/sx/orchestration.sx

@@ -6,6 +6,9 @@
 (import (web adapter-dom))
 (import (web engine))
 
+(import (hyperscript integration)) ;; end define-library
+
+;; Re-export to global namespace for backward compatibility
 (define-library
   (web orchestration)
   (export
@@ -626,7 +629,8 @@
         (sx-hydrate-islands root)
         (run-post-render-hooks)
         (flush-collected-styles)
-        (process-elements root)))
+        (process-elements root)
+        (hs-boot-subtree! root)))
     (define
       process-settle-hooks
       :effects (mutation io)
@@ -1632,7 +1636,6 @@
         (do
           (sx-process-scripts nil)
           (sx-hydrate nil)
-          (process-elements nil)))))) ;; end define-library
+          (process-elements nil))))))
 
-;; Re-export to global namespace for backward compatibility
 (import (web orchestration))

shared/static/wasm/sx/vm.sx

@@ -137,10 +137,13 @@
       code-from-value
       (fn
         (v)
-        "Convert a compiler output dict to a vm-code object."
+        "Convert a compiler output dict to a vm-code dict. Idempotent — if v\n   already has vm-code keys (vc-bytecode), returns as-is."
         (if
           (not (dict? v))
           (make-vm-code 0 16 (list) (list))
+          (if
+            (has-key? v "vc-bytecode")
+            v
             (let
               ((bc-raw (get v "bytecode"))
                 (bc (if (nil? bc-raw) (list) bc-raw))
@@ -148,7 +151,7 @@
                 (consts (if (nil? consts-raw) (list) consts-raw))
                 (arity-raw (get v "arity"))
                 (arity (if (nil? arity-raw) 0 arity-raw)))
-            (make-vm-code arity (+ arity 16) bc consts)))))
+              (make-vm-code arity (+ arity 16) bc consts))))))
     (define vm-closure? (fn (v) (and (dict? v) (has-key? v "vm-code"))))
     (define *active-vm* nil)
     (define *jit-compile-fn* nil)
@@ -297,27 +300,32 @@
       vm-global-get
       (fn
         (vm frame name)
-        "Look up a global: globals table → closure env → primitives → HO wrappers"
+        "Look up a global: closure env → globals table → primitives → HO forms"
+        (let
+          ((closure-env (get (frame-closure frame) "vm-closure-env")))
+          (if
+            (nil? closure-env)
             (let
               ((globals (vm-globals-ref vm)))
               (if
                 (has-key? globals name)
                 (get globals name)
-            (let
-              ((closure-env (-> frame frame-closure closure-env)))
-              (if
-                (nil? closure-env)
                 (cek-try
                   (fn () (get-primitive name))
-                  (fn (e) (vm-resolve-ho-form vm name)))
+                  (fn (e) (vm-resolve-ho-form vm name)))))
             (let
               ((found (env-walk closure-env name)))
               (if
                 (nil? found)
+                (let
+                  ((globals (vm-globals-ref vm)))
+                  (if
+                    (has-key? globals name)
+                    (get globals name)
                     (cek-try
                       (fn () (get-primitive name))
-                      (fn (e) (vm-resolve-ho-form vm name)))
+                      (fn (e) (vm-resolve-ho-form vm name)))))
-                    found))))))))
+                found))))))
     (define
       vm-resolve-ho-form
       (fn

shared/static/wasm/sx_browser.bc.wasm.js

@@ -1792,7 +1792,7 @@
             blake2_js_for_wasm_create: blake2_js_for_wasm_create};
    }
    (globalThis))
-({"link":[["runtime-0db9b496",0],["prelude-d7e4b000",0],["stdlib-23ce0836",[]],["re-9a0de245",[2]],["sx-f96dc336",[2,3]],["jsoo_runtime-f96b44a8",[2]],["js_of_ocaml-651f6707",[2,5]],["dune__exe__Sx_browser-b7a948a6",[2,4,6]],["std_exit-10fb8830",[2]],["start-f808dbe1",0]],"generated":(b=>{var
+({"link":[["runtime-0db9b496",0],["prelude-d7e4b000",0],["stdlib-23ce0836",[]],["re-9a0de245",[2]],["sx-9799aa33",[2,3]],["jsoo_runtime-f96b44a8",[2]],["js_of_ocaml-651f6707",[2,5]],["dune__exe__Sx_browser-b7a948a6",[2,4,6]],["std_exit-10fb8830",[2]],["start-f808dbe1",0]],"generated":(b=>{var
 c=b,a=b?.module?.export||b;return{"env":{"caml_ba_kind_of_typed_array":()=>{throw new
 Error("caml_ba_kind_of_typed_array not implemented")},"caml_exn_with_js_backtrace":()=>{throw new
 Error("caml_exn_with_js_backtrace not implemented")},"caml_int64_create_lo_mi_hi":()=>{throw new