feat(opencode): add changed-files tree with change indicators (#815)

* feat(opencode): add changed-files tree with change indicators

* feat(opencode): address changed-files review feedback

---------

Co-authored-by: Affaan Mustafa <me@affaanmustafa.com>

.opencode/plugins/ecc-hooks.ts

@@ -14,6 +14,14 @@
  */
 
 import type { PluginInput } from "@opencode-ai/plugin"
+import * as fs from "fs"
+import * as path from "path"
+import {
+  initStore,
+  recordChange,
+  clearChanges,
+} from "./lib/changed-files-store.js"
+import changedFilesTool from "../tools/changed-files.js"
 
 export const ECCHooksPlugin = async ({
   client,
@@ -23,9 +31,25 @@ export const ECCHooksPlugin = async ({
 }: PluginInput) => {
   type HookProfile = "minimal" | "standard" | "strict"
 
-  // Track files edited in current session for console.log audit
+  const worktreePath = worktree || directory
+  initStore(worktreePath)
+
   const editedFiles = new Set<string>()
 
+  function resolvePath(p: string): string {
+    if (path.isAbsolute(p)) return p
+    return path.join(worktreePath, p)
+  }
+
+  const pendingToolChanges = new Map<string, { path: string; type: "added" | "modified" }>()
+  let writeCounter = 0
+
+  function getFilePath(args: Record<string, unknown> | undefined): string | null {
+    if (!args) return null
+    const p = (args.filePath ?? args.file_path ?? args.path) as string | undefined
+    return typeof p === "string" && p.trim() ? p : null
+  }
+
   // Helper to call the SDK's log API with correct signature
   const log = (level: "debug" | "info" | "warn" | "error", message: string) =>
     client.app.log({ body: { service: "ecc", level, message } })
@@ -73,8 +97,8 @@ export const ECCHooksPlugin = async ({
      * Action: Runs prettier --write on the file
      */
     "file.edited": async (event: { path: string }) => {
-      // Track edited files for console.log audit
       editedFiles.add(event.path)
+      recordChange(event.path, "modified")
 
       // Auto-format JS/TS files
       if (hookEnabled("post:edit:format", ["strict"]) && event.path.match(/\.(ts|tsx|js|jsx)$/)) {
@@ -111,9 +135,24 @@ export const ECCHooksPlugin = async ({
      * Action: Runs tsc --noEmit to check for type errors
      */
     "tool.execute.after": async (
-      input: { tool: string; args?: { filePath?: string } },
+      input: { tool: string; callID?: string; args?: { filePath?: string; file_path?: string; path?: string } },
       output: unknown
     ) => {
+      const filePath = getFilePath(input.args as Record<string, unknown>)
+      if (input.tool === "edit" && filePath) {
+        recordChange(filePath, "modified")
+      }
+      if (input.tool === "write" && filePath) {
+        const key = input.callID ?? `write-${++writeCounter}-${filePath}`
+        const pending = pendingToolChanges.get(key)
+        if (pending) {
+          recordChange(pending.path, pending.type)
+          pendingToolChanges.delete(key)
+        } else {
+          recordChange(filePath, "modified")
+        }
+      }
+
       // Check if a TypeScript file was edited
       if (
         hookEnabled("post:edit:typecheck", ["strict"]) &&
@@ -152,8 +191,25 @@ export const ECCHooksPlugin = async ({
      * Action: Warns about potential security issues
      */
     "tool.execute.before": async (
-      input: { tool: string; args?: Record<string, unknown> }
+      input: { tool: string; callID?: string; args?: Record<string, unknown> }
     ) => {
+      if (input.tool === "write") {
+        const filePath = getFilePath(input.args)
+        if (filePath) {
+          const absPath = resolvePath(filePath)
+          let type: "added" | "modified" = "modified"
+          try {
+            if (typeof fs.existsSync === "function") {
+              type = fs.existsSync(absPath) ? "modified" : "added"
+            }
+          } catch {
+            type = "modified"
+          }
+          const key = input.callID ?? `write-${++writeCounter}-${filePath}`
+          pendingToolChanges.set(key, { path: filePath, type })
+        }
+      }
+
       // Git push review reminder
       if (
         hookEnabled("pre:bash:git-push-reminder", "strict") &&
@@ -293,6 +349,8 @@ export const ECCHooksPlugin = async ({
       if (!hookEnabled("session:end-marker", ["minimal", "standard", "strict"])) return
       log("info", "[ECC] Session ended - cleaning up")
       editedFiles.clear()
+      clearChanges()
+      pendingToolChanges.clear()
     },
 
     /**
@@ -303,6 +361,10 @@ export const ECCHooksPlugin = async ({
      * Action: Updates tracking
      */
     "file.watcher.updated": async (event: { path: string; type: string }) => {
+      let changeType: "added" | "modified" | "deleted" = "modified"
+      if (event.type === "create" || event.type === "add") changeType = "added"
+      else if (event.type === "delete" || event.type === "remove") changeType = "deleted"
+      recordChange(event.path, changeType)
       if (event.type === "change" && event.path.match(/\.(ts|tsx|js|jsx)$/)) {
         editedFiles.add(event.path)
       }
@@ -394,7 +456,7 @@ export const ECCHooksPlugin = async ({
         "",
         "## Active Plugin: Everything Claude Code v1.8.0",
         "- Hooks: file.edited, tool.execute.before/after, session.created/idle/deleted, shell.env, compacting, permission.ask",
-        "- Tools: run-tests, check-coverage, security-audit, format-code, lint-check, git-summary",
+        "- Tools: run-tests, check-coverage, security-audit, format-code, lint-check, git-summary, changed-files",
         "- Agents: 13 specialized (planner, architect, tdd-guide, code-reviewer, security-reviewer, build-error-resolver, e2e-runner, refactor-cleaner, doc-updater, go-reviewer, go-build-resolver, database-reviewer, python-reviewer)",
         "",
         "## Key Principles",
@@ -449,6 +511,10 @@ export const ECCHooksPlugin = async ({
       // Everything else: let user decide
       return { approved: undefined }
     },
+
+    tool: {
+      "changed-files": changedFilesTool,
+    },
   }
 }
 

.opencode/plugins/lib/changed-files-store.ts

@@ -0,0 +1,98 @@
+import * as path from "path"
+
+export type ChangeType = "added" | "modified" | "deleted"
+
+const changes = new Map<string, ChangeType>()
+let worktreeRoot = ""
+
+export function initStore(worktree: string): void {
+  worktreeRoot = worktree || process.cwd()
+}
+
+function toRelative(p: string): string {
+  if (!p) return ""
+  const normalized = path.normalize(p)
+  if (path.isAbsolute(normalized) && worktreeRoot) {
+    const rel = path.relative(worktreeRoot, normalized)
+    return rel.startsWith("..") ? normalized : rel
+  }
+  return normalized
+}
+
+export function recordChange(filePath: string, type: ChangeType): void {
+  const rel = toRelative(filePath)
+  if (!rel) return
+  changes.set(rel, type)
+}
+
+export function getChanges(): Map<string, ChangeType> {
+  return new Map(changes)
+}
+
+export function clearChanges(): void {
+  changes.clear()
+}
+
+export type TreeNode = {
+  name: string
+  path: string
+  changeType?: ChangeType
+  children: TreeNode[]
+}
+
+function addToTree(children: TreeNode[], segs: string[], fullPath: string, changeType: ChangeType): void {
+  if (segs.length === 0) return
+  const [head, ...rest] = segs
+  let child = children.find((c) => c.name === head)
+
+  if (rest.length === 0) {
+    if (child) {
+      child.changeType = changeType
+      child.path = fullPath
+    } else {
+      children.push({ name: head, path: fullPath, changeType, children: [] })
+    }
+    return
+  }
+
+  if (!child) {
+    const dirPath = segs.slice(0, -rest.length).join(path.sep)
+    child = { name: head, path: dirPath, children: [] }
+    children.push(child)
+  }
+  addToTree(child.children, rest, fullPath, changeType)
+}
+
+export function buildTree(filter?: ChangeType): TreeNode[] {
+  const root: TreeNode[] = []
+  for (const [relPath, changeType] of changes) {
+    if (filter && changeType !== filter) continue
+    const segs = relPath.split(path.sep).filter(Boolean)
+    if (segs.length === 0) continue
+    addToTree(root, segs, relPath, changeType)
+  }
+
+  function sortNodes(nodes: TreeNode[]): TreeNode[] {
+    return [...nodes].sort((a, b) => {
+      const aIsFile = a.changeType !== undefined
+      const bIsFile = b.changeType !== undefined
+      if (aIsFile !== bIsFile) return aIsFile ? 1 : -1
+      return a.name.localeCompare(b.name)
+    }).map((n) => ({ ...n, children: sortNodes(n.children) }))
+  }
+  return sortNodes(root)
+}
+
+export function getChangedPaths(filter?: ChangeType): Array<{ path: string; changeType: ChangeType }> {
+  const list: Array<{ path: string; changeType: ChangeType }> = []
+  for (const [p, t] of changes) {
+    if (filter && t !== filter) continue
+    list.push({ path: p, changeType: t })
+  }
+  list.sort((a, b) => a.path.localeCompare(b.path))
+  return list
+}
+
+export function hasChanges(): boolean {
+  return changes.size > 0
+}