Function runMcpTask

apps/vscode-e2e/src/suite/tools/use-mcp-tool.test.ts:119–172

(text: string)

	}

	async function runMcpTask(text: string): Promise<TaskRunResult> {
		const api = globalThis.api
		const messages: ClineMessage[] = []
		let attemptCompletionCalled = false
		let mcpRequest: ParsedMcpRequest | null = null
		let mcpServerResponse: string | null = null
		let errorOccurred: string | null = null

		const messageHandler = ({ message }: { message: ClineMessage }) => {
			messages.push(message)

			if (message.type === "ask" && message.ask === "use_mcp_server" && message.text) {
				try {
					const parsed = JSON.parse(message.text) as ParsedMcpRequest
					if (parsed.serverName && parsed.toolName) {
						mcpRequest = parsed
					}
				} catch {
					// Ignore partial JSON; a later complete ask will overwrite.
				}
			}

			if (message.type === "say" && message.say === "mcp_server_response") {
				mcpServerResponse = message.text || null
			}

			if (message.type === "say" && message.say === "completion_result") {
				attemptCompletionCalled = true
			}

			if (message.type === "say" && message.say === "error") {
				errorOccurred = message.text || "Unknown error"
			}
		}

		api.on(RooCodeEventName.Message, messageHandler)

		try {
			await api.startNewTask({
				configuration: {
					mode: "code",
					autoApprovalEnabled: true,
					alwaysAllowMcp: true,
					mcpEnabled: true,
				},
				text,
			})

			await waitFor(() => attemptCompletionCalled, { timeout: 45_000 })
			return { messages, mcpRequest, mcpServerResponse, errorOccurred }
		} finally {
			api.off(RooCodeEventName.Message, messageHandler)
		}
	}

	suiteSetup(async () => {
		const workspaceFolders = vscode.workspace.workspaceFolders