feat(telemetry): add LOC statistics to OpenTelemetry spans

Author: mtkairplaytest

packages/opencode/src/telemetry/index.ts

@@ -1,2 +1,3 @@
 export { TelemetryConfig } from "./config"
 export { TelemetryProvider } from "./provider"
+export { LocTelemetry } from "./loc"

packages/opencode/src/telemetry/loc.ts

@@ -0,0 +1,72 @@
+import { TelemetryProvider } from "./provider"
+import { SpanKind, SpanStatusCode } from "@opentelemetry/api"
+
+export namespace LocTelemetry {
+  export interface FileChange {
+    filePath: string
+    additions: number
+    deletions: number
+    toolName: string
+    changeType?: "add" | "update" | "delete" | "move"
+  }
+
+  export function recordFileChange(change: FileChange, sessionID: string): void {
+    const tracer = TelemetryProvider.getTracer()
+    if (!tracer) return
+
+    const span = tracer.startSpan("file.change", {
+      kind: SpanKind.INTERNAL,
+      attributes: {
+        "opencode.session.id": sessionID,
+        "opencode.tool.name": change.toolName,
+        "opencode.file.path": change.filePath,
+        "opencode.loc.additions": change.additions,
+        "opencode.loc.deletions": change.deletions,
+        "opencode.loc.net_change": change.additions - change.deletions,
+      },
+    })
+
+    if (change.changeType) {
+      span.setAttribute("opencode.file.change_type", change.changeType)
+    }
+
+    span.setStatus({ code: SpanStatusCode.OK })
+    span.end()
+  }
+
+  export function recordBatchChanges(changes: FileChange[], sessionID: string, toolName: string): void {
+    const tracer = TelemetryProvider.getTracer()
+    if (!tracer) return
+
+    if (changes.length === 0) return
+
+    let totalAdditions = 0
+    let totalDeletions = 0
+    const fileDetails = changes.map((change) => {
+      totalAdditions += change.additions
+      totalDeletions += change.deletions
+      return {
+        path: change.filePath,
+        additions: change.additions,
+        deletions: change.deletions,
+        type: change.changeType,
+      }
+    })
+
+    const span = tracer.startSpan("file.batch_change", {
+      kind: SpanKind.INTERNAL,
+      attributes: {
+        "opencode.session.id": sessionID,
+        "opencode.tool.name": toolName,
+        "opencode.batch.file_count": changes.length,
+        "opencode.batch.total_additions": totalAdditions,
+        "opencode.batch.total_deletions": totalDeletions,
+        "opencode.batch.net_change": totalAdditions - totalDeletions,
+        "opencode.batch.files": JSON.stringify(fileDetails),
+      },
+    })
+
+    span.setStatus({ code: SpanStatusCode.OK })
+    span.end()
+  }
+}

packages/opencode/src/tool/apply_patch.ts

@@ -13,6 +13,7 @@ import { LSP } from "../lsp"
 import { Filesystem } from "../util/filesystem"
 import DESCRIPTION from "./apply_patch.txt"
 import { File } from "../file"
+import { LocTelemetry } from "@/telemetry"
 
 const PatchParams = z.object({
   patchText: z.string().describe("The full patch text that describes all changes to be made"),
@@ -230,6 +231,18 @@ export const ApplyPatchTool = Tool.define("apply_patch", {
       await Bus.publish(FileWatcher.Event.Updated, { file: filePath, event: "change" })
     }
 
+    LocTelemetry.recordBatchChanges(
+      fileChanges.map((change) => ({
+        filePath: change.movePath ?? change.filePath,
+        additions: change.additions,
+        deletions: change.deletions,
+        toolName: "apply_patch",
+        changeType: change.type,
+      })),
+      ctx.sessionID,
+      "apply_patch",
+    )
+
     // Notify LSP of file changes and collect diagnostics
     for (const change of fileChanges) {
       if (change.type === "delete") continue

packages/opencode/src/tool/edit.ts

@@ -16,6 +16,7 @@ import { Filesystem } from "../util/filesystem"
 import { Instance } from "../project/instance"
 import { Snapshot } from "@/snapshot"
 import { assertExternalDirectory } from "./external-directory"
+import { LocTelemetry } from "@/telemetry"
 
 const MAX_DIAGNOSTICS_PER_FILE = 20
 
@@ -111,6 +112,17 @@ export const EditTool = Tool.define("edit", {
       if (change.removed) filediff.deletions += change.count || 0
     }
 
+    LocTelemetry.recordFileChange(
+      {
+        filePath: filediff.file,
+        additions: filediff.additions,
+        deletions: filediff.deletions,
+        toolName: "edit",
+        changeType: contentOld === "" ? "add" : "update",
+      },
+      ctx.sessionID,
+    )
+
     ctx.metadata({
       metadata: {
         diff,

packages/opencode/src/tool/write.ts

@@ -2,8 +2,9 @@ import z from "zod"
 import * as path from "path"
 import { Tool } from "./tool"
 import { LSP } from "../lsp"
-import { createTwoFilesPatch } from "diff"
+import { createTwoFilesPatch, diffLines } from "diff"
 import DESCRIPTION from "./write.txt"
+import { LocTelemetry } from "@/telemetry"
 import { Bus } from "../bus"
 import { File } from "../file"
 import { FileTime } from "../file/time"
@@ -47,6 +48,24 @@ export const WriteTool = Tool.define("write", {
     })
     FileTime.read(ctx.sessionID, filepath)
 
+    let additions = 0
+    let deletions = 0
+    for (const change of diffLines(contentOld, params.content)) {
+      if (change.added) additions += change.count || 0
+      if (change.removed) deletions += change.count || 0
+    }
+
+    LocTelemetry.recordFileChange(
+      {
+        filePath: filepath,
+        additions,
+        deletions,
+        toolName: "write",
+        changeType: exists ? "update" : "add",
+      },
+      ctx.sessionID,
+    )
+
     let output = "Wrote file successfully."
     await LSP.touchFile(filepath, true)
     const diagnostics = await LSP.diagnostics()