diff --git a/.aiwg/reports/g-icm-01-interface-inventory.json b/.aiwg/reports/g-icm-01-interface-inventory.json index 4a2322d6f..306d3e788 100644 --- a/.aiwg/reports/g-icm-01-interface-inventory.json +++ b/.aiwg/reports/g-icm-01-interface-inventory.json @@ -3,9 +3,9 @@ "control_id": "G-ICM-01", "project_id": "github.com/chronodeai/agentmemory", "source_identity": { - "commit_sha": "facabd34882d1e66a5ec3d4821eecde235fed1b1", - "commit_tree_sha": "b58a99a88f05e094b42be7c52e72784d87cc4e6d", - "inventory_input_sha256": "2e776824dd49040af5451aab80bbbe2e2f0dcab5aab982653711558baa74625b" + "commit_sha": "260beb4a954eca7a71019b89f8e09df8c65c10bb", + "commit_tree_sha": "1b692f290d11ae470cb2009156266d6de039ebe7", + "inventory_input_sha256": "8091d93e47a45cd4cb2d4c38cab6448af9186743c84d73406ed2ea2a269fc51e" }, "public_route_allowlist": [ "GET /agentmemory/livez" diff --git a/ci/r13-test-manifest.json b/ci/r13-test-manifest.json index 13e5b68b8..9618f7fb6 100644 --- a/ci/r13-test-manifest.json +++ b/ci/r13-test-manifest.json @@ -1,5 +1,5 @@ { "count": 180, "sha256": "e8489acf3396ad149ca9342214e4865124021fd1e05d37ff548e63dcf2f6a242", - "content_sha256": "43402e473a95ebcfa5a7a27c1a7cf0f0a056ffdd9b95ed6fd5f8ade4ddcc2b10" + "content_sha256": "480974ca30f7632c133fd0fcd7aff9bb03b99c04783d7f86a005134fb4b5e87e" } diff --git a/src/state/live-stream-rotation.ts b/src/state/live-stream-rotation.ts index 233a3e8c7..03b415735 100644 --- a/src/state/live-stream-rotation.ts +++ b/src/state/live-stream-rotation.ts @@ -21,8 +21,11 @@ export function resolveLiveStreamMaxBytes( } export function viewerLiveStreamPath(dataDir: string = resolveDataDir()): string { + // The stream store lives under /data/stream_store — the same + // layout iii-runtime-config materializes and health resources inventory. return join( dataDir, + "data", "stream_store", `stream%3A${STREAM.name}%3A${STREAM.viewerGroup}.bin`, ); diff --git a/test/live-stream-rotation.test.ts b/test/live-stream-rotation.test.ts index fad96c781..7e2551926 100644 --- a/test/live-stream-rotation.test.ts +++ b/test/live-stream-rotation.test.ts @@ -63,14 +63,16 @@ describe("resolveLiveStreamMaxBytes", () => { }); describe("viewerLiveStreamPath", () => { - it("mirrors the iii-stream file-backed adapter layout", () => { - expect(viewerLiveStreamPath("/data")).toBe(join("/data", "stream_store", VIEWER_STREAM_NAME)); + it("mirrors the iii-stream file-backed adapter layout under /data", () => { + expect(viewerLiveStreamPath("/root")).toBe( + join("/root", "data", "stream_store", VIEWER_STREAM_NAME), + ); }); }); describe("rotateLiveStreamIfOversized", () => { function seedStream(dataDir: string, bytes: number): string { - const store = join(dataDir, "stream_store"); + const store = join(dataDir, "data", "stream_store"); mkdirSync(store, { recursive: true }); const filePath = join(store, VIEWER_STREAM_NAME); writeFileSync(filePath, Buffer.alloc(bytes, 0x61));