App catalog

rg --version | head -1
rg -n --color never nano notes.txt

const events = [];
const m = await nano.installApp("hexyl", { onProgress: (e) => events.push(e) });
for (const e of events) print(e.phase, e.file ?? "", e.total != null ? `${e.fetched}/${e.total}` : "");
print(m.name, m.version, m.files.map((f) => `${f.path} ${f.mode}`).join(", "));

const phases = [];
await nano.installApp("fd", { lazy: true, onProgress: (e) => phases.push(e.phase) });
print("install phases:", phases.join(" → "));
print((await nano.shExec("fd --version")).stdout.trim());

const r = await nano.installBundle("math");
print(r.topic, "→", r.installed.map((m) => `${m.name}@${m.version}`).join(" "), "| failed:", JSON.stringify(r.failed));
print((await nano.shExec("numbat --version", { maxSteps: 1e10 })).stdout.trim());

const cat = nano.catalog();
const idx = await cat.index();
print("generation", idx.generation, "|", Object.keys(idx.apps).length, "app versions");
print("categories:", Object.keys(await cat.categories()).join(", "));
const cols = await cat.collections();
for (const [slug, col] of Object.entries(cols)) print("collection", slug, "→", col.members.join(" "));
const m = await cat.manifest("ripgrep");
print(m.name, m.version, m.abi, "|", m.files.map((f) => `${f.path} ${f.mode} ${f.size} bytes in ${f.chunks.length} chunks`).join(", "));

const seen = [];
const cat = new sdk.Catalog({ cdn: { fetchFn: (url, init) => (seen.push(String(url).replace(/[0-9a-f]{64}/, "<sha256>")), fetch(url, init)) } });
await cat.manifest("hexyl");
print(seen.join("\n"));

const gen = (await nano.catalog().index()).generation;
const mirror = (url, init) => fetch(String(url)
  .replace("https://mirror.example/catalog/index.json", `https://cdn.jsdelivr.net/npm/@userland-run/nano-catalog@0.0.${gen}/index.json`)
  .replace("https://mirror.example/catalog/cas/", `https://cdn.jsdelivr.net/npm/@userland-run/nano-cas@0.0.${gen}/cas/`), init);
const cdn = { baseUrl: "https://mirror.example/catalog", fetchFn: mirror };
const store = new Map();
const generations = { get: (scope) => store.get(scope) ?? null, set: (scope, g) => void store.set(scope, g) };
const cat = new sdk.Catalog({ cdn, generations });
print("mirror index generation:", (await cat.index()).generation === gen);
print("rg via mirror:", (await cat.manifest("ripgrep")).name);
for (const scope of store.keys()) store.set(scope, gen + 1); // pretend we saw a newer one
print(await new sdk.Catalog({ cdn, generations }).index().then(() => "accepted", (e) => e.message.replace(/\d+/g, "N")));

const mem = new Map();
const stats = { get: 0, put: 0 };
const cache = { async get(k) { stats.get++; return mem.get(k) ?? null; }, async put(k, v) { stats.put++; mem.set(k, v); } };
const cat = new sdk.Catalog({ cache });
await cat.install(nano.fs, "hexyl");
await cat.install(nano.fs, "hexyl");
print("cache gets:", stats.get, "puts:", stats.put);
print("bundled key:", sdk.CATALOG_PUBLIC_KEY_B64.length, "chars of base64");
const otherKey = btoa(String.fromCharCode(...new Uint8Array(32).fill(7)));
print(await new sdk.Catalog({ publicKeyB64: otherKey }).index().then(() => "accepted", (e) => e.message));

const m = await nano.catalog().manifest("ripgrep");
print("ripgrep:", sdk.manifestKind(m), "→", sdk.manifestTier(m));
for (const k of ["wasm-app", "wasm-service", "node-app", "boa-app"]) print(k, "→", sdk.kindToTier(k), "| wasm kind:", sdk.isWasmKind(k));

const bytes = new Uint8Array(await (await fetch("/nano/photon.wasm")).arrayBuffer());
const unregister = await nano.registerWasmApp("photon", bytes);
nano.fs.writeFile("/work/in.jpg", new Uint8Array(await (await fetch("/demo-files/photon/sample.jpg")).arrayBuffer()));
const r = await nano.execWasmApp(["photon", "in.jpg", "out.png", "--filter", "invert"], { cwd: "/work" });
print(JSON.stringify({ exitCode: r.exitCode, stdout: r.stdout, stderr: r.stderr }), "| out.png:", nano.fs.readFile("/work/out.png").length > 0);
const sh = await nano.shExec("cd /work && photon in.jpg g.png --filter grayscale > log.txt; echo rc=$?; cat log.txt");
print("shell:", sh.stdout.trim().split("\n").join(" / "));
const slow = await nano.execWasmApp(["photon", "in.jpg", "b.png", "--filter", "blur"], { cwd: "/work", timeoutMs: 1 });
print("timeout exit code:", slow.exitCode);
unregister();
print("after unregister:", (await nano.execWasmApp(["photon"])).stderr.trim());

photon in.jpg sepia.png --filter sepia
photon in.jpg bright.png --filter brighten --strength 40