test(agents): add payload builder fixture helper

src/agents/pi-embedded-runner/run/payloads.e2e.test.ts

@@ -41,16 +41,24 @@ describe("buildEmbeddedRunPayloads", () => {
     ...overrides,
   });
 
-  it("suppresses raw API error JSON when the assistant errored", () => {
+  type BuildPayloadParams = Parameters<typeof buildEmbeddedRunPayloads>[0];
-    const lastAssistant = makeAssistant({});
+  const buildPayloads = (overrides: Partial<BuildPayloadParams> = {}) =>
-    const payloads = buildEmbeddedRunPayloads({
+    buildEmbeddedRunPayloads({
-      assistantTexts: [errorJson],
+      assistantTexts: [],
       toolMetas: [],
-      lastAssistant,
+      lastAssistant: undefined,
       sessionKey: "session:telegram",
       inlineToolResultsAllowed: false,
       verboseLevel: "off",
       reasoningLevel: "off",
+      toolResultFormat: "plain",
+      ...overrides,
+    });
+
+  it("suppresses raw API error JSON when the assistant errored", () => {
+    const payloads = buildPayloads({
+      assistantTexts: [errorJson],
+      lastAssistant: makeAssistant({}),
     });
 
     expect(payloads).toHaveLength(1);
@@ -62,15 +70,11 @@ describe("buildEmbeddedRunPayloads", () => {
   });
 
   it("suppresses pretty-printed error JSON that differs from the errorMessage", () => {
-    const lastAssistant = makeAssistant({ errorMessage: errorJson });
+    const payloads = buildPayloads({
-    const payloads = buildEmbeddedRunPayloads({
       assistantTexts: [errorJsonPretty],
-      toolMetas: [],
+      lastAssistant: makeAssistant({ errorMessage: errorJson }),
-      lastAssistant,
-      sessionKey: "session:telegram",
       inlineToolResultsAllowed: true,
       verboseLevel: "on",
-      reasoningLevel: "off",
     });
 
     expect(payloads).toHaveLength(1);
@@ -81,15 +85,8 @@ describe("buildEmbeddedRunPayloads", () => {
   });
 
   it("suppresses raw error JSON from fallback assistant text", () => {
-    const lastAssistant = makeAssistant({ content: [{ type: "text", text: errorJsonPretty }] });
+    const payloads = buildPayloads({
-    const payloads = buildEmbeddedRunPayloads({
+      lastAssistant: makeAssistant({ content: [{ type: "text", text: errorJsonPretty }] }),
-      assistantTexts: [],
-      toolMetas: [],
-      lastAssistant,
-      sessionKey: "session:telegram",
-      inlineToolResultsAllowed: false,
-      verboseLevel: "off",
-      reasoningLevel: "off",
     });
 
     expect(payloads).toHaveLength(1);
@@ -100,19 +97,12 @@ describe("buildEmbeddedRunPayloads", () => {
   });
 
   it("includes provider context for billing errors", () => {
-    const lastAssistant = makeAssistant({
+    const payloads = buildPayloads({
-      errorMessage: "insufficient credits",
+      lastAssistant: makeAssistant({
-      content: [{ type: "text", text: "insufficient credits" }],
+        errorMessage: "insufficient credits",
-    });
+        content: [{ type: "text", text: "insufficient credits" }],
-    const payloads = buildEmbeddedRunPayloads({
+      }),
-      assistantTexts: [],
-      toolMetas: [],
-      lastAssistant,
-      sessionKey: "session:telegram",
       provider: "Anthropic",
-      inlineToolResultsAllowed: false,
-      verboseLevel: "off",
-      reasoningLevel: "off",
     });
 
     expect(payloads).toHaveLength(1);
@@ -121,15 +111,9 @@ describe("buildEmbeddedRunPayloads", () => {
   });
 
   it("suppresses raw error JSON even when errorMessage is missing", () => {
-    const lastAssistant = makeAssistant({ errorMessage: undefined });
+    const payloads = buildPayloads({
-    const payloads = buildEmbeddedRunPayloads({
       assistantTexts: [errorJsonPretty],
-      toolMetas: [],
+      lastAssistant: makeAssistant({ errorMessage: undefined }),
-      lastAssistant,
-      sessionKey: "session:telegram",
-      inlineToolResultsAllowed: false,
-      verboseLevel: "off",
-      reasoningLevel: "off",
     });
 
     expect(payloads).toHaveLength(1);
@@ -138,19 +122,13 @@ describe("buildEmbeddedRunPayloads", () => {
   });
 
   it("does not suppress error-shaped JSON when the assistant did not error", () => {
-    const lastAssistant = makeAssistant({
+    const payloads = buildPayloads({
-      stopReason: "stop",
-      errorMessage: undefined,
-      content: [],
-    });
-    const payloads = buildEmbeddedRunPayloads({
       assistantTexts: [errorJsonPretty],
-      toolMetas: [],
+      lastAssistant: makeAssistant({
-      lastAssistant,
+        stopReason: "stop",
-      sessionKey: "session:telegram",
+        errorMessage: undefined,
-      inlineToolResultsAllowed: false,
+        content: [],
-      verboseLevel: "off",
+      }),
-      reasoningLevel: "off",
     });
 
     expect(payloads).toHaveLength(1);
@@ -158,16 +136,8 @@ describe("buildEmbeddedRunPayloads", () => {
   });
 
   it("adds a fallback error when a tool fails and no assistant output exists", () => {
-    const payloads = buildEmbeddedRunPayloads({
+    const payloads = buildPayloads({
-      assistantTexts: [],
-      toolMetas: [],
-      lastAssistant: undefined,
       lastToolError: { toolName: "browser", error: "tab not found" },
-      sessionKey: "session:telegram",
-      inlineToolResultsAllowed: false,
-      verboseLevel: "off",
-      reasoningLevel: "off",
-      toolResultFormat: "plain",
     });
 
     expect(payloads).toHaveLength(1);
@@ -177,21 +147,14 @@ describe("buildEmbeddedRunPayloads", () => {
   });
 
   it("does not add tool error fallback when assistant output exists", () => {
-    const lastAssistant = makeAssistant({
+    const payloads = buildPayloads({
-      stopReason: "stop",
-      errorMessage: undefined,
-      content: [],
-    });
-    const payloads = buildEmbeddedRunPayloads({
       assistantTexts: ["All good"],
-      toolMetas: [],
+      lastAssistant: makeAssistant({
-      lastAssistant,
+        stopReason: "stop",
+        errorMessage: undefined,
+        content: [],
+      }),
       lastToolError: { toolName: "browser", error: "tab not found" },
-      sessionKey: "session:telegram",
-      inlineToolResultsAllowed: false,
-      verboseLevel: "off",
-      reasoningLevel: "off",
-      toolResultFormat: "plain",
     });
 
     expect(payloads).toHaveLength(1);
@@ -199,28 +162,20 @@ describe("buildEmbeddedRunPayloads", () => {
   });
 
   it("adds tool error fallback when the assistant only invoked tools", () => {
-    const lastAssistant = makeAssistant({
+    const payloads = buildPayloads({
-      stopReason: "toolUse",
+      lastAssistant: makeAssistant({
-      errorMessage: undefined,
+        stopReason: "toolUse",
-      content: [
+        errorMessage: undefined,
-        {
+        content: [
-          type: "toolCall",
+          {
-          id: "toolu_01",
+            type: "toolCall",
-          name: "exec",
+            id: "toolu_01",
-          arguments: { command: "echo hi" },
+            name: "exec",
-        },
+            arguments: { command: "echo hi" },
-      ],
+          },
-    });
+        ],
-    const payloads = buildEmbeddedRunPayloads({
+      }),
-      assistantTexts: [],
-      toolMetas: [],
-      lastAssistant,
       lastToolError: { toolName: "exec", error: "Command exited with code 1" },
-      sessionKey: "session:telegram",
-      inlineToolResultsAllowed: false,
-      verboseLevel: "off",
-      reasoningLevel: "off",
-      toolResultFormat: "plain",
     });
 
     expect(payloads).toHaveLength(1);
@@ -230,16 +185,8 @@ describe("buildEmbeddedRunPayloads", () => {
   });
 
   it("suppresses recoverable tool errors containing 'required' for non-mutating tools", () => {
-    const payloads = buildEmbeddedRunPayloads({
+    const payloads = buildPayloads({
-      assistantTexts: [],
-      toolMetas: [],
-      lastAssistant: undefined,
       lastToolError: { toolName: "browser", error: "url required" },
-      sessionKey: "session:telegram",
-      inlineToolResultsAllowed: false,
-      verboseLevel: "off",
-      reasoningLevel: "off",
-      toolResultFormat: "plain",
     });
 
     // Recoverable errors should not be sent to the user
@@ -247,66 +194,34 @@ describe("buildEmbeddedRunPayloads", () => {
   });
 
   it("suppresses recoverable tool errors containing 'missing' for non-mutating tools", () => {
-    const payloads = buildEmbeddedRunPayloads({
+    const payloads = buildPayloads({
-      assistantTexts: [],
-      toolMetas: [],
-      lastAssistant: undefined,
       lastToolError: { toolName: "browser", error: "url missing" },
-      sessionKey: "session:telegram",
-      inlineToolResultsAllowed: false,
-      verboseLevel: "off",
-      reasoningLevel: "off",
-      toolResultFormat: "plain",
     });
 
     expect(payloads).toHaveLength(0);
   });
 
   it("suppresses recoverable tool errors containing 'invalid' for non-mutating tools", () => {
-    const payloads = buildEmbeddedRunPayloads({
+    const payloads = buildPayloads({
-      assistantTexts: [],
-      toolMetas: [],
-      lastAssistant: undefined,
       lastToolError: { toolName: "browser", error: "invalid parameter: url" },
-      sessionKey: "session:telegram",
-      inlineToolResultsAllowed: false,
-      verboseLevel: "off",
-      reasoningLevel: "off",
-      toolResultFormat: "plain",
     });
 
     expect(payloads).toHaveLength(0);
   });
 
   it("suppresses non-mutating non-recoverable tool errors when messages.suppressToolErrors is enabled", () => {
-    const payloads = buildEmbeddedRunPayloads({
+    const payloads = buildPayloads({
-      assistantTexts: [],
-      toolMetas: [],
-      lastAssistant: undefined,
       lastToolError: { toolName: "browser", error: "connection timeout" },
       config: { messages: { suppressToolErrors: true } },
-      sessionKey: "session:telegram",
-      inlineToolResultsAllowed: false,
-      verboseLevel: "off",
-      reasoningLevel: "off",
-      toolResultFormat: "plain",
     });
 
     expect(payloads).toHaveLength(0);
   });
 
   it("still shows mutating tool errors when messages.suppressToolErrors is enabled", () => {
-    const payloads = buildEmbeddedRunPayloads({
+    const payloads = buildPayloads({
-      assistantTexts: [],
-      toolMetas: [],
-      lastAssistant: undefined,
       lastToolError: { toolName: "write", error: "connection timeout" },
       config: { messages: { suppressToolErrors: true } },
-      sessionKey: "session:telegram",
-      inlineToolResultsAllowed: false,
-      verboseLevel: "off",
-      reasoningLevel: "off",
-      toolResultFormat: "plain",
     });
 
     expect(payloads).toHaveLength(1);
@@ -315,16 +230,8 @@ describe("buildEmbeddedRunPayloads", () => {
   });
 
   it("shows recoverable tool errors for mutating tools", () => {
-    const payloads = buildEmbeddedRunPayloads({
+    const payloads = buildPayloads({
-      assistantTexts: [],
-      toolMetas: [],
-      lastAssistant: undefined,
       lastToolError: { toolName: "message", meta: "reply", error: "text required" },
-      sessionKey: "session:telegram",
-      inlineToolResultsAllowed: false,
-      verboseLevel: "off",
-      reasoningLevel: "off",
-      toolResultFormat: "plain",
     });
 
     expect(payloads).toHaveLength(1);
@@ -333,16 +240,10 @@ describe("buildEmbeddedRunPayloads", () => {
   });
 
   it("shows mutating tool errors even when assistant output exists", () => {
-    const payloads = buildEmbeddedRunPayloads({
+    const payloads = buildPayloads({
       assistantTexts: ["Done."],
-      toolMetas: [],
       lastAssistant: { stopReason: "end_turn" } as AssistantMessage,
       lastToolError: { toolName: "write", error: "file missing" },
-      sessionKey: "session:telegram",
-      inlineToolResultsAllowed: false,
-      verboseLevel: "off",
-      reasoningLevel: "off",
-      toolResultFormat: "plain",
     });
 
     expect(payloads).toHaveLength(2);
@@ -352,20 +253,14 @@ describe("buildEmbeddedRunPayloads", () => {
   });
 
   it("does not treat session_status read failures as mutating when explicitly flagged", () => {
-    const payloads = buildEmbeddedRunPayloads({
+    const payloads = buildPayloads({
       assistantTexts: ["Status loaded."],
-      toolMetas: [],
       lastAssistant: { stopReason: "end_turn" } as AssistantMessage,
       lastToolError: {
         toolName: "session_status",
         error: "model required",
         mutatingAction: false,
       },
-      sessionKey: "session:telegram",
-      inlineToolResultsAllowed: false,
-      verboseLevel: "off",
-      reasoningLevel: "off",
-      toolResultFormat: "plain",
     });
 
     expect(payloads).toHaveLength(1);
@@ -373,38 +268,24 @@ describe("buildEmbeddedRunPayloads", () => {
   });
 
   it("dedupes identical tool warning text already present in assistant output", () => {
-    const seed = buildEmbeddedRunPayloads({
+    const seed = buildPayloads({
-      assistantTexts: [],
-      toolMetas: [],
-      lastAssistant: undefined,
       lastToolError: {
         toolName: "write",
         error: "file missing",
         mutatingAction: true,
       },
-      sessionKey: "session:telegram",
-      inlineToolResultsAllowed: false,
-      verboseLevel: "off",
-      reasoningLevel: "off",
-      toolResultFormat: "plain",
     });
     const warningText = seed[0]?.text;
     expect(warningText).toBeTruthy();
 
-    const payloads = buildEmbeddedRunPayloads({
+    const payloads = buildPayloads({
       assistantTexts: [warningText ?? ""],
-      toolMetas: [],
       lastAssistant: { stopReason: "end_turn" } as AssistantMessage,
       lastToolError: {
         toolName: "write",
         error: "file missing",
         mutatingAction: true,
       },
-      sessionKey: "session:telegram",
-      inlineToolResultsAllowed: false,
-      verboseLevel: "off",
-      reasoningLevel: "off",
-      toolResultFormat: "plain",
     });
 
     expect(payloads).toHaveLength(1);
@@ -412,16 +293,8 @@ describe("buildEmbeddedRunPayloads", () => {
   });
 
   it("shows non-recoverable tool errors to the user", () => {
-    const payloads = buildEmbeddedRunPayloads({
+    const payloads = buildPayloads({
-      assistantTexts: [],
-      toolMetas: [],
-      lastAssistant: undefined,
       lastToolError: { toolName: "browser", error: "connection timeout" },
-      sessionKey: "session:telegram",
-      inlineToolResultsAllowed: false,
-      verboseLevel: "off",
-      reasoningLevel: "off",
-      toolResultFormat: "plain",
     });
 
     // Non-recoverable errors should still be shown