-
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathbytes_binary_io.deno.js
More file actions
494 lines (485 loc) · 26.5 KB
/
Copy pathbytes_binary_io.deno.js
File metadata and controls
494 lines (485 loc) · 26.5 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
// Generated by AffineScript compiler (Deno-ESM target, issue #122)
// SPDX-License-Identifier: MPL-2.0
// ---- AffineScript Deno-ESM runtime ----
const Some = (value) => ({ tag: "Some", value });
const None = { tag: "None" };
const Ok = (value) => ({ tag: "Ok", value });
const Err = (error) => ({ tag: "Err", error });
const Unit = null;
const print = (s) => { Deno.stdout.writeSync(new TextEncoder().encode(String(s))); };
const println = (s) => { console.log(String(s)); };
// ---- Deno host shims (extern fn lowering targets, issue #122) ----
// Kept tiny + inlined so emitted modules are genuinely drop-in (no extra
// package to publish or resolve). The same surface is mirrored, for
// standalone `deno test`, by packages/affine-deno/mod.js.
const __as_ensureDir = (p) => {
try { Deno.mkdirSync(p, { recursive: true }); }
catch (e) { if (!(e instanceof Deno.errors.AlreadyExists)) throw e; }
};
const __as_pathJoin = (a, b) => {
if (a.length === 0) return b;
const sep = a.endsWith("/") || a.endsWith("\\") ? "" : "/";
return a + sep + b;
};
const __as_readDirNames = (p) => {
const names = [];
for (const entry of Deno.readDirSync(p)) {
if (entry.isFile) names.push(entry.name);
}
return names;
};
const __as_isNotFound = (e) => (e instanceof Deno.errors.NotFound);
const __as_walkRecursive = (root) => {
const out = [];
const rec = (dir) => {
for (const entry of Deno.readDirSync(dir)) {
const full = (dir.endsWith("/") ? dir : dir + "/") + entry.name;
if (entry.isFile) out.push(full);
else if (entry.isDirectory) rec(full);
}
};
rec(root);
return out;
};
const __as_regexMatch = (s, pat) => new RegExp(pat).test(String(s));
const __as_wasmInstance = (bytes) =>
new WebAssembly.Instance(new WebAssembly.Module(bytes),
{ wasi_snapshot_preview1: { fd_write: () => 0 } }).exports;
const __as_wasmCall = (exports, name, args) => Number(exports[name](...(args || [])));
// ---- WasmValue (Deno.affine #455 — Tier 1 #5, Option B) ----
// Opaque tagged value crossing the AS/JS boundary as `{ kind, v }`.
// `kind` is one of "i32" | "i64" | "f32" | "f64". The `v` payload is
// `BigInt` for i64 (preserves precision beyond 2^53), `Number` otherwise.
const __as_wv_i32 = (n) => ({ kind: "i32", v: (Number(n) | 0) });
const __as_wv_i64 = (n) => ({ kind: "i64", v: BigInt(n) });
const __as_wv_f32 = (f) => ({ kind: "f32", v: Math.fround(Number(f)) });
const __as_wv_f64 = (f) => ({ kind: "f64", v: Number(f) });
const __as_wv_as_int = (v) => {
if (v == null) return 0;
if (typeof v.v === "bigint") {
// i64: truncate to safe-integer Number; caller's responsibility for
// precision-sensitive paths (use wv_kind to detect).
return Number(v.v);
}
// i32 / f32 / f64: truncate toward zero per AS Int semantics.
return (Number(v.v) | 0);
};
const __as_wv_as_float = (v) => {
if (v == null) return 0;
return typeof v.v === "bigint" ? Number(v.v) : Number(v.v);
};
const __as_wv_kind = (v) => (v && typeof v.kind === "string") ? v.kind : "";
const __as_wasm_export_call = (exports, name, args) => {
// Unmarshal AS-side [WasmValue] to raw JS scalars for the wasm call.
const rawArgs = (args || []).map((wv) => {
if (wv == null) return 0;
// i64 payload is BigInt; wasm i64 imports accept BigInt directly.
return wv.v;
});
const result = exports[name](...rawArgs);
// Wrap return as f64 (lossless for any numeric; callers expecting i32/i64
// can rebuild via wv_i32(wv_as_int(result)) or inspect wv_kind).
if (typeof result === "bigint") {
return { kind: "i64", v: result };
}
return { kind: "f64", v: Number(result) };
};
// ---- motion (bindings #4): consumer-provided import ----
// Host JS environment must expose globalThis.__as_motion (the motion
// library or a compatible mock). Tests set it in the harness before
// importing the generated module; production consumers typically do
// `import * as m from "motion"; globalThis.__as_motion = m;` once at
// module-init time. The AffineScript-side externs (stdlib/Motion.affine)
// don't see this indirection — they call __as_motion* helpers directly.
const __as_motionAnimate = (target, keyframes, options) =>
globalThis.__as_motion.animate(target, keyframes, options);
const __as_motionAwait = (controls) =>
Promise.resolve(controls).then(() => 0);
const __as_motionCancel = (controls) => {
if (controls && typeof controls.cancel === "function") controls.cancel();
return 0;
};
// `animateMini` / `tween` / `spring` / `ease` — bindings #4 follow-up
// surface. Each helper resolves the host method on globalThis.__as_motion
// at call time so a mock that only stubs a subset still works for the
// rest (the smoke harness exercises every variant).
const __as_motionAnimateMini = (target, keyframes, options) =>
globalThis.__as_motion.animateMini(target, keyframes, options);
const __as_motionTween = (target, from, to, options) =>
globalThis.__as_motion.tween(target, from, to, options);
const __as_motionSpring = (target, keyframes, springConfig) =>
globalThis.__as_motion.spring(target, keyframes, springConfig);
const __as_motionEase = (name) =>
globalThis.__as_motion.ease(name);
// ---- pixi.js (bindings #1): consumer-provided import ----
// Host JS environment exposes globalThis.__as_pixi (the PIXI namespace
// from `import * as PIXI from "pixi.js"`). Tests set it in the harness
// before importing the generated module.
const __as_pixiAppInit = async (options) => {
const app = new globalThis.__as_pixi.Application();
await app.init(options);
return app;
};
const __as_pixiAppCanvas = (app) => app.canvas;
const __as_pixiAppStage = (app) => app.stage;
const __as_pixiAppTicker = (app) => app.ticker;
const __as_pixiAppDestroy = (app) => { app.destroy(); return 0; };
const __as_pixiContainerNew = () => new globalThis.__as_pixi.Container();
const __as_pixiContainerAddChild = (p, c) => { p.addChild(c); return 0; };
const __as_pixiContainerRemoveChild = (p, c) => { p.removeChild(c); return 0; };
const __as_pixiContainerSetPosition = (c, x, y) => { c.x = x; c.y = y; return 0; };
const __as_pixiContainerSetScale = (c, x, y) => { c.scale.set(x, y); return 0; };
const __as_pixiContainerSetPivot = (c, x, y) => { c.pivot.set(x, y); return 0; };
const __as_pixiContainerSetRotation = (c, rad) => { c.rotation = rad; return 0; };
const __as_pixiContainerSetAlpha = (c, a) => { c.alpha = a; return 0; };
const __as_pixiContainerSetZIndex = (c, z) => { c.zIndex = z; return 0; };
const __as_pixiContainerSetSortableChildren = (c, v) => { c.sortableChildren = v; return 0; };
const __as_pixiContainerSetEventMode = (c, mode) => { c.eventMode = mode; return 0; };
const __as_pixiContainerSetCursor = (c, cursor) => { c.cursor = cursor; return 0; };
const __as_pixiContainerSetVisible = (c, v) => { c.visible = v; return 0; };
const __as_pixiContainerOn = (c, event, handler) => { c.on(event, handler); return 0; };
const __as_pixiContainerOff = (c, event, handler) => { c.off(event, handler); return 0; };
const __as_pixiContainerDestroy = (c) => { c.destroy(); return 0; };
const __as_pixiSpriteFrom = (t) => new globalThis.__as_pixi.Sprite(t);
const __as_pixiSpriteSetAnchor = (s, x, y) => { s.anchor.set(x, y); return 0; };
// Upcasts are identity — PIXI's class hierarchy makes Sprite/Graphics/
// Text actual Container subclasses, so the JS object is the same.
const __as_pixiSpriteAsContainer = (s) => s;
const __as_pixiTextureFromUrl = (url) => globalThis.__as_pixi.Texture.from(url);
const __as_pixiGraphicsNew = () => new globalThis.__as_pixi.Graphics();
const __as_pixiGraphicsRect = (g, x, y, w, h) => { g.rect(x, y, w, h); return 0; };
const __as_pixiGraphicsFill = (g, color) => { g.fill({ color }); return 0; };
const __as_pixiGraphicsClear = (g) => { g.clear(); return 0; };
const __as_pixiGraphicsAsContainer = (g) => g;
const __as_pixiTextNew = (options) => new globalThis.__as_pixi.Text(options);
const __as_pixiTextSetText = (t, content) => { t.text = content; return 0; };
const __as_pixiTextAsContainer = (t) => t;
const __as_pixiTickerAdd = (t, cb) => { t.add(cb); return 0; };
const __as_pixiTickerStart = (t) => { t.start(); return 0; };
const __as_pixiTickerStop = (t) => { t.stop(); return 0; };
// ---- @pixi/ui (bindings #3): consumer-provided import ----
// Host JS environment exposes globalThis.__as_pixi_ui (the namespace
// from `import * as PixiUI from "@pixi/ui"`). Tests set it in the
// harness before importing the generated module; production
// consumers typically do once at module-init time. The
// AffineScript-side externs (stdlib/PixiUI.affine) don't see this
// indirection — they call __as_pixiUi* helpers directly.
//
// Upcasts to Container are identity — @pixi/ui's Button /
// FancyButton / Slider / Switch are all real PIXI.Container
// subclasses, so the JS object is the same.
const __as_pixiUiButtonNew = (options) => new globalThis.__as_pixi_ui.Button(options);
const __as_pixiUiButtonOnPress = (b, cb) => { b.onPress.connect(cb); return 0; };
const __as_pixiUiButtonAsContainer = (b) => b;
const __as_pixiUiFancyButtonNew = (options) => new globalThis.__as_pixi_ui.FancyButton(options);
const __as_pixiUiFancyButtonAsContainer = (b) => b;
const __as_pixiUiSliderNew = (options) => new globalThis.__as_pixi_ui.Slider(options);
const __as_pixiUiSliderOnUpdate = (s, cb) => { s.onUpdate.connect(cb); return 0; };
const __as_pixiUiSliderAsContainer = (s) => s;
const __as_pixiUiSwitchNew = (options) => new globalThis.__as_pixi_ui.Switch(options);
const __as_pixiUiSwitchOnChange = (sw, cb) => { sw.onChange.connect(cb); return 0; };
const __as_pixiUiSwitchAsContainer = (sw) => sw;
// ---- @pixi/sound (bindings #2): consumer-provided import ----
// Host JS environment exposes globalThis.__as_pixi_sound (the `Sound`
// named export from `@pixi/sound`). Tests set it in the harness before
// importing the generated module; production consumers typically do
// `import { Sound } from "@pixi/sound"; globalThis.__as_pixi_sound = Sound;`
// once at module-init time. The AffineScript-side externs
// (stdlib/PixiSound.affine) don't see this indirection — they call
// __as_pixiSound* helpers directly.
const __as_pixiSoundFrom = (url) => globalThis.__as_pixi_sound.from(url);
const __as_pixiSoundPlay = (s) => { s.play(); return 0; };
const __as_pixiSoundStop = (s) => { s.stop(); return 0; };
const __as_pixiSoundPause = (s) => { s.pause(); return 0; };
const __as_pixiSoundResume = (s) => { s.resume(); return 0; };
const __as_pixiSoundSetVolume = (s, vol) => { s.volume = vol; return 0; };
const __as_pixiSoundSetLoop = (s, loop) => { s.loop = loop; return 0; };
// ---- Ipc (bindings #9): web-platform MessageChannel/MessagePort ----
// Uses standard web globals (MessageChannel, structuredClone) — no
// consumer-side init required. Available unmodified in Deno, Node 16+,
// browsers, and Web Workers.
const __as_messageChannelNew = () => new MessageChannel();
const __as_messageChannelPort1 = (ch) => ch.port1;
const __as_messageChannelPort2 = (ch) => ch.port2;
const __as_messagePortPostMessage = (p, data) => { p.postMessage(data); return 0; };
const __as_messagePortOnMessage = (p, handler) => { p.onmessage = handler; return 0; };
const __as_messagePortStart = (p) => { p.start(); return 0; };
const __as_messagePortClose = (p) => { p.close(); return 0; };
const __as_targetPostMessage = (t, msg) => { t.postMessage(msg); return 0; };
const __as_structuredCloneValue = (v) => structuredClone(v);
// ---- Canvas (bindings #8): HTML5 Canvas 2D rendering context ----
// `canvas` arg is the consumer-supplied HTMLCanvasElement; helpers
// dispatch directly to the standard CanvasRenderingContext2D
// methods. Available unmodified in browsers, jsdom-under-Deno,
// idaptik's WebView host, and any DOM emulator.
const __as_canvasGetContext2D = (canvas) => canvas.getContext("2d");
const __as_canvasFillStyle = (ctx, color) => { ctx.fillStyle = color; return 0; };
const __as_canvasStrokeStyle = (ctx, color) => { ctx.strokeStyle = color; return 0; };
const __as_canvasLineWidth = (ctx, w) => { ctx.lineWidth = w; return 0; };
const __as_canvasGlobalAlpha = (ctx, a) => { ctx.globalAlpha = a; return 0; };
const __as_canvasFillRect = (ctx, x, y, w, h) => { ctx.fillRect(x, y, w, h); return 0; };
const __as_canvasStrokeRect = (ctx, x, y, w, h) => { ctx.strokeRect(x, y, w, h); return 0; };
const __as_canvasClearRect = (ctx, x, y, w, h) => { ctx.clearRect(x, y, w, h); return 0; };
const __as_canvasBeginPath = (ctx) => { ctx.beginPath(); return 0; };
const __as_canvasClosePath = (ctx) => { ctx.closePath(); return 0; };
const __as_canvasMoveTo = (ctx, x, y) => { ctx.moveTo(x, y); return 0; };
const __as_canvasLineTo = (ctx, x, y) => { ctx.lineTo(x, y); return 0; };
const __as_canvasArc = (ctx, x, y, r, s, e) => { ctx.arc(x, y, r, s, e); return 0; };
const __as_canvasFill = (ctx) => { ctx.fill(); return 0; };
const __as_canvasStroke = (ctx) => { ctx.stroke(); return 0; };
const __as_canvasSave = (ctx) => { ctx.save(); return 0; };
const __as_canvasRestore = (ctx) => { ctx.restore(); return 0; };
const __as_canvasTranslate = (ctx, x, y) => { ctx.translate(x, y); return 0; };
const __as_canvasRotate = (ctx, rad) => { ctx.rotate(rad); return 0; };
const __as_canvasScale = (ctx, x, y) => { ctx.scale(x, y); return 0; };
const __as_canvasFont = (ctx, font) => { ctx.font = font; return 0; };
const __as_canvasTextAlign = (ctx, align) => { ctx.textAlign = align; return 0; };
const __as_canvasTextBaseline = (ctx, baseline) => { ctx.textBaseline = baseline; return 0; };
const __as_canvasFillText = (ctx, text, x, y) => { ctx.fillText(text, x, y); return 0; };
const __as_canvasStrokeText = (ctx, text, x, y) => { ctx.strokeText(text, x, y); return 0; };
const __as_canvasMeasureText = (ctx, text) => ctx.measureText(text);
const __as_canvasDrawImage = (ctx, img, x, y) => { ctx.drawImage(img, x, y); return 0; };
const __as_canvasDrawImageScaled = (ctx, img, x, y, w, h) => { ctx.drawImage(img, x, y, w, h); return 0; };
// `++` is overloaded (string concat / array concat); `a + b` would
// stringify arrays. Dispatch on shape so stdlib/string.affine's
// `result ++ [x]` and `a ++ b` are both correct.
const __as_concat = (a, b) => Array.isArray(a) ? a.concat(b) : (a + b);
// Honest host/runtime primitives underpinning the AffineScript-level
// stdlib/string.affine (its is_empty/starts_with/ends_with/split/join/
// replace/... are real AffineScript on top of these).
const __as_strSub = (s, start, n) => String(s).slice(start, start + n);
const __as_strGet = (s, i) => String(s)[i];
const __as_strFind = (s, n) => String(s).indexOf(n);
const __as_charToInt = (c) => String(c).codePointAt(0);
const __as_intToChar = (n) => String.fromCodePoint(n);
const __as_strCharCodeAt = (s, i) => (i >= 0 && i < s.length ? s.charCodeAt(i) : -1);
const __as_strFromCharCode = (n) => String.fromCharCode(n & 0xff);
const __as_parseInt = (s) => {
const n = parseInt(String(s), 10);
return Number.isNaN(n) ? None : Some(n);
};
const __as_parseFloat = (s) => {
const n = parseFloat(String(s));
return Number.isNaN(n) ? None : Some(n);
};
const __as_show = (v) => (typeof v === "string" ? v : JSON.stringify(v));
// ---- Http (issue #160): portable fetch round-trip ----
// `headers` crosses the boundary as an AffineScript [(String, String)]
// assoc list == JS array of [name, value] pairs. `body` is an
// AffineScript Option<String> == { tag: "Some", value } | { tag: "None" }.
// The result is the `Response` record shape { status, headers, body }.
const __as_httpHeadersToObject = (pairs) => {
const o = {};
for (const kv of (pairs || [])) o[kv[0]] = kv[1];
return o;
};
const __as_httpHeadersFromResponse = (res) => {
const out = [];
res.headers.forEach((value, key) => out.push([key, value]));
return out;
};
// ---- hpm-json-rsr Zig FFI shims (stdlib/json.affine v0.3) ----
// `HpmJsonValue` is opaque to AffineScript; on Deno-ESM it's just the
// underlying JS value from JSON.parse. The shims mirror the sentinel
// conventions of the Zig exports so the AffineScript-side wrappers
// (`to_json`, `parse`) behave identically across backends.
const __as_hpmJsonParse = (s) => {
try { return Some(JSON.parse(String(s))); } catch (_e) { return None; }
};
const __as_hpmJsonFree = (_v) => 0;
const __as_hpmJsonType = (v) => {
if (v === null || v === undefined) return 0;
if (typeof v === "boolean") return 1;
if (typeof v === "number") return Number.isInteger(v) ? 2 : 3;
if (typeof v === "string") return 4;
if (Array.isArray(v)) return 5;
if (typeof v === "object") return 6;
return -1;
};
const __as_hpmJsonBool = (v) => (typeof v === "boolean" ? (v ? 1 : 0) : -1);
const __as_hpmJsonInt = (v) =>
(typeof v === "number" ? Math.trunc(v) : Number.MIN_SAFE_INTEGER);
const __as_hpmJsonFloat = (v) => (typeof v === "number" ? v : NaN);
const __as_hpmJsonString = (v) => (typeof v === "string" ? v : "");
const __as_hpmJsonObjectGet = (v, k) => {
if (v === null || typeof v !== "object" || Array.isArray(v)) return None;
return Object.prototype.hasOwnProperty.call(v, String(k))
? Some(v[String(k)]) : None;
};
const __as_hpmJsonArrayLen = (v) => (Array.isArray(v) ? v.length : 0);
const __as_hpmJsonArrayGet = (v, i) => {
if (!Array.isArray(v)) return None;
const idx = Number(i);
return (idx >= 0 && idx < v.length) ? Some(v[idx]) : None;
};
const __as_hpmJsonEscapeString = (s) => {
let out = "";
const src = String(s);
for (let i = 0; i < src.length; i++) {
const c = src.charCodeAt(i);
if (c === 0x22) out += "\\\"";
else if (c === 0x5c) out += "\\\\";
else if (c === 0x0a) out += "\\n";
else if (c === 0x0d) out += "\\r";
else if (c === 0x09) out += "\\t";
else if (c === 0x08) out += "\\b";
else if (c === 0x0c) out += "\\f";
else if (c < 0x20) out += "\\u00" + c.toString(16).padStart(2, "0");
else out += src[i];
}
return out;
};
// ---- Sqlite (db-theory #1a / stdlib/Sqlite.affine): SQL via host adapter ----
// Host JS environment must expose globalThis.__as_sqlite, a namespace
// implementing the small adapter contract below. Consumers init once
// (Deno):
// import * as s from "jsr:@db/sqlite";
// globalThis.__as_sqlite = {
// open: (p) => new s.Database(p),
// close: (db) => db.close(),
// execute: (db, sql) => db.exec(sql),
// query: (db, sql, params) => db.prepare(sql).all(...params),
// queryOne: (db, sql, params) => db.prepare(sql).get(...params),
// queryInt: (db, sql, params) => db.prepare(sql).value(...params),
// };
// or (Node + better-sqlite3): adapt the same shape. The smoke harness
// installs an in-memory mock that implements the same contract.
//
// Parameter marshalling is intentionally simple: the AffineScript side
// hands the adapter a JSON-encoded `params` string (`"[]"` for none);
// rows + single-row results come back as JSON strings for caller-side
// decoding via `json::parse`. This matches the existing 6-extern
// stdlib/Sqlite.affine surface; richer typed bindings (prepared
// statements, schema introspection, bulk I/O) land in db-theory #1b.
const __as_dbOpen = (path) => globalThis.__as_sqlite.open(path);
const __as_dbClose = (h) => { globalThis.__as_sqlite.close(h); return 0; };
const __as_dbExecute = (h, sql) => { globalThis.__as_sqlite.execute(h, sql); return 0; };
const __as_dbQuery = (h, sql, paramsJson) => {
const params = paramsJson === "" || paramsJson === "[]" ? [] : JSON.parse(paramsJson);
const rows = globalThis.__as_sqlite.query(h, sql, params);
return JSON.stringify(rows);
};
const __as_dbQueryOne = (h, sql, paramsJson) => {
const params = paramsJson === "" || paramsJson === "[]" ? [] : JSON.parse(paramsJson);
const row = globalThis.__as_sqlite.queryOne(h, sql, params);
return JSON.stringify(row);
};
const __as_dbQueryInt = (h, sql, paramsJson) => {
const params = paramsJson === "" || paramsJson === "[]" ? [] : JSON.parse(paramsJson);
const v = globalThis.__as_sqlite.queryInt(h, sql, params);
return Number(v) | 0;
};
// ---- Sqlite prepared statements (db-theory #1b) ----
// Layered on top of the convenience surface above. The host adapter
// gains nine extra methods (`prepare`, `bindInt`, `bindText`, `bindNull`,
// `step`, `columnCount`, `columnInt`, `columnText`, `reset`, `finalize`);
// the smoke harness's mock implements them, and both `jsr:@db/sqlite`
// and `better-sqlite3` provide direct one-line wrappers (each library
// already exposes a `prepare()` + iterator-style step + typed column
// accessors). Bind-index convention is sqlite3's 1-indexed; column-index
// convention is 0-indexed (matches both adapter libraries).
const __as_dbPrepare = (h, sql) => globalThis.__as_sqlite.prepare(h, sql);
const __as_dbBindInt = (s, idx, v) => { globalThis.__as_sqlite.bindInt(s, idx, v); return 0; };
const __as_dbBindText = (s, idx, v) => { globalThis.__as_sqlite.bindText(s, idx, v); return 0; };
const __as_dbBindNull = (s, idx) => { globalThis.__as_sqlite.bindNull(s, idx); return 0; };
const __as_dbStep = (s) => (globalThis.__as_sqlite.step(s) ? 1 : 0);
const __as_dbColumnCount = (s) => Number(globalThis.__as_sqlite.columnCount(s)) | 0;
const __as_dbColumnInt = (s, idx) => {
const v = globalThis.__as_sqlite.columnInt(s, idx);
return v == null ? 0 : (Number(v) | 0);
};
const __as_dbColumnText = (s, idx) => {
const v = globalThis.__as_sqlite.columnText(s, idx);
return v == null ? "" : String(v);
};
const __as_dbReset = (s) => { globalThis.__as_sqlite.reset(s); return 0; };
const __as_dbFinalize = (s) => { globalThis.__as_sqlite.finalize(s); return 0; };
// ---- Sqlite schema introspection + bulk I/O + error inspection (db-theory #1c) ----
// Five more adapter methods (`schemaTables`, `schemaColumns`,
// `tableExists`, `importCsv`, `exportCsv`, `lastError`); each
// real-world adapter (jsr:@db/sqlite, better-sqlite3) backs them with
// a one-liner over `PRAGMA table_info` / a `Database.prepare()`
// iterator / a `fs.writeFileSync(..., csv)` call.
const __as_dbSchemaTables = (h) => String(globalThis.__as_sqlite.schemaTables(h));
const __as_dbSchemaColumns = (h, table) => String(globalThis.__as_sqlite.schemaColumns(h, table));
const __as_dbTableExists = (h, table) => Boolean(globalThis.__as_sqlite.tableExists(h, table));
const __as_dbImportCsv = (h, table, path, hasHeader) =>
Number(globalThis.__as_sqlite.importCsv(h, table, path, Boolean(hasHeader))) | 0;
const __as_dbExportCsv = (h, sql, paramsJson, path) => {
const params = paramsJson === "" || paramsJson === "[]" ? [] : JSON.parse(paramsJson);
return Number(globalThis.__as_sqlite.exportCsv(h, sql, params, path)) | 0;
};
const __as_dbLastError = (h) => {
const v = globalThis.__as_sqlite.lastError(h);
return v == null ? "" : String(v);
};
// ---- Sqlite transactions (db-theory #2) ----
// `Tx` is an opaque handle; the host adapter is required to
// invalidate it on `commit` / `rollback` so that subsequent calls
// throw a host-side `Error` (the affine type system's
// at-most-one-use guarantee is enforced statically on the AS side;
// this host invariant catches FFI-side aliasing bugs in tests).
const __as_txBegin = (h) => globalThis.__as_sqlite.txBegin(h);
const __as_txCommit = (t) => { globalThis.__as_sqlite.txCommit(t); return 0; };
const __as_txRollback = (t) => { globalThis.__as_sqlite.txRollback(t); return 0; };
const __as_txSavepoint = (t, n) => { globalThis.__as_sqlite.txSavepoint(t, n); return 0; };
const __as_txRelease = (t, n) => { globalThis.__as_sqlite.txRelease(t, n); return 0; };
const __as_txRollbackTo = (t, n) => { globalThis.__as_sqlite.txRollbackTo(t, n); return 0; };
const __as_txDb = (t) => globalThis.__as_sqlite.txDb(t);
const __as_txIsLive = (t) => (globalThis.__as_sqlite.txIsLive(t) ? 1 : 0);
// ---- Sqlite aggregation (db-theory #3 / stdlib/Aggregate.affine) ----
// Each scalar aggregator delegates to a host adapter method that runs
// the SQL, expects a single-row result, and unwraps column 0. `groupBy`
// / `groupCount` return JSON strings (caller parses).
const __as_dbCount = (h, sql, params) => Number(globalThis.__as_sqlite.aggCount(h, sql, params)) | 0;
const __as_dbSum = (h, sql, params) => Number(globalThis.__as_sqlite.aggSum(h, sql, params)) | 0;
const __as_dbMinInt = (h, sql, params) => Number(globalThis.__as_sqlite.aggMinInt(h, sql, params)) | 0;
const __as_dbMaxInt = (h, sql, params) => Number(globalThis.__as_sqlite.aggMaxInt(h, sql, params)) | 0;
const __as_dbAvg = (h, sql, params) => Number(globalThis.__as_sqlite.aggAvg(h, sql, params));
const __as_dbGroupBy = (h, sql, params) => String(globalThis.__as_sqlite.groupBy(h, sql, params));
const __as_dbGroupCount = (h, table, keyCol) => String(globalThis.__as_sqlite.groupCount(h, table, keyCol));
const __as_httpFetch = async (url, method, headers, bodyOpt) => {
const init = { method, headers: __as_httpHeadersToObject(headers) };
if (bodyOpt && bodyOpt.tag === "Some") init.body = bodyOpt.value;
// `globalThis.fetch` explicitly: the stdlib `Http.fetch` compiles to a
// module-level `function fetch`, which would otherwise shadow the host.
const res = await globalThis.fetch(url, init);
const text = await res.text();
return {
status: res.status,
headers: __as_httpHeadersFromResponse(res),
body: text,
};
};
// ---- end runtime ----
export function build_event(kind, key_code, modifiers, mouse_x, mouse_y) {
const b = new Uint8Array(16);
const _r0 = ((new DataView((b).buffer, (b).byteOffset, (b).byteLength)).setInt32(0, (kind) | 0, true), 0);
const _r4 = ((new DataView((b).buffer, (b).byteOffset, (b).byteLength)).setUint32(4, (key_code) >>> 0, true), 0);
const _r8 = ((new DataView((b).buffer, (b).byteOffset, (b).byteLength)).setUint8(8, (modifiers) & 0xFF), 0);
const _ra = ((new DataView((b).buffer, (b).byteOffset, (b).byteLength)).setUint16(10, (mouse_x) & 0xFFFF, true), 0);
const _rc = ((new DataView((b).buffer, (b).byteOffset, (b).byteLength)).setUint16(12, (mouse_y) & 0xFFFF, true), 0);
return b;
}
export function read_kind(b) {
return (new DataView((b).buffer, (b).byteOffset, (b).byteLength)).getInt32(0, true);
}
export function read_key_code(b) {
return (new DataView((b).buffer, (b).byteOffset, (b).byteLength)).getUint32(4, true);
}
export function read_modifiers(b) {
return (new DataView((b).buffer, (b).byteOffset, (b).byteLength)).getUint8(8);
}
export function read_mouse_x(b) {
return (new DataView((b).buffer, (b).byteOffset, (b).byteLength)).getUint16(10, true);
}
export function read_mouse_y(b) {
return (new DataView((b).buffer, (b).byteOffset, (b).byteLength)).getUint16(12, true);
}
export function fill_byte(n, byte) {
return (new Uint8Array(n)).fill((byte) & 0xFF);
}
export function fill_first(n, byte) {
const b = (new Uint8Array(n)).fill((byte) & 0xFF);
return (new DataView((b).buffer, (b).byteOffset, (b).byteLength)).getUint8(0);
}