rum

type ClickEvent struct {
	Selector string `json:"selector"` // CSS selector of clicked element
	Text     string `json:"text"`     // inner text (truncated)
	X        int    `json:"x"`
	Y        int    `json:"y"`
	IsRage   bool   `json:"is_rage"` // 3+ clicks on same element in 1s
	URL      string `json:"url"`
}

type Engine struct {
	// contains filtered or unexported fields
}

type EngineConfig struct {
	SampleRate float64 // 0.0–1.0, fraction of sessions to keep
	MaxEvents  int     // circular buffer capacity
}

type ErrorGroup struct {
	Fingerprint string    `json:"fingerprint"`
	Message     string    `json:"message"`
	Source      string    `json:"source"`
	Count       int       `json:"count"`
	Sessions    int       `json:"sessions"`
	LastSeen    time.Time `json:"last_seen"`
	Stack       string    `json:"stack"`
	TraceID     string    `json:"trace_id,omitempty"` // most-recent event's backend trace, if any
}

type EventType string

type JSErrorEvent struct {
	Message     string `json:"message"`
	Source      string `json:"source"`
	Lineno      int    `json:"lineno"`
	Colno       int    `json:"colno"`
	Stack       string `json:"stack"`
	Fingerprint string `json:"fingerprint"` // computed server-side
}

type NavigationEvent struct {
	FromURL string `json:"from_url"`
	ToURL   string `json:"to_url"`
	Type    string `json:"type"` // "push", "replace", "back", "forward"
}

type PageLoadEvent struct {
	Route            string  `json:"route"`
	DurationMs       float64 `json:"duration_ms"`
	TTFB             float64 `json:"ttfb_ms"`
	DOMContentLoaded float64 `json:"dom_content_loaded_ms"`
	Load             float64 `json:"load_ms"`
	TransferSizeKB   float64 `json:"transfer_size_kb"`
}

type PagePerformance struct {
	Route             string  `json:"route"`
	Views             int     `json:"views"`
	AvgDurationMs     float64 `json:"avg_duration_ms"`
	P75DurationMs     float64 `json:"p75_duration_ms"`
	AvgTTFB           float64 `json:"avg_ttfb_ms"`
	AvgTransferSizeKB float64 `json:"avg_transfer_size_kb"`
}

type RUMEvent struct {
	ID        string    `json:"id"`
	Type      EventType `json:"type"`
	SessionID string    `json:"session_id"`
	URL       string    `json:"url"`
	UserAgent string    `json:"user_agent"`
	Timestamp time.Time `json:"timestamp"`
	TraceID   string    `json:"trace_id,omitempty"` // backend distributed trace this event belongs to

	// Exactly one of these will be populated, depending on Type.
	PageLoad       *PageLoadEvent       `json:"page_load,omitempty"`
	WebVital       *WebVitalEvent       `json:"web_vital,omitempty"`
	JSError        *JSErrorEvent        `json:"js_error,omitempty"`
	ResourceTiming *ResourceTimingEvent `json:"resource_timing,omitempty"`
	Click          *ClickEvent          `json:"click,omitempty"`
	Navigation     *NavigationEvent     `json:"navigation,omitempty"`
}

type RUMStore interface {
	// WriteEvent persists a single RUM event.
	WriteEvent(event RUMEvent) error

	// WriteBatch persists multiple RUM events atomically.
	WriteBatch(events []RUMEvent) error

	// WebVitalsOverview returns an aggregate view of core web vitals.
	WebVitalsOverview() (*WebVitalsOverview, error)

	// PageLoads returns per-route performance metrics.
	PageLoads() ([]PagePerformance, error)

	// ErrorGroups returns JS errors grouped by fingerprint.
	ErrorGroups() ([]ErrorGroup, error)

	// PagePerformance returns detailed performance for a specific route.
	PagePerformance(route string) (*PagePerformance, error)

	// Sessions returns a list of recent session summaries.
	Sessions(limit int) ([]SessionSummary, error)

	// SessionDetail returns all events for a given session.
	SessionDetail(sessionID string) ([]RUMEvent, error)

	// RageClicks returns rage click events from the last N minutes.
	RageClicks(minutes int) ([]ClickEvent, error)

	// UserJourneys returns navigation events for a given session, ordered by time.
	UserJourneys(sessionID string) ([]NavigationEvent, error)

	// PerformanceByRoute returns aggregated performance metrics per route.
	PerformanceByRoute() ([]RoutePerformance, error)
}

type ResourceTimingEvent struct {
	Name           string  `json:"name"`           // URL of the resource
	InitiatorType  string  `json:"initiator_type"` // fetch, xmlhttprequest, script, css, img
	DurationMs     float64 `json:"duration_ms"`
	TransferSizeKB float64 `json:"transfer_size_kb"`
	StatusCode     int     `json:"status_code"`
}

type RoutePerformance struct {
	Route         string  `json:"route"`
	AvgDurationMs float64 `json:"avg_duration_ms"`
	P75DurationMs float64 `json:"p75_duration_ms"`
	AvgTTFB       float64 `json:"avg_ttfb_ms"`
	Views         int     `json:"views"`
}

type SessionSummary struct {
	SessionID  string    `json:"session_id"`
	StartedAt  time.Time `json:"started_at"`
	LastSeen   time.Time `json:"last_seen"`
	PageViews  int       `json:"page_views"`
	ErrorCount int       `json:"error_count"`
	UserAgent  string    `json:"user_agent"`
}

type VitalRating struct {
	Good             int     `json:"good"`
	NeedsImprovement int     `json:"needs_improvement"`
	Poor             int     `json:"poor"`
	P75              float64 `json:"p75"`
}

type WebVitalEvent struct {
	Name   string  `json:"name"`  // LCP, FID, CLS, TTFB, FCP, INP
	Value  float64 `json:"value"` // ms for timing metrics, unitless for CLS
	Delta  float64 `json:"delta"`
	Rating string  `json:"rating"` // "good", "needs-improvement", "poor"
}

type WebVitalsOverview struct {
	LCP           VitalRating `json:"lcp"`
	FID           VitalRating `json:"fid"`
	CLS           VitalRating `json:"cls"`
	TTFB          VitalRating `json:"ttfb"`
	FCP           VitalRating `json:"fcp"`
	INP           VitalRating `json:"inp"`
	TotalSessions int         `json:"total_sessions"`
}