vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-06 07:40:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: route session lifecycle test through fast lane

Browse Source
This commit is contained in:
Peter Steinberger
2026-04-28 08:52:20 +01:00
parent 2d575bc00e
commit c788aa025e
2 changed files with 32 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

48
src/sessions/session-lifecycle-events.test.ts
View File

@@ -1,9 +1,22 @@
import { describe, expect, it, vi } from "vitest";
import { describe, expect, it } from "vitest";
import { emitSessionLifecycleEvent, onSessionLifecycleEvent } from "./session-lifecycle-events.js";
function createListenerSpy(options: { throws?: boolean } = {}) {
const calls: unknown[][] = [];
return {
calls,
listener: (...args: unknown[]) => {
calls.push(args);
if (options.throws) {
throw new Error("boom");
}
},
};
}
describe("session lifecycle events", () => {
it("delivers events to active listeners and stops after unsubscribe", () => {
const listener = vi.fn();
const { calls, listener } = createListenerSpy();
const unsubscribe = onSessionLifecycleEvent(listener);
emitSessionLifecycleEvent({
@@ -11,28 +24,29 @@ describe("session lifecycle events", () => {
reason: "created",
label: "Main",
});
expect(listener).toHaveBeenCalledTimes(1);
expect(listener).toHaveBeenCalledWith({
sessionKey: "agent:main:main",
reason: "created",
label: "Main",
});
expect(calls).toEqual([
[
{
sessionKey: "agent:main:main",
reason: "created",
label: "Main",
},
],
]);
unsubscribe();
emitSessionLifecycleEvent({
sessionKey: "agent:main:main",
reason: "updated",
});
expect(listener).toHaveBeenCalledTimes(1);
expect(calls).toHaveLength(1);
});
it("keeps notifying other listeners when one throws", () => {
const noisy = vi.fn(() => {
throw new Error("boom");
});
const healthy = vi.fn();
const unsubscribeNoisy = onSessionLifecycleEvent(noisy);
const unsubscribeHealthy = onSessionLifecycleEvent(healthy);
const noisy = createListenerSpy({ throws: true });
const healthy = createListenerSpy();
const unsubscribeNoisy = onSessionLifecycleEvent(noisy.listener);
const unsubscribeHealthy = onSessionLifecycleEvent(healthy.listener);
expect(() =>
emitSessionLifecycleEvent({
@@ -41,8 +55,8 @@ describe("session lifecycle events", () => {
}),
).not.toThrow();
expect(noisy).toHaveBeenCalledTimes(1);
expect(healthy).toHaveBeenCalledTimes(1);
expect(noisy.calls).toHaveLength(1);
expect(healthy.calls).toHaveLength(1);
unsubscribeNoisy();
unsubscribeHealthy();

1
test/vitest-unit-fast-config.test.ts
View File

@@ -36,6 +36,7 @@ describe("unit-fast vitest lane", () => {
expect(config.test?.include).toContain("src/plugins/config-policy.test.ts");
expect(config.test?.include).toContain("src/proxy-capture/proxy-server.test.ts");
expect(config.test?.include).toContain("src/realtime-voice/agent-consult-tool.test.ts");
expect(config.test?.include).toContain("src/sessions/session-lifecycle-events.test.ts");
expect(config.test?.include).toContain("src/sessions/transcript-events.test.ts");
expect(config.test?.include).toContain(
"src/security/audit-channel-source-config-slack.test.ts",