feat(cli): integrate MetricsStore with automatic persistence

Phase 1 Complete! Foundation + Event Bus

CLI Integration:
- Wired up MetricsStore in dev index and dev update commands
- Created event bus for each command invocation
- Subscribed MetricsStore to index.updated events
- Automatic snapshot recording on every index/update
- Proper error logging (non-blocking, metrics are non-critical)
- Proper cleanup (close() on completion)

Metrics Database:
- Stored in ~/.dev-agent/indexes/<repo>/metrics.db
- SQLite with WAL mode for concurrency
- Automatic persistence via event-driven architecture

Phase 1 Deliverables (ALL COMPLETE):
✅ better-sqlite3 dependency added
✅ MetricsStore class with CRUD operations
✅ SQLite schema with indexes and WAL mode
✅ Comprehensive tests (25 tests, all passing)
✅ Event bus integration in RepositoryIndexer
✅ CLI commands automatically record metrics
✅ Fire-and-forget pattern for non-blocking persistence
✅ Proper error handling with logging

Next: Phase 2 - code_metadata table and hotspot detection

Author: prosdev

packages/cli/src/commands/index.ts

@@ -2,11 +2,14 @@ import { execSync } from 'node:child_process';
 import { existsSync } from 'node:fs';
 import { join } from 'node:path';
 import {
+  AsyncEventBus,
   ensureStorageDirectory,
   GitIndexer,
   getStorageFilePaths,
   getStoragePath,
+  type IndexUpdatedEvent,
   LocalGitExtractor,
+  MetricsStore,
   RepositoryIndexer,
   updateIndexedStats,
   VectorStorage,
@@ -116,16 +119,39 @@ export const indexCommand = new Command('index')
       const filePaths = getStorageFilePaths(storagePath);
 
       spinner.text = 'Initializing indexer...';
-      const indexer = new RepositoryIndexer({
-        repositoryPath: resolvedRepoPath,
-        vectorStorePath: filePaths.vectors,
-        statePath: filePaths.indexerState,
-        excludePatterns: config.repository?.excludePatterns || config.excludePatterns,
-        languages: config.repository?.languages || config.languages,
-        embeddingModel: config.embeddingModel,
-        embeddingDimension: config.dimension,
+
+      // Create event bus for metrics (no logger in CLI to keep it simple)
+      const eventBus = new AsyncEventBus();
+
+      // Initialize metrics store (no logger in CLI to avoid noise)
+      const metricsDbPath = join(storagePath, 'metrics.db');
+      const metricsStore = new MetricsStore(metricsDbPath);
+
+      // Subscribe to index.updated events for automatic metrics persistence
+      eventBus.on<IndexUpdatedEvent>('index.updated', async (event) => {
+        try {
+          metricsStore.recordSnapshot(event.stats, event.isIncremental ? 'update' : 'index');
+        } catch (error) {
+          // Log error but don't fail indexing - metrics are non-critical
+          logger.error(
+            `Failed to record metrics snapshot: ${error instanceof Error ? error.message : String(error)}`
+          );
+        }
       });
 
+      const indexer = new RepositoryIndexer(
+        {
+          repositoryPath: resolvedRepoPath,
+          vectorStorePath: filePaths.vectors,
+          statePath: filePaths.indexerState,
+          excludePatterns: config.repository?.excludePatterns || config.excludePatterns,
+          languages: config.repository?.languages || config.languages,
+          embeddingModel: config.embeddingModel,
+          embeddingDimension: config.dimension,
+        },
+        eventBus
+      );
+
       await indexer.initialize();
 
       spinner.text = 'Scanning repository...';
@@ -165,6 +191,7 @@ export const indexCommand = new Command('index')
       });
 
       await indexer.close();
+      metricsStore.close();
 
       const codeDuration = (Date.now() - startTime) / 1000;
 

packages/cli/src/commands/update.ts

@@ -1,8 +1,11 @@
 import * as path from 'node:path';
 import {
+  AsyncEventBus,
   ensureStorageDirectory,
   getStorageFilePaths,
   getStoragePath,
+  type IndexUpdatedEvent,
+  MetricsStore,
   RepositoryIndexer,
 } from '@lytics/dev-agent-core';
 import chalk from 'chalk';
@@ -38,14 +41,37 @@ export const updateCommand = new Command('update')
       const filePaths = getStorageFilePaths(storagePath);
 
       spinner.text = 'Initializing indexer...';
-      const indexer = new RepositoryIndexer({
-        repositoryPath: resolvedRepoPath,
-        vectorStorePath: filePaths.vectors,
-        statePath: filePaths.indexerState,
-        excludePatterns: config.repository?.excludePatterns || config.excludePatterns,
-        languages: config.repository?.languages || config.languages,
+
+      // Create event bus for metrics (no logger in CLI to keep it simple)
+      const eventBus = new AsyncEventBus();
+
+      // Initialize metrics store (no logger in CLI to avoid noise)
+      const metricsDbPath = path.join(storagePath, 'metrics.db');
+      const metricsStore = new MetricsStore(metricsDbPath);
+
+      // Subscribe to index.updated events for automatic metrics persistence
+      eventBus.on<IndexUpdatedEvent>('index.updated', async (event) => {
+        try {
+          metricsStore.recordSnapshot(event.stats, event.isIncremental ? 'update' : 'index');
+        } catch (error) {
+          // Log error but don't fail update - metrics are non-critical
+          logger.error(
+            `Failed to record metrics snapshot: ${error instanceof Error ? error.message : String(error)}`
+          );
+        }
       });
 
+      const indexer = new RepositoryIndexer(
+        {
+          repositoryPath: resolvedRepoPath,
+          vectorStorePath: filePaths.vectors,
+          statePath: filePaths.indexerState,
+          excludePatterns: config.repository?.excludePatterns || config.excludePatterns,
+          languages: config.repository?.languages || config.languages,
+        },
+        eventBus
+      );
+
       await indexer.initialize();
 
       spinner.text = 'Detecting changed files...';
@@ -66,6 +92,7 @@ export const updateCommand = new Command('update')
       });
 
       await indexer.close();
+      metricsStore.close();
 
       const duration = (Date.now() - startTime) / 1000;