yumaikas / chalk.js

(() => globalThis.chalk = () => { // A naive tuplespace. Mostly for global event coordination let messages = []; let handlers = []; const rm = (from, idx) => { for (let i = idx.length - 1; i >= 0; i--) { from.splice(idx[i], 1) } } const mutate = () => { let matched = false; let toRm = []; let idx = 0; let msgToRm = new Set(); for (let h of handlers) { const isMatch = h.doQuery(msgToRm); matched ||= isMatch; if (isMatch && h.isOnce) { toRm.push(idx); } idx++; } let rmIdx = Array.from(msgToRm); rmIdx.sort((a,b) => a-b); rm(handlers, toRm); rm(messages, rmIdx); }; const query = (vars, predicates, callback, toRm, pIdx = 0) => { let matched = false; let mIdx = 0; for (const m of messages) { if (predicates[pIdx](vars, m)) { let keep = predicates[pIdx].keep; if (pIdx < predicates.length - 1) { let didMatch = query(vars, predicates, callback, toRm, pIdx+1); matched ||= didMatch; if (matched && !keep) { toRm.add(mIdx); } } else { callback(vars); if (!keep) { toRm.add(mIdx); } matched = true; } } mIdx++; } return matched; } const doWhen = (patterns, handler, isOnce=false) => { const predicates = []; const vars = new Set(); for (let patt of patterns) { let keep = false; if (patt.endsWith("?")) { patt = patt.slice(0,-1); keep = true; } const init = []; const conditions = []; const cleanup = []; let idx = 0; for (const p of patt.split(" ")) { const k = p.slice(1); if (p.startsWith("~$") && vars.has(p)) { if (vars.has(p)) { conditions.push(`t[${idx}] !== v["${k.slice(1)}"]`); } else { throw new Error("Cannot negate a var until after it has been captured"); } } else if (p.startsWith("~")) { conditions.push(`t[${idx}] !== "${k}"`); } else if (p.startsWith("$")) { if (vars.has(k)) { conditions.push(`t[${idx}] === v["${k}"]`); } else { init.push(`v["${k}"] = t[${idx}]`) cleanup.push(`delete v["${k}"]`) vars.add(k); } } else { conditions.push(`t[${idx}] === "${p}"`); } idx++; } let fn = new Function('v', 't', `${init.join(';')}; let ret = t.length === ${idx} && ${conditions.join(' && ')}; if (!ret) { ${cleanup.join('; ')}; } return ret;` ); fn.keep = keep; predicates.push(fn); } handlers.push({ doQuery(toRm) { return query({}, predicates, handler, toRm); }, isOnce }); mutate(); } return { _:{ messages, handlers }, msg(...data) { messages.push(data); mutate(); }, when(...args) { doWhen(args.slice(0,-1), args.at(-1)); }, once(patt, handler) { doWhen(patt, handler, true); } } })();

import "./test.js"; import "./chalk.js"; test("chalk", { basicTest() { const board = globalThis.chalk(); let didFire = false; board.when("test", (_) => didFire = true); board.msg("test"); assert(didFire, "Did not fire"); }, basicTest2() { const board = globalThis.chalk(); let didFire = false; board.when("test $x", (_) => { didFire = (_.x === "yo"); }) board.msg("test", "yo"); assert(didFire, "Did not fire"); }, joinTest(){ const board = chalk(); let didFire = false; board.when("test $a", "taste $a", (_) => { didFire = _.a == "yo"}) board.msg("test", "yo"); assert(!didFire, "Fired prematurely"); board.msg("taste", "ey"); assert(!didFire, "Fired prematurely"); board.msg("taste", "yo"); assert(didFire, "Did not fire when it should have"); }, keepTest() { const board = chalk(); let didFire = false; board.when("test $a?", "taste $a", (_) => { didFire = _.a == "yo"}) board.msg("test", "yo"); assert(!didFire, "Fired prematurely"); board.msg("taste", "ey"); assert(!didFire, "Fired prematurely"); board.msg("taste", "yo"); assert(didFire, "Did not fire when it should have"); assert(board._.messages.find((x) => x[0] === "test" && x[1] === "yo"), "Message was removed and shouldn't have been") }, negationTest(){ const board = chalk(); let didFire = false; board.when("test ~foo", (_) => { didFire = true}) board.msg("test", "foo"); assert(!didFire, "Fired prematurely"); board.msg("test", "yo"); assert(didFire, "Did not fire when it should have"); }, saturationTest() { const board = chalk(); let $aFired = false; let fooFired = false; board.when("test $a", (_) => { $aFired = true; }) board.when("test foo", (_) => { fooFired = true; }) board.msg("test", "foo"); assert($aFired && fooFired, "Two handlers should have fired"); } });

globalThis.test = (suite, tests) => { process.stdout.write(suite + ": "); for (const [name, t] of Object.entries(tests)) { try { t(); process.stdout.write("."); } catch(ex) { console.error("In " + suite +", test " + name + " failed:", ex) } } console.log(); } // For global scope globalThis.assert = (cond, msg) => { if (!cond) throw new Error(msg); };