import { isToolLifecycleItemType, type AssetResource, type ToolActivitySource, type ToolActivitySurface, type ToolActivityIcon, type OrchestrationV2TurnItem, type ThreadId,} from "@t3tools/contracts";import { resolveT3McpToolSummaryAction, type T3McpToolSummaryAction,} from "@t3tools/shared/t3McpToolPresentation";import { isWorkspaceImagePreviewPath } from "@t3tools/shared/filePreview"; import { classifyMarkdownImageSource } from "../markdownImages.ts";import { resolveMediaSource } from "../mediaSource.ts"; import { summarizeT3ToolCalls, type T3ToolSummaryCall,} from "@t3tools/client-runtime/t3ToolSummary"; export type WorkLogToolLifecycleStatus = | "inProgress" | "completed" | "failed" | "declined" | "stopped" | "idle"; export interface WorkLogPresentationEntry { readonly id: string; readonly createdAt: string; readonly label: string; readonly tone: "thinking" | "tool" | "info" | "error"; readonly command?: string; readonly rawCommand?: string; readonly detail?: string; readonly viewedImagePath?: string; readonly changedFiles?: ReadonlyArray<string>; readonly toolTitle?: string; readonly toolData?: unknown; readonly requestKind?: string; readonly itemType?: OrchestrationV2TurnItem["type"]; readonly toolLifecycleStatus?: WorkLogToolLifecycleStatus; readonly structuredPayload?: OrchestrationV2TurnItem; readonly toolSource?: ToolActivitySource; readonly toolSurface?: ToolActivitySurface; readonly toolIcon?: ToolActivityIcon;} export type ToolGroupAction = | "read" | "edit" | "command" | "browser" | "code-search" | "search" | "other" | "update"; export type ToolGroupSummaryKind = | ToolGroupAction | "dynamic-tool" | "agent-tool" | "tone-tool" | "mixed"; export function normalizeCompactToolLabel(value: string): string { return value.replace(/\s+(?:complete|completed)\s*$/i, "").trim();} const T3_MCP_TOOL_LABELS: Record< string, readonly [action: string, running: string, completed: string, detail: string]> = { orchestrator_capabilities: ["Get", "Getting", "Got", "orchestration capabilities"], delegate_task: ["Delegate", "Delegating", "Delegated", "a child task"], task_status: ["Get", "Getting", "Got", "delegated task status"], task_cancel: ["Cancel", "Canceling", "Canceled", "delegated task"], schedule_task: ["Schedule", "Scheduling", "Scheduled", "a recurring task"], list_scheduled_tasks: ["List", "Listing", "Listed", "scheduled tasks"], update_scheduled_task: ["Update", "Updating", "Updated", "a scheduled task"], delete_scheduled_task: ["Delete", "Deleting", "Deleted", "a scheduled task"], create_threads: ["Create", "Creating", "Created", "T3 threads"], t3_thread_start: ["Start", "Starting", "Started", "a T3 thread"], t3_thread_list: ["List", "Listing", "Listed", "T3 threads"], t3_thread_read: ["Read", "Reading", "Read", "a T3 thread"], t3_thread_send: ["Send", "Sending", "Sent", "to a T3 thread"], t3_thread_wait: ["Wait", "Waiting", "Waited", "for a T3 thread"], t3_thread_interrupt: ["Interrupt", "Interrupting", "Interrupted", "a T3 thread"], t3_worktree_handoff: ["Hand off", "Handing off", "Handed off", "thread to a git worktree"], t3_worktree_status: ["Get", "Getting", "Got", "thread worktree status"], preview_status: ["Get", "Getting", "Got", "preview browser status"], preview_open: ["Open", "Opening", "Opened", "a page in the preview browser"], preview_navigate: ["Navigate", "Navigating", "Navigated", "the preview browser"], preview_snapshot: [ "Take a snapshot of", "Taking a snapshot of", "Took a snapshot of", "the preview page", ], preview_click: ["Click", "Clicking", "Clicked", "in the preview browser"], preview_press: ["Press", "Pressing", "Pressed", "a key in the preview browser"], preview_type: ["Type", "Typing", "Typed", "in the preview browser"], preview_scroll: ["Scroll", "Scrolling", "Scrolled", "the preview browser"], preview_resize: ["Resize", "Resizing", "Resized", "the preview browser"], preview_evaluate: ["Evaluate", "Evaluating", "Evaluated", "script in the preview browser"], preview_wait_for: ["Wait", "Waiting", "Waited", "for the preview page"], preview_set_appearance: ["Set", "Setting", "Set", "preview browser appearance"], preview_recording_start: ["Start", "Starting", "Started", "recording the preview browser"], preview_recording_stop: ["Stop", "Stopping", "Stopped", "recording the preview browser"],}; function resolveT3McpToolPresentation(value: string | undefined, status: string | undefined) { if (!value) return null; const name = normalizeCompactToolLabel(value).replace( /^(?:mcp__(?:t3-code|t3_code|t3code)__|(?:t3-code|t3_code|t3code)(?:[.:/]|\s*·\s*))/i, "", ); if (!Object.hasOwn(T3_MCP_TOOL_LABELS, name)) return null; const [action, running, completed, detail] = T3_MCP_TOOL_LABELS[name]!; const verb = status === "inProgress" ? running : status === "completed" ? completed : status === "failed" ? `Failed to ${action.toLowerCase()}` : status === "declined" ? `Declined to ${action.toLowerCase()}` : status === "stopped" ? `Stopped ${running.toLowerCase()}` : running; return { displayName: `${verb} ${detail}`, icon: name.startsWith("preview_") ? ("browser" as const) : ("t3-code" as const), };} /** Only active or completed calls can inherit the live group’s present tense. */export function liveActivityToolStatus(status: string | undefined, presentTense: boolean) { if (status === "failed" || status === "declined" || status === "stopped" || status === "idle") { return status; } if (presentTense || status === "inProgress") return "inProgress"; return "completed";} /** Resolves tool identity before choosing labels or icons in either client. */export function resolveWorkEntryToolPresentation( entry: Pick<WorkLogPresentationEntry, "label" | "toolTitle" | "toolData" | "toolLifecycleStatus">, fallbackStatus?: "inProgress" | "completed",) { const status = entry.toolLifecycleStatus ?? fallbackStatus; const data = entry.toolData; if (data !== null && typeof data === "object") { if ( "server" in data && typeof data.server === "string" && "tool" in data && typeof data.tool === "string" ) { return resolveT3McpToolPresentation(`${data.server}.${data.tool}`, status); } if ("toolName" in data && typeof data.toolName === "string") { return resolveT3McpToolPresentation(data.toolName, status); } } return ( resolveT3McpToolPresentation(entry.toolTitle, status) ?? resolveT3McpToolPresentation(entry.label, status) );} function asRecord(value: unknown): Record<string, unknown> | null { return value !== null && typeof value === "object" && !Array.isArray(value) ? (value as Record<string, unknown>) : null;} function nonEmptyString(value: unknown): string | null { return typeof value === "string" && value.trim().length > 0 ? value : null;} function commandResultContent(value: unknown): string | null { const direct = nonEmptyString(value); if (direct) return direct; const directContent = Array.isArray(value) ? value : null; const record = asRecord(value); const content = record?.content; const contentText = nonEmptyString(content); if (contentText) return contentText; const blocks = directContent ?? (Array.isArray(content) ? content : null); if (!blocks) return null; const chunks = blocks.flatMap((entry) => { const text = nonEmptyString(entry) ?? nonEmptyString(asRecord(entry)?.text); return text ? [text] : []; }); return chunks.length > 0 ? chunks.join("\n") : null;} /** Returns provider command output before it is formatted for a work-log row. */export function extractCommandOutputText(dataValue: unknown): string | null { const data = asRecord(dataValue); const item = asRecord(data?.item); const itemResult = asRecord(item?.result); const rawOutput = asRecord(data?.rawOutput); const outputStreams = [ nonEmptyString(rawOutput?.stdout), nonEmptyString(rawOutput?.stderr), ].filter((value): value is string => value !== null); const acpContent = Array.isArray(data?.content) ? data.content .flatMap((entryValue) => { const entry = asRecord(entryValue); const content = asRecord(entry?.content); const text = entry?.type === "content" ? nonEmptyString(content?.text) : null; return text ? [text] : []; }) .join("\n") : null; const candidates = [ item?.aggregatedOutput, itemResult?.content, data?.rawOutput, rawOutput?.content, outputStreams.length > 0 ? outputStreams.join("\n") : null, rawOutput?.output, acpContent, data?.result, ]; for (const candidate of candidates) { const text = commandResultContent(candidate); if (text) return text; } return null;} /** * Ingestion caps tool details at 180 chars and appends "...", so a long command * echo no longer equals the command it repeats. Treat a truncated prefix of the * command as the same echo. */function textRepeatsCommand(text: string, commands: ReadonlyArray<string | null>): boolean { const truncated = text.endsWith("...") ? text.slice(0, -3) : text.endsWith("\u2026") ? text.slice(0, -1) : null; return commands.some((candidate) => { const command = candidate?.trim(); if (!command) return false; if (command === text) return true; return ( truncated !== null && truncated.length > 0 && command.length > truncated.length && command.startsWith(truncated) ); });} /** * Decides whether a command row's `detail` is a synthetic echo of the command * rather than real output. OpenCode stores completed output in `detail` with no * other output channel, so plain equality is only treated as synthetic when the * payload shape shows the detail came from the command: Codex item metadata, * an ACP tool call (`data.toolCallId`, `kind: "execute"`), a Claude tool-name * prefix, or no structured command at all. */export function commandDetailRepeatsCommand(input: { readonly detail: string; readonly command: string | null; readonly rawCommand: string | null; readonly toolName: unknown; readonly data: unknown;}): boolean { const toolName = nonEmptyString(input.toolName)?.trim(); const detail = input.detail.trim(); const commands = [input.command, input.rawCommand]; if (toolName) { const prefix = `${toolName}:`; if (detail.toLowerCase().startsWith(prefix.toLowerCase())) { const unprefixed = detail.slice(prefix.length).trim(); if (textRepeatsCommand(unprefixed, commands)) return true; } } if (!textRepeatsCommand(detail, commands)) return false; const data = asRecord(input.data); const item = asRecord(data?.item); const itemInput = asRecord(item?.input); const itemResult = asRecord(item?.result); const hasStructuredCommand = [ item?.command, itemInput?.command, itemResult?.command, data?.command, ].some((value) => Array.isArray(value) ? value.some((part) => nonEmptyString(part) !== null) : nonEmptyString(value) !== null, ); return ( !hasStructuredCommand || item !== null || data?.toolCallId !== undefined || nonEmptyString(data?.kind)?.toLowerCase() === "execute" );} export function workLogEntryIsToolLike(entry: WorkLogPresentationEntry): boolean { if (entry.tone === "tool" || entry.tone === "thinking" || entry.tone === "error") return true; if (entry.command !== undefined && entry.command.trim().length > 0) return true; if (entry.requestKind !== undefined) return true; return entry.itemType !== undefined && isToolLifecycleItemType(entry.itemType);} function toolDetailTextLooksLikeFailure(text: string): boolean { const normalized = text.toLowerCase(); return ( normalized.includes("file not found") || normalized.includes("no files found") || normalized.includes("enoent") || normalized.includes("no such file or directory") || normalized.includes("no such file") || (normalized.includes("cannot find path") && normalized.includes("because it does not exist")) || normalized.includes("commandnotfoundexception") || normalized.includes("is not recognized as the name of a cmdlet") || (normalized.includes("is not recognized") && normalized.includes("the term '")) || normalized.includes("a parameter cannot be found that matches parameter name") || normalized.includes("command not found") || /<exited with exit code\s+[1-9]\d*\s*>/i.test(text) || /exit(?:ed)? with exit code\s+[1-9]\d*/i.test(text) || /exit code\s*[:\s]\s*[1-9]\d*\b/i.test(text) );} export function workEntryDisplayIndicatesToolFailure(entry: WorkLogPresentationEntry): boolean { if ( entry.tone === "error" || entry.toolLifecycleStatus === "failed" || entry.toolLifecycleStatus === "declined" ) { return true; } return ( workLogEntryIsToolLike(entry) && entry.detail !== undefined && toolDetailTextLooksLikeFailure(entry.detail) );} export function workLogEntryIsLocalCodeSearch(entry: WorkLogPresentationEntry): boolean { return ( entry.itemType === "file_search" || (entry.itemType === "web_search" && /\bgrep\b/i.test(normalizeCompactToolLabel(entry.toolTitle ?? entry.label))) );} export function toolGroupAction(entry: WorkLogPresentationEntry): ToolGroupAction { if (resolveWorkEntryToolPresentation(entry)?.icon === "browser") return "browser"; if (entry.requestKind === "file-read" || entry.viewedImagePath !== undefined) return "read"; if ( entry.itemType === "dynamic_tool" && /^read(?:\s+file)?$/i.test(normalizeCompactToolLabel(entry.toolTitle ?? entry.label)) ) { return "read"; } if (entry.itemType === "file_change" || (entry.changedFiles?.length ?? 0) > 0) return "edit"; if (entry.itemType === "command_execution" || entry.command) return "command"; if (workLogEntryIsLocalCodeSearch(entry)) return "code-search"; if (entry.itemType === "web_search") return "search"; return workLogEntryIsToolLike(entry) ? "other" : "update";} export function workEntryViewedImagePath(entry: WorkLogPresentationEntry): string | null { const viewedImagePath = entry.viewedImagePath?.trim(); if ( viewedImagePath !== undefined && !/[\r\n]/.test(viewedImagePath) && isWorkspaceImagePreviewPath(viewedImagePath) ) { return viewedImagePath; } const detail = entry.detail?.trim(); return toolGroupAction(entry) === "read" && detail !== undefined && !/[\r\n]/.test(detail) && isWorkspaceImagePreviewPath(detail) ? detail : null;} export interface ViewedImageAsset { readonly resource: Extract<AssetResource, { readonly _tag: "media-file" }>; readonly alt: string; readonly srcFragment: string;} export function resolveViewedImageAsset( source: string, input: { readonly threadId: ThreadId; readonly workspaceRoot?: string | null | undefined; },): ViewedImageAsset | null { // A relative path with no known workspace still names a media-file relative // to the thread's workspace, so classify against "." and drop the prefix. const imageSource = classifyMarkdownImageSource(source, input.workspaceRoot ?? "."); if (imageSource._tag !== "WorkspaceFile") return null; const resolvedFilePath = input.workspaceRoot == null && imageSource.path.startsWith("./") ? imageSource.path.slice(2) : imageSource.path; const media = resolveMediaSource(source, { threadId: input.threadId, workspaceRoot: input.workspaceRoot, resolvedFilePath, }); if (media === null || media.access !== "environment") return null; return { resource: media.resource, alt: media.name, srcFragment: media.srcFragment };} function toolGroupActionCount( action: ToolGroupAction, entries: ReadonlyArray<WorkLogPresentationEntry>,): number { if (action !== "edit") return entries.length; const changedFiles = new Set<string>(); let editsWithoutFileDetails = 0; for (const entry of entries) { if (!entry.changedFiles || entry.changedFiles.length === 0) { editsWithoutFileDetails += 1; } else { for (const file of entry.changedFiles) changedFiles.add(file); } } return changedFiles.size + editsWithoutFileDetails;} function toolGroupActionLabel(action: ToolGroupAction, count: number): string { switch (action) { case "read": return `Read ${count} ${count === 1 ? "file" : "files"}`; case "edit": return `Changed ${count} ${count === 1 ? "file" : "files"}`; case "command": return `Ran ${count} ${count === 1 ? "command" : "commands"}`; case "browser": return `Used browser ${count} ${count === 1 ? "time" : "times"}`; case "search": return `Searched the web ${count} ${count === 1 ? "time" : "times"}`; case "code-search": return `Searched code ${count} ${count === 1 ? "time" : "times"}`; case "other": return `Used ${count} ${count === 1 ? "tool" : "tools"}`; case "update": return `Received ${count} ${count === 1 ? "update" : "updates"}`; }} function t3ToolSummaryCall(entry: WorkLogPresentationEntry): T3ToolSummaryCall { const item = entry.structuredPayload; const data = entry.toolData !== null && typeof entry.toolData === "object" ? (entry.toolData as Record<string, unknown>) : undefined; return { input: item?.type === "dynamic_tool" ? item.input : data?.input, output: item?.type === "dynamic_tool" ? item.output : data?.output, outcome: entry.toolLifecycleStatus === "failed" || entry.toolLifecycleStatus === "declined" || entry.tone === "error" ? "failed" : entry.toolLifecycleStatus === "completed" ? "completed" : "unfinished", };} function summaryActionPriority(action: ToolGroupAction | T3McpToolSummaryAction): number { switch (action) { case "command": case "edit": case "delegate": case "task-cancel": case "thread-create":Lines 1–500 of 610. Load more
import { isToolLifecycleItemType, type AssetResource, type ToolActivitySource, type ToolActivitySurface, type ToolActivityIcon, type OrchestrationV2TurnItem, type ThreadId, } from "@t3tools/contracts"; import { resolveT3McpToolSummaryAction, type T3McpToolSummaryAction, } from "@t3tools/shared/t3McpToolPresentation"; import { isWorkspaceImagePreviewPath } from "@t3tools/shared/filePreview"; import { classifyMarkdownImageSource } from "../markdownImages.ts"; import { resolveMediaSource } from "../mediaSource.ts"; import { summarizeT3ToolCalls, type T3ToolSummaryCall, } from "@t3tools/client-runtime/t3ToolSummary"; export type WorkLogToolLifecycleStatus = | "inProgress" | "completed" | "failed" | "declined" | "stopped" | "idle"; export interface WorkLogPresentationEntry { readonly id: string; readonly createdAt: string; readonly label: string; readonly tone: "thinking" | "tool" | "info" | "error"; readonly command?: string; readonly rawCommand?: string; readonly detail?: string; readonly viewedImagePath?: string; readonly changedFiles?: ReadonlyArray<string>; readonly toolTitle?: string; readonly toolData?: unknown; readonly requestKind?: string; readonly itemType?: OrchestrationV2TurnItem["type"]; readonly toolLifecycleStatus?: WorkLogToolLifecycleStatus; readonly structuredPayload?: OrchestrationV2TurnItem; readonly toolSource?: ToolActivitySource; readonly toolSurface?: ToolActivitySurface; readonly toolIcon?: ToolActivityIcon; } export type ToolGroupAction = | "read" | "edit" | "command" | "browser" | "code-search" | "search" | "other" | "update"; export type ToolGroupSummaryKind = | ToolGroupAction | "dynamic-tool" | "agent-tool" | "tone-tool" | "mixed"; export function normalizeCompactToolLabel(value: string): string { return value.replace(/\s+(?:complete|completed)\s*$/i, "").trim(); } const T3_MCP_TOOL_LABELS: Record< string, readonly [action: string, running: string, completed: string, detail: string] > = { orchestrator_capabilities: ["Get", "Getting", "Got", "orchestration capabilities"], delegate_task: ["Delegate", "Delegating", "Delegated", "a child task"], task_status: ["Get", "Getting", "Got", "delegated task status"], task_cancel: ["Cancel", "Canceling", "Canceled", "delegated task"], schedule_task: ["Schedule", "Scheduling", "Scheduled", "a recurring task"], list_scheduled_tasks: ["List", "Listing", "Listed", "scheduled tasks"], update_scheduled_task: ["Update", "Updating", "Updated", "a scheduled task"], delete_scheduled_task: ["Delete", "Deleting", "Deleted", "a scheduled task"], create_threads: ["Create", "Creating", "Created", "T3 threads"], t3_thread_start: ["Start", "Starting", "Started", "a T3 thread"], t3_thread_list: ["List", "Listing", "Listed", "T3 threads"], t3_thread_read: ["Read", "Reading", "Read", "a T3 thread"], t3_thread_send: ["Send", "Sending", "Sent", "to a T3 thread"], t3_thread_wait: ["Wait", "Waiting", "Waited", "for a T3 thread"], t3_thread_interrupt: ["Interrupt", "Interrupting", "Interrupted", "a T3 thread"], t3_worktree_handoff: ["Hand off", "Handing off", "Handed off", "thread to a git worktree"], t3_worktree_status: ["Get", "Getting", "Got", "thread worktree status"], preview_status: ["Get", "Getting", "Got", "preview browser status"], preview_open: ["Open", "Opening", "Opened", "a page in the preview browser"], preview_navigate: ["Navigate", "Navigating", "Navigated", "the preview browser"], preview_snapshot: [ "Take a snapshot of", "Taking a snapshot of", "Took a snapshot of", "the preview page", ], preview_click: ["Click", "Clicking", "Clicked", "in the preview browser"], preview_press: ["Press", "Pressing", "Pressed", "a key in the preview browser"], preview_type: ["Type", "Typing", "Typed", "in the preview browser"], preview_scroll: ["Scroll", "Scrolling", "Scrolled", "the preview browser"], preview_resize: ["Resize", "Resizing", "Resized", "the preview browser"], preview_evaluate: ["Evaluate", "Evaluating", "Evaluated", "script in the preview browser"], preview_wait_for: ["Wait", "Waiting", "Waited", "for the preview page"], preview_set_appearance: ["Set", "Setting", "Set", "preview browser appearance"], preview_recording_start: ["Start", "Starting", "Started", "recording the preview browser"], preview_recording_stop: ["Stop", "Stopping", "Stopped", "recording the preview browser"], }; function resolveT3McpToolPresentation(value: string | undefined, status: string | undefined) { if (!value) return null; const name = normalizeCompactToolLabel(value).replace( /^(?:mcp__(?:t3-code|t3_code|t3code)__|(?:t3-code|t3_code|t3code)(?:[.:/]|\s*·\s*))/i, "", ); if (!Object.hasOwn(T3_MCP_TOOL_LABELS, name)) return null; const [action, running, completed, detail] = T3_MCP_TOOL_LABELS[name]!; const verb = status === "inProgress" ? running : status === "completed" ? completed : status === "failed" ? `Failed to ${action.toLowerCase()}` : status === "declined" ? `Declined to ${action.toLowerCase()}` : status === "stopped" ? `Stopped ${running.toLowerCase()}` : running; return { displayName: `${verb} ${detail}`, icon: name.startsWith("preview_") ? ("browser" as const) : ("t3-code" as const), }; } /** Only active or completed calls can inherit the live group’s present tense. */ export function liveActivityToolStatus(status: string | undefined, presentTense: boolean) { if (status === "failed" || status === "declined" || status === "stopped" || status === "idle") { return status; } if (presentTense || status === "inProgress") return "inProgress"; return "completed"; } /** Resolves tool identity before choosing labels or icons in either client. */ export function resolveWorkEntryToolPresentation( entry: Pick<WorkLogPresentationEntry, "label" | "toolTitle" | "toolData" | "toolLifecycleStatus">, fallbackStatus?: "inProgress" | "completed", ) { const status = entry.toolLifecycleStatus ?? fallbackStatus; const data = entry.toolData; if (data !== null && typeof data === "object") { if ( "server" in data && typeof data.server === "string" && "tool" in data && typeof data.tool === "string" ) { return resolveT3McpToolPresentation(`${data.server}.${data.tool}`, status); } if ("toolName" in data && typeof data.toolName === "string") { return resolveT3McpToolPresentation(data.toolName, status); } } return ( resolveT3McpToolPresentation(entry.toolTitle, status) ?? resolveT3McpToolPresentation(entry.label, status) ); } function asRecord(value: unknown): Record<string, unknown> | null { return value !== null && typeof value === "object" && !Array.isArray(value) ? (value as Record<string, unknown>) : null; } function nonEmptyString(value: unknown): string | null { return typeof value === "string" && value.trim().length > 0 ? value : null; } function commandResultContent(value: unknown): string | null { const direct = nonEmptyString(value); if (direct) return direct; const directContent = Array.isArray(value) ? value : null; const record = asRecord(value); const content = record?.content; const contentText = nonEmptyString(content); if (contentText) return contentText; const blocks = directContent ?? (Array.isArray(content) ? content : null); if (!blocks) return null; const chunks = blocks.flatMap((entry) => { const text = nonEmptyString(entry) ?? nonEmptyString(asRecord(entry)?.text); return text ? [text] : []; }); return chunks.length > 0 ? chunks.join("\n") : null; } /** Returns provider command output before it is formatted for a work-log row. */ export function extractCommandOutputText(dataValue: unknown): string | null { const data = asRecord(dataValue); const item = asRecord(data?.item); const itemResult = asRecord(item?.result); const rawOutput = asRecord(data?.rawOutput); const outputStreams = [ nonEmptyString(rawOutput?.stdout), nonEmptyString(rawOutput?.stderr), ].filter((value): value is string => value !== null); const acpContent = Array.isArray(data?.content) ? data.content .flatMap((entryValue) => { const entry = asRecord(entryValue); const content = asRecord(entry?.content); const text = entry?.type === "content" ? nonEmptyString(content?.text) : null; return text ? [text] : []; }) .join("\n") : null; const candidates = [ item?.aggregatedOutput, itemResult?.content, data?.rawOutput, rawOutput?.content, outputStreams.length > 0 ? outputStreams.join("\n") : null, rawOutput?.output, acpContent, data?.result, ]; for (const candidate of candidates) { const text = commandResultContent(candidate); if (text) return text; } return null; } /** * Ingestion caps tool details at 180 chars and appends "...", so a long command * echo no longer equals the command it repeats. Treat a truncated prefix of the * command as the same echo. */ function textRepeatsCommand(text: string, commands: ReadonlyArray<string | null>): boolean { const truncated = text.endsWith("...") ? text.slice(0, -3) : text.endsWith("\u2026") ? text.slice(0, -1) : null; return commands.some((candidate) => { const command = candidate?.trim(); if (!command) return false; if (command === text) return true; return ( truncated !== null && truncated.length > 0 && command.length > truncated.length && command.startsWith(truncated) ); }); } /** * Decides whether a command row's `detail` is a synthetic echo of the command * rather than real output. OpenCode stores completed output in `detail` with no * other output channel, so plain equality is only treated as synthetic when the * payload shape shows the detail came from the command: Codex item metadata, * an ACP tool call (`data.toolCallId`, `kind: "execute"`), a Claude tool-name * prefix, or no structured command at all. */ export function commandDetailRepeatsCommand(input: { readonly detail: string; readonly command: string | null; readonly rawCommand: string | null; readonly toolName: unknown; readonly data: unknown; }): boolean { const toolName = nonEmptyString(input.toolName)?.trim(); const detail = input.detail.trim(); const commands = [input.command, input.rawCommand]; if (toolName) { const prefix = `${toolName}:`; if (detail.toLowerCase().startsWith(prefix.toLowerCase())) { const unprefixed = detail.slice(prefix.length).trim(); if (textRepeatsCommand(unprefixed, commands)) return true; } } if (!textRepeatsCommand(detail, commands)) return false; const data = asRecord(input.data); const item = asRecord(data?.item); const itemInput = asRecord(item?.input); const itemResult = asRecord(item?.result); const hasStructuredCommand = [ item?.command, itemInput?.command, itemResult?.command, data?.command, ].some((value) => Array.isArray(value) ? value.some((part) => nonEmptyString(part) !== null) : nonEmptyString(value) !== null, ); return ( !hasStructuredCommand || item !== null || data?.toolCallId !== undefined || nonEmptyString(data?.kind)?.toLowerCase() === "execute" ); } export function workLogEntryIsToolLike(entry: WorkLogPresentationEntry): boolean { if (entry.tone === "tool" || entry.tone === "thinking" || entry.tone === "error") return true; if (entry.command !== undefined && entry.command.trim().length > 0) return true; if (entry.requestKind !== undefined) return true; return entry.itemType !== undefined && isToolLifecycleItemType(entry.itemType); } function toolDetailTextLooksLikeFailure(text: string): boolean { const normalized = text.toLowerCase(); return ( normalized.includes("file not found") || normalized.includes("no files found") || normalized.includes("enoent") || normalized.includes("no such file or directory") || normalized.includes("no such file") || (normalized.includes("cannot find path") && normalized.includes("because it does not exist")) || normalized.includes("commandnotfoundexception") || normalized.includes("is not recognized as the name of a cmdlet") || (normalized.includes("is not recognized") && normalized.includes("the term '")) || normalized.includes("a parameter cannot be found that matches parameter name") || normalized.includes("command not found") || /<exited with exit code\s+[1-9]\d*\s*>/i.test(text) || /exit(?:ed)? with exit code\s+[1-9]\d*/i.test(text) || /exit code\s*[:\s]\s*[1-9]\d*\b/i.test(text) ); } export function workEntryDisplayIndicatesToolFailure(entry: WorkLogPresentationEntry): boolean { if ( entry.tone === "error" || entry.toolLifecycleStatus === "failed" || entry.toolLifecycleStatus === "declined" ) { return true; } return ( workLogEntryIsToolLike(entry) && entry.detail !== undefined && toolDetailTextLooksLikeFailure(entry.detail) ); } export function workLogEntryIsLocalCodeSearch(entry: WorkLogPresentationEntry): boolean { return ( entry.itemType === "file_search" || (entry.itemType === "web_search" && /\bgrep\b/i.test(normalizeCompactToolLabel(entry.toolTitle ?? entry.label))) ); } export function toolGroupAction(entry: WorkLogPresentationEntry): ToolGroupAction { if (resolveWorkEntryToolPresentation(entry)?.icon === "browser") return "browser"; if (entry.requestKind === "file-read" || entry.viewedImagePath !== undefined) return "read"; if ( entry.itemType === "dynamic_tool" && /^read(?:\s+file)?$/i.test(normalizeCompactToolLabel(entry.toolTitle ?? entry.label)) ) { return "read"; } if (entry.itemType === "file_change" || (entry.changedFiles?.length ?? 0) > 0) return "edit"; if (entry.itemType === "command_execution" || entry.command) return "command"; if (workLogEntryIsLocalCodeSearch(entry)) return "code-search"; if (entry.itemType === "web_search") return "search"; return workLogEntryIsToolLike(entry) ? "other" : "update"; } export function workEntryViewedImagePath(entry: WorkLogPresentationEntry): string | null { const viewedImagePath = entry.viewedImagePath?.trim(); if ( viewedImagePath !== undefined && !/[\r\n]/.test(viewedImagePath) && isWorkspaceImagePreviewPath(viewedImagePath) ) { return viewedImagePath; } const detail = entry.detail?.trim(); return toolGroupAction(entry) === "read" && detail !== undefined && !/[\r\n]/.test(detail) && isWorkspaceImagePreviewPath(detail) ? detail : null; } export interface ViewedImageAsset { readonly resource: Extract<AssetResource, { readonly _tag: "media-file" }>; readonly alt: string; readonly srcFragment: string; } export function resolveViewedImageAsset( source: string, input: { readonly threadId: ThreadId; readonly workspaceRoot?: string | null | undefined; }, ): ViewedImageAsset | null { // A relative path with no known workspace still names a media-file relative // to the thread's workspace, so classify against "." and drop the prefix. const imageSource = classifyMarkdownImageSource(source, input.workspaceRoot ?? "."); if (imageSource._tag !== "WorkspaceFile") return null; const resolvedFilePath = input.workspaceRoot == null && imageSource.path.startsWith("./") ? imageSource.path.slice(2) : imageSource.path; const media = resolveMediaSource(source, { threadId: input.threadId, workspaceRoot: input.workspaceRoot, resolvedFilePath, }); if (media === null || media.access !== "environment") return null; return { resource: media.resource, alt: media.name, srcFragment: media.srcFragment }; } function toolGroupActionCount( action: ToolGroupAction, entries: ReadonlyArray<WorkLogPresentationEntry>, ): number { if (action !== "edit") return entries.length; const changedFiles = new Set<string>(); let editsWithoutFileDetails = 0; for (const entry of entries) { if (!entry.changedFiles || entry.changedFiles.length === 0) { editsWithoutFileDetails += 1; } else { for (const file of entry.changedFiles) changedFiles.add(file); } } return changedFiles.size + editsWithoutFileDetails; } function toolGroupActionLabel(action: ToolGroupAction, count: number): string { switch (action) { case "read": return `Read ${count} ${count === 1 ? "file" : "files"}`; case "edit": return `Changed ${count} ${count === 1 ? "file" : "files"}`; case "command": return `Ran ${count} ${count === 1 ? "command" : "commands"}`; case "browser": return `Used browser ${count} ${count === 1 ? "time" : "times"}`; case "search": return `Searched the web ${count} ${count === 1 ? "time" : "times"}`; case "code-search": return `Searched code ${count} ${count === 1 ? "time" : "times"}`; case "other": return `Used ${count} ${count === 1 ? "tool" : "tools"}`; case "update": return `Received ${count} ${count === 1 ? "update" : "updates"}`; } } function t3ToolSummaryCall(entry: WorkLogPresentationEntry): T3ToolSummaryCall { const item = entry.structuredPayload; const data = entry.toolData !== null && typeof entry.toolData === "object" ? (entry.toolData as Record<string, unknown>) : undefined; return { input: item?.type === "dynamic_tool" ? item.input : data?.input, output: item?.type === "dynamic_tool" ? item.output : data?.output, outcome: entry.toolLifecycleStatus === "failed" || entry.toolLifecycleStatus === "declined" || entry.tone === "error" ? "failed" : entry.toolLifecycleStatus === "completed" ? "completed" : "unfinished", }; } function summaryActionPriority(action: ToolGroupAction | T3McpToolSummaryAction): number { switch (action) { case "command": case "edit": case "delegate": case "task-cancel": case "thread-create":