@@ -304,6 +304,12 @@ function expectPersistedAcpTranscript(params: { userContent: string; assistantTe
|
304 | 304 | expect(transcript?.finalText).toBe(params.assistantText); |
305 | 305 | } |
306 | 306 | |
| 307 | +function firstRunTurnInput(runTurn: { mock: { calls: unknown[][] } }) { |
| 308 | +return runTurn.mock.calls[0]?.[0] as |
| 309 | +| { mode?: string; sessionKey?: string; text?: string } |
| 310 | +| undefined; |
| 311 | +} |
| 312 | + |
307 | 313 | async function runAcpSessionWithPolicyOverridesAndExpectBlocked(params: { |
308 | 314 | acpOverrides: Partial<NonNullable<OpenClawConfig["acp"]>>; |
309 | 315 | resolveSession?: Parameters<typeof mockAcpManager>[0]["resolveSession"]; |
@@ -360,9 +366,7 @@ describe("agentCommand ACP runtime routing", () => {
|
360 | 366 | message: " ping\n", |
361 | 367 | chunks: [" ACP_OK\n"], |
362 | 368 | }); |
363 | | -const runTurnInput = runTurn.mock.calls.at(0)?.[0] as |
364 | | -| { mode?: string; sessionKey?: string; text?: string } |
365 | | -| undefined; |
| 369 | +const runTurnInput = firstRunTurnInput(runTurn); |
366 | 370 | expect(runTurnInput?.sessionKey).toBe("agent:codex:acp:test"); |
367 | 371 | expect(runTurnInput?.text).toBe(" ping\n"); |
368 | 372 | expect(runTurnInput?.mode).toBe("prompt"); |
@@ -489,9 +493,7 @@ describe("agentCommand ACP runtime routing", () => {
|
489 | 493 | |
490 | 494 | await agentCommand({ message: "ping", sessionKey: "agent:kimi:acp:test" }, runtime); |
491 | 495 | |
492 | | -const runTurnInput = runTurn.mock.calls.at(0)?.[0] as |
493 | | -| { sessionKey?: string; text?: string } |
494 | | -| undefined; |
| 496 | +const runTurnInput = firstRunTurnInput(runTurn); |
495 | 497 | expect(runTurnInput?.sessionKey).toBe("agent:kimi:acp:test"); |
496 | 498 | expect(runTurnInput?.text).toBe("ping"); |
497 | 499 | expect(runEmbeddedPiAgentSpy).not.toHaveBeenCalled(); |
|
