native

type Dashboard struct {
	TotalUsers       int64     `json:"total_users"`
	ActiveUsers      int64     `json:"active_users"`
	ExpiredUsers     int64     `json:"expired_users"`
	BannedUsers      int64     `json:"banned_users"`
	TodayNewUsers    int64     `json:"today_new_users"`
	TotalOrders      int64     `json:"total_orders"`
	PendingOrders    int64     `json:"pending_orders"`
	PaidOrders       int64     `json:"paid_orders"`
	TotalRevenue     int64     `json:"total_revenue"`
	MonthlyIncome    int64     `json:"monthly_income"`
	TodayIncome      int64     `json:"today_income"`
	TotalNodes       int64     `json:"total_nodes"`
	ActiveNodes      int64     `json:"active_nodes"`
	OnlineUsers      int64     `json:"online_users"`
	TotalTrafficUsed int64     `json:"total_traffic_used"`
	TodayTraffic     int64     `json:"today_traffic"`
	CachedAt         time.Time `json:"cached_at"`
}

type HourlyTraffic struct {
	HourTs  int64 `json:"hour_ts"`
	Traffic int64 `json:"traffic"`
}

type NodeServices struct {
	NodeID uint64 `json:"node_id"`
	// Enabled is the node's setting; without it the collector is off and
	// the table is empty.
	Enabled bool `json:"enabled"`
	// Include and Exclude are the node's unit globs.
	Include []string `json:"include"`
	Exclude []string `json:"exclude"`
	// Reported is true once the node has a stored report.
	Reported bool `json:"reported"`
	// Supported and UnsupportedReason are the report's: false, with a
	// reason, on a node without systemd or cgroup v2.
	Supported         bool   `json:"supported"`
	UnsupportedReason string `json:"unsupported_reason"`
	// Stale is true when the report is older than 25 minutes.
	Stale         bool            `json:"stale"`
	ObservedAt    *time.Time      `json:"observed_at"`
	Version       string          `json:"version"`
	WindowSeconds int             `json:"window_seconds"`
	Summary       ServicesSummary `json:"summary"`
	Units         []ServiceUnit   `json:"units"`
}

type Service struct {
	// Open returns the package's storage connection, on which the
	// kapi_traffic_log_v1 and kapi_user_directory_v1 views are visible.
	Open func(ctx context.Context) (*gorm.DB, error)
	// Telemetry is the kernel's KernelTelemetry; without it the dashboard
	// has no native handler and stays legacy.
	Telemetry Telemetry
	// Now defaults to time.Now. The hourly buckets are in the local time
	// zone, as the kernel's; the kernel passes its TZ to the host.
	Now func() time.Time
}

type ServiceUnit struct {
	Name            string  `json:"name"`
	ActiveState     string  `json:"active_state"`
	SubState        string  `json:"sub_state"`
	CPUAvgPercent   float64 `json:"cpu_avg_percent"`
	CPUPeakPercent  float64 `json:"cpu_peak_percent"`
	MemoryBytes     uint64  `json:"memory_bytes"`
	MemoryPeakBytes uint64  `json:"memory_peak_bytes"`
}

type ServicesSummary struct {
	Total    int `json:"total"`
	Failed   int `json:"failed"`
	Active   int `json:"active"`
	Inactive int `json:"inactive"`
}

type Telemetry interface {
	GetDashboard(ctx context.Context, in *kerneltelemetryv1.GetDashboardRequest, opts ...grpc.CallOption) (*kerneltelemetryv1.GetDashboardResponse, error)
}

type TrafficLogMeta struct {
	LatestLogAt int64 `json:"latest_log_at"`
}

type UserTrafficRank struct {
	UserID  uint   `json:"user_id"`
	Email   string `json:"email"`
	Traffic int64  `json:"traffic"`
}