Refactor

v2rayN/ServiceLib/Services/CoreConfig/Singbox/CoreConfigSingboxService.cs

@@ -451,7 +451,7 @@ public partial class CoreConfigSingboxService(Config config)
                 ret.Msg = ResUI.FailedGenDefaultConfiguration;
                 return ret;
             }
-            await GenOutboundsList(proxyProfiles, singboxConfig, multipleLoad);
+            await GenOutboundsListWithChain(proxyProfiles, singboxConfig, multipleLoad);
 
             await GenDns(null, singboxConfig);
             await ConvertGeo2Ruleset(singboxConfig);

v2rayN/ServiceLib/Services/CoreConfig/Singbox/SingboxOutboundService.cs

@@ -179,13 +179,21 @@ public partial class CoreConfigSingboxService
             if (node.ConfigType == EConfigType.WireGuard)
             {
                 var endpoint = JsonUtils.Deserialize<Endpoints4Sbox>(txtOutbound);
-                await GenEndpoint(node, endpoint);
+                var ret = await GenEndpoint(node, endpoint);
+                if (ret != 0)
+                {
+                    return null;
+                }
                 return endpoint;
             }
             else
             {
                 var outbound = JsonUtils.Deserialize<Outbound4Sbox>(txtOutbound);
-                await GenOutbound(node, outbound);
+                var ret = await GenOutbound(node, outbound);
+                if (ret != 0)
+                {
+                    return null;
+                }
                 return outbound;
             }
         }
@@ -410,7 +418,7 @@ public partial class CoreConfigSingboxService
         return 0;
     }
 
