Muse
f887f47bb9
- nodes: port node-type (traditional/agent) picker back from web-src into the embedded frontend; backend annotates NodeView.nodeType from agent_nodes bindings; fix agent-node update path (skip reachability probe and apiToken requirement for agent-managed nodes); restore i18n keys in all 13 locales; install command now uses the Gitea mirror - jobs: expire agent-bound nodes whose agent_nodes.last_seen is older than max(3x heartbeat interval, 120s) = 180s; last_seen=0 (never registered) is left untouched; transitions reuse UpdateHeartbeat + node event broadcast - config: GetBaseVersion honors ldflags-injected buildVersion; release builds inject 3.7.0-agent.1 so the panel no longer reports a phantom update against the Gitea release tag - logger/server: remove the three log viewers (panel/xray/amneziawg), their API endpoints and the 10240-entry in-memory log buffer; file logging via lumberjack unchanged; tests assert via a new optional logger hook instead of the removed buffer - server: remove system history and xray metrics modules end to end (endpoints, sampling appends in RefreshStatus, per-minute persist cron, gob snapshot/restore, XrayMetricsService); realtime status and per-node history are untouched - settings: subPort may be 0/unset - subscription links are generated without a port while the subscription service keeps binding the default 2096; the settings form declares the cleared state via onNumber's new onClear option instead of snapping back to 1
110 lines
3.4 KiB
Go
110 lines
3.4 KiB
Go
package config
|
|
|
|
import (
|
|
"os"
|
|
"testing"
|
|
)
|
|
|
|
func TestGetPanelVersion(t *testing.T) {
|
|
orig := buildCommit
|
|
t.Cleanup(func() { buildCommit = orig })
|
|
|
|
buildCommit = ""
|
|
if got := GetPanelVersion(); got != GetBaseVersion() {
|
|
t.Fatalf("stable build: GetPanelVersion = %q, want %q", got, GetBaseVersion())
|
|
}
|
|
|
|
buildCommit = "1d1128cf"
|
|
if got := GetPanelVersion(); got != "dev+1d1128cf" {
|
|
t.Fatalf("dev build: GetPanelVersion = %q, want %q", got, "dev+1d1128cf")
|
|
}
|
|
|
|
buildCommit = "1d1128cf945c4615efa05cf41ba7fa766e2ee428"
|
|
if got := GetPanelVersion(); got != "dev+1d1128cf" {
|
|
t.Fatalf("dev build (full sha): GetPanelVersion = %q, want %q", got, "dev+1d1128cf")
|
|
}
|
|
}
|
|
|
|
func TestGetBaseVersionBuildVersionOverride(t *testing.T) {
|
|
orig := buildVersion
|
|
t.Cleanup(func() { buildVersion = orig })
|
|
|
|
// No injection (plain `go build`): the embedded version file wins.
|
|
buildVersion = ""
|
|
embedded := GetBaseVersion()
|
|
if embedded == "" {
|
|
t.Fatal("embedded version file must not be empty")
|
|
}
|
|
|
|
// Injected fork release version wins over the embedded file and flows
|
|
// into GetPanelVersion untouched (stable channel, no dev label).
|
|
buildVersion = "3.7.0-agent.1"
|
|
if got := GetBaseVersion(); got != "3.7.0-agent.1" {
|
|
t.Fatalf("injected build: GetBaseVersion = %q, want %q", got, "3.7.0-agent.1")
|
|
}
|
|
if got := GetPanelVersion(); got != "3.7.0-agent.1" {
|
|
t.Fatalf("injected build: GetPanelVersion = %q, want %q", got, "3.7.0-agent.1")
|
|
}
|
|
|
|
// Whitespace-only injection counts as unset.
|
|
buildVersion = " "
|
|
if got := GetBaseVersion(); got != embedded {
|
|
t.Fatalf("blank injection: GetBaseVersion = %q, want embedded %q", got, embedded)
|
|
}
|
|
}
|
|
|
|
func TestGetPortOverride(t *testing.T) {
|
|
tests := []struct {
|
|
name string
|
|
value string
|
|
set bool
|
|
wantPort int
|
|
configured bool
|
|
wantErr bool
|
|
}{
|
|
{name: "unset"},
|
|
{name: "empty", value: "", set: true},
|
|
{name: "whitespace", value: " ", set: true},
|
|
{name: "minimum", value: "1", set: true, wantPort: 1, configured: true},
|
|
{name: "default panel port", value: "2053", set: true, wantPort: 2053, configured: true},
|
|
{name: "surrounding whitespace", value: " 8080 ", set: true, wantPort: 8080, configured: true},
|
|
{name: "maximum", value: "65535", set: true, wantPort: 65535, configured: true},
|
|
{name: "zero", value: "0", set: true, configured: true, wantErr: true},
|
|
{name: "above maximum", value: "65536", set: true, configured: true, wantErr: true},
|
|
{name: "negative", value: "-1", set: true, configured: true, wantErr: true},
|
|
{name: "non-numeric", value: "abc", set: true, configured: true, wantErr: true},
|
|
{name: "decimal", value: "8080.0", set: true, configured: true, wantErr: true},
|
|
}
|
|
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
if tt.set {
|
|
t.Setenv("XUI_PORT", tt.value)
|
|
} else {
|
|
original, existed := os.LookupEnv("XUI_PORT")
|
|
if err := os.Unsetenv("XUI_PORT"); err != nil {
|
|
t.Fatalf("unset XUI_PORT: %v", err)
|
|
}
|
|
t.Cleanup(func() {
|
|
if existed {
|
|
_ = os.Setenv("XUI_PORT", original)
|
|
} else {
|
|
_ = os.Unsetenv("XUI_PORT")
|
|
}
|
|
})
|
|
}
|
|
|
|
port, configured, err := GetPortOverride()
|
|
if port != tt.wantPort {
|
|
t.Errorf("port = %d, want %d", port, tt.wantPort)
|
|
}
|
|
if configured != tt.configured {
|
|
t.Errorf("configured = %t, want %t", configured, tt.configured)
|
|
}
|
|
if (err != nil) != tt.wantErr {
|
|
t.Errorf("error = %v, wantErr %t", err, tt.wantErr)
|
|
}
|
|
})
|
|
}
|
|
}
|