mirror of
https://github.com/J3vb/OwnCord.git
synced 2026-09-03 03:50:00 +03:00
jevb
6a5d3d53cb
- Add LiveKit health check guard to voice_join (reject if process not running) - Log webhook DB cleanup errors instead of swallowing - Reject camera enable if CountActiveCameras query fails - Add LiveKit health status to /metrics endpoint - Add 13 unit tests for livekit.go, livekit_process.go, livekit_webhook.go
48 lines
1.5 KiB
Go
48 lines
1.5 KiB
Go
package api
|
|
|
|
import (
|
|
"net/http"
|
|
"runtime"
|
|
"time"
|
|
)
|
|
|
|
// ServerMetrics holds runtime metrics for the /api/v1/metrics endpoint.
|
|
type ServerMetrics struct {
|
|
Uptime string `json:"uptime"`
|
|
UptimeSeconds float64 `json:"uptime_seconds"`
|
|
GoRoutines int `json:"goroutines"`
|
|
HeapAllocMB float64 `json:"heap_alloc_mb"`
|
|
HeapSysMB float64 `json:"heap_sys_mb"`
|
|
NumGC uint32 `json:"num_gc"`
|
|
ConnectedUsers int `json:"connected_users"`
|
|
LiveKitHealthy *bool `json:"livekit_healthy,omitempty"`
|
|
}
|
|
|
|
// handleMetrics returns an HTTP handler that reports runtime server metrics.
|
|
// getConnectedUsers is a callback to retrieve the current WebSocket client count.
|
|
// livekitHealthCheck is optional — if non-nil, it probes the LiveKit companion process.
|
|
func handleMetrics(getConnectedUsers func() int, livekitHealthCheck func() (bool, error)) http.HandlerFunc {
|
|
return func(w http.ResponseWriter, r *http.Request) {
|
|
var m runtime.MemStats
|
|
runtime.ReadMemStats(&m)
|
|
|
|
uptime := time.Since(serverStartTime)
|
|
metrics := ServerMetrics{
|
|
Uptime: uptime.Truncate(time.Second).String(),
|
|
UptimeSeconds: uptime.Seconds(),
|
|
GoRoutines: runtime.NumGoroutine(),
|
|
HeapAllocMB: float64(m.HeapAlloc) / 1024 / 1024,
|
|
HeapSysMB: float64(m.HeapSys) / 1024 / 1024,
|
|
NumGC: m.NumGC,
|
|
ConnectedUsers: getConnectedUsers(),
|
|
}
|
|
|
|
if livekitHealthCheck != nil {
|
|
healthy, _ := livekitHealthCheck()
|
|
metrics.LiveKitHealthy = &healthy
|
|
}
|
|
|
|
writeJSON(w, http.StatusOK, metrics)
|
|
}
|
|
}
|