feat(telemetry): add OpenTelemetry instrumentation with Aspire Dashboard support

packages/opencode/package.json

@@ -10,6 +10,9 @@
     "test": "bun test",
     "build": "bun run script/build.ts",
     "dev": "bun run --conditions=browser ./src/index.ts",
+    "aspire:start": "docker run --rm -d -p 18888:18888 -p 4317:18889 -e ASPIRE_DASHBOARD_UNSECURED_ALLOW_ANONYMOUS=true --name aspire-dashboard mcr.microsoft.com/dotnet/aspire-dashboard:latest && echo 'Aspire Dashboard: http://localhost:18888'",
+    "aspire:stop": "docker stop aspire-dashboard 2>/dev/null || true",
+    "dev:otel": "bun run aspire:start; OTEL_EXPORTER_OTLP_ENDPOINT=http://localhost:4317 OTEL_INSTRUMENTATION_GENAI_CAPTURE_MESSAGE_CONTENT=true bun dev",
     "random": "echo 'Random script updated at $(date)' && echo 'Change queued successfully' && echo 'Another change made' && echo 'Yet another change' && echo 'One more change' && echo 'Final change' && echo 'Another final change' && echo 'Yet another final change'",
     "clean": "echo 'Cleaning up...' && rm -rf node_modules dist",
     "lint": "echo 'Running lint checks...' && bun test --coverage",
@@ -81,6 +84,14 @@
     "@opencode-ai/sdk": "workspace:*",
     "@opencode-ai/util": "workspace:*",
     "@openrouter/ai-sdk-provider": "1.5.2",
+    "@opentelemetry/api": "1.9.0",
+    "@opentelemetry/api-logs": "0.208.0",
+    "@opentelemetry/sdk-logs": "0.208.0",
+    "@opentelemetry/resources": "2.2.0",
+    "@opentelemetry/sdk-node": "0.208.0",
+    "@opentelemetry/semantic-conventions": "1.37.0",
+    "@opentelemetry/exporter-trace-otlp-grpc": "0.208.0",
+    "@opentelemetry/exporter-logs-otlp-grpc": "0.208.0",
     "@opentui/core": "0.1.69",
     "@opentui/solid": "0.1.69",
     "@parcel/watcher": "2.5.1",

packages/opencode/src/agent/agent.ts

@@ -12,6 +12,7 @@ import PROMPT_SUMMARY from "./prompt/summary.txt"
 import PROMPT_TITLE from "./prompt/title.txt"
 import { PermissionNext } from "@/permission/next"
 import { mergeDeep, pipe, sortBy, values } from "remeda"