-    private async Task<int> GenOutboundsList(List<ProfileItem> nodes, SingboxConfig singboxConfig, EMultipleLoad multipleLoad, string baseTagName = Global.ProxyTag)
+    private async Task<int> GenOutboundsListWithChain(List<ProfileItem> nodes, SingboxConfig singboxConfig, EMultipleLoad multipleLoad, string baseTagName = Global.ProxyTag)
     {
         try
         {
@@ -458,7 +466,7 @@ public partial class CoreConfigSingboxService
                     var ret = node.ConfigType switch
                     {
                         EConfigType.PolicyGroup =>
-                            await GenOutboundsList(childProfiles, singboxConfig, profileGroupItem.MultipleLoad, childBaseTagName),
+                            await GenOutboundsListWithChain(childProfiles, singboxConfig, profileGroupItem.MultipleLoad, childBaseTagName),
                         EConfigType.ProxyChain =>
                             await GenChainOutboundsList(childProfiles, singboxConfig, childBaseTagName),
                         _ => throw new NotImplementedException()
@@ -612,6 +620,66 @@ public partial class CoreConfigSingboxService
         return null;
     }
 
+    private async Task<int> GenOutboundsList(List<ProfileItem> nodes, SingboxConfig singboxConfig, EMultipleLoad multipleLoad, string baseTagName = Global.ProxyTag)
+    {
+        var resultOutbounds = new List<Outbound4Sbox>();
+        var resultEndpoints = new List<Endpoints4Sbox>(); // For endpoints
+        var proxyTags = new List<string>(); // For selector and urltest outbounds
+        for (var i = 0; i < nodes.Count; i++)
+        {
+            var node = nodes[i];
+            var server = await GenServer(node);
+            if (server is null)
+            {
+                break;
+            }
+            server.tag = baseTagName + (i + 1).ToString();
+            if (server is Endpoints4Sbox endpoint)
+            {
+                resultEndpoints.Add(endpoint);
+            }
+            else if (server is Outbound4Sbox outbound)
+            {
+                resultOutbounds.Add(outbound);
+            }
+            proxyTags.Add(server.tag);
+        }
+        // Add urltest outbound (auto selection based on latency)
+        if (proxyTags.Count > 0)
+        {
+            var outUrltest = new Outbound4Sbox
+            {
+                type = "urltest",
+                tag = $"{baseTagName}-auto",
+                outbounds = proxyTags,
+                interrupt_exist_connections = false,
+            };
+            if (multipleLoad == EMultipleLoad.Fallback)
+            {
+                outUrltest.tolerance = 5000;
+            }
+            // Add selector outbound (manual selection)
+            var outSelector = new Outbound4Sbox
+            {
+                type = "selector",
+                tag = baseTagName,
+                outbounds = JsonUtils.DeepCopy(proxyTags),
+                interrupt_exist_connections = false,
+            };
+            outSelector.outbounds.Insert(0, outUrltest.tag);
+            // Insert these at the beginning
+            resultOutbounds.Insert(0, outUrltest);
+            resultOutbounds.Insert(0, outSelector);
+        }
+        singboxConfig.outbounds ??= new();
+        resultOutbounds.AddRange(singboxConfig.outbounds);
+        singboxConfig.outbounds = resultOutbounds;
+        singboxConfig.endpoints ??= new();
+        resultEndpoints.AddRange(singboxConfig.endpoints);
+        singboxConfig.endpoints = resultEndpoints;
+        return await Task.FromResult(0);
+    }
+
     private async Task<int> GenChainOutboundsList(List<ProfileItem> nodes, SingboxConfig singboxConfig, string baseTagName = Global.ProxyTag)
     {
         var resultOutbounds = new List<Outbound4Sbox>();

v2rayN/ServiceLib/Services/CoreConfig/Singbox/SingboxRoutingService.cs

@@ -403,7 +403,7 @@ public partial class CoreConfigSingboxService
             var ret = node.ConfigType switch
             {
                 EConfigType.PolicyGroup =>
-                    await GenOutboundsList(childProfiles, singboxConfig, profileGroupItem.MultipleLoad, childBaseTagName),
+                    await GenOutboundsListWithChain(childProfiles, singboxConfig, profileGroupItem.MultipleLoad, childBaseTagName),
                 EConfigType.ProxyChain =>
                     await GenChainOutboundsList(childProfiles, singboxConfig, childBaseTagName),
                 _ => throw new NotImplementedException()

v2rayN/ServiceLib/Services/CoreConfig/V2ray/CoreConfigV2rayService.cs

@@ -180,7 +180,7 @@ public partial class CoreConfigV2rayService(Config config)
                 ret.Msg = ResUI.FailedGenDefaultConfiguration;
                 return ret;
             }
-            await GenOutboundsList(proxyProfiles, v2rayConfig);
+            await GenOutboundsListWithChain(proxyProfiles, v2rayConfig);
 
             //add balancers
             await GenObservatory(v2rayConfig, multipleLoad);

v2rayN/ServiceLib/Services/CoreConfig/V2ray/V2rayBalancerService.cs

@@ -2,13 +2,13 @@ namespace ServiceLib.Services.CoreConfig;
 
 public partial class CoreConfigV2rayService
 {
-    private async Task<int> GenObservatory(V2rayConfig v2rayConfig, EMultipleLoad multipleLoad)
+    private async Task<int> GenObservatory(V2rayConfig v2rayConfig, EMultipleLoad multipleLoad, string baseTagName = Global.ProxyTag)
     {
         if (multipleLoad == EMultipleLoad.LeastPing)
         {
             var observatory = new Observatory4Ray
             {
-                subjectSelector = [Global.ProxyTag],
+                subjectSelector = [baseTagName],
                 probeUrl = AppManager.Instance.Config.SpeedTestItem.SpeedPingTestUrl,
                 probeInterval = "3m",
                 enableConcurrency = true,
@@ -19,7 +19,7 @@ public partial class CoreConfigV2rayService
         {
             var burstObservatory = new BurstObservatory4Ray
             {
-                subjectSelector = [Global.ProxyTag],
+                subjectSelector = [baseTagName],
                 pingConfig = new()
                 {
                     destination = AppManager.Instance.Config.SpeedTestItem.SpeedPingTestUrl,

v2rayN/ServiceLib/Services/CoreConfig/V2ray/V2rayOutboundService.cs

@@ -552,7 +552,7 @@ public partial class CoreConfigV2rayService
         return 0;
     }
 
-    private async Task<int> GenOutboundsList(List<ProfileItem> nodes, V2rayConfig v2rayConfig, string baseTagName = Global.ProxyTag)
+    private async Task<int> GenOutboundsListWithChain(List<ProfileItem> nodes, V2rayConfig v2rayConfig, string baseTagName = Global.ProxyTag)
     {
         try
         {
@@ -597,7 +597,7 @@ public partial class CoreConfigV2rayService
                     var ret = node.ConfigType switch
                     {
                         EConfigType.PolicyGroup =>
-                            await GenOutboundsList(childProfiles, v2rayConfig, childBaseTagName),
+                            await GenOutboundsListWithChain(childProfiles, v2rayConfig, childBaseTagName),
                         EConfigType.ProxyChain =>
                             await GenChainOutboundsList(childProfiles, v2rayConfig, childBaseTagName),
                         _ => throw new NotImplementedException()
@@ -721,6 +721,32 @@ public partial class CoreConfigV2rayService
         return null;
     }
 
+    private async Task<int> GenOutboundsList(List<ProfileItem> nodes, V2rayConfig v2rayConfig, string baseTagName = Global.ProxyTag)
+    {
+        var resultOutbounds = new List<Outbounds4Ray>();
+        for (var i = 0; i < nodes.Count; i++)
+        {
+            var node = nodes[i];
+            var txtOutbound = EmbedUtils.GetEmbedText(Global.V2raySampleOutbound);
+            if (txtOutbound.IsNullOrEmpty())
+            {
+                break;
+            }
+            var outbound = JsonUtils.Deserialize<Outbounds4Ray>(txtOutbound);
+            var result = await GenOutbound(node, outbound);
+            if (result != 0)
+            {
+                break;
+            }
+            outbound.tag = baseTagName + (i + 1).ToString();
+            resultOutbounds.Add(outbound);
+        }
+        v2rayConfig.outbounds ??= new();
+        resultOutbounds.AddRange(v2rayConfig.outbounds);
+        v2rayConfig.outbounds = resultOutbounds;
+        return await Task.FromResult(0);
+    }
+
     private async Task<int> GenChainOutboundsList(List<ProfileItem> nodes, V2rayConfig v2RayConfig, string baseTagName = Global.ProxyTag)
     {
         var resultOutbounds = new List<Outbounds4Ray>();

v2rayN/ServiceLib/Services/CoreConfig/V2ray/V2rayRoutingService.cs

@@ -159,7 +159,7 @@ public partial class CoreConfigV2rayService
             var ret = node.ConfigType switch
             {
                 EConfigType.PolicyGroup =>
-                    await GenOutboundsList(childProfiles, v2rayConfig, childBaseTagName),
+                    await GenOutboundsListWithChain(childProfiles, v2rayConfig, childBaseTagName),
                 EConfigType.ProxyChain =>
                     await GenChainOutboundsList(childProfiles, v2rayConfig, childBaseTagName),
                 _ => throw new NotImplementedException()

v2rayN/ServiceLib/ViewModels/AddGroupServerViewModel.cs

@@ -1,4 +1,3 @@
-using System.Data;
 using System.Reactive;
 using DynamicData.Binding;
 using ReactiveUI;

v2rayN/v2rayN/Views/AddGroupServerWindow.xaml.cs

@@ -1,8 +1,8 @@
+using System.Reactive.Disposables;
 using System.Windows;
 using System.Windows.Input;
-using ReactiveUI;
-using System.Reactive.Disposables;
 using DynamicData;
+using ReactiveUI;
 
 namespace v2rayN.Views;