mirror of
https://github.com/badlogic/pi-mono.git
synced 2026-11-05 23:37:25 +00:00
e9c0ff4d84
src/next is src (the main export), src/next-node is src/node with short subpaths (/http, /workers, /plugins, /plugins/runtime, /app, /surfaces, /web, /react, /tui, /tui/launcher); the foundations get /json and /watch; Chord v1 moves to src/old (/old, /old/node) until p2 runs on v2; tests and docs move likewise (test/, docs/, test/old, docs/old). Durable and env import the foundations from their subpaths.
40 lines
1.8 KiB
TypeScript
40 lines
1.8 KiB
TypeScript
// Writes the stored data of the schema switch's proof (`stored/`): a SQLite store and its export archive, made by the
|
|
// code before the switch (TypeBox helpers). Kept as it was written; rerun only to make a new fixture on purpose.
|
|
// Run from packages/chord:
|
|
// node --conditions=source --experimental-strip-types test/schema/write-stored.ts
|
|
|
|
import { createWriteStream } from "node:fs";
|
|
import { copyFile, mkdir, mkdtemp, rm } from "node:fs/promises";
|
|
import { tmpdir } from "node:os";
|
|
import { join } from "node:path";
|
|
import { pipeline } from "node:stream/promises";
|
|
import { fileURLToPath } from "node:url";
|
|
import { BACKGROUND_CONTEXT as context } from "../../src/context/index.ts";
|
|
import { encodeJsonl } from "../../src/store/index.ts";
|
|
import { EditsV1, Owner } from "./declarations.ts";
|
|
import { ownerHost } from "./owner.ts";
|
|
|
|
const stored = fileURLToPath(new URL("./stored/", import.meta.url));
|
|
const directory = await mkdtemp(join(tmpdir(), "chord-schema-switch-"));
|
|
const path = join(directory, "store.db");
|
|
try {
|
|
const { store, host } = await ownerHost(path, EditsV1, "wait", context);
|
|
const owner = await host.get(Owner, {}, context);
|
|
for (const [id, body] of [
|
|
["a", "first note"],
|
|
["b", "second"],
|
|
["c", "third one"],
|
|
] as const) {
|
|
await owner.write({ id, body }, context);
|
|
}
|
|
await new Promise((resolve) => setTimeout(resolve, 200));
|
|
await mkdir(stored, { recursive: true });
|
|
await pipeline(encodeJsonl(store.export(context)), createWriteStream(join(stored, "archive.jsonl")));
|
|
// A clean close: the waiting runs are stored `stopped`, resumed by the next host.
|
|
await host.close(context);
|
|
await store.close(context);
|
|
await copyFile(path, join(stored, "store.db"));
|
|
console.log("written to", stored);
|
|
} finally {
|
|
await rm(directory, { recursive: true, force: true });
|
|
}
|