feat(web): add source-segmented analytics with MCP/API tracking

Restructure analytics dashboard to segment metrics by source (web, MCP,
API). Add audit events for file source, file tree, and repo listing
actions. Pass source metadata through all audit event paths including
MCP server, chat blocking API, and code navigation. Backfill historical
audit events with sourcebot-web-client source.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: msukkari

packages/db/prisma/migrations/20260226000000_backfill_audit_source_metadata/migration.sql

@@ -14,6 +14,6 @@ WHERE action IN ('user.performed_code_search', 'user.created_ask_chat')
 -- Navigation events (find references, goto definition) were web-only
 -- (created from the symbolHoverPopup client component)
 UPDATE "Audit"
-SET metadata = jsonb_set(COALESCE(metadata, '{}')::jsonb, '{source}', '"sourcebot-ui-codenav"')
+SET metadata = jsonb_set(COALESCE(metadata, '{}')::jsonb, '{source}', '"sourcebot-web-client"')
 WHERE action IN ('user.performed_find_references', 'user.performed_goto_definition')
   AND (metadata IS NULL OR metadata->>'source' IS NULL);

packages/db/tools/scripts/inject-audit-data-v2.ts

@@ -180,10 +180,10 @@ export const injectAuditDataV2: Script = {
                 const activityChance = isWeekend ? user.weekendActivity : user.weekdayActivity;
                 if (Math.random() >= activityChance) continue;
 
-                // --- Web UI activity (source='sourcebot-web-client' or 'sourcebot-ui-codenav') ---
+                // --- Web UI activity (source='sourcebot-web-client') ---
                 if (user.webWeight > 0) {
                     const webMeta: Prisma.InputJsonValue = { source: 'sourcebot-web-client' };
-                    const codenavMeta: Prisma.InputJsonValue = { source: 'sourcebot-ui-codenav' };
+                    const codenavMeta: Prisma.InputJsonValue = { source: 'sourcebot-web-client' };
 
                     // Code searches (2-5 base)
                     await createAudits(user.id, 'user.performed_code_search',

packages/web/src/app/[domain]/browse/[...path]/components/codePreviewPanel.tsx

@@ -18,7 +18,7 @@ export const CodePreviewPanel = async ({ path, repoName, revisionName }: CodePre
             path,
             repo: repoName,
             ref: revisionName,
-        }),
+        }, { sourceOverride: 'sourcebot-web-client' }),
         getRepoInfoByName(repoName),
     ]);
 

packages/web/src/app/api/(server)/chat/blocking/route.ts

@@ -45,7 +45,8 @@ export const POST = apiHandler(async (request: NextRequest) => {
         return serviceErrorResponse(requestBodySchemaValidationError(parsed.error));
     }
 
-    const response = await askCodebase(parsed.data);
+    const source = request.headers.get('X-Sourcebot-Client-Source') ?? undefined;
+    const response = await askCodebase({ ...parsed.data, source });
 
     if (isServiceError(response)) {
         return serviceErrorResponse(response);

packages/web/src/ee/features/analytics/actions.ts

@@ -81,26 +81,43 @@ export const getAnalytics = async (domain: string, apiKey: string | undefined =
             ELSE              c.month
           END AS bucket,
 
-          -- Global active users (any action, any source)
-          COUNT(DISTINCT c."actorId") AS active_users,
+          -- Global active users (any action, any source; excludes web repo listings)
+          COUNT(DISTINCT c."actorId") FILTER (
+            WHERE NOT (c.action = 'user.listed_repos' AND c.metadata->>'source' LIKE 'sourcebot-%')
+          ) AS active_users,
 
-          -- Web App metrics (source LIKE 'sourcebot-%')
+          -- Web App metrics
+          COUNT(DISTINCT c."actorId") FILTER (
+            WHERE c.action = 'user.performed_code_search'
+              AND c.metadata->>'source' = 'sourcebot-web-client'
+          ) AS web_search_active_users,
           COUNT(*) FILTER (
             WHERE c.action = 'user.performed_code_search'
-              AND c.metadata->>'source' LIKE 'sourcebot-%'
+              AND c.metadata->>'source' = 'sourcebot-web-client'
           ) AS web_code_searches,
           COUNT(*) FILTER (
             WHERE c.action IN ('user.performed_find_references', 'user.performed_goto_definition')
-              AND c.metadata->>'source' LIKE 'sourcebot-%'
+              AND c.metadata->>'source' = 'sourcebot-web-client'
           ) AS web_navigations,
+          COUNT(DISTINCT c."actorId") FILTER (
+            WHERE c.action = 'user.created_ask_chat'
+              AND c.metadata->>'source' = 'sourcebot-web-client'
+          ) AS web_ask_active_users,
           COUNT(*) FILTER (
             WHERE c.action = 'user.created_ask_chat'
-              AND c.metadata->>'source' LIKE 'sourcebot-%'
+              AND c.metadata->>'source' = 'sourcebot-web-client'
           ) AS web_ask_chats,
           COUNT(DISTINCT c."actorId") FILTER (
-            WHERE c.metadata->>'source' LIKE 'sourcebot-%'
+            WHERE c.metadata->>'source' = 'sourcebot-web-client'
+              AND c.action != 'user.listed_repos'
           ) AS web_active_users,
 
+          -- MCP + API combined active users (any non-web source)
+          COUNT(DISTINCT c."actorId") FILTER (
+            WHERE c.metadata->>'source' IS NULL
+              OR c.metadata->>'source' NOT LIKE 'sourcebot-%'
+          ) AS non_web_active_users,
+
           -- MCP metrics (source = 'mcp')
           COUNT(*) FILTER (
             WHERE c.metadata->>'source' = 'mcp'
@@ -130,10 +147,13 @@ export const getAnalytics = async (domain: string, apiKey: string | undefined =
         b.period,
         b.bucket,
         COALESCE(a.active_users, 0)::int AS active_users,
+        COALESCE(a.web_search_active_users, 0)::int AS web_search_active_users,
         COALESCE(a.web_code_searches, 0)::int AS web_code_searches,
         COALESCE(a.web_navigations, 0)::int AS web_navigations,
+        COALESCE(a.web_ask_active_users, 0)::int AS web_ask_active_users,
         COALESCE(a.web_ask_chats, 0)::int AS web_ask_chats,
         COALESCE(a.web_active_users, 0)::int AS web_active_users,
+        COALESCE(a.non_web_active_users, 0)::int AS non_web_active_users,
         COALESCE(a.mcp_requests, 0)::int AS mcp_requests,
         COALESCE(a.mcp_active_users, 0)::int AS mcp_active_users,
         COALESCE(a.api_requests, 0)::int AS api_requests,