test(e2e-mock): address PR review — injection-guard all parent fixtures, link fixture format contract

- Regular parent turn-1 fixture: exclude resume turns via
  SUBTASK_RESULT_INJECTION instead of relying on registration order
  (sequenceIndex is not viable here — the fixture is shared by 4 tests)
- Fast and api-hang parent-resume guards: match SUBTASK_RESULT_INJECTION
  instead of the child result text, which is embedded verbatim in the
  parent prompts and could match the parent's initial request on retry
- Add unit-test assertion pinning reopenParentFromDelegation's injected
  tool_result format to the 'completed.\n\nResult:' contract the e2e
  fixtures match on
- lastUserMessageContains: mirror aimock's getTextContent (text parts
  only) instead of JSON.stringify for non-string content
- Extract SUBTASK_FAST_CHILD_RESULT constant
- Replace tautological find()/assert pairs in the api-hang test
- Move the no-parent-resume assertion in the cancellation test behind
  the async settle gates and also assert no completion_result

Author: roomote

apps/vscode-e2e/src/fixtures/subtasks.ts

@@ -18,7 +18,8 @@ const SUBTASK_XPROFILE_DIFFERENT_CHILD_MARKER = "SUBTASK_CHILD_DIFFERENT_PROFILE
 const SUBTASK_CHILD_PROMPT = `${SUBTASK_CHILD_MARKER}: Ask the user exactly this follow-up question: What is the square root of 81? After the user answers, complete with only the answer.`
 export const SUBTASK_PARENT_PROMPT = `${SUBTASK_PARENT_MARKER}: Use the new_task tool exactly once. Create an ask-mode subtask with this exact message: "${SUBTASK_CHILD_PROMPT}" Do not answer directly.`
 export const SUBTASK_CHILD_FOLLOWUP_ANSWER = "9"
-const SUBTASK_FAST_CHILD_PROMPT = `${SUBTASK_FAST_CHILD_MARKER}: Complete immediately with the exact result "Fast child completed".`
+export const SUBTASK_FAST_CHILD_RESULT = "Fast child completed"
+const SUBTASK_FAST_CHILD_PROMPT = `${SUBTASK_FAST_CHILD_MARKER}: Complete immediately with the exact result "${SUBTASK_FAST_CHILD_RESULT}".`
 export const SUBTASK_FAST_PARENT_PROMPT = `${SUBTASK_FAST_PARENT_MARKER}: Use the new_task tool exactly once. Create an ask-mode subtask with this exact message: "${SUBTASK_FAST_CHILD_PROMPT}" Do not answer directly.`
 
 const SUBTASK_INTERRUPT_CHILD_PROMPT = `${SUBTASK_INTERRUPT_CHILD_MARKER}: Ask the user exactly this follow-up question: What is the square root of 81? After the user answers, complete with only the answer.`
@@ -54,14 +55,21 @@ const requestContains = (req: ChatCompletionRequest, expected: string[]) => {
 	return expected.every((text) => rawRequest.includes(text))
 }
 
-// aimock's `userMessage` matcher only inspects the LAST user message. Fixtures that need
+// aimock's `userMessage` matcher only inspects the LAST user message and joins only the
+// `type: "text"` content parts (see getTextContent in aimock's router). Fixtures that need
 // whole-request exclusions must replicate that scoping inside a predicate so they keep the
 // same matching semantics as the bare-regex fixtures they replace.
 const lastUserMessageContains = (req: ChatCompletionRequest, text: string) => {
 	const userMessages = req.messages?.filter((message) => message.role === "user") ?? []
 	const last = userMessages.at(-1)
 	if (!last) return false
-	const content = typeof last.content === "string" ? last.content : JSON.stringify(last.content ?? "")
+	const content =
+		typeof last.content === "string"
+			? last.content
+			: (last.content ?? [])
+					.filter((part): part is { type: "text"; text: string } => part?.type === "text")
+					.map((part) => part.text)
+					.join("")
 	return content.includes(text)
 }
 
