refactor: Split environment details into modular components

Converted monolithic environment details implementation into separate context modules.
Each module handles a specific aspect of the environment (VSCode, terminal, files, etc.).
Replaced reminder.ts with integrated todo implementation and standardized XML attributes.

Signed-off-by: Eric Wheeler <[email protected]>

Author: Eric Wheeler

src/core/environment/context/file.ts

@@ -0,0 +1,13 @@
+import type { Task } from "../../task/Task"
+
+export function getFileContext(cline: Task) {
+	const recentlyModifiedFiles = cline.fileContextTracker.getAndClearRecentlyModifiedFiles()
+	if (recentlyModifiedFiles.length > 0) {
+		return {
+			recentlyModified: {
+				file: recentlyModifiedFiles.map((p) => ({ "@path": p })),
+			},
+		}
+	}
+	return {}
+}

src/core/environment/context/metadata.ts

@@ -0,0 +1,65 @@
+import * as vscode from "vscode"
+
+import type { ExperimentId } from "@roo-code/types"
+
+import { EXPERIMENT_IDS, experiments as Experiments } from "../../../shared/experiments"
+import { formatLanguage } from "../../../shared/language"
+import { defaultModeSlug, getFullModeDetails } from "../../../shared/modes"
+import { getApiMetrics } from "../../../shared/getApiMetrics"
+import type { Task } from "../../task/Task"
+
+export async function getMetadataContext(cline: Task) {
+	const state = await cline.providerRef.deref()?.getState()
+	const {
+		mode,
+		customModes,
+		customModePrompts,
+		experiments = {} as Record<ExperimentId, boolean>,
+		customInstructions: globalCustomInstructions,
+		language,
+	} = state ?? {}
+
+	// High-Frequency Metadata
+	const now = new Date()
+	const timeZoneOffset = -now.getTimezoneOffset()
+	const offsetHours = Math.floor(Math.abs(timeZoneOffset) / 60)
+	const offsetMinutes = Math.abs(timeZoneOffset) % 60
+	const offsetSign = timeZoneOffset >= 0 ? "+" : "-"
+	const offsetString = `${offsetSign}${offsetHours
+		.toString()
+		.padStart(2, "0")}:${offsetMinutes.toString().padStart(2, "0")}`
+	const isoDateWithOffset = now.toISOString().replace(/Z$/, offsetString)
+	const time = {
+		"@v": isoDateWithOffset,
+	}
+
+	const { totalCost } = getApiMetrics(cline.clineMessages)
+	const cost = {
+		"@t": totalCost !== null ? totalCost.toFixed(2) : "0.00",
+		"@c": "USD",
+		"#text": "Must form responses to minimize cost growth",
+	}
+
+	// Low-Frequency Metadata
+	const currentMode = mode ?? defaultModeSlug
+	const modeDetails = await getFullModeDetails(currentMode, customModes, customModePrompts, {
+		cwd: cline.cwd,
+		globalCustomInstructions,
+		language: language ?? formatLanguage(vscode.env.language),
+	})
+
+	const { id: modelId } = cline.api.getModel()
+	const modeInfo = {
+		"@slug": currentMode,
+		"@name": modeDetails.name,
+		"@model": modelId,
+		...(Experiments.isEnabled(experiments ?? {}, EXPERIMENT_IDS.POWER_STEERING) && {
+			"@role": modeDetails.roleDefinition,
+			...(modeDetails.customInstructions && {
+				"@customInstructions": modeDetails.customInstructions,
+			}),
+		}),
+	}
+
+	return { time, cost, mode: modeInfo }
+}

src/core/environment/context/terminal.ts

