Alex-Devera/3x-ui
1
0
Fork 0
mirror of https://github.com/MHSanaei/3x-ui.git synced 2025-09-12 13:10:05 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Merge branch 'fix-subscriptions'

Browse source
This commit is contained in:
Ilya05228 2025-08-28 20:55:20 +03:00
commit d61046f29f
2 changed files with 35 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
sub/subJsonService.go
View file

@ -87,24 +87,28 @@ func (s *SubJsonService) GetJson(subId string, host string) (string, string, err
if clients == nil { if clients == nil {
continue continue
} }
if len(inbound.Listen) > 0 && inbound.Listen[0] == '@' { listenAddress := host
listen, port, streamSettings, err := s.SubService.getFallbackMaster(inbound.Listen, inbound.StreamSettings) if len(inbound.Listen) > 0 {
if err == nil { if inbound.Listen[0] == '@' {
inbound.Listen = listen listen, port, streamSettings, err := s.SubService.getFallbackMaster(inbound.Listen, inbound.StreamSettings)
inbound.Port = port if err == nil {
inbound.StreamSettings = streamSettings listenAddress = listen
inbound.Port = port
inbound.StreamSettings = streamSettings
}
} else {
listenAddress = inbound.Listen
} }
} }
for _, client := range clients { for _, client := range clients {
if client.Enable && client.SubID == subId { if client.Enable && client.SubID == subId {
clientTraffics = append(clientTraffics, s.SubService.getClientTraffics(inbound.ClientStats, client.Email)) clientTraffics = append(clientTraffics, s.SubService.getClientTraffics(inbound.ClientStats, client.Email))
newConfigs := s.getConfig(inbound, client, host) newConfigs := s.getConfig(inbound, client, listenAddress)
configArray = append(configArray, newConfigs...) configArray = append(configArray, newConfigs...)
} }
} }
} }
if len(configArray) == 0 { if len(configArray) == 0 {
return "", "", nil return "", "", nil
} }

33
sub/subService.go
View file

@ -1,5 +1,7 @@
package sub package sub
// TODO: We need to create a service for link generation and remove link generation from the frontend
import ( import (
"encoding/base64" "encoding/base64"
"fmt" "fmt"
@ -33,9 +35,7 @@ func NewSubService(showInfo bool, remarkModel string) *SubService {
remarkModel: remarkModel, remarkModel: remarkModel,
} }
} }
func (s *SubService) GetSubs(subId string, host string) ([]string, string, error) { func (s *SubService) GetSubs(subId string, host string) ([]string, string, error) {
s.address = host
var result []string var result []string
var header string var header string
var traffic xray.ClientTraffic var traffic xray.ClientTraffic
@ -61,12 +61,17 @@ func (s *SubService) GetSubs(subId string, host string) ([]string, string, error
if clients == nil { if clients == nil {
continue continue
} }
if len(inbound.Listen) > 0 && inbound.Listen[0] == '@' { s.address = host
listen, port, streamSettings, err := s.getFallbackMaster(inbound.Listen, inbound.StreamSettings) if len(inbound.Listen) > 0 {
if err == nil { if inbound.Listen[0] == '@' {
inbound.Listen = listen listen, port, streamSettings, err := s.getFallbackMaster(inbound.Listen, inbound.StreamSettings)
inbound.Port = port if err == nil {
inbound.StreamSettings = streamSettings s.address = listen
inbound.Port = port
inbound.StreamSettings = streamSettings
}
} else {
s.address = inbound.Listen
} }
} }
for _, client := range clients { for _, client := range clients {
@ -442,7 +447,11 @@ func (s *SubService) genVlessLink(inbound *model.Inbound, email string) string {
params["pqv"] = pqv params["pqv"] = pqv
} }
} }
params["spx"] = "/" + random.Seq(15) if spxValue, ok := searchKey(realitySettings, "spiderX"); ok {
if spx, ok := spxValue.(string); ok && len(spx) > 0 {
params["spx"] = spx
}
}
} }
if streamNetwork == "tcp" && len(clients[clientIndex].Flow) > 0 { if streamNetwork == "tcp" && len(clients[clientIndex].Flow) > 0 {
@ -637,7 +646,11 @@ func (s *SubService) genTrojanLink(inbound *model.Inbound, email string) string
params["pqv"] = pqv params["pqv"] = pqv
} }
} }
params["spx"] = "/" + random.Seq(15) if spxValue, ok := searchKey(realitySettings, "spiderX"); ok {
if spx, ok := spxValue.(string); ok && len(spx) > 0 {
params["spx"] = spx
}
}
} }
if streamNetwork == "tcp" && len(clients[clientIndex].Flow) > 0 { if streamNetwork == "tcp" && len(clients[clientIndex].Flow) > 0 {