mirror of
https://github.com/MHSanaei/3x-ui.git
synced 2026-11-12 08:05:00 +03:00
fix(sub): never use X-Real-IP as the subscription host (#6608)
ResolveRequest and the panel's resolveHost fell back to X-Real-IP for the host when a trusted proxy sent no X-Forwarded-Host. X-Real-IP names the visitor, so behind nginx with only that header set, subscription and exported links advertised the subscriber's own public IP as the server. The host now comes from a trusted X-Forwarded-Host, else the dialed request Host. X-Real-IP stays a client-IP source only. Fixes #6589.
This commit is contained in:
@@ -154,6 +154,29 @@ func TestResolveRequest_GatesRealIPFallback(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// nginx often sets X-Real-IP without X-Forwarded-Host; a trusted proxy's X-Real-IP
|
||||||
|
// used to put the subscriber's public IP into subscription "server" fields (#6589).
|
||||||
|
func TestResolveRequest_IgnoresRealIPEvenWhenTrusted(t *testing.T) {
|
||||||
|
initSubDB(t)
|
||||||
|
// Empty / shipped-default CIDRs → forwardedHeadersTrusted returns true.
|
||||||
|
s := &SubService{}
|
||||||
|
|
||||||
|
c := requestFrom(t, "10.1.2.3:44000", map[string]string{
|
||||||
|
"X-Real-IP": "198.51.100.7",
|
||||||
|
})
|
||||||
|
_, host, hostWithPort, hostHeader := s.ResolveRequest(c)
|
||||||
|
|
||||||
|
if host != "panel.example.com" {
|
||||||
|
t.Errorf("host = %q, want request host (not X-Real-IP)", host)
|
||||||
|
}
|
||||||
|
if hostWithPort != "panel.example.com:2096" {
|
||||||
|
t.Errorf("hostWithPort = %q, want request Host", hostWithPort)
|
||||||
|
}
|
||||||
|
if hostHeader != "panel.example.com" {
|
||||||
|
t.Errorf("hostHeader = %q, want request host (not X-Real-IP)", hostHeader)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func TestHasForwardedHeaders(t *testing.T) {
|
func TestHasForwardedHeaders(t *testing.T) {
|
||||||
tests := []struct {
|
tests := []struct {
|
||||||
name string
|
name string
|
||||||
|
|||||||
@@ -2992,8 +2992,8 @@ type PageData struct {
|
|||||||
Emails []string
|
Emails []string
|
||||||
}
|
}
|
||||||
|
|
||||||
// ResolveRequest extracts scheme and host info from request/headers consistently.
|
|
||||||
// ResolveRequest extracts scheme, host, and header information from an HTTP request.
|
// ResolveRequest extracts scheme, host, and header information from an HTTP request.
|
||||||
|
// X-Real-IP names the visitor, never the panel, so it is no host source (#6589).
|
||||||
func (s *SubService) ResolveRequest(c *gin.Context) (scheme string, host string, hostWithPort string, hostHeader string) {
|
func (s *SubService) ResolveRequest(c *gin.Context) (scheme string, host string, hostWithPort string, hostHeader string) {
|
||||||
trusted := s.forwardedHeadersTrusted(c)
|
trusted := s.forwardedHeadersTrusted(c)
|
||||||
if !trusted {
|
if !trusted {
|
||||||
@@ -3012,13 +3012,10 @@ func (s *SubService) ResolveRequest(c *gin.Context) (scheme string, host string,
|
|||||||
scheme = "https"
|
scheme = "https"
|
||||||
}
|
}
|
||||||
|
|
||||||
// base host (no port)
|
// base host (no port): trusted X-Forwarded-Host, then the dialed request Host.
|
||||||
if h, err := getHostFromXFH(forwarded("X-Forwarded-Host")); err == nil && h != "" {
|
if h, err := getHostFromXFH(forwarded("X-Forwarded-Host")); err == nil && h != "" {
|
||||||
host = h
|
host = h
|
||||||
}
|
}
|
||||||
if host == "" {
|
|
||||||
host = forwarded("X-Real-IP")
|
|
||||||
}
|
|
||||||
if host == "" {
|
if host == "" {
|
||||||
var err error
|
var err error
|
||||||
host, _, err = net.SplitHostPort(c.Request.Host)
|
host, _, err = net.SplitHostPort(c.Request.Host)
|
||||||
@@ -3038,9 +3035,6 @@ func (s *SubService) ResolveRequest(c *gin.Context) (scheme string, host string,
|
|||||||
|
|
||||||
// header display host
|
// header display host
|
||||||
hostHeader = forwarded("X-Forwarded-Host")
|
hostHeader = forwarded("X-Forwarded-Host")
|
||||||
if hostHeader == "" {
|
|
||||||
hostHeader = forwarded("X-Real-IP")
|
|
||||||
}
|
|
||||||
if hostHeader == "" {
|
if hostHeader == "" {
|
||||||
hostHeader = host
|
hostHeader = host
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -442,11 +442,8 @@ func (a *InboundController) importInbound(c *gin.Context) {
|
|||||||
notifyClientsChanged()
|
notifyClientsChanged()
|
||||||
}
|
}
|
||||||
|
|
||||||
// resolveHost mirrors what sub.SubService.ResolveRequest does for the host
|
// resolveHost mirrors SubService.ResolveRequest's host: trusted X-Forwarded-Host,
|
||||||
// field: prefers X-Forwarded-Host (first entry of any list, port stripped),
|
// else the dialed request Host. X-Real-IP names the visitor, not the panel (#6589).
|
||||||
// then X-Real-IP, then the host portion of c.Request.Host. Keeping it in the
|
|
||||||
// controller layer means the service interface stays HTTP-agnostic — service
|
|
||||||
// methods receive a plain host string instead of a *gin.Context.
|
|
||||||
func resolveHost(c *gin.Context) string {
|
func resolveHost(c *gin.Context) string {
|
||||||
if isTrustedForwardedRequest(c) {
|
if isTrustedForwardedRequest(c) {
|
||||||
if h := strings.TrimSpace(c.GetHeader("X-Forwarded-Host")); h != "" {
|
if h := strings.TrimSpace(c.GetHeader("X-Forwarded-Host")); h != "" {
|
||||||
@@ -458,9 +455,6 @@ func resolveHost(c *gin.Context) string {
|
|||||||
}
|
}
|
||||||
return h
|
return h
|
||||||
}
|
}
|
||||||
if h := c.GetHeader("X-Real-IP"); h != "" {
|
|
||||||
return h
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
if h, _, err := net.SplitHostPort(c.Request.Host); err == nil {
|
if h, _, err := net.SplitHostPort(c.Request.Host); err == nil {
|
||||||
return h
|
return h
|
||||||
|
|||||||
@@ -32,3 +32,30 @@ func TestGetRemoteIpHonorsForwardedHeadersFromTrustedLoopbackProxy(t *testing.T)
|
|||||||
t.Fatalf("remote IP = %q, want forwarded client IP", got)
|
t.Fatalf("remote IP = %q, want forwarded client IP", got)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestResolveHostPrefersForwardedHostOverRealIP(t *testing.T) {
|
||||||
|
gin.SetMode(gin.TestMode)
|
||||||
|
c, _ := gin.CreateTestContext(httptest.NewRecorder())
|
||||||
|
c.Request = httptest.NewRequest(http.MethodGet, "/", nil)
|
||||||
|
c.Request.Host = "panel.example.com:2053"
|
||||||
|
c.Request.RemoteAddr = "127.0.0.1:12345"
|
||||||
|
c.Request.Header.Set("X-Forwarded-Host", "sub.example.net:443")
|
||||||
|
c.Request.Header.Set("X-Real-IP", "198.51.100.7")
|
||||||
|
|
||||||
|
if got := resolveHost(c); got != "sub.example.net" {
|
||||||
|
t.Fatalf("resolveHost = %q, want X-Forwarded-Host", got)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestResolveHostIgnoresRealIPFromTrustedProxy(t *testing.T) {
|
||||||
|
gin.SetMode(gin.TestMode)
|
||||||
|
c, _ := gin.CreateTestContext(httptest.NewRecorder())
|
||||||
|
c.Request = httptest.NewRequest(http.MethodGet, "/", nil)
|
||||||
|
c.Request.Host = "panel.example.com:2053"
|
||||||
|
c.Request.RemoteAddr = "127.0.0.1:12345"
|
||||||
|
c.Request.Header.Set("X-Real-IP", "198.51.100.7")
|
||||||
|
|
||||||
|
if got := resolveHost(c); got != "panel.example.com" {
|
||||||
|
t.Fatalf("resolveHost = %q, want request host (not X-Real-IP)", got)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user