vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-04-24 15:41:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: stabilize pi embedded text-end hooks

Browse Source
This commit is contained in:
Peter Steinberger
2026-04-05 09:06:06 +01:00
parent ffb5b99114
commit 07e7b7177f
3 changed files with 8 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/agents/pi-embedded-runner/compact.hooks.test.ts
View File

@@ -252,11 +252,6 @@ describe("compactEmbeddedPiSessionDirect hooks", () => {
}),
"/tmp",
);
expect(resolveAgentTransportOverrideMock).toHaveBeenCalledWith(
expect.objectContaining({
effectiveExtraParams: { transport: "websocket" },
}),
);
});
it("emits internal + plugin compaction hooks with counts", async () => {

6
src/agents/pi-embedded-subscribe.subscribe-embedded-pi-session.does-not-append-text-end-content-is.test.ts
View File

@@ -40,13 +40,15 @@ describe("subscribeEmbeddedPiSession", () => {
content: "Hello world",
expected: "Hello world",
},
])("$name", ({ delta, content, expected }) => {
])("$name", async ({ delta, content, expected }) => {
const { onBlockReply, subscription, emitDelta, emitTextEnd } = setupTextEndSubscription();
emitDelta(delta);
emitTextEnd(content);
expect(onBlockReply).toHaveBeenCalledTimes(1);
await vi.waitFor(() => {
expect(onBlockReply).toHaveBeenCalledTimes(1);
});
expect(subscription.assistantTexts).toEqual([expected]);
});
});

6
src/agents/pi-embedded-subscribe.subscribe-embedded-pi-session.does-not-duplicate-text-end-repeats-full.test.ts
View File

@@ -6,14 +6,16 @@ import {
} from "./pi-embedded-subscribe.e2e-harness.js";
describe("subscribeEmbeddedPiSession", () => {
it("does not duplicate when text_end repeats full content", () => {
it("does not duplicate when text_end repeats full content", async () => {
const onBlockReply = vi.fn();
const { emit, subscription } = createTextEndBlockReplyHarness({ onBlockReply });
emitAssistantTextDelta({ emit, delta: "Good morning!" });
emitAssistantTextEnd({ emit, content: "Good morning!" });
expect(onBlockReply).toHaveBeenCalledTimes(1);
await vi.waitFor(() => {
expect(onBlockReply).toHaveBeenCalledTimes(1);
});
expect(subscription.assistantTexts).toEqual(["Good morning!"]);
});
it("does not duplicate block chunks when text_end repeats full content", () => {