dashboard

type BeaconStatsProvider interface {
	RelayForwarded() uint64
	RelayDropped() uint64
	RelayNotFound() uint64
}

type Callbacks struct {
	// GetDashboardToken returns the current dashboard token.
	GetDashboardToken func() string
	// GetAdminToken returns the current admin token.
	GetAdminToken func() string
	// BuildStatsPayload assembles the core /api/stats JSON payload (without
	// probe state and maintenance banner, which are owned by Handler).
	// The returned map is JSON-safe; callers must not mutate it.
	BuildStatsPayload func(authenticated bool) map[string]interface{}
	// GetNodes returns a snapshot of registered nodes for /api/nodes.
	GetNodes func() []NodeSnapshot
	// RequestCount returns the current total request count.
	RequestCount func() int64
	// StartTime returns when the server started.
	StartTime func() time.Time
	// NodeCount returns the number of registered nodes.
	NodeCount func() int
	// OnlineCount returns the number of nodes online at or after threshold.
	OnlineCount func(threshold time.Time) int
	// StaleThreshold returns the configured stale-node threshold.
	StaleThreshold func() time.Duration
	// TriggerSnapshot triggers a snapshot save.
	TriggerSnapshot func() error
	// UpdateGauges updates Prometheus gauges before /metrics scrape.
	UpdateGauges func()
	// WriteMetrics writes Prometheus metrics to w.
	WriteMetrics func(w io.Writer)
	// ListenerAddr returns the registry TCP listener address for probeRegistry.
	// Returns "" when no listener is bound.
	ListenerAddr func() string
	// BeaconAddr returns the beacon UDP address for probeBeacon. "" = disabled.
	BeaconAddr func() string
	// ReadyCh returns the channel closed when the server is ready.
	ReadyCh func() <-chan struct{}
	// Done returns the channel closed on server shutdown.
	Done func() <-chan struct{}
	// Save triggers a debounced snapshot after probe state changes.
	Save func()
}

type DashboardStats struct {
	TotalNodes        int                    `json:"total_nodes"`
	ActiveNodes       int                    `json:"active_nodes"`
	TotalTrustLinks   int                    `json:"-"`
	TotalRequests     int64                  `json:"total_requests"`
	RelayForwarded    uint64                 `json:"relay_forwarded,omitempty"`
	RelayDropped      uint64                 `json:"relay_dropped,omitempty"`
	RelayNotFound     uint64                 `json:"relay_not_found,omitempty"`
	ReqPerDay         int64                  `json:"req_per_day"`
	UptimeSecs        int64                  `json:"uptime_secs"`
	Versions          map[string]int         `json:"versions,omitempty"`
	Networks          []NetworkStats         `json:"networks,omitempty"` // only populated with dashboard token
	Hourly            []StatsSample          `json:"hourly,omitempty"`
	Daily             []StatsSample          `json:"daily,omitempty"`
	RestartEvents     []int64                `json:"restart_events,omitempty"`
	DowntimeIntervals [][2]int64             `json:"downtime_intervals,omitempty"`
	Probes            map[string]*ProbeState `json:"probes,omitempty"`
	ReleaseBanner     *ReleaseBanner         `json:"release_banner,omitempty"`
}

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

type NetHistoryRing struct {
	Samples []NetworkSampleEntry // length == Size; heap-allocated per ring
	Size    int                  // ring capacity (24 for hourly, 30 for daily)
	Idx     int                  // next write index
}

type NetworkSampleEntry struct {
	Timestamp int64  `json:"ts"`
	ID        uint16 `json:"id"`
	Name      string `json:"name"`
	Members   int    `json:"members"`
	Online    int    `json:"online"`
	Requests  int64  `json:"requests"`
}

type NetworkStats struct {
	ID         uint16               `json:"id"`
	Name       string               `json:"name"`
	Members    int                  `json:"members"`
	Online     int                  `json:"online"`
	Requests   int64                `json:"requests"`
	TrustLinks int                  `json:"-"`
	Hourly     []NetworkSampleEntry `json:"hourly,omitempty"`
	Daily      []NetworkSampleEntry `json:"daily,omitempty"`
}

type NodeSnapshot struct {
	ID       uint32
	Hostname string
	LastSeen time.Time
}

type ProbeState struct {
	LastSuccess       int64      `json:"last_success,omitempty"`       // millis
	DowntimeIntervals [][2]int64 `json:"downtime_intervals,omitempty"` // pruned to 30d
	CurrentDownStart  int64      `json:"current_down_start,omitempty"` // 0 when up
}

type PulseSample struct {
	Ts    int64 `json:"ts"`
	Total int64 `json:"total"`
}

type ReleaseBanner struct {
	Version     string `json:"version"`
	PublishedAt int64  `json:"published_at"`
}

type StatsSample struct {
	Timestamp     int64 `json:"ts"`
	TotalNodes    int   `json:"total_nodes"`
	OnlineNodes   int   `json:"online_nodes"`
	TrustLinks    int   `json:"trust_links,omitempty"`
	TotalRequests int64 `json:"total_requests"`
}

type StatsSampleResult struct {
	Global   StatsSample
	Networks map[uint16]NetworkSampleEntry
}