@@ -15,7 +15,6 @@ import {
1515createSessionEntryWithTranscript,
1616listSessionEntries,
1717loadSessionEntry,
18-loadTranscriptEvents,
1918patchSessionEntry,
2019persistSessionResetLifecycle,
2120persistSessionRolloverLifecycle,
@@ -709,7 +708,7 @@ describe("session accessor file-backed seam", () => {
709708expect(fs.existsSync(result.previousSessionTranscript.sessionFile ?? "")).toBe(true);
710709});
711710712-it("loads and appends transcript events through a session scope", async () => {
711+it("appends transcript events through a session scope", async () => {
713712const scope = {
714713sessionFile: transcriptPath,
715714sessionId: "session-1",
@@ -724,10 +723,6 @@ describe("session accessor file-backed seam", () => {
724723await appendTranscriptEvent(scope, { type: "session", sessionId: "session-1" });
725724await appendTranscriptEvent(scope, event);
726725727-await expect(loadTranscriptEvents(scope)).resolves.toEqual([
728-{ type: "session", sessionId: "session-1" },
729-event,
730-]);
731726expect(fs.statSync(transcriptPath).mode & 0o777).toBe(0o600);
732727});
733728@@ -890,7 +885,6 @@ describe("session accessor file-backed seam", () => {
890885891886await appendTranscriptEvent(scope, event);
892887893-await expect(loadTranscriptEvents(scope)).resolves.toEqual([event]);
894888// Explicit-artifact writes never touch entry metadata: no entry appears.
895889expect(listSessionEntries({ storePath })).toEqual([]);
896890});
@@ -1353,44 +1347,6 @@ describe("session accessor file-backed seam", () => {
13531347expect(fs.existsSync(transcriptPath)).toBe(false);
13541348});
135513491356-it("loads transcript events without a session key when the read target is explicit", async () => {
1357-const scope = {
1358-sessionFile: transcriptPath,
1359-sessionId: "session-1",
1360-};
1361-const event = {
1362-payload: { value: "hello" },
1363-type: "metadata",
1364-};
1365-1366-await appendTranscriptEvent(
1367-{
1368- ...scope,
1369-sessionKey: "agent:main:main",
1370- storePath,
1371-},
1372-event,
1373-);
1374-1375-await expect(loadTranscriptEvents(scope)).resolves.toEqual([event]);
1376-});
1377-1378-it("loads transcript events from a generated read target without a session key", async () => {
1379-const event = {
1380-payload: { value: "hello" },
1381-type: "metadata",
1382-};
1383-1384-fs.writeFileSync(path.join(tempDir, "session-1.jsonl"), `${JSON.stringify(event)}\n`, "utf-8");
1385-1386-await expect(
1387-loadTranscriptEvents({
1388-sessionId: "session-1",
1389- storePath,
1390-}),
1391-).resolves.toEqual([event]);
1392-});
1393-13941350it("appends messages and publishes updates through a session scope", async () => {
13951351const scope = {
13961352agentId: "main",
@@ -1438,17 +1394,6 @@ describe("session accessor file-backed seam", () => {
14381394idempotencyKey: "assistant-once",
14391395}),
14401396});
1441-await expect(loadTranscriptEvents(scope)).resolves.toEqual([
1442-expect.objectContaining({ type: "session" }),
1443-expect.objectContaining({
1444-id: appended.messageId,
1445-message: expect.objectContaining({
1446-content: "hello",
1447-idempotencyKey: "assistant-once",
1448-}),
1449-type: "message",
1450-}),
1451-]);
14521397expect(updates).toEqual([
14531398{
14541399agentId: "main",
@@ -1516,22 +1461,6 @@ describe("session accessor file-backed seam", () => {
15161461updatedAt: expect.any(Number),
15171462});
15181463expect(loadSessionEntry(scope)?.updatedAt).toBeGreaterThanOrEqual(10);
1519-const events = await loadTranscriptEvents({ ...scope, sessionFile: result.sessionFile });
1520-expect(events).toEqual([
1521-expect.objectContaining({ type: "session" }),
1522-expect.objectContaining({
1523-id: result.messages[0]?.messageId,
1524-message: expect.objectContaining({ role: "user", content: "hello" }),
1525-parentId: null,
1526-type: "message",
1527-}),
1528-expect.objectContaining({
1529-id: result.messages[1]?.messageId,
1530-message: expect.objectContaining({ role: "assistant", content: "hi there" }),
1531-parentId: result.messages[0]?.messageId,
1532-type: "message",
1533-}),
1534-]);
15351464expect(updates).toEqual([
15361465{
15371466lineCount: 3,
@@ -1600,19 +1529,7 @@ describe("session accessor file-backed seam", () => {
16001529}),
16011530]);
16021531expect(completed).toBe(true);
1603-const [turnResult] = await results;
1604-1605-const events = await loadTranscriptEvents({ ...scope, sessionFile: turnResult.sessionFile });
1606-expect(
1607-events
1608-.filter(
1609-(event): event is { message?: { content?: unknown }; type?: unknown } =>
1610-typeof event === "object" &&
1611-event !== null &&
1612-(event as { type?: unknown }).type === "message",
1613-)
1614-.map((event) => event.message?.content),
1615-).toEqual(["batch reply", "queued prompt"]);
1532+await results;
16161533});
1617153416181535it("rejects expected-session transcript turns after a queued session rebind", async () => {
@@ -1726,13 +1643,6 @@ describe("session accessor file-backed seam", () => {
17261643expect.objectContaining({ kind: "header" }),
17271644expect.objectContaining({ kind: "id" }),
17281645]);
1729-await expect(loadTranscriptEvents(scope)).resolves.toEqual([
1730-expect.objectContaining({ type: "session" }),
1731-expect.objectContaining({
1732-message: expect.objectContaining({ content: "owned batch" }),
1733-type: "message",
1734-}),
1735-]);
17361646});
1737164717381648it("honors thread fallback paths when resolving transcript scope from the store", async () => {
@@ -1759,7 +1669,6 @@ describe("session accessor file-backed seam", () => {
17591669expect(fs.realpathSync(loadSessionEntry(scope)?.sessionFile ?? "")).toBe(
17601670fs.realpathSync(expectedTranscriptPath),
17611671);
1762-await expect(loadTranscriptEvents(scope)).resolves.toEqual([event]);
17631672});
1764167317651674it("resolves runtime transcript targets from scope without caller-owned paths", async () => {
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。