3 files changed, 58 insertions, 2 deletions

diff --git a/cmd/relay/main.go b/cmd/relay/main.go
index e4fe9bc..8948ebf 100644
--- a/cmd/relay/main.go
+++ b/cmd/relay/main.go
@@ -9,6 +9,7 @@ import (
         "os"
         "os/signal"
         "syscall"
+        "time"
 
         "connectrpc.com/connect"
         "golang.org/x/net/http2"
@@ -95,6 +96,23 @@ func main() {
         wsHandler := wshandler.NewHandler(store, subManager)
         if m != nil {
                 wsHandler.SetMetrics(m)
+
+                // Update storage stats periodically
+                go func() {
+                        ticker := time.NewTicker(30 * time.Second)
+                        defer ticker.Stop()
+
+                        // Update immediately on start
+                        if stats, err := store.GetStats(context.Background()); err == nil {
+                                m.UpdateStorageStats(stats.EventCount, stats.DBSizeBytes)
+                        }
+
+                        for range ticker.C {
+                                if stats, err := store.GetStats(context.Background()); err == nil {
+                                        m.UpdateStorageStats(stats.EventCount, stats.DBSizeBytes)
+                                }
+                        }
+                }()
         }
 
         var grpcDisplay, httpDisplay, wsDisplay string
diff --git a/internal/metrics/dashboard.html b/internal/metrics/dashboard.html
index 363f1f7..63b42ed 100644
--- a/internal/metrics/dashboard.html
+++ b/internal/metrics/dashboard.html
@@ -295,6 +295,12 @@
                 document.getElementById('event_deletions').textContent =
                     sumMetric(metrics, `${prefix}_relay_event_deletions_total`);
 
+                const durationSum = sumMetric(metrics, `${prefix}_relay_request_duration_seconds_sum`);
+                const durationCount = sumMetric(metrics, `${prefix}_relay_request_duration_seconds_count`);
+                const avgLatencyMs = durationCount > 0 ? (durationSum / durationCount * 1000) : 0;
+                document.getElementById('avg_latency').innerHTML =
+                    `${avgLatencyMs.toFixed(1)}<span class="metric-unit">ms</span>`;
+
                 const processStart = sumMetric(metrics, 'process_start_time_seconds');
                 if (processStart > 0) {
                     if (!processStartTime) processStartTime = processStart;
diff --git a/internal/storage/storage.go b/internal/storage/storage.go
index 9ef9956..ca9b264 100644
--- a/internal/storage/storage.go
+++ b/internal/storage/storage.go
@@ -4,6 +4,7 @@ import (
         "context"
         "database/sql"
         "fmt"
+        "os"
 
         _ "modernc.org/sqlite" // Pure Go SQLite driver
 )
@@ -11,7 +12,8 @@ import (
 // Storage provides event persistence using SQLite.
 // Consumers should define their own interface based on their needs.
 type Storage struct {
-        db *sql.DB
+        db     *sql.DB
+        dbPath string
 }
 
 // New creates a new Storage instance and initializes the database schema.
@@ -48,7 +50,10 @@ func New(dbPath string) (*Storage, error) {
                 }
         }
 
-        s := &Storage{db: db}
+        s := &Storage{
+                db:     db,
+                dbPath: dbPath,
+        }
 
         // Initialize schema
         if err := s.initSchema(context.Background()); err != nil {
@@ -142,3 +147,30 @@ func (s *Storage) initSchema(ctx context.Context) error {
 func (s *Storage) DB() *sql.DB {
         return s.db
 }
+
+type Stats struct {
+        EventCount int64
+        DBSizeBytes int64
+}
+
+func (s *Storage) GetStats(ctx context.Context) (*Stats, error) {
+        var eventCount int64
+        err := s.db.QueryRowContext(ctx, "SELECT COUNT(*) FROM events WHERE deleted = 0").Scan(&eventCount)
+        if err != nil {
+                return nil, fmt.Errorf("failed to count events: %w", err)
+        }
+
+        var dbSize int64
+        if s.dbPath != ":memory:" {
+                info, err := os.Stat(s.dbPath)
+                if err != nil {
+                        return nil, fmt.Errorf("failed to stat database file: %w", err)
+                }
+                dbSize = info.Size()
+        }
+
+        return &Stats{
+                EventCount: eventCount,
+                DBSizeBytes: dbSize,
+        }, nil
+}