88 lines
2.7 KiB
Go
88 lines
2.7 KiB
Go
|
package handlers
|
||
|
|
|
||
|
|
import (
|
||
|
|
"encoding/json"
|
||
|
|
"net/http"
|
||
|
|
"net/http/httptest"
|
||
|
|
"testing"
|
||
|
|
|
||
|
|
"github.com/Silo-Server/silo-server/internal/config"
|
||
|
|
)
|
||
|
|
|
||
|
|
func TestAdminServerStatusClearsAfterProcessRestart(t *testing.T) {
|
||
|
|
t.Parallel()
|
||
|
|
|
||
|
|
restartStatus := NewServerRestartStatusTracker()
|
||
|
|
restartStatus.MarkRequired("settings")
|
||
|
|
|
||
|
|
handler := &AdminHandler{RestartStatus: restartStatus}
|
||
|
|
req := httptest.NewRequest(http.MethodGet, "/admin/server/status", nil)
|
||
|
|
rec := httptest.NewRecorder()
|
||
|
|
handler.HandleGetServerStatus(rec, req)
|
||
|
|
|
||
|
|
if rec.Code != http.StatusOK {
|
||
|
|
t.Fatalf("status = %d, body = %s", rec.Code, rec.Body.String())
|
||
|
|
}
|
||
|
|
var resp adminServerStatusResponse
|
||
|
|
if err := json.NewDecoder(rec.Body).Decode(&resp); err != nil {
|
||
|
|
t.Fatalf("decode response: %v", err)
|
||
|
|
}
|
||
|
|
if !resp.RestartRequired {
|
||
|
|
t.Fatal("RestartRequired = false, want true")
|
||
|
|
}
|
||
|
|
|
||
|
|
restartedHandler := &AdminHandler{RestartStatus: NewServerRestartStatusTracker()}
|
||
|
|
rec = httptest.NewRecorder()
|
||
|
|
restartedHandler.HandleGetServerStatus(rec, req)
|
||
|
|
|
||
|
|
if rec.Code != http.StatusOK {
|
||
|
|
t.Fatalf("status after restart = %d, body = %s", rec.Code, rec.Body.String())
|
||
|
|
}
|
||
|
|
if err := json.NewDecoder(rec.Body).Decode(&resp); err != nil {
|
||
|
|
t.Fatalf("decode response after restart: %v", err)
|
||
|
|
}
|
||
|
|
if resp.RestartRequired {
|
||
|
|
t.Fatal("RestartRequired = true after new process tracker, want false")
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
func TestAdminServerStatusDoesNotPromoteLiveJellyfinIdentitySettings(t *testing.T) {
|
||
|
|
t.Parallel()
|
||
|
|
|
||
|
|
cfg, err := config.LoadFromDB(map[string]string{
|
||
|
|
"jellyfin_compat.enabled": "true",
|
||
|
|
"jellyfin_compat.listen": ":8096",
|
||
|
|
"jellyfin_compat.public_url": "http://127.0.0.1:8096",
|
||
|
|
"jellyfin_compat.server_name": "Silo",
|
||
|
|
"jellyfin_compat.emulated_server_version": "10.11.0",
|
||
|
|
})
|
||
|
|
if err != nil {
|
||
|
|
t.Fatalf("LoadFromDB: %v", err)
|
||
|
|
}
|
||
|
|
|
||
|
|
handler := &AdminHandler{
|
||
|
|
Config: cfg,
|
||
|
|
RestartStatus: NewServerRestartStatusTracker(),
|
||
|
|
SettingsRepo: &fakeServerSettingsStore{values: map[string]string{
|
||
|
|
"jellyfin_compat.public_url": "https://compat.example.test",
|
||
|
|
"jellyfin_compat.server_name": "Silo Compat",
|
||
|
|
"jellyfin_compat.emulated_server_version": "10.11.6",
|
||
|
|
}},
|
||
|
|
}
|
||
|
|
req := httptest.NewRequest(http.MethodGet, "/admin/server/status", nil)
|
||
|
|
rec := httptest.NewRecorder()
|
||
|
|
|
||
|
|
handler.HandleGetServerStatus(rec, req)
|
||
|
|
|
||
|
|
if rec.Code != http.StatusOK {
|
||
|
|
t.Fatalf("status = %d, body = %s", rec.Code, rec.Body.String())
|
||
|
|
}
|
||
|
|
var resp adminServerStatusResponse
|
||
|
|
if err := json.NewDecoder(rec.Body).Decode(&resp); err != nil {
|
||
|
|
t.Fatalf("decode response: %v", err)
|
||
|
|
}
|
||
|
|
if resp.RestartRequired {
|
||
|
|
t.Fatal("RestartRequired = true, want false for live Jellyfin identity settings")
|
||
|
|
}
|
||
|
|
}
|