* feat(jellycompat): install web assets at runtime * fix(jellycompat): recover stale web operation locks * fix(jellycompat): harden web component management * feat(admin): refine compat settings and restart status * chore(dev): add hot-reload docker compose stack * fix(dev): include npm in hot-reload backend * feat(admin): refine Jellyfin compatibility settings * feat(settings): improve jellyfin proxy summary * feat(settings): improve jellyfin web controls * fix(settings): update jellyfin web removal status * fix(settings): enable jellyfin web after install * feat(jellycompat): auto-select web ui version * test(api): update rate limit handler setup * feat(jellycompat): refine web ui install onboarding * fix(jellycompat): address web ui install review issues * fix(onboarding): mirror jellyfin api runtime status * fix(admin): remove global restart banner * fix(settings): gate restart required tracking * fix(jellyfin): ignore live settings for restart status * fix(jellyfin): avoid restart for live compat settings * fix(subtitles): normalize AI language codes * fix(catalog): support partial title search tokens * feat(branding): add white-label customization * Add push relay engineering plan - Document relay API contracts, APNs/FCM behavior, auth, storage, and ops - Capture implementation plan, provider references, decisions, and README --------- Co-authored-by: Quick <31828688+Quick104@users.noreply.github.com>
103 lines
2.1 KiB
Go
103 lines
2.1 KiB
Go
package handlers
|
|
|
|
import (
|
|
"strings"
|
|
"sync"
|
|
"time"
|
|
)
|
|
|
|
// ServerRestartStatusTracker keeps process-local restart state. A real server
|
|
// restart creates a new tracker, which clears any pending restart banner state.
|
|
type ServerRestartStatusTracker struct {
|
|
mu sync.RWMutex
|
|
|
|
startedAt time.Time
|
|
restartRequired bool
|
|
restartRequiredAt time.Time
|
|
restartRequiredReason string
|
|
restartRequested bool
|
|
restartRequestedAt time.Time
|
|
}
|
|
|
|
type ServerRestartStatusSnapshot struct {
|
|
StartedAt time.Time
|
|
RestartRequired bool
|
|
RestartRequiredAt *time.Time
|
|
RestartRequiredReason string
|
|
RestartRequested bool
|
|
RestartRequestedAt *time.Time
|
|
}
|
|
|
|
func NewServerRestartStatusTracker() *ServerRestartStatusTracker {
|
|
return &ServerRestartStatusTracker{
|
|
startedAt: time.Now().UTC(),
|
|
}
|
|
}
|
|
|
|
func (s *ServerRestartStatusTracker) MarkRequired(reason string) {
|
|
if s == nil {
|
|
return
|
|
}
|
|
|
|
now := time.Now().UTC()
|
|
reason = strings.TrimSpace(reason)
|
|
|
|
s.mu.Lock()
|
|
defer s.mu.Unlock()
|
|
|
|
if !s.restartRequired {
|
|
s.restartRequired = true
|
|
s.restartRequiredAt = now
|
|
}
|
|
if reason != "" {
|
|
s.restartRequiredReason = reason
|
|
}
|
|
}
|
|
|
|
func (s *ServerRestartStatusTracker) MarkRestartRequested() {
|
|
if s == nil {
|
|
return
|
|
}
|
|
|
|
now := time.Now().UTC()
|
|
|
|
s.mu.Lock()
|
|
defer s.mu.Unlock()
|
|
|
|
if !s.restartRequested {
|
|
s.restartRequested = true
|
|
s.restartRequestedAt = now
|
|
}
|
|
}
|
|
|
|
func (s *ServerRestartStatusTracker) Snapshot() ServerRestartStatusSnapshot {
|
|
if s == nil {
|
|
now := time.Now().UTC()
|
|
return ServerRestartStatusSnapshot{StartedAt: now}
|
|
}
|
|
|
|
s.mu.RLock()
|
|
defer s.mu.RUnlock()
|
|
|
|
var restartRequiredAt *time.Time
|
|
if !s.restartRequiredAt.IsZero() {
|
|
t := s.restartRequiredAt
|
|
restartRequiredAt = &t
|
|
}
|
|
|
|
var restartRequestedAt *time.Time
|
|
if !s.restartRequestedAt.IsZero() {
|
|
t := s.restartRequestedAt
|
|
restartRequestedAt = &t
|
|
}
|
|
|
|
return ServerRestartStatusSnapshot{
|
|
StartedAt: s.startedAt,
|
|
RestartRequired: s.restartRequired,
|
|
RestartRequiredAt: restartRequiredAt,
|
|
RestartRequiredReason: s.restartRequiredReason,
|
|
RestartRequested: s.restartRequested,
|
|
RestartRequestedAt: restartRequestedAt,
|
|
}
|
|
}
|