Added telemetry

Author: vishal veerareddy

package.json

@@ -1,6 +1,6 @@
 {
   "name": "lynkr",
-  "version": "9.7.2",
+  "version": "9.7.3",
   "description": "Self-hosted LLM gateway and tier-routing proxy for Claude Code, Cursor, and Codex. Routes across Ollama, AWS Bedrock, OpenRouter, Databricks, Azure OpenAI, llama.cpp, and LM Studio with prompt caching, MCP tools, and 60-80% cost savings.",
   "main": "index.js",
   "bin": {

src/clients/databricks.js

@@ -2708,7 +2708,7 @@ async function invokeModel(body, options = {}) {
       message_count: Array.isArray(body?.messages) ? body.messages.length : 0,
       request_type: routingResult.analysis?.requestType || null,
       provider: initialProvider,
-      model: routingDecision.model,
+      model: routingDecision.model ?? body._tierModel ?? null,
       routing_method: routingDecision.method,
       was_fallback: false,
       output_tokens: outputTokens || null,
@@ -2826,7 +2826,7 @@ async function invokeModel(body, options = {}) {
         message_count: Array.isArray(body?.messages) ? body.messages.length : 0,
         request_type: routingResult.analysis?.requestType || null,
         provider: initialProvider,
-        model: routingDecision.model,
+        model: routingDecision.model ?? body._tierModel ?? null,
         routing_method: routingDecision.method,
         was_fallback: false,
         latency_ms: failLatency,
@@ -2934,7 +2934,7 @@ async function invokeModel(body, options = {}) {
         message_count: Array.isArray(body?.messages) ? body.messages.length : 0,
         request_type: routingResult.analysis?.requestType || null,
         provider: fallbackProvider,
-        model: routingDecision.model,
+        model: routingDecision.model ?? body._tierModel ?? null,
         routing_method: "fallback",
         was_fallback: true,
         output_tokens: fbOutputTokens || null,
@@ -2980,7 +2980,7 @@ async function invokeModel(body, options = {}) {
         complexity_score: routingResult.score ?? null,
         tier: routingDecision.tier,
         provider: fallbackProvider,
-        model: routingDecision.model,
+        model: routingDecision.model ?? body._tierModel ?? null,
         routing_method: "fallback",
         was_fallback: true,
         latency_ms: Date.now() - startTime,

src/routing/telemetry.js

@@ -49,12 +49,27 @@ function init() {
   }
 
   try {
-    const dbDir = path.resolve(process.cwd(), ".lynkr");
-    if (!fs.existsSync(dbDir)) {
-      fs.mkdirSync(dbDir, { recursive: true });
+    // Allow tests to redirect telemetry to an isolated DB so unit/integration
+    // runs never pollute the production .lynkr/telemetry.db that build-knn-index.js
+    // reads from. Empty string disables telemetry entirely.
+    const override = process.env.LYNKR_TELEMETRY_DB_PATH;
+    let dbPath;
+    if (override === "") {
+      logger.debug("Telemetry: LYNKR_TELEMETRY_DB_PATH is empty, telemetry disabled");
+      return false;
+    } else if (override) {
+      dbPath = path.resolve(override);
+      const overrideDir = path.dirname(dbPath);
+      if (!fs.existsSync(overrideDir)) {
+        fs.mkdirSync(overrideDir, { recursive: true });
+      }
+    } else {
+      const dbDir = path.resolve(process.cwd(), ".lynkr");
+      if (!fs.existsSync(dbDir)) {
+        fs.mkdirSync(dbDir, { recursive: true });
+      }
+      dbPath = path.join(dbDir, "telemetry.db");
     }
-
-    const dbPath = path.join(dbDir, "telemetry.db");
     db = new Database(dbPath, {
       verbose: process.env.DEBUG_SQL ? console.log : null,
       fileMustExist: false,

test/telemetry-routing.test.js

@@ -1,6 +1,17 @@
 const assert = require("assert");
+const os = require("os");
+const path = require("path");
 const { describe, it, beforeEach, afterEach, mock } = require("node:test");
 
+// Redirect telemetry writes to an isolated temp DB before requiring the
+// telemetry module. Otherwise this suite pollutes .lynkr/telemetry.db with
+// fixtures like "stats-provider-...", which then end up in build-knn-index.js
+// output and the kNN index.
+process.env.LYNKR_TELEMETRY_DB_PATH = path.join(
+  os.tmpdir(),
+  `lynkr-telemetry-test-${process.pid}.db`
+);
+
 // ============================================================================
 // Module imports
 // ============================================================================