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

test: share anthropic cache payload fixture

Browse Source
This commit is contained in:
Peter Steinberger
2026-04-19 04:12:37 +01:00
parent f5c49758fc
commit ab4eb5aa94
1 changed files with 32 additions and 78 deletions
Download Patch File Download Diff File Expand all files Collapse all files

110
src/agents/anthropic-vertex-stream.test.ts
View File

@@ -90,6 +90,34 @@ function captureCacheBoundaryPayloadHook(onPayload: PayloadHook) {
return { model, onPayload: transportOptions.onPayload };
}
function buildExpectedCacheBoundaryPayload(messageText: string) {
return {
system: [
{
type: "text",
text: "Stable prefix",
cache_control: { type: "ephemeral" },
},
{
type: "text",
text: "Dynamic suffix",
},
],
messages: [
{
role: "user",
content: [
{
type: "text",
text: messageText,
cache_control: { type: "ephemeral" },
},
],
},
],
};
}
describe("createAnthropicVertexStreamFn", () => {
beforeAll(async () => {
({ createAnthropicVertexStreamFn, createAnthropicVertexStreamFnForModel } =
@@ -205,59 +233,9 @@ describe("createAnthropicVertexStreamFn", () => {
const nextPayload = await transportPayloadHook?.(payload, model);
expect(onPayload).toHaveBeenCalledWith(
{
system: [
{
type: "text",
text: "Stable prefix",
cache_control: { type: "ephemeral" },
},
{
type: "text",
text: "Dynamic suffix",
},
],
messages: [
{
role: "user",
content: [
{
type: "text",
text: "Hello",
cache_control: { type: "ephemeral" },
},
],
},
],
},
model,
);
expect(nextPayload).toEqual({
system: [
{
type: "text",
text: "Stable prefix",
cache_control: { type: "ephemeral" },
},
{
type: "text",
text: "Dynamic suffix",
},
],
messages: [
{
role: "user",
content: [
{
type: "text",
text: "Hello",
cache_control: { type: "ephemeral" },
},
],
},
],
});
const expectedPayload = buildExpectedCacheBoundaryPayload("Hello");
expect(onPayload).toHaveBeenCalledWith(expectedPayload, model);
expect(nextPayload).toEqual(expectedPayload);
});
it("reapplies Anthropic cache-boundary shaping when payload hooks return a fresh payload", async () => {
@@ -285,31 +263,7 @@ describe("createAnthropicVertexStreamFn", () => {
model,
);
expect(nextPayload).toEqual({
system: [
{
type: "text",
text: "Stable prefix",
cache_control: { type: "ephemeral" },
},
{
type: "text",
text: "Dynamic suffix",
},
],
messages: [
{
role: "user",
content: [
{
type: "text",
text: "Hello again",
cache_control: { type: "ephemeral" },
},
],
},
],
});
expect(nextPayload).toEqual(buildExpectedCacheBoundaryPayload("Hello again"));
});
it("omits maxTokens when neither the model nor request provide a finite limit", () => {