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
74 lines
2.3 KiB
Go
74 lines
2.3 KiB
Go
package sub
|
|
|
|
import (
|
|
"reflect"
|
|
"strconv"
|
|
"strings"
|
|
"sync"
|
|
"testing"
|
|
|
|
"github.com/mhsanaei/3x-ui/v3/internal/database/model"
|
|
"github.com/mhsanaei/3x-ui/v3/internal/logger"
|
|
)
|
|
|
|
func TestExtraSalamanderKeys(t *testing.T) {
|
|
if got := extraSalamanderKeys(map[string]any{"password": "pw"}); len(got) != 0 {
|
|
t.Fatalf("expressible settings reported extras: %v", got)
|
|
}
|
|
got := extraSalamanderKeys(map[string]any{"password": "pw", "packetSize": "512-1200"})
|
|
if want := []string{"packetSize"}; !reflect.DeepEqual(got, want) {
|
|
t.Fatalf("extraSalamanderKeys = %v, want %v", got, want)
|
|
}
|
|
}
|
|
|
|
// captureLogLines installs a logger hook collecting "LEVEL message" lines
|
|
// for the rest of the test. It replaces reads of the in-memory log buffer,
|
|
// which was removed together with the web log viewer.
|
|
func captureLogLines(t *testing.T) *[]string {
|
|
t.Helper()
|
|
var mu sync.Mutex
|
|
lines := &[]string{}
|
|
prev := logger.SetLogHook(func(level, msg string) {
|
|
mu.Lock()
|
|
defer mu.Unlock()
|
|
*lines = append(*lines, level+" "+msg)
|
|
})
|
|
t.Cleanup(func() { logger.SetLogHook(prev) })
|
|
return lines
|
|
}
|
|
|
|
func TestGenHysteriaLinkWarnsOnceForUnsupportedSalamanderSettings(t *testing.T) {
|
|
makeInbound := func(id int, settings string) *model.Inbound {
|
|
return &model.Inbound{
|
|
Id: id, Listen: "203.0.113.1", Port: 443, Protocol: model.Hysteria,
|
|
Settings: `{"version":2,"clients":[{"auth":"secret","email":"user"}]}`,
|
|
StreamSettings: `{"security":"tls","finalmask":{"udp":[{"type":"salamander","settings":` + settings + `}]}}`,
|
|
}
|
|
}
|
|
logLines := captureLogLines(t)
|
|
countWarnings := func(id int) int {
|
|
needle := "inbound " + strconv.Itoa(id) + ": salamander settings"
|
|
count := 0
|
|
for _, line := range *logLines {
|
|
if strings.Contains(line, needle) {
|
|
count++
|
|
}
|
|
}
|
|
return count
|
|
}
|
|
|
|
const standardID = 910001
|
|
(&SubService{}).genHysteriaLink(makeInbound(standardID, `{"password":"pw"}`), "user")
|
|
if got := countWarnings(standardID); got != 0 {
|
|
t.Fatalf("password-only warning count = %d, want 0", got)
|
|
}
|
|
|
|
const unsupportedID = 910002
|
|
in := makeInbound(unsupportedID, `{"password":"pw","packetSize":"512-1200"}`)
|
|
(&SubService{}).genHysteriaLink(in, "user")
|
|
(&SubService{}).genHysteriaLink(in, "user")
|
|
if got := countWarnings(unsupportedID); got != 1 {
|
|
t.Fatalf("unsupported-settings warning count = %d, want 1", got)
|
|
}
|
|
}
|