| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152 |
- package controller
- import (
- "encoding/json"
- "net/http"
- "net/http/httptest"
- "net/url"
- "os"
- "runtime"
- "strings"
- "testing"
- "github.com/mhsanaei/3x-ui/v3/internal/config"
- "github.com/gin-gonic/gin"
- )
- // newPanelUpdateTestEngine registers only updatePanel/getUpdateStatus directly
- // on the controller's zero value, bypassing NewServerController's cron/metrics
- // setup (unrelated to these two handlers, and unnecessary weight for a unit
- // test). Callers must set up a DB first (newHostTestDB(t)) since StartUpdate
- // reads the dev-channel setting before doing anything else.
- func newPanelUpdateTestEngine() *gin.Engine {
- a := &ServerController{}
- engine := gin.New()
- engine.GET("/panel/api/server/getUpdateStatus", a.getUpdateStatus)
- engine.POST("/panel/api/server/updatePanel", a.updatePanel)
- return engine
- }
- func doPanelUpdateReq(t *testing.T, engine *gin.Engine, method, path string) hostEnvelope {
- t.Helper()
- req := httptest.NewRequest(method, path, nil)
- w := httptest.NewRecorder()
- engine.ServeHTTP(w, req)
- if w.Code != http.StatusOK {
- t.Fatalf("%s %s: status %d, body=%s", method, path, w.Code, w.Body.String())
- }
- var env hostEnvelope
- if err := json.Unmarshal(w.Body.Bytes(), &env); err != nil {
- t.Fatalf("%s %s: decode envelope: %v body=%s", method, path, err, w.Body.String())
- }
- return env
- }
- // TestGetUpdateStatus_NoStatusFileYet exercises the read-only status endpoint
- // with no prior update having run: it must report "pending" (not an error),
- // since a missing status file is an expected, ordinary state, not a failure.
- func TestGetUpdateStatus_NoStatusFileYet(t *testing.T) {
- newHostTestDB(t)
- engine := newPanelUpdateTestEngine()
- env := doPanelUpdateReq(t, engine, http.MethodGet, "/panel/api/server/getUpdateStatus")
- if !env.Success {
- t.Fatalf("getUpdateStatus should always report success=true (it's a best-effort read): msg=%s", env.Msg)
- }
- var status struct {
- RunID string `json:"runId"`
- State string `json:"state"`
- }
- if err := json.Unmarshal(env.Obj, &status); err != nil {
- t.Fatalf("decode status: %v", err)
- }
- if status.State != "pending" {
- t.Fatalf("State = %q, want %q", status.State, "pending")
- }
- }
- // TestGetUpdateStatus_RunIdIsAlwaysAString is the regression test for the
- // precision bug found in review: RunID is a 19-digit UnixNano timestamp, so
- // it must round-trip over the wire as a JSON string, never a bare number -- a
- // bare number would silently lose precision in JavaScript past
- // Number.MAX_SAFE_INTEGER, breaking every future runId comparison on the
- // frontend. Decoding into a Go string field below only succeeds if the wire
- // value is actually a JSON string; a bare number there would fail to decode,
- // so this test doubles as the wire-format check.
- func TestGetUpdateStatus_RunIdIsAlwaysAString(t *testing.T) {
- newHostTestDB(t)
- engine := newPanelUpdateTestEngine()
- statusPath := config.GetUpdateStatusFilePath()
- body := `{"runId":"1735689600123456789","state":"success","exitCode":0,"finishedAt":1735689612}`
- if err := os.WriteFile(statusPath, []byte(body), 0o644); err != nil {
- t.Fatal(err)
- }
- env := doPanelUpdateReq(t, engine, http.MethodGet, "/panel/api/server/getUpdateStatus")
- var status struct {
- RunID string `json:"runId"`
- State string `json:"state"`
- }
- if err := json.Unmarshal(env.Obj, &status); err != nil {
- t.Fatalf("decode status (would fail here if runId were a bare JSON number instead of a string): %v, body=%s", err, env.Obj)
- }
- if status.RunID != "1735689600123456789" {
- t.Fatalf("RunID = %q, want %q", status.RunID, "1735689600123456789")
- }
- if status.State != "success" {
- t.Fatalf("State = %q, want %q", status.State, "success")
- }
- }
- // TestUpdatePanel_UnsupportedPlatformReturnsNoRunId covers the one path of
- // updatePanel that's safe to exercise in an automated test on any OS/CI
- // runner: the runtime.GOOS != "linux" guard. Actually invoking StartUpdate's
- // launch logic on Linux would make a real network call and could launch a
- // real update.sh process, so that path is deliberately not covered here --
- // see the PR description for why.
- func TestUpdatePanel_UnsupportedPlatformReturnsNoRunId(t *testing.T) {
- if runtime.GOOS == "linux" {
- t.Skip("this test only exercises the non-Linux guard path; on Linux, updatePanel would attempt a real download/exec")
- }
- newHostTestDB(t)
- engine := newPanelUpdateTestEngine()
- env := doPanelUpdateReq(t, engine, http.MethodPost, "/panel/api/server/updatePanel")
- if env.Success {
- t.Fatal("updatePanel on an unsupported platform: success = true, want false")
- }
- if len(env.Obj) != 0 && string(env.Obj) != "null" {
- t.Fatalf("updatePanel error response must not carry an obj/runId: got %s", env.Obj)
- }
- }
- // TestUpdatePanel_InvalidDevValueRejectedBeforeLaunch covers the one branch of
- // updatePanel that's both untested and safe to exercise on any OS/CI runner:
- // an unparseable "dev" form value is rejected by strconv.ParseBool before
- // StartUpdateChannel (and therefore any real exec/network call) is ever
- // reached, on Linux or otherwise.
- func TestUpdatePanel_InvalidDevValueRejectedBeforeLaunch(t *testing.T) {
- newHostTestDB(t)
- engine := newPanelUpdateTestEngine()
- form := url.Values{"dev": {"notabool"}}
- req := httptest.NewRequest(http.MethodPost, "/panel/api/server/updatePanel", strings.NewReader(form.Encode()))
- req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
- w := httptest.NewRecorder()
- engine.ServeHTTP(w, req)
- if w.Code != http.StatusOK {
- t.Fatalf("status %d, body=%s", w.Code, w.Body.String())
- }
- var env hostEnvelope
- if err := json.Unmarshal(w.Body.Bytes(), &env); err != nil {
- t.Fatalf("decode envelope: %v body=%s", err, w.Body.String())
- }
- if env.Success {
- t.Fatal("updatePanel with dev=notabool: success = true, want false")
- }
- if len(env.Obj) != 0 && string(env.Obj) != "null" {
- t.Fatalf("updatePanel error response must not carry an obj/runId: got %s", env.Obj)
- }
- }
|