@@ -0,0 +1,76 @@
+import pWaitFor from "p-wait-for"
+import delay from "delay"
+
+import { TerminalRegistry } from "../../../integrations/terminal/TerminalRegistry"
+import { Terminal } from "../../../integrations/terminal/Terminal"
+import type { Task } from "../../task/Task"
+
+export async function getTerminalContext(cline: Task) {
+	const state = await cline.providerRef.deref()?.getState()
+	const { terminalOutputLineLimit = 500 } = state ?? {}
+	const terminalsData: any[] = []
+	const busyTerminals = [
+		...TerminalRegistry.getTerminals(true, cline.taskId),
+		...TerminalRegistry.getBackgroundTerminals(true),
+	]
+	const inactiveTerminals = [
+		...TerminalRegistry.getTerminals(false, cline.taskId),
+		...TerminalRegistry.getBackgroundTerminals(false),
+	]
+
+	// Wait for terminals to cool down if needed
+	if (busyTerminals.length > 0 && cline.didEditFile) {
+		await delay(300) // Delay after saving file to let terminals catch up
+		await pWaitFor(() => busyTerminals.every((t) => !TerminalRegistry.isProcessHot(t.id)), {
+			interval: 100,
+			timeout: 5_000,
+		}).catch(() => {})
+	}
+	cline.didEditFile = false
+
+	// Process active terminals
+	busyTerminals.forEach((terminal) => {
+		const cwd = terminal.getCurrentWorkingDirectory()
+		const command = terminal.getLastCommand()
+		let output = TerminalRegistry.getUnretrievedOutput(terminal.id)
+
+		const terminalData: any = {
+			"@id": terminal.id.toString(),
+			"@status": "Active",
+			"@cwd": cwd,
+			"@command": command,
+		}
+
+		if (output) {
+			terminalData["#cdata"] = Terminal.compressTerminalOutput(output, terminalOutputLineLimit)
+		}
+
+		terminalsData.push(terminalData)
+	})
+
+	// Process inactive terminals with output
+	inactiveTerminals
+		.filter((t) => t.getProcessesWithOutput().length > 0)
+		.forEach((terminal) => {
+			const cwd = terminal.getCurrentWorkingDirectory()
+			const processes = terminal.getProcessesWithOutput()
+
+			processes.forEach((process) => {
+				const output = process.getUnretrievedOutput()
+
+				if (output) {
+					terminalsData.push({
+						"@id": terminal.id.toString(),
+						"@status": "Inactive",
+						"@cwd": cwd,
+						"@command": process.command,
+						"#cdata": Terminal.compressTerminalOutput(output, terminalOutputLineLimit),
+					})
+				}
+			})
+
+			terminal.cleanCompletedProcessQueue()
+		})
+
+	return terminalsData.length > 0 ? { terminal: terminalsData } : undefined
+}

src/core/environment/context/todo.ts

@@ -0,0 +1,31 @@
+import type { Task } from "../../task/Task"
+
+export function getTodoContext(cline: Task) {
+	if (cline.todoList && cline.todoList.length > 0) {
+		const todoLines = cline.todoList
+			.map((todo) => {
+				let statusPrefix = "[ ]" // pending
+				if (todo.status === "in_progress") statusPrefix = "[-]"
+				else if (todo.status === "completed") statusPrefix = "[x]"
+				return `${statusPrefix} ${todo.content}`
+			})
+			.join("\n")
+
+		const todoText = [
+			todoLines,
+			"IMPORTANT: When task status changes, remember to call the `update_todo_list` tool to update your progress.",
+		].join("\n")
+
+		return {
+			todo: {
+				"#text": todoText,
+			},
+		}
+	}
+	return {
+		todo: {
+			"#text":
+				"You have not created a todo list yet. Create one with `update_todo_list` if your task is complicated or involves multiple steps.",
+		},
+	}
+}

src/core/environment/context/vscode.ts

