puter/paseo
1
0
Fork 0
mirror of https://github.com/getpaseo/paseo.git synced 2026-10-14 13:22:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(server): retain deferred timeline flush diagnosis for #3542

Browse Source
This commit is contained in:
paseo-bot[bot]
2026-10-12 13:46:36 +02:00
parent acb3a8f207
commit 5f86772c07
1 changed files with 56 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/server/src/server/agent/agent-manager-stream-coalescing.test.ts
+56 -1
View File
@@ -5,6 +5,7 @@ import { afterEach, describe, expect, test, vi } from "vitest";
import { createTestLogger } from "../../test-utils/test-logger.js";
import { AgentManager, type AgentManagerEvent } from "./agent-manager.js";
import { AgentStorage } from "./agent-storage.js";
import { AGENT_STREAM_COALESCE_DEFAULT_WINDOW_MS } from "./agent-stream-coalescer.js";
import type { AgentTimelineRow } from "./agent-timeline-store-types.js";
import { projectTimelineRows } from "./timeline-projection.js";
@@ -243,11 +244,14 @@ interface Harness {
cleanup: () => void;
}
function createHarness(options?: { provider?: AgentProvider }): Harness {
function createHarness(options?: { provider?: AgentProvider; storage?: boolean }): Harness {
const workdir = mkdtempSync(join(tmpdir(), "agent-manager-stream-coalescing-"));
const client = new TestAgentClient(options?.provider ?? "codex");
const manager = new AgentManager({
clients: { [client.provider]: client },
registry: options?.storage
? new AgentStorage(join(workdir, "agents"), createTestLogger())
: undefined,
idFactory: createIdFactory(),
logger: createTestLogger(),
});
@@ -1419,3 +1423,54 @@ describe("target coalesced behavior", () => {
}
});
});
describe("issue 3542 deferred flush diagnosis", () => {
test.each(["close", "archive"] as const)(
"%s drains a trailing flush before tearing down agent state",
async (operation) => {
vi.useFakeTimers();
const harness = createHarness({ storage: true });
try {
const { agentId, session } = await createManagedSession(harness);
session.pushEvent(assistant("first"));
await waitForSessionEventQueue();
session.pushEvent(assistant("-pending"));
await waitForSessionEventQueue();
expect(getTimelineStreamEvents(harness.events, agentId)).toHaveLength(1);
if (operation === "close") await harness.manager.closeAgent(agentId);
else await harness.manager.archiveAgent(agentId);
expect(getTimelineStreamEvents(harness.events, agentId)).toHaveLength(2);
await vi.advanceTimersByTimeAsync(COALESCE_WINDOW_MS * 2);
expect(getTimelineStreamEvents(harness.events, agentId)).toHaveLength(2);
expect(harness.manager.getAgent(agentId)).toBeNull();
} finally {
await harness.manager.flush();
harness.cleanup();
}
},
);
test("deleting retained state with a live trailing flush does not throw", async () => {
vi.useFakeTimers();
const harness = createHarness();
try {
const { agentId, session } = await createManagedSession(harness);
session.pushEvent(assistant("first"));
await waitForSessionEventQueue();
session.pushEvent(assistant("-pending"));
await waitForSessionEventQueue();
expect(getTimelineStreamEvents(harness.events, agentId)).toHaveLength(1);
// Diagnostic adaptation: the report does not identify the operation that
// deleted its timeline. Direct deletion tests that condition, rather than
// claiming close or archive reaches it.
await harness.manager.deleteAgentState(agentId);
await vi.advanceTimersByTimeAsync(COALESCE_WINDOW_MS * 2);
} finally {
await harness.manager.closeAgent(AGENT_IDS[0]);
harness.cleanup();
}
});
});