427 lines
13 KiB
Go
427 lines
13 KiB
Go
package service
|
||
|
||
import (
|
||
"encoding/json"
|
||
"errors"
|
||
"runtime"
|
||
"sync"
|
||
"strconv"
|
||
|
||
"x-ui/logger"
|
||
"x-ui/xray"
|
||
json_util "x-ui/util/json_util"
|
||
|
||
"go.uber.org/atomic"
|
||
)
|
||
|
||
var (
|
||
p *xray.Process
|
||
lock sync.Mutex
|
||
isNeedXrayRestart atomic.Bool // Indicates that restart was requested for Xray
|
||
isManuallyStopped atomic.Bool // Indicates that Xray was stopped manually from the panel
|
||
result string
|
||
)
|
||
|
||
type XrayService struct {
|
||
inboundService InboundService
|
||
settingService SettingService
|
||
xrayAPI xray.XrayAPI
|
||
}
|
||
|
||
// IsXrayRunning 检查 Xray 是否正在运行
|
||
func (s *XrayService) IsXrayRunning() bool {
|
||
return p != nil && p.IsRunning()
|
||
}
|
||
|
||
// 中文注释:
|
||
// 新增 GetApiPort 函数。
|
||
// 这个函数的作用是安全地返回当前 Xray 进程正在监听的 API 端口号。
|
||
// 如果 Xray 没有运行 (p == nil)，则返回 0。
|
||
// 我们的后台任务将调用这个函数来获取端口号。
|
||
func (s *XrayService) GetApiPort() int {
|
||
if p == nil {
|
||
return 0
|
||
}
|
||
return p.GetAPIPort()
|
||
}
|
||
|
||
|
||
func (s *XrayService) GetXrayErr() error {
|
||
if p == nil {
|
||
return nil
|
||
}
|
||
|
||
err := p.GetErr()
|
||
|
||
if runtime.GOOS == "windows" && err.Error() == "exit status 1" {
|
||
// exit status 1 on Windows means that Xray process was killed
|
||
// as we kill process to stop in on Windows, this is not an error
|
||
return nil
|
||
}
|
||
|
||
return err
|
||
}
|
||
|
||
func (s *XrayService) GetXrayResult() string {
|
||
if result != "" {
|
||
return result
|
||
}
|
||
if s.IsXrayRunning() {
|
||
return ""
|
||
}
|
||
if p == nil {
|
||
return ""
|
||
}
|
||
|
||
result = p.GetResult()
|
||
|
||
if runtime.GOOS == "windows" && result == "exit status 1" {
|
||
// exit status 1 on Windows means that Xray process was killed
|
||
// as we kill process to stop in on Windows, this is not an error
|
||
return ""
|
||
}
|
||
|
||
return result
|
||
}
|
||
|
||
func (s *XrayService) GetXrayVersion() string {
|
||
if p == nil {
|
||
return "Unknown"
|
||
}
|
||
return p.GetVersion()
|
||
}
|
||
|
||
func RemoveIndex(s []any, index int) []any {
|
||
return append(s[:index], s[index+1:]...)
|
||
}
|
||
|
||
func (s *XrayService) GetXrayConfig() (*xray.Config, error) {
|
||
templateConfig, err := s.settingService.GetXrayConfigTemplate()
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
xrayConfig := &xray.Config{}
|
||
if err := json.Unmarshal([]byte(templateConfig), xrayConfig); err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
s.inboundService.AddTraffic(nil, nil)
|
||
|
||
inbounds, err := s.inboundService.GetAllInbounds()
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
// =================================================================
|
||
// 中文注释: 动态限速核心逻辑 - 第一步: 收集所有限速值
|
||
// =================================================================
|
||
// 创建一个 map 用于存储所有出现过的、不为0的限速值
|
||
uniqueSpeeds := make(map[int]bool)
|
||
for _, inbound := range inbounds {
|
||
if !inbound.Enable {
|
||
continue
|
||
}
|
||
// 获取该入站下的所有客户端设置
|
||
dbClients, _ := s.inboundService.GetClients(inbound)
|
||
for _, dbClient := range dbClients {
|
||
if dbClient.SpeedLimit > 0 {
|
||
uniqueSpeeds[dbClient.SpeedLimit] = true
|
||
}
|
||
}
|
||
}
|
||
|
||
// =================================================================
|
||
// 中文注释: 动态限速核心逻辑 - 第二步: 根据收集到的限速值，动态生成 Policy Levels
|
||
// =================================================================
|
||
// 初始化 policy levels，并加入默认的 level 0 (不限速)
|
||
policyLevels := make(map[string]interface{})
|
||
policyLevels["0"] = map[string]interface{}{"handshake": 8, "connIdle": 500}
|
||
|
||
// 遍历所有收集到的限速值
|
||
for speed := range uniqueSpeeds {
|
||
// 为每个速率创建一个 level，level 的名字就是速率的字符串形式
|
||
// 例如，速率 1024 KB/s 对应 level "1024"
|
||
policyLevels[strconv.Itoa(speed)] = map[string]interface{}{
|
||
"downlinkOnly": speed,
|
||
"uplinkOnly": speed,
|
||
}
|
||
}
|
||
|
||
// 将生成的 policy 应用到 Xray 配置中
|
||
policyJSON, err := json.Marshal(map[string]interface{}{"levels": policyLevels})
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
xrayConfig.Policy = json_util.RawMessage(policyJSON)
|
||
|
||
|
||
// =================================================================
|
||
// 中文注释: 在这里增加日志，打印最终生成的限速策略
|
||
// =================================================================
|
||
if len(uniqueSpeeds) > 0 {
|
||
finalPolicyLog, _ := json.Marshal(policyLevels)
|
||
logger.Infof("已为Xray动态生成〔限速策略〕: %s", string(finalPolicyLog))
|
||
}
|
||
|
||
// =================================================================
|
||
// 中文注释: 动态限速核心逻辑 - 第三步: 为设置了限速的用户分配对应的 Level，逐个 inbound 构建 inboundConfig
|
||
// =================================================================
|
||
for _, inbound := range inbounds {
|
||
if !inbound.Enable {
|
||
continue
|
||
}
|
||
|
||
// 先生成一个 inboundConfig（后面会覆盖 Settings/StreamSettings）
|
||
inboundConfig := inbound.GenXrayInboundConfig()
|
||
|
||
// 从 DB clients 建立 email/id -> speedLimit 映射（优先使用 DB 的值）
|
||
speedByEmail := make(map[string]int)
|
||
speedById := make(map[string]int)
|
||
dbClients, _ := s.inboundService.GetClients(inbound)
|
||
for _, dbc := range dbClients {
|
||
if dbc.Email != "" {
|
||
speedByEmail[dbc.Email] = dbc.SpeedLimit
|
||
}
|
||
// 如果有 id 字段也建立映射（以防 email 不存在）
|
||
if dbc.ID != "" {
|
||
speedById[dbc.ID] = dbc.SpeedLimit
|
||
}
|
||
}
|
||
|
||
// 解析 inbound.Settings
|
||
var settings map[string]interface{}
|
||
if err := json.Unmarshal([]byte(inbound.Settings), &settings); err != nil {
|
||
logger.Warningf("无法解析 inbound.Settings (inbound %d): %v ，跳过该入站", inbound.Id, err)
|
||
continue
|
||
}
|
||
|
||
originalClients, ok := settings["clients"].([]interface{})
|
||
if ok {
|
||
clientStats := inbound.ClientStats
|
||
|
||
var xrayClients []interface{}
|
||
for _, clientRaw := range originalClients {
|
||
c, ok := clientRaw.(map[string]interface{})
|
||
if !ok {
|
||
continue
|
||
}
|
||
|
||
// -----------------------------------------------------------------
|
||
// 中文注释: 用户过滤 - 1) settings 中的 enable 字段检查
|
||
// -----------------------------------------------------------------
|
||
if en, ok := c["enable"].(bool); ok && !en {
|
||
if em, _ := c["email"].(string); em != "" {
|
||
logger.Infof("已从Xray配置中移除被settings标记为禁用的用户: %s", em)
|
||
}
|
||
continue
|
||
}
|
||
|
||
// -----------------------------------------------------------------
|
||
// 中文注释: 用户过滤 - 2) inbound.ClientStats 检查 (DB/流量层禁用)
|
||
// -----------------------------------------------------------------
|
||
email, _ := c["email"].(string)
|
||
idStr, _ := c["id"].(string)
|
||
disabledByStat := false
|
||
for _, stat := range clientStats {
|
||
if stat.Email == email && !stat.Enable {
|
||
disabledByStat = true
|
||
break
|
||
}
|
||
}
|
||
if disabledByStat {
|
||
logger.Infof("已从Xray配置中移除被禁用的用户: %s", email)
|
||
continue
|
||
}
|
||
|
||
// -----------------------------------------------------------------
|
||
// 中文注释: 构建干净的 xrayClient（只保留白名单字段）
|
||
// -----------------------------------------------------------------
|
||
xrayClient := make(map[string]interface{})
|
||
if id, ok := c["id"]; ok { xrayClient["id"] = id }
|
||
if email != "" { xrayClient["email"] = email }
|
||
|
||
// 规范化 flow
|
||
if flow, ok := c["flow"]; ok {
|
||
if fs, ok2 := flow.(string); ok2 && fs == "xtls-rprx-vision-udp443" {
|
||
xrayClient["flow"] = "xtls-rprx-vision"
|
||
} else {
|
||
xrayClient["flow"] = flow
|
||
}
|
||
}
|
||
if password, ok := c["password"]; ok { xrayClient["password"] = password }
|
||
if method, ok := c["method"]; ok { xrayClient["method"] = method }
|
||
|
||
// ⚠️ security 字段已移除，不再加入到 xrayClient
|
||
|
||
// -----------------------------------------------------------------
|
||
// 中文注释: 限速等级映射（优先 DB，再回退 settings.speedLimit）
|
||
// -----------------------------------------------------------------
|
||
|
||
// =================================================================
|
||
// 这里的逻辑是准备将 client 对象提交给 Xray-core。
|
||
// 我们需要将 speedLimit 转换为 Xray 认识的 level 字段。
|
||
// 这样可以确保包含 speedLimit 的完整用户信息被用于生成配置。
|
||
// =================================================================
|
||
level := 0
|
||
if email != "" {
|
||
if v, ok := speedByEmail[email]; ok && v > 0 {
|
||
level = v
|
||
}
|
||
}
|
||
if level == 0 && idStr != "" {
|
||
if v, ok := speedById[idStr]; ok && v > 0 {
|
||
level = v
|
||
}
|
||
}
|
||
if level == 0 {
|
||
if sl, ok := c["speedLimit"]; ok {
|
||
switch vv := sl.(type) {
|
||
case float64:
|
||
level = int(vv)
|
||
case int:
|
||
level = vv
|
||
case int64:
|
||
level = int(vv)
|
||
case string:
|
||
if n, err := strconv.Atoi(vv); err == nil {
|
||
level = n
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
// 【新增功能】在这里添加日志记录
|
||
// 只有当最终计算出的 level 大于 0，且 email 存在时，才记录日志
|
||
if level > 0 && email != "" {
|
||
logger.Infof("为用户 %s 应用〔独立限速〕: %d KB/s", email, level)
|
||
}
|
||
// =================================================================
|
||
|
||
xrayClient["level"] = level
|
||
|
||
xrayClients = append(xrayClients, xrayClient)
|
||
}
|
||
|
||
// 把纯净的 clients 应用到 settings，并写入 inboundConfig.Settings
|
||
settings["clients"] = xrayClients
|
||
finalSettingsForXray, err := json.Marshal(settings)
|
||
if err != nil {
|
||
logger.Warningf("无法序列化用于Xray的入站设置 in GetXrayConfig for inbound %d: %v，跳过该入站", inbound.Id, err)
|
||
continue
|
||
}
|
||
inboundConfig.Settings = json_util.RawMessage(finalSettingsForXray)
|
||
}
|
||
|
||
// -----------------------------------------------------------------
|
||
// 中文注释: 处理 StreamSettings（清理敏感字段）
|
||
// -----------------------------------------------------------------
|
||
if len(inbound.StreamSettings) > 0 {
|
||
var stream map[string]interface{}
|
||
if err := json.Unmarshal([]byte(inbound.StreamSettings), &stream); err != nil {
|
||
logger.Warningf("无法解析 StreamSettings (inbound %d): %v ，跳过该入站", inbound.Id, err)
|
||
continue
|
||
}
|
||
|
||
if tlsSettings, ok := stream["tlsSettings"].(map[string]interface{}); ok {
|
||
delete(tlsSettings, "settings")
|
||
}
|
||
if realitySettings, ok := stream["realitySettings"].(map[string]interface{}); ok {
|
||
delete(realitySettings, "settings")
|
||
}
|
||
delete(stream, "externalProxy")
|
||
|
||
newStream, err := json.Marshal(stream)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
inboundConfig.StreamSettings = json_util.RawMessage(newStream)
|
||
}
|
||
|
||
xrayConfig.InboundConfigs = append(xrayConfig.InboundConfigs, *inboundConfig)
|
||
}
|
||
|
||
return xrayConfig, nil
|
||
}
|
||
|
||
|
||
func (s *XrayService) GetXrayTraffic() ([]*xray.Traffic, []*xray.ClientTraffic, error) {
|
||
if !s.IsXrayRunning() {
|
||
err := errors.New("xray is not running")
|
||
logger.Debug("Attempted to fetch Xray traffic, but Xray is not running:", err)
|
||
return nil, nil, err
|
||
}
|
||
apiPort := p.GetAPIPort()
|
||
s.xrayAPI.Init(apiPort)
|
||
defer s.xrayAPI.Close()
|
||
|
||
traffic, clientTraffic, err := s.xrayAPI.GetTraffic(true)
|
||
if err != nil {
|
||
logger.Debug("Failed to fetch Xray traffic:", err)
|
||
return nil, nil, err
|
||
}
|
||
return traffic, clientTraffic, nil
|
||
}
|
||
|
||
func (s *XrayService) RestartXray(isForce bool) error {
|
||
lock.Lock()
|
||
defer lock.Unlock()
|
||
logger.Debug("restart Xray, force:", isForce)
|
||
isManuallyStopped.Store(false)
|
||
|
||
xrayConfig, err := s.GetXrayConfig()
|
||
if err != nil {
|
||
return err
|
||
}
|
||
|
||
// 【新功能】重启时，将完整配置打印到 Debug 日志以供验证
|
||
configBytes, jsonErr := json.MarshalIndent(xrayConfig, "", " ")
|
||
if jsonErr == nil {
|
||
logger.Debugf("使用新配置重启 Xray：\n%s", string(configBytes))
|
||
} else {
|
||
logger.Warning("无法将 Xray 配置编组以进行日志记录：", jsonErr)
|
||
}
|
||
|
||
|
||
if s.IsXrayRunning() {
|
||
if !isForce && p.GetConfig().Equals(xrayConfig) && !isNeedXrayRestart.Load() {
|
||
logger.Debug("It does not need to restart Xray")
|
||
return nil
|
||
}
|
||
p.Stop()
|
||
}
|
||
|
||
p = xray.NewProcess(xrayConfig)
|
||
result = ""
|
||
err = p.Start()
|
||
if err != nil {
|
||
return err
|
||
}
|
||
|
||
return nil
|
||
}
|
||
|
||
func (s *XrayService) StopXray() error {
|
||
lock.Lock()
|
||
defer lock.Unlock()
|
||
isManuallyStopped.Store(true)
|
||
logger.Debug("Attempting to stop Xray...")
|
||
if s.IsXrayRunning() {
|
||
return p.Stop()
|
||
}
|
||
return errors.New("xray is not running")
|
||
}
|
||
|
||
func (s *XrayService) SetToNeedRestart() {
|
||
isNeedXrayRestart.Store(true)
|
||
}
|
||
|
||
func (s *XrayService) IsNeedRestartAndSetFalse() bool {
|
||
return isNeedXrayRestart.CompareAndSwap(true, false)
|
||
}
|
||
|
||
// Check if Xray is not running and wasn't stopped manually, i.e. crashed
|
||
func (s *XrayService) DidXrayCrash() bool {
|
||
return !s.IsXrayRunning() && !isManuallyStopped.Load()
|
||
}
|