@@ -0,0 +1,50 @@
+import path from "path"
+import * as vscode from "vscode"
+
+import type { Task } from "../../task/Task"
+
+export async function getVscodeEditorContext(cline: Task) {
+	const state = await cline.providerRef.deref()?.getState()
+	const { maxWorkspaceFiles = 200 } = state ?? {}
+
+	// Get visible files in the editor
+	const visibleFilePaths = vscode.window.visibleTextEditors
+		?.map((editor) => editor.document?.uri?.fsPath)
+		.filter(Boolean)
+		.map((absolutePath) => path.relative(cline.cwd, absolutePath))
+		.slice(0, maxWorkspaceFiles)
+
+	const allowedVisibleFiles = cline.rooIgnoreController
+		? cline.rooIgnoreController.filterPaths(visibleFilePaths)
+		: visibleFilePaths.map((p) => p.toPosix())
+
+	const visibleFiles =
+		allowedVisibleFiles?.length > 0
+			? {
+					file: allowedVisibleFiles.map((p) => ({ "@path": p })),
+				}
+			: undefined
+
+	// Get open tabs (high-frequency data - using compact representation)
+	const { maxOpenTabsContext } = state ?? {}
+	const maxTabs = maxOpenTabsContext ?? 20
+	const openTabPaths = vscode.window.tabGroups.all
+		.flatMap((group) => group.tabs)
+		.map((tab) => (tab.input as vscode.TabInputText)?.uri?.fsPath)
+		.filter(Boolean)
+		.map((absolutePath) => path.relative(cline.cwd, absolutePath).toPosix())
+		.slice(0, maxTabs)
+
+	const allowedOpenTabs = cline.rooIgnoreController
+		? cline.rooIgnoreController.filterPaths(openTabPaths)
+		: openTabPaths
+
+	const openTabs =
+		allowedOpenTabs?.length > 0
+			? {
+					t: allowedOpenTabs.map((p) => ({ "@p": p })),
+				}
+			: undefined
+
+	return { visibleFiles, openTabs }
+}

src/core/environment/context/workspace.ts

@@ -0,0 +1,56 @@
+import path from "path"
+import os from "os"
+
+import { listFiles } from "../../../services/glob/list-files"
+import { arePathsEqual } from "../../../utils/path"
+import { formatResponse } from "../../prompts/responses"
+import type { Task } from "../../task/Task"
+
+export async function getWorkspaceContext(cline: Task, includeFileDetails: boolean) {
+	if (!includeFileDetails) {
+		return {}
+	}
+	const state = await cline.providerRef.deref()?.getState()
+	const { maxWorkspaceFiles = 200, showRooIgnoredFiles = true } = state ?? {}
+
+	const isDesktop = arePathsEqual(cline.cwd, path.join(os.homedir(), "Desktop"))
+	const workspaceData: any = { "@directory": cline.cwd.toPosix() }
+
+	if (isDesktop) {
+		workspaceData.note = "Desktop files not shown automatically. Use list_files to explore if needed."
+	} else if (maxWorkspaceFiles === 0) {
+		workspaceData.note = "Workspace files context disabled. Use list_files to explore if needed."
+	} else {
+		const [files, didHitLimit] = await listFiles(cline.cwd, true, maxWorkspaceFiles)
+		const formattedFilesList = formatResponse.formatFilesList(
+			cline.cwd,
+			files,
+			didHitLimit,
+			cline.rooIgnoreController,
+			showRooIgnoredFiles,
+		)
+
+		if (formattedFilesList && formattedFilesList !== "No files found.") {
+			const fileLines = formattedFilesList.split("\n").filter((line) => line.trim() !== "")
+			const fileObjects: any[] = []
+			const dirObjects: any[] = []
+
+			fileLines.forEach((line) => {
+				if (line.endsWith("/")) {
+					dirObjects.push({ "@path": line })
+				} else if (!line.includes("File list truncated")) {
+					fileObjects.push({ "@path": line })
+				}
+			})
+
+			if (fileObjects.length > 0) workspaceData.file = fileObjects
+			if (dirObjects.length > 0) workspaceData.directory = dirObjects
+			if (didHitLimit) {
+				workspaceData.note =
+					"File list truncated. Use list_files on specific subdirectories if you need to explore further."
+			}
+		}
+	}
+
+	return { workspace: workspaceData }
+}