feat(telemetry): implement rich multi-turn telemetry collection

- Update integration to properly record user messages with content
- Record assistant responses with model ID and token counts
- Track tool calls with status, duration, and input/output sizes
- Finalize turns and upload to telemetry service
- Deduplicate user message recording
- Get user info (userId, organizationId) from consent endpoint
- Read qBraid API key from config (provider.qbraid.options.apiKey)
- Update default telemetry endpoint to production Cloud Run URL

The telemetry now captures:
- Full user message content (sanitized)
- Full assistant response content
- Tool call metadata (name, status, duration, sizes)
- File changes with path hashes
- Session metrics (turn count, token counts, tool counts)
- Implicit signals (retries, compactions, abandonment)

Author: Kenny-Heitritter

packages/opencode/src/config/config.ts

@@ -77,18 +77,18 @@ export namespace Config {
     for (const [key, value] of Object.entries(auth)) {
       if (value.type === "wellknown") {
         process.env[value.key] = value.token
-        log.debug("fetching remote config", { url: `${key}/.well-known/opencode` })
-        const response = await fetch(`${key}/.well-known/opencode`)
+        log.debug("fetching remote config", { url: `${key}/.well-known/codeq` })
+        const response = await fetch(`${key}/.well-known/codeq`)
         if (!response.ok) {
           throw new Error(`failed to fetch remote config from ${key}: ${response.status}`)
         }
         const wellknown = (await response.json()) as any
         const remoteConfig = wellknown.config ?? {}
         // Add $schema to prevent load() from trying to write back to a non-existent file
-        if (!remoteConfig.$schema) remoteConfig.$schema = "https://opencode.ai/config.json"
+        if (!remoteConfig.$schema) remoteConfig.$schema = "https://codeq.ai/config.json"
         result = mergeConfigConcatArrays(
           result,
-          await load(JSON.stringify(remoteConfig), `${key}/.well-known/opencode`),
+          await load(JSON.stringify(remoteConfig), `${key}/.well-known/codeq`),
         )
         log.debug("loaded remote config from well-known", { url: key })
       }
@@ -132,7 +132,7 @@ export namespace Config {
       // Always scan ~/.opencode/ (user home directory)
       ...(await Array.fromAsync(
         Filesystem.up({
-          targets: [".opencode"],
+          targets: [".codeq"],
           start: Global.Path.home,
           stop: Global.Path.home,
         }),
@@ -148,7 +148,7 @@ export namespace Config {
     const deps = []
 
     for (const dir of unique(directories)) {
-      if (dir.endsWith(".opencode") || dir === Flag.OPENCODE_CONFIG_DIR) {
+      if (dir.endsWith(".codeq") || dir === Flag.OPENCODE_CONFIG_DIR) {
         for (const file of ["opencode.jsonc", "opencode.json"]) {
           log.debug(`loading config from ${path.join(dir, file)}`)
           result = mergeConfigConcatArrays(result, await loadFile(path.join(dir, file)))
@@ -473,7 +473,7 @@ export namespace Config {
    *
    * @example
    * getPluginName("file:///path/to/plugin/foo.js") // "foo"
-   * getPluginName("oh-my-opencode@2.4.3") // "oh-my-opencode"
+   * getPluginName("oh-my-codeq@2.4.3") // "oh-my-codeq"
    * getPluginName("@scope/pkg@1.0.0") // "@scope/pkg"
    */
   export function getPluginName(plugin: string): string {
@@ -500,11 +500,11 @@ export namespace Config {
    */
   export function deduplicatePlugins(plugins: string[]): string[] {
     // seenNames: canonical plugin names for duplicate detection
-    // e.g., "oh-my-opencode", "@scope/pkg"
+    // e.g., "oh-my-codeq", "@scope/pkg"
     const seenNames = new Set<string>()
 
     // uniqueSpecifiers: full plugin specifiers to return
-    // e.g., "oh-my-opencode@2.4.3", "file:///path/to/plugin.js"
+    // e.g., "oh-my-codeq@2.4.3", "file:///path/to/plugin.js"
     const uniqueSpecifiers: string[] = []
 
     for (const specifier of plugins.toReversed()) {
@@ -1006,7 +1006,7 @@ export namespace Config {
       keybinds: Keybinds.optional().describe("Custom keybind configurations"),
       logLevel: Log.Level.optional().describe("Log level"),
       tui: TUI.optional().describe("TUI specific settings"),
-      server: Server.optional().describe("Server configuration for opencode serve and web commands"),
+      server: Server.optional().describe("Server configuration for codeq serve and web commands"),
       command: z
         .record(z.string(), Command)
         .optional()
@@ -1078,7 +1078,7 @@ export namespace Config {
         })
         .catchall(Agent)
         .optional()
-        .describe("Agent configuration, see https://opencode.ai/docs/agents"),
+        .describe("Agent configuration, see https://codeq.ai/docs/agents"),
       provider: z
         .record(z.string(), Provider)
         .optional()
@@ -1184,7 +1184,7 @@ export namespace Config {
         })
         .optional(),
       // qBraid-specific configuration (CodeQ customizations)
-      // This section is ignored by upstream opencode and contains qBraid-specific features
+      // This section is ignored by upstream codeq and contains qBraid-specific features
       qbraid: z
         .object({
           telemetry: z
@@ -1350,9 +1350,9 @@ export namespace Config {
     const parsed = Info.safeParse(data)
     if (parsed.success) {
       if (!parsed.data.$schema) {
-        parsed.data.$schema = "https://opencode.ai/config.json"
+        parsed.data.$schema = "https://codeq.ai/config.json"
         // Write the $schema to the original text to preserve variables like {env:VAR}
-        const updated = original.replace(/^\s*\{/, '{\n  "$schema": "https://opencode.ai/config.json",')
+        const updated = original.replace(/^\s*\{/, '{\n  "$schema": "https://codeq.ai/config.json",')
         await Bun.write(configFilepath, updated).catch(() => {})
       }
       const data = parsed.data

packages/opencode/src/telemetry/collector.ts

@@ -343,7 +343,7 @@ export class TelemetryCollector {
   /**
    * Finalize the current turn and queue for upload
    */
-  private finalizeTurn(): void {
+  finalizeTurn(): void {
     if (!this.sessionState?.currentTurn) return
 
     const turn = this.sessionState.currentTurn as TelemetryTurn

packages/opencode/src/telemetry/consent.ts

@@ -11,7 +11,7 @@ import type { ConsentStatus, DataLevel, UserTier } from "./types"
 const log = Log.create({ service: "telemetry:consent" })
 
 // Default telemetry endpoint
-const DEFAULT_TELEMETRY_ENDPOINT = "https://telemetry.qbraid.com"
+const DEFAULT_TELEMETRY_ENDPOINT = "https://qbraid-telemetry-314301605548.us-central1.run.app"
 
 // Cache consent status to avoid repeated API calls
 let cachedConsent: ConsentStatus | null = null

packages/opencode/src/telemetry/index.ts

@@ -2,7 +2,7 @@
  * CodeQ Telemetry Module
  *
  * Collects session telemetry for analysis and model improvement.
- * This module is qBraid-specific and not part of upstream opencode.
+ * This module is qBraid-specific and not part of upstream codeq.
  *
  * Usage:
  *   import { Telemetry } from "./telemetry"
@@ -113,7 +113,7 @@ export namespace Telemetry {
   /**
    * Start collecting for a new session
    *
-   * @param sessionId - OpenCode session ID
+   * @param sessionId - CodeQ session ID
    * @param userId - qBraid user ID
    * @param organizationId - Organization ID
    */