CI / go-test (push) Canceled after 0s
CI / postgres-durable-first (push) Canceled after 0s
CI / codegen (push) Canceled after 0s
CI / govulncheck (push) Canceled after 0s
CI / race (push) Canceled after 0s
CI / fuzz-smoke (push) Canceled after 0s
CI / golangci (push) Canceled after 0s
CI / frontend (push) Canceled after 0s
CodeQL Advanced / Analyze (go) (push) Canceled after 0s
CodeQL Advanced / Analyze (actions) (push) Canceled after 0s
CodeQL Advanced / Analyze (javascript-typescript) (push) Canceled after 0s
Docs CI / build (push) Canceled after 0s
Docs Deploy (GitHub Pages) / build (push) Canceled after 0s
Release 3X-UI / build (386) (push) Canceled after 0s
Release 3X-UI / build (amd64) (push) Canceled after 0s
Release 3X-UI / build (arm64) (push) Canceled after 0s
Release 3X-UI / build (armv5) (push) Canceled after 0s
Release 3X-UI / build (armv6) (push) Canceled after 0s
Release 3X-UI / build (armv7) (push) Canceled after 0s
Release 3X-UI / build (s390x) (push) Canceled after 0s
Release 3X-UI / Build for Windows (amd64) (push) Canceled after 0s
Deploy Smoke Tests / noninteractive-install (ubuntu-24.04-arm) (push) Canceled after 0s
Deploy Smoke Tests / noninteractive-install (ubuntu-latest) (push) Canceled after 0s
Deploy Smoke Tests / release-tag-install (ubuntu-24.04-arm) (push) Canceled after 0s
Deploy Smoke Tests / release-tag-install (ubuntu-latest) (push) Canceled after 0s
Docs Deploy (GitHub Pages) / deploy (push) Canceled after 0s
Release 3X-UI / Publish rolling dev release (push) Canceled after 0s
128 lines
4.1 KiB
Go
128 lines
4.1 KiB
Go
package sub
|
|
|
|
import (
|
|
"encoding/json"
|
|
"net/http"
|
|
"net/http/httptest"
|
|
"strings"
|
|
"testing"
|
|
|
|
"github.com/gin-gonic/gin"
|
|
|
|
"github.com/mhsanaei/3x-ui/v3/internal/database"
|
|
"github.com/mhsanaei/3x-ui/v3/internal/database/model"
|
|
)
|
|
|
|
func seedInfoEndpointSub(t *testing.T, subId, email string) {
|
|
t.Helper()
|
|
db := database.GetDB()
|
|
rec := &model.ClientRecord{Email: email, SubID: subId, UUID: "info-uuid", Enable: true}
|
|
if err := db.Create(rec).Error; err != nil {
|
|
t.Fatalf("seed client: %v", err)
|
|
}
|
|
link := "vless://11111111-1111-1111-1111-111111111111@example.com:443?type=tcp&security=reality&pbk=abc&sid=12&fp=chrome#orig"
|
|
if err := db.Create(&model.ClientExternalLink{ClientId: rec.Id, Kind: model.ExternalLinkKindLink, Value: link, Remark: "DE-Provider", SortIndex: 1}).Error; err != nil {
|
|
t.Fatalf("seed external link: %v", err)
|
|
}
|
|
}
|
|
|
|
func TestSubInfoEndpoint_ServesStatusJSONEvenForBrowsers(t *testing.T) {
|
|
gin.SetMode(gin.TestMode)
|
|
initSubDB(t)
|
|
seedInfoEndpointSub(t, "info-sub", "info@x")
|
|
|
|
router := gin.New()
|
|
NewSUBController(router.Group("/"))
|
|
|
|
req := httptest.NewRequest(http.MethodGet, "/sub/info-sub?format=info", nil)
|
|
req.Host = "sub.example.com"
|
|
req.Header.Set("Accept", "text/html")
|
|
w := httptest.NewRecorder()
|
|
router.ServeHTTP(w, req)
|
|
|
|
if w.Code != http.StatusOK {
|
|
t.Fatalf("status = %d, want 200; body=%s", w.Code, w.Body.String())
|
|
}
|
|
if ct := w.Header().Get("Content-Type"); !strings.Contains(ct, "application/json") {
|
|
t.Fatalf("Content-Type = %q, want application/json", ct)
|
|
}
|
|
if cc := w.Header().Get("Cache-Control"); !strings.Contains(cc, "no-store") {
|
|
t.Fatalf("Cache-Control = %q, want a no-store directive", cc)
|
|
}
|
|
|
|
var info map[string]any
|
|
if err := json.Unmarshal(w.Body.Bytes(), &info); err != nil {
|
|
t.Fatalf("body is not valid JSON: %v; body=%s", err, w.Body.String())
|
|
}
|
|
if info["sId"] != "info-sub" {
|
|
t.Fatalf("sId = %v, want %q", info["sId"], "info-sub")
|
|
}
|
|
if _, hasLinks := info["links"]; hasLinks {
|
|
t.Fatal("info payload must not include the links list")
|
|
}
|
|
if isOnline, ok := info["isOnline"].(bool); !ok || isOnline {
|
|
t.Fatalf("isOnline = %v, want false with no live xray", info["isOnline"])
|
|
}
|
|
emails, ok := info["emails"].([]any)
|
|
if !ok || len(emails) != 1 || emails[0] != "info@x" {
|
|
t.Fatalf("emails = %v, want [info@x]", info["emails"])
|
|
}
|
|
subUrl, _ := info["subUrl"].(string)
|
|
if !strings.HasSuffix(subUrl, "/sub/info-sub") {
|
|
t.Fatalf("subUrl = %q, want a /sub/info-sub suffix", subUrl)
|
|
}
|
|
for _, key := range []string{"enabled", "used", "remained", "expire", "lastOnline", "datepicker", "announce"} {
|
|
if _, present := info[key]; !present {
|
|
t.Fatalf("info payload missing %q; body=%s", key, w.Body.String())
|
|
}
|
|
}
|
|
}
|
|
|
|
func TestSubInfoEndpoint_UnknownSubIs404(t *testing.T) {
|
|
gin.SetMode(gin.TestMode)
|
|
initSubDB(t)
|
|
|
|
router := gin.New()
|
|
NewSUBController(router.Group("/"))
|
|
|
|
req := httptest.NewRequest(http.MethodGet, "/sub/does-not-exist?format=info", nil)
|
|
req.Host = "sub.example.com"
|
|
w := httptest.NewRecorder()
|
|
router.ServeHTTP(w, req)
|
|
|
|
if w.Code != http.StatusNotFound {
|
|
t.Fatalf("status = %d, want 404", w.Code)
|
|
}
|
|
}
|
|
|
|
func TestSubInfoEndpoint_HTMLPageStillWinsWithoutFormatParam(t *testing.T) {
|
|
gin.SetMode(gin.TestMode)
|
|
initSubDB(t)
|
|
seedInfoEndpointSub(t, "html-sub", "html@x")
|
|
oldDistFS := distFS
|
|
distFS = testDistFS
|
|
t.Cleanup(func() { distFS = oldDistFS })
|
|
|
|
router := gin.New()
|
|
NewSUBController(router.Group("/"))
|
|
|
|
req := httptest.NewRequest(http.MethodGet, "/sub/html-sub", nil)
|
|
req.Host = "sub.example.com"
|
|
req.Header.Set("Accept", "text/html")
|
|
w := httptest.NewRecorder()
|
|
router.ServeHTTP(w, req)
|
|
|
|
if w.Code != http.StatusOK {
|
|
t.Fatalf("status = %d, want 200; body=%s", w.Code, w.Body.String())
|
|
}
|
|
if ct := w.Header().Get("Content-Type"); !strings.Contains(ct, "text/html") {
|
|
t.Fatalf("Content-Type = %q, want text/html for a browser request", ct)
|
|
}
|
|
if !strings.Contains(w.Body.String(), "__SUB_PAGE_DATA__") {
|
|
t.Fatal("browser request must still get the SPA page with injected page data")
|
|
}
|
|
if !strings.Contains(w.Body.String(), `"isOnline":false`) {
|
|
t.Fatalf("injected page data must carry isOnline; body=%s", w.Body.String())
|
|
}
|
|
}
|