+import { Telemetry } from "@/telemetry"
 
 export namespace Agent {
   export const Info = z
@@ -214,18 +215,24 @@ export namespace Agent {
   }
 
   export async function generate(input: { description: string; model?: { providerID: string; modelID: string } }) {
-    const cfg = await Config.get()
     const defaultModel = input.model ?? (await Provider.defaultModel())
+    using _ = Telemetry.span("agent.generate", {
+      "llm.provider_id": defaultModel.providerID,
+      "llm.model_id": defaultModel.modelID,
+    })
+    const cfg = await Config.get()
     const model = await Provider.getModel(defaultModel.providerID, defaultModel.modelID)
     const language = await Provider.getLanguage(model)
     const system = SystemPrompt.header(defaultModel.providerID)
     system.push(PROMPT_GENERATE)
     const existing = await list()
     const result = await generateObject({
       experimental_telemetry: {
-        isEnabled: cfg.experimental?.openTelemetry,
+        isEnabled: Telemetry.isEnabled(),
+        functionId: "opencode.agent.generate",
         metadata: {
-          userId: cfg.username ?? "unknown",
+          "llm.provider_id": defaultModel.providerID,
+          "llm.model_id": defaultModel.modelID,
         },
       },
       temperature: 0.3,

packages/opencode/src/cli/cmd/tui/worker.ts

@@ -17,6 +17,12 @@ await Log.init({
   })(),
 })
 
+const globalConfig = await Config.global()
+if (globalConfig?.experimental?.openTelemetry) {
+  const { Telemetry } = await import("@/telemetry")
+  Telemetry.init(Telemetry.resolveConfig("opencode-server", true))
+}
+
 process.on("unhandledRejection", (e) => {
   Log.Default.error("rejection", {
     e: e instanceof Error ? e.message : e,
@@ -58,7 +64,10 @@ export const rpc = {
   },
   async shutdown() {
     Log.Default.info("worker shutting down")
+    Log.Default.info("disposing all instances")
     await Instance.disposeAll()
+    const { Telemetry } = await import("@/telemetry")
+    await Telemetry.shutdown()
     // TODO: this should be awaited, but ws connections are
     // causing this to hang, need to revisit this
     server.stop(true)

packages/opencode/src/config/config.ts

@@ -954,7 +954,7 @@ export namespace Config {
           openTelemetry: z
             .boolean()
             .optional()
-            .describe("Enable OpenTelemetry spans for AI SDK calls (using the 'experimental_telemetry' flag)"),
+            .describe("Enable OpenTelemetry tracing. Set OTEL_EXPORTER_OTLP_ENDPOINT env var for endpoint."),
           primary_tools: z
             .array(z.string())
             .optional()

packages/opencode/src/flag/flag.ts

@@ -15,6 +15,7 @@ export namespace Flag {
   export const OPENCODE_DISABLE_MODELS_FETCH = truthy("OPENCODE_DISABLE_MODELS_FETCH")
   export const OPENCODE_FAKE_VCS = process.env["OPENCODE_FAKE_VCS"]
   export const OPENCODE_CLIENT = process.env["OPENCODE_CLIENT"] ?? "cli"
+  export const OTEL_EXPORTER_OTLP_ENDPOINT = process.env["OTEL_EXPORTER_OTLP_ENDPOINT"]
 
   // Experimental
   export const OPENCODE_EXPERIMENTAL = truthy("OPENCODE_EXPERIMENTAL")

packages/opencode/src/index.ts

@@ -27,6 +27,8 @@ import { EOL } from "os"
 import { WebCommand } from "./cli/cmd/web"
 import { PrCommand } from "./cli/cmd/pr"
 import { SessionCommand } from "./cli/cmd/session"
+import { Config } from "./config/config"
+import { Telemetry } from "./telemetry"
 
 process.on("unhandledRejection", (e) => {
   Log.Default.error("rejection", {
@@ -40,6 +42,14 @@ process.on("uncaughtException", (e) => {
   })
 })
 
+process.on("SIGTERM", async () => {
+  await Telemetry.shutdown()
+})
+
+process.on("SIGINT", async () => {
+  await Telemetry.shutdown()
+})
+
 const cli = yargs(hideBin(process.argv))
   .parserConfiguration({ "populate--": true })
   .scriptName("opencode")
@@ -75,6 +85,11 @@ const cli = yargs(hideBin(process.argv))
       version: Installation.VERSION,
       args: process.argv.slice(2),
     })
+
+    const globalConfig = await Config.global()
+    if (globalConfig?.experimental?.openTelemetry) {
+      Telemetry.init(Telemetry.resolveConfig("opencode-cli", true))
+    }
   })
   .usage("\n" + UI.logo())
   .completion("completion", "generate shell completion script")
@@ -151,6 +166,8 @@ try {
   }
   process.exitCode = 1
 } finally {
+  // Shutdown telemetry before exit
+  await Telemetry.shutdown()
   // Some subprocesses don't react properly to SIGTERM and similar signals.
   // Most notably, some docker-container-based MCP servers don't handle such signals unless
   // run using `docker run --init`.

packages/opencode/src/lsp/client.ts

@@ -12,6 +12,7 @@ import { NamedError } from "@opencode-ai/util/error"
 import { withTimeout } from "../util/timeout"
 import { Instance } from "../project/instance"
 import { Filesystem } from "../util/filesystem"
+import { Telemetry } from "@/telemetry"
 
 const DIAGNOSTICS_DEBOUNCE_MS = 150
 
@@ -40,6 +41,10 @@ export namespace LSPClient {
   }
 
   export async function create(input: { serverID: string; server: LSPServer.Handle; root: string }) {
+    using _span = Telemetry.span("lsp.client.create", {
+      "lsp.server_id": input.serverID,
+      "lsp.root": input.root,
+    })
     const l = log.clone().tag("serverID", input.serverID)
     l.info("starting client")
 
@@ -79,50 +84,58 @@ export namespace LSPClient {
     connection.listen()
 
     l.info("sending initialize")
-    await withTimeout(
-      connection.sendRequest("initialize", {
-        rootUri: pathToFileURL(input.root).href,
-        processId: input.server.process.pid,
-        workspaceFolders: [
-          {
-            name: "workspace",
-            uri: pathToFileURL(input.root).href,
-          },
-        ],
-        initializationOptions: {
-          ...input.server.initialization,
-        },
-        capabilities: {
-          window: {
-            workDoneProgress: true,
-          },
-          workspace: {
-            configuration: true,
-            didChangeWatchedFiles: {
-              dynamicRegistration: true,
+    await Telemetry.withSpan(
+      "lsp.request.initialize",
+      {
+        "lsp.server_id": input.serverID,
+      },
+      async () => {
+        await withTimeout(
+          connection.sendRequest("initialize", {
+            rootUri: pathToFileURL(input.root).href,
+            processId: input.server.process.pid,
+            workspaceFolders: [
+              {
+                name: "workspace",
+                uri: pathToFileURL(input.root).href,
+              },
+            ],
+            initializationOptions: {
+              ...input.server.initialization,
             },
-          },
-          textDocument: {
-            synchronization: {
-              didOpen: true,
-              didChange: true,
+            capabilities: {
+              window: {
+                workDoneProgress: true,
+              },
+              workspace: {
+                configuration: true,
+                didChangeWatchedFiles: {
+                  dynamicRegistration: true,
+                },
+              },
+              textDocument: {
+                synchronization: {
+                  didOpen: true,
+                  didChange: true,
+                },
+                publishDiagnostics: {
+                  versionSupport: true,
+                },
+              },
             },
-            publishDiagnostics: {
-              versionSupport: true,
+          }),
+          45_000,
+        ).catch((err) => {
+          l.error("initialize error", { error: err })
+          throw new InitializeError(
+            { serverID: input.serverID },
+            {
+              cause: err,
             },
-          },
-        },
-      }),
-      45_000,
-    ).catch((err) => {
-      l.error("initialize error", { error: err })
-      throw new InitializeError(
-        { serverID: input.serverID },
-        {
-          cause: err,
-        },
-      )
-    })
+          )
+        })
+      },
+    )
 
     await connection.sendNotification("initialized", {})
 

packages/opencode/src/lsp/index.ts

@@ -10,6 +10,7 @@ import { Config } from "../config/config"
 import { spawn } from "child_process"
 import { Instance } from "../project/instance"
 import { Flag } from "@/flag/flag"
+import { Telemetry, traced } from "@/telemetry"
 
 export namespace LSP {
   const log = Log.create({ service: "lsp" })
@@ -275,6 +276,7 @@ export namespace LSP {
   }
 
   export async function touchFile(input: string, waitForDiagnostics?: boolean) {
+    using _span = Telemetry.span("lsp.touch_file", { "lsp.file": input })
     log.info("touching file", { file: input })
     const clients = await getClients(input)
     await Promise.all(
@@ -300,7 +302,14 @@ export namespace LSP {
     return results
   }
 
-  export async function hover(input: { file: string; line: number; character: number }) {
+  export const hover = traced<{ file: string; line: number; character: number }, (unknown | null)[]>(
+    "lsp.request.hover",
+    (input) => ({
+      "lsp.file": input.file,
+      "lsp.line": input.line,
+      "lsp.character": input.character,
+    }),
+  )(async (input) => {
     return run(input.file, (client) => {
       return client.connection
         .sendRequest("textDocument/hover", {
@@ -314,7 +323,7 @@ export namespace LSP {
         })
         .catch(() => null)
     })
-  }
+  })
 
   enum SymbolKind {
     File = 1,
@@ -383,7 +392,14 @@ export namespace LSP {
       .then((result) => result.filter(Boolean))
   }
 
-  export async function definition(input: { file: string; line: number; character: number }) {
+  export const definition = traced<{ file: string; line: number; character: number }, unknown[]>(
+    "lsp.request.definition",
+    (input) => ({
+      "lsp.file": input.file,
+      "lsp.line": input.line,
+      "lsp.character": input.character,
+    }),
+  )(async (input) => {
     return run(input.file, (client) =>
       client.connection
         .sendRequest("textDocument/definition", {
@@ -392,9 +408,16 @@ export namespace LSP {
         })
         .catch(() => null),
     ).then((result) => result.flat().filter(Boolean))
-  }
-
-  export async function references(input: { file: string; line: number; character: number }) {
+  })
+
+  export const references = traced<{ file: string; line: number; character: number }, unknown[]>(
+    "lsp.request.references",
+    (input) => ({
+      "lsp.file": input.file,
+      "lsp.line": input.line,
+      "lsp.character": input.character,
+    }),
+  )(async (input) => {
     return run(input.file, (client) =>
       client.connection
         .sendRequest("textDocument/references", {
@@ -404,7 +427,7 @@ export namespace LSP {
         })
         .catch(() => []),
     ).then((result) => result.flat().filter(Boolean))
-  }
+  })
 
   export async function implementation(input: { file: string; line: number; character: number }) {
     return run(input.file, (client) =>