mirror of
https://github.com/MHSanaei/3x-ui.git
synced 2026-06-28 12:10:56 +00:00
7605902324
* test(audit): add gremlins/rapid/coverage tooling + AUDIT.md scaffold * test(audit): hygiene sweep (race-clean except logger global; Finding #2) + smell inventory * test(audit): cover untested error/edge branches (TLS proxy+pin, migration tag cleanup=Finding #1) * test(audit): strengthen internal/sub link tests (dedup key, TLS/Reality mapping, clash well-formedness) * test(audit): property (rapid) + fuzz tests for joinHostPort/userinfo/pin/ParseLink * test(audit): tighten frontend subSortIndex rejection assertions + wire coverage * ci(audit): add shuffle gate + non-blocking race job (Finding #2) + fuzz-smoke; document mutation policy * chore(audit): gitignore frontend coverage output * test(audit): exhaustive whole-repo pass — strengthen 5 weak/fake tests (netproxy, CSP, modal per-protocol loops, schema coercions) * docs(contributing): add Testing section (conventions, race/shuffle, fuzz, mutation policy); drop AUDIT.md ledger * fix(logger,migration): guard logBuffer with mutex; execute legacy tag cleanup (tx.Exec); make CI race gate blocking * ci(mutation): add nightly scoped gremlins workflow (informational artifacts) * test(audit): strengthen runtime tests — baseURL scheme/port bounds, isNonEmptySlice, trafficReset * test(audit): strengthen clash tests — reality field mapping + tcp-header validation * test(audit): runtime — egress-proxy + content-type tests; drop redundant bp=='' branch * test(audit): strengthen link parser/helper tests (defaultPort, splitComma, base64, canonicalQuery, tls/reality/transport mapping) * test(audit): strengthen sub/xray/common/netsafe/mtproto/config/middleware tests (kill surviving mutants) * test(audit): raise timeout on protocol-iteration modal tests (heavy re-renders, slow on CI) * fix(logger): GetLogs returns at most c entries (off-by-one fix; addresses PR review) * perf(logger): snapshot logBuffer under lock so GetLogs doesn't block logging; clarify fuzz-seed docs (addresses PR review)
80 lines
2.7 KiB
Go
80 lines
2.7 KiB
Go
package netproxy
|
|
|
|
import (
|
|
"net/http"
|
|
"net/http/httptest"
|
|
"reflect"
|
|
"testing"
|
|
"time"
|
|
)
|
|
|
|
func TestNewHTTPClient(t *testing.T) {
|
|
tests := []struct {
|
|
name string
|
|
proxyURL string
|
|
wantErr bool
|
|
wantProxy bool
|
|
wantDial bool
|
|
}{
|
|
{name: "empty returns direct client", proxyURL: ""},
|
|
{name: "socks5 sets custom dialer", proxyURL: "socks5://127.0.0.1:1080", wantDial: true},
|
|
{name: "socks5 with auth", proxyURL: "socks5://user:pass@127.0.0.1:1080", wantDial: true},
|
|
{name: "http sets transport proxy", proxyURL: "http://127.0.0.1:8080", wantProxy: true},
|
|
{name: "https sets transport proxy", proxyURL: "https://127.0.0.1:8080", wantProxy: true},
|
|
{name: "unsupported scheme errors", proxyURL: "ftp://127.0.0.1:21", wantErr: true},
|
|
}
|
|
|
|
// baseTransport clones http.DefaultTransport, whose Proxy and DialContext are already
|
|
// non-nil — so "!= nil" can't prove our proxy/dialer was applied. Check the real values.
|
|
defaultDialPtr := reflect.ValueOf(http.DefaultTransport.(*http.Transport).DialContext).Pointer()
|
|
|
|
for _, tc := range tests {
|
|
t.Run(tc.name, func(t *testing.T) {
|
|
client, err := NewHTTPClient(tc.proxyURL, 5*time.Second)
|
|
if tc.wantErr {
|
|
if err == nil {
|
|
t.Fatalf("expected error for %q, got nil", tc.proxyURL)
|
|
}
|
|
return
|
|
}
|
|
if err != nil {
|
|
t.Fatalf("unexpected error for %q: %v", tc.proxyURL, err)
|
|
}
|
|
if client.Timeout != 5*time.Second {
|
|
t.Errorf("timeout = %v, want 5s", client.Timeout)
|
|
}
|
|
// Empty proxyURL → a plain direct client with no custom transport.
|
|
if tc.proxyURL == "" {
|
|
if client.Transport != nil {
|
|
t.Errorf("empty proxy must yield a direct client (nil Transport), got %T", client.Transport)
|
|
}
|
|
return
|
|
}
|
|
transport, ok := client.Transport.(*http.Transport)
|
|
if !ok {
|
|
t.Fatalf("transport is %T, want *http.Transport", client.Transport)
|
|
}
|
|
if tc.wantProxy {
|
|
// Prove the CONFIGURED proxy is applied: transport.Proxy(req) must
|
|
// return our URL, not the cloned default's ProxyFromEnvironment.
|
|
req := httptest.NewRequest(http.MethodGet, "https://example.com", nil)
|
|
u, perr := transport.Proxy(req)
|
|
if perr != nil {
|
|
t.Fatalf("transport.Proxy returned error: %v", perr)
|
|
}
|
|
if u == nil || u.String() != tc.proxyURL {
|
|
t.Errorf("transport.Proxy(req) = %v, want %q (configured proxy not applied)", u, tc.proxyURL)
|
|
}
|
|
}
|
|
if tc.wantDial {
|
|
if transport.DialContext == nil {
|
|
t.Fatal("DialContext is nil")
|
|
}
|
|
// Must be the socks5 dialer, not the cloned default DialContext.
|
|
if reflect.ValueOf(transport.DialContext).Pointer() == defaultDialPtr {
|
|
t.Error("DialContext is still the default; socks5 dialer was not applied")
|
|
}
|
|
}
|
|
})
|
|
}
|
|
}
|