c0d30e8081
tests/fixtures/idunn-runtime holds expected.cc, activation.cc, the activation seed, the presence identity credential and the machine-id it is bound to, copied from CultLib 217a9480 (Rust-written; test keys only). fake-idunn-rudp.ts is the accept server idunn-rudp-health.test.ts built inline, now keeping a session per remote and every delivered frame, so a boot test can receive several pulses. Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
66 lines
2.8 KiB
TypeScript
66 lines
2.8 KiB
TypeScript
import { mkdtemp } from "node:fs/promises";
|
|
import os from "node:os";
|
|
import path from "node:path";
|
|
import { decode } from "@msgpack/msgpack";
|
|
import { parseCultNetMessage } from "cultnet-ts";
|
|
import { describe, expect, it, vi } from "vitest";
|
|
import { loadConfig } from "../src/config.js";
|
|
import { publishIdunnRudpHealth } from "../src/idunn-rudp-health.js";
|
|
import { startFakeIdunnRudp } from "./fixtures/fake-idunn-rudp.js";
|
|
|
|
vi.mock("node:fs/promises", async (importOriginal) => {
|
|
const original = await importOriginal<typeof import("node:fs/promises")>();
|
|
return {
|
|
...original,
|
|
readFile: async (file: Parameters<typeof original.readFile>[0], ...args: unknown[]) => {
|
|
if (file === "/etc/machine-id") return "heimdall-rudp-test-machine\n";
|
|
return (original.readFile as (...values: unknown[]) => Promise<unknown>)(file, ...args);
|
|
},
|
|
};
|
|
});
|
|
|
|
describe("Heimdall Idunn health publication", () => {
|
|
it("completes the canonical RUDP handshake before publishing its signed frame", async () => {
|
|
const server = await startFakeIdunnRudp();
|
|
|
|
try {
|
|
const tmp = await mkdtemp(path.join(os.tmpdir(), "heimdall-idunn-rudp-"));
|
|
const config = loadConfig({
|
|
GC_ACCESS_IDUNN_RUDP_HEALTH: `127.0.0.1:${server.port}`,
|
|
GC_ACCESS_PROVIDER_HEALTH_IDENTITY_PATH: path.join(tmp, "provider-health-identity.cc"),
|
|
});
|
|
const observedAt = "2026-08-22T00:45:00.000Z";
|
|
|
|
// The transport is handed an already-signed statement; building one is
|
|
// the presence module's job and is covered against the Rust vectors in
|
|
// cultnet-ts. What this asserts is that the envelope keys the document by
|
|
// the signed target, which is the pairing Odin refuses when it differs.
|
|
const presence = {
|
|
target: "heimdall",
|
|
payload: new Uint8Array([0x01, 0x02, 0x03]),
|
|
};
|
|
|
|
await publishIdunnRudpHealth(config, {
|
|
daemonId: "yggdrasil-heimdall",
|
|
state: "active",
|
|
detail: "private-command-plane-ready",
|
|
observedAt,
|
|
presence,
|
|
});
|
|
const frame = await server.frame(0);
|
|
const message = parseCultNetMessage(decode(frame.payload), "cultnet.schema.v0");
|
|
|
|
expect(frame.channelId).toBe("schema");
|
|
expect(message.schemaVersion).toBe("cultnet.document_put_raw.v0");
|
|
if (message.schemaVersion !== "cultnet.document_put_raw.v0") {
|
|
throw new Error("Expected raw document publication.");
|
|
}
|
|
expect(message.document.schemaId).toBe("gamecult.runtime_presence_health.v2");
|
|
expect(message.document.recordKey).toBe(presence.target);
|
|
expect(message.document.sourceRole).toBe("runtime-presence-publisher");
|
|
expect(Buffer.from(message.document.payload)).toEqual(Buffer.from(presence.payload));
|
|
} finally {
|
|
server.close();
|
|
}
|
|
});
|
|
});
|