7 Commits

Author SHA1 Message Date
杨黄林
cbd9611c3d Merge pull request #7 from mourenZhu/main
fix: JudgePort Function
2023-10-08 09:28:31 +08:00
zhumouren
8d54567c0f fix JudgePort Function
1: fix portAllowed judge
2: fix domainAllowed judge
3: fix subdomainAllowed judge
2023-10-07 14:46:27 +08:00
zhumouren
245f4fa32f fix proxyType judge in JudgePort Function 2023-10-07 11:58:39 +08:00
4a714dcd0e fix proxy to https issue 2023-09-27 14:05:25 +08:00
43d3ef275e fix proxy to https issue 2023-09-27 14:02:12 +08:00
d581a65002 update version code 2023-09-27 12:03:22 +08:00
f6d2362f48 fix dashboard_addr https issue 2023-09-27 12:01:29 +08:00
4 changed files with 27 additions and 12 deletions

View File

@@ -12,7 +12,7 @@ import (
"strings"
)
const version = "1.7.1"
const version = "1.7.2"
var (
showVersion bool
@@ -87,7 +87,7 @@ func parseConfigFile(configFile, tokensFile string) (controller.HandleController
}
}
common.Common.DashboardTls = strings.HasPrefix("https://", strings.ToLower(common.Common.DashboardAddr))
common.Common.DashboardTls = strings.HasPrefix(strings.ToLower(common.Common.DashboardAddr), "https://")
tls := server.TLS{
Enable: common.Common.TlsMode,

2
go.mod
View File

@@ -8,7 +8,6 @@ require (
github.com/gin-contrib/i18n v1.0.0
github.com/gin-contrib/sessions v0.0.5
github.com/gin-gonic/gin v1.9.1
github.com/pelletier/go-toml/v2 v2.0.9
github.com/spf13/cobra v0.0.3
golang.org/x/text v0.11.0
)
@@ -36,6 +35,7 @@ require (
github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
github.com/modern-go/reflect2 v1.0.2 // indirect
github.com/nicksnyder/go-i18n/v2 v2.2.1 // indirect
github.com/pelletier/go-toml/v2 v2.0.9 // indirect
github.com/spf13/pflag v1.0.5 // indirect
github.com/twitchyliquid64/golang-asm v0.15.1 // indirect
github.com/ugorji/go/codec v1.2.11 // indirect

View File

@@ -556,6 +556,9 @@ func (c *HandleController) MakeProxyFunc() func(context *gin.Context) {
res := ProxyResponse{}
host := c.CommonInfo.DashboardAddr
port := c.CommonInfo.DashboardPort
host, _ = strings.CutPrefix(host, protocol)
requestUrl := protocol + host + ":" + strconv.Itoa(port) + context.Param("serverApi")
request, _ := http.NewRequest("GET", requestUrl, nil)
username := c.CommonInfo.DashboardUser

View File

@@ -77,7 +77,7 @@ func (c *HandleController) JudgePort(content *plugin.NewProxyContent) plugin.Res
"tcp", "tcpmux", "udp", "http", "https",
}
proxyType := content.ProxyType
if stringContains(proxyType, supportProxyTypes) {
if !stringContains(proxyType, supportProxyTypes) {
log.Printf("proxy type [%v] not support, plugin do nothing", proxyType)
res.Unchange = true
return res
@@ -115,6 +115,10 @@ func (c *HandleController) JudgePort(content *plugin.NewProxyContent) plugin.Res
break
}
} else {
if str == "" {
portAllowed = true
break
}
allowed, err := strconv.Atoi(str)
if err != nil {
portErr = fmt.Errorf("user [%v] allowed port [%v] is not a number", user, port)
@@ -148,10 +152,14 @@ func (c *HandleController) JudgePort(content *plugin.NewProxyContent) plugin.Res
if proxyType == "http" || proxyType == "https" || proxyType == "tcpmux" {
if portAllowed {
if token, exist := c.Tokens[user]; exist {
for _, userDomain := range userDomains {
if stringContains(userDomain, token.Domains) {
domainAllowed = false
break
if stringContains("", token.Domains) {
domainAllowed = true
} else {
for _, userDomain := range userDomains {
if !stringContains(userDomain, token.Domains) {
domainAllowed = false
break
}
}
}
}
@@ -167,10 +175,14 @@ func (c *HandleController) JudgePort(content *plugin.NewProxyContent) plugin.Res
subdomainAllowed = false
if portAllowed && domainAllowed {
if token, exist := c.Tokens[user]; exist {
for _, subdomain := range token.Subdomains {
if subdomain == userSubdomain {
subdomainAllowed = true
break
if stringContains("", token.Subdomains) {
subdomainAllowed = true
} else {
for _, subdomain := range token.Subdomains {
if subdomain == userSubdomain {
subdomainAllowed = true
break
}
}
}
} else {