Add the ability for Roo to send log messages to the Roo-Code Output Channel.

.changeset/healthy-fans-drum.md

@@ -0,0 +1,5 @@
+---
+"roo-cline": minor
+---
+
+Added structured logging system with schema validation for log entries, allowing the AI assistant to output diagnostic information to the VSCode output channel via <log_entry> blocks without requiring user approval

src/core/Cline.ts

@@ -88,6 +88,7 @@ import { validateToolUse } from "./mode-validator"
 import { MultiSearchReplaceDiffStrategy } from "./diff/strategies/multi-search-replace"
 import { readApiMessages, saveApiMessages, readTaskMessages, saveTaskMessages, taskMetadata } from "./task-persistence"
 import { getEnvironmentDetails } from "./environment/getEnvironmentDetails"
+import { LogManager } from "./logging"
 
 type UserContent = Array<Anthropic.Messages.ContentBlockParam>
 
@@ -151,6 +152,7 @@ export class Cline extends EventEmitter<ClineEvents> {
 	diffStrategy?: DiffStrategy
 	diffEnabled: boolean = false
 	fuzzyMatchThreshold: number
+	private logManager: LogManager
 
 	apiConversationHistory: (Anthropic.MessageParam & { ts?: number })[] = []
 	clineMessages: ClineMessage[] = []
@@ -232,7 +234,7 @@ export class Cline extends EventEmitter<ClineEvents> {
 
 		this.rooIgnoreController = new RooIgnoreController(this.cwd)
 		this.fileContextTracker = new FileContextTracker(provider, this.taskId)
-
+		this.logManager = new LogManager(provider)
 		this.rooIgnoreController.initialize().catch((error) => {
 			console.error("Failed to initialize RooIgnoreController:", error)
 		})
@@ -1621,6 +1623,12 @@ export class Cline extends EventEmitter<ClineEvents> {
 		const block = cloneDeep(this.assistantMessageContent[this.currentStreamingContentIndex]) // need to create copy bc while stream is updating the array, it could be updating the reference block properties too
 
 		switch (block.type) {
+			case "log_message": {
+				// Log messages are processed immediately without requiring approval
+				// and don't count as a tool use
+				this.logManager.processLogEntry(block.message, block.level, block.partial)
+				break
+			}
 			case "text": {
 				if (this.didRejectTool || this.didAlreadyUseTool) {
 					break

src/core/assistant-message/__tests__/log-message.test.ts

@@ -0,0 +1,168 @@
+import { parseAssistantMessage } from "../parse-assistant-message"
+
+describe("Log Entry Parsing", () => {
+	it("should parse complete log entries correctly", () => {
+		const message = `<log_message>
+<message>This is a test log message</message>
+<level>debug</level>
+</log_message>`
+
+		const result = parseAssistantMessage(message)
+
+		// Filter out empty text blocks
+		const filteredResult = result.filter((block) => !(block.type === "text" && block.content === ""))
+
+		expect(filteredResult).toHaveLength(1)
+		expect(filteredResult[0]).toEqual({
+			type: "log_message",
+			message: "This is a test log message",
+			level: "debug",
+			partial: false,
+		})
+	})
+
+	it("should mark partial log entries as partial", () => {
+		const message = `<log_message>
+<message>This is a test log message</message>`
+
+		const result = parseAssistantMessage(message)
+
+		// Filter out empty text blocks
+		const filteredResult = result.filter((block) => !(block.type === "text" && block.content === ""))
+
+		expect(filteredResult).toHaveLength(1)
+		expect(filteredResult[0]).toEqual({
+			type: "log_message",
+			message: "This is a test log message",
+			level: "info", // Default level
+			partial: true,
+		})
+	})
+
+	it("should handle log entries with only message tag", () => {
+		const message = `<log_message>
+<message>This is a test log message</message>
+</log_message>`
+
+		const result = parseAssistantMessage(message)
+
+		// Filter out empty text blocks
+		const filteredResult = result.filter((block) => !(block.type === "text" && block.content === ""))
+
+		expect(filteredResult).toHaveLength(1)
+		expect(filteredResult[0]).toEqual({
+			type: "log_message",
+			message: "This is a test log message",
+			level: "info", // Default level
+			partial: false,
+		})
+	})
+
+	it("should simulate streaming behavior with partial log entries", () => {
+		// Simulate streaming chunks
+		const chunks = [
+			"<log_message>\n",
+			"<message>This is a debug level log message</message>\n",
+			"<level>debug</level>\n",
+			"</log_message>",
+		]
+
+		let accumulatedMessage = ""
+		const results = []
+
+		// Process each chunk as it would happen during streaming
+		for (const chunk of chunks) {
+			accumulatedMessage += chunk
+			const result = parseAssistantMessage(accumulatedMessage)
+			results.push(result)
+		}
+
+		// First chunk: Just the opening tag - filter out empty text blocks
+		const filteredResults0 = results[0].filter((block) => !(block.type === "text" && block.content === ""))
+		expect(filteredResults0[0]).toEqual({
+			type: "log_message",
+			message: "",
+			level: "info", // Default level
+			partial: true,
+		})
+
+		// Second chunk: Has message but not level - filter out empty text blocks
+		const filteredResults1 = results[1].filter((block) => !(block.type === "text" && block.content === ""))
+		expect(filteredResults1[0]).toEqual({
+			type: "log_message",
+			message: "This is a debug level log message</message>",
+			level: "info", // Still default level
+			partial: true,
+		})
+
+		// Third chunk: Has message and level but not closing tag - filter out empty text blocks
+		const filteredResults2 = results[2].filter((block) => !(block.type === "text" && block.content === ""))
+		expect(filteredResults2[0]).toEqual({
+			type: "log_message",
+			message: "This is a debug level log message</message>\n<level>debug</level>",
+			level: "info", // Still default level at this point
+			partial: true,
+		})
+
+		// Fourth chunk: Complete log entry - filter out empty text blocks
+		const filteredResults3 = results[3].filter((block) => !(block.type === "text" && block.content === ""))
+		expect(filteredResults3[0]).toEqual({
+			type: "log_message",
+			message: "This is a debug level log message",
+			level: "debug",
+			partial: false,
+		})
+	})
+
+	it("should handle multiple log entries with different levels", () => {
+		const message = `<log_message>
+<message>This is a debug message</message>
+<level>debug</level>
+</log_message>
+
+<log_message>
+<message>This is an info message</message>
+</log_message>
+
+<log_message>
+<message>This is a warning message</message>
+<level>warn</level>
+</log_message>
+
+<log_message>
+<message>This is an error message</message>
+<level>error</level>
+</log_message>`
+
+		const result = parseAssistantMessage(message)
+
+		// Filter out empty text blocks
+		const filteredResult = result.filter((block) => !(block.type === "text" && block.content === ""))
+
+		expect(filteredResult).toHaveLength(4)
+		expect(filteredResult[0]).toEqual({
+			type: "log_message",
+			message: "This is a debug message",
+			level: "debug",
+			partial: false,
+		})
+		expect(filteredResult[1]).toEqual({
+			type: "log_message",
+			message: "This is an info message",
+			level: "info", // Default level
+			partial: false,
+		})
+		expect(filteredResult[2]).toEqual({
+			type: "log_message",
+			message: "This is a warning message",
+			level: "warn",
+			partial: false,
+		})
+		expect(filteredResult[3]).toEqual({
+			type: "log_message",
+			message: "This is an error message",
+			level: "error",
+			partial: false,
+		})
+	})
+})

src/core/assistant-message/directives/log-directive.ts

@@ -0,0 +1,12 @@
+import { logLevels } from "../../../schemas"
+
+/**
+ * Represents a log message directive from the assistant to the system.
+ * This directive instructs the system to record a message to its internal logs.
+ */
+export interface LogDirective {
+	type: "log_message"
+	message: string
+	level: (typeof logLevels)[number]
+	partial: boolean
+}

src/core/assistant-message/index.ts

@@ -1 +1,2 @@
 export { type AssistantMessageContent, parseAssistantMessage } from "./parse-assistant-message"
+export { type LogDirective } from "./directives/log-directive"