@@ -72,7 +80,6 @@ const lastUserMessageContains = (req: ChatCompletionRequest, text: string) => {
 // tool-call id directly proved flaky (the id can be rewritten, the fixture then misses, and
 // a looser child fixture wins and serves the child's response to the parent).
 const SUBTASK_RESULT_INJECTION = "completed.\\n\\nResult:"
-
 const completionAfterAnswer = (followupId: string, completionId: string) => ({
 	match: {
 		predicate: (req: ChatCompletionRequest) =>
@@ -132,17 +139,20 @@ export function addSubtaskFixtures(mock: InstanceType<typeof LLMock>) {
 			toolCalls: [
 				{
 					name: "attempt_completion",
-					arguments: JSON.stringify({ result: "Fast child completed" }),
+					arguments: JSON.stringify({ result: SUBTASK_FAST_CHILD_RESULT }),
 					id: "call_subtasks_fast_child_completion_002",
 				},
 			],
 		},
 	})
 
+	// Guard on SUBTASK_RESULT_INJECTION (not the child result text): the child result is
+	// embedded verbatim in SUBTASK_FAST_PARENT_PROMPT, so it cannot distinguish the parent's
+	// initial request from its resume turn.
 	mock.addFixture({
 		match: {
 			predicate: (req: ChatCompletionRequest) =>
-				requestContains(req, [SUBTASK_FAST_PARENT_MARKER, "Fast child completed"]),
+				requestContains(req, [SUBTASK_FAST_PARENT_MARKER, SUBTASK_RESULT_INJECTION]),
 		},
 		response: {
 			toolCalls: [
@@ -155,9 +165,15 @@ export function addSubtaskFixtures(mock: InstanceType<typeof LLMock>) {
 		},
 	})
 
+	// This fixture is shared by several tests, so sequenceIndex cannot guard it. Exclude
+	// resume turns via the injected tool_result prefix instead: when the tool_result is
+	// serialized as role:"tool", the original parent prompt is the last user message again
+	// and would otherwise re-serve new_task on the parent's resume turn.
 	mock.addFixture({
 		match: {
-			userMessage: new RegExp(SUBTASK_PARENT_MARKER),
+			predicate: (req: ChatCompletionRequest) =>
+				lastUserMessageContains(req, SUBTASK_PARENT_MARKER) &&
+				!requestContains(req, [SUBTASK_RESULT_INJECTION]),
 		},
 		response: {
 			toolCalls: [
@@ -265,10 +281,12 @@ export function addSubtaskFixtures(mock: InstanceType<typeof LLMock>) {
 		},
 	})
 
+	// Same as the fast parent-resume fixture: the child result is embedded verbatim in
+	// SUBTASK_API_HANG_PARENT_PROMPT, so guard on the injected tool_result prefix instead.
 	mock.addFixture({
 		match: {
 			predicate: (req: ChatCompletionRequest) =>
-				requestContains(req, [SUBTASK_API_HANG_PARENT_MARKER, SUBTASK_API_HANG_CHILD_RESULT]),
+				requestContains(req, [SUBTASK_API_HANG_PARENT_MARKER, SUBTASK_RESULT_INJECTION]),
 		},
 		response: {
 			toolCalls: [

apps/vscode-e2e/src/suite/subtasks.test.ts

@@ -14,6 +14,7 @@ import {
 	SUBTASK_API_HANG_PARENT_RESULT,
 	SUBTASK_API_HANG_RESUME_MESSAGE,
 	SUBTASK_CHILD_FOLLOWUP_ANSWER,
+	SUBTASK_FAST_CHILD_RESULT,
 	SUBTASK_FAST_PARENT_PROMPT,
 	SUBTASK_INTERRUPT_CHILD_FOLLOWUP_ANSWER,
 	SUBTASK_INTERRUPT_PARENT_PROMPT,
@@ -101,7 +102,8 @@ suite("Roo Code Subtasks", function () {
 					([taskId, messages]) =>
 						taskId !== parentTaskId &&
 						messages.some(
-							({ say, text }) => say === "completion_result" && text?.trim() === "Fast child completed",
+							({ say, text }) =>
+								say === "completion_result" && text?.trim() === SUBTASK_FAST_CHILD_RESULT,
 						),
 				),
 				"Immediately-completing child should emit its expected result",
@@ -357,15 +359,23 @@ suite("Roo Code Subtasks", function () {
 
 			await api.cancelCurrentTask()
 
+			// Gate on the async settle before asserting the parent never resumed: a spurious
+			// resume would be an async downstream effect of the cancellation, so a synchronous
+			// check right after cancelCurrentTask() proves nothing.
+			await waitFor(() => api.getCurrentTaskStack().at(-1) === spawnedTaskId)
+			await waitFor(
+				() => asks[spawnedTaskId!]?.some(({ type, ask }) => type === "ask" && ask === "resume_task") ?? false,
+			)
+
 			assert.ok(
 				messages[parentTaskId]?.find(({ type, text }) => type === "say" && text === "Parent task resumed") ===
 					undefined,
 				"Parent task should not have resumed after subtask cancellation",
 			)
-
-			await waitFor(() => api.getCurrentTaskStack().at(-1) === spawnedTaskId)
-			await waitFor(
-				() => asks[spawnedTaskId!]?.some(({ type, ask }) => type === "ask" && ask === "resume_task") ?? false,
+			assert.strictEqual(
+				messages[parentTaskId]?.find(({ say }) => say === "completion_result"),
+				undefined,
+				"Parent must not have completed after subtask cancellation",
 			)
 
 			await api.clearCurrentTask()
@@ -539,15 +549,15 @@ suite("Roo Code Subtasks", function () {
 				says[childTaskId!]
 					?.filter(({ say }) => say === "completion_result")
 					.map(({ text }) => text?.trim())
-					.find((text) => text === SUBTASK_API_HANG_CHILD_RESULT),
+					.find((text): text is string => !!text),
 				SUBTASK_API_HANG_CHILD_RESULT,
 				"Child should complete with its expected result after resume",
 			)
 			assert.strictEqual(
 				says[parentTaskId]
 					?.filter(({ say }) => say === "completion_result")
 					.map(({ text }) => text?.trim())
-					.find((text) => text === SUBTASK_API_HANG_PARENT_RESULT),
+					.find((text): text is string => !!text),
 				SUBTASK_API_HANG_PARENT_RESULT,
 				"Parent should resume and complete with its expected result",
 			)

src/__tests__/history-resume-delegation.spec.ts

@@ -345,6 +345,12 @@ describe("History resume delegation - parent metadata transitions", () => {
 		expect(injectedMsg.role).toBe("user")
 		expect((injectedMsg.content[0] as any).type).toBe("tool_result")
 		expect((injectedMsg.content[0] as any).tool_use_id).toBe("toolu_abc123")
+
+		// Format contract with the e2e mock fixtures: the parent-resume fixtures in
+		// apps/vscode-e2e/src/fixtures/subtasks.ts match on this injected
+		// "completed.\n\nResult:" prefix (SUBTASK_RESULT_INJECTION). If this template
+		// changes, update the fixtures in the same PR or they silently never fire.
+		expect((injectedMsg.content[0] as any).content).toMatch(/^Subtask .+ completed\.\n\nResult:\n/)
 	})
 
 	it("reopenParentFromDelegation injects plain text when no new_task tool_use exists in API history", async () => {