mirror of
https://github.com/2dust/v2rayN.git
synced 2026-02-28 05:03:02 +00:00
Merge f7dbc5a995 into 67c4ae02ba
This commit is contained in:
commit
94720fe422
8 changed files with 36 additions and 29 deletions
|
|
@ -94,11 +94,9 @@ public static class CoreConfigHandler
|
||||||
{
|
{
|
||||||
var result = new RetResult();
|
var result = new RetResult();
|
||||||
var context = await BuildCoreConfigContext(config, new());
|
var context = await BuildCoreConfigContext(config, new());
|
||||||
var ids = selecteds.Where(serverTestItem => !serverTestItem.IndexId.IsNullOrEmpty())
|
foreach (var testItem in selecteds)
|
||||||
.Select(serverTestItem => serverTestItem.IndexId);
|
|
||||||
var nodes = await AppManager.Instance.GetProfileItemsByIndexIds(ids);
|
|
||||||
foreach (var node in nodes)
|
|
||||||
{
|
{
|
||||||
|
var node = testItem.Profile;
|
||||||
var actNode = await FillNodeContext(context, node, true);
|
var actNode = await FillNodeContext(context, node, true);
|
||||||
if (node.IndexId == actNode.IndexId)
|
if (node.IndexId == actNode.IndexId)
|
||||||
{
|
{
|
||||||
|
|
|
||||||
|
|
@ -230,7 +230,7 @@ public sealed class AppManager
|
||||||
return await SQLiteHelper.Instance.TableAsync<ProfileItem>().FirstOrDefaultAsync(it => it.IndexId == indexId);
|
return await SQLiteHelper.Instance.TableAsync<ProfileItem>().FirstOrDefaultAsync(it => it.IndexId == indexId);
|
||||||
}
|
}
|
||||||
|
|
||||||
public async Task<List<ProfileItem>> GetProfileItemsByIndexIds(IEnumerable<string> indexIds)
|
public async Task<List<ProfileItem>> GetProfileItemsByIndexIdsAsync(IEnumerable<string> indexIds)
|
||||||
{
|
{
|
||||||
var ids = indexIds.Where(id => !id.IsNullOrEmpty()).Distinct().ToList();
|
var ids = indexIds.Where(id => !id.IsNullOrEmpty()).Distinct().ToList();
|
||||||
if (ids.Count == 0)
|
if (ids.Count == 0)
|
||||||
|
|
@ -242,6 +242,12 @@ public sealed class AppManager
|
||||||
.ToListAsync();
|
.ToListAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public async Task<Dictionary<string, ProfileItem>> GetProfileItemsByIndexIdsAsMapAsync(IEnumerable<string> indexIds)
|
||||||
|
{
|
||||||
|
var items = await GetProfileItemsByIndexIdsAsync(indexIds);
|
||||||
|
return items.ToDictionary(it => it.IndexId);
|
||||||
|
}
|
||||||
|
|
||||||
public async Task<ProfileItem?> GetProfileItemViaRemarks(string? remarks)
|
public async Task<ProfileItem?> GetProfileItemViaRemarks(string? remarks)
|
||||||
{
|
{
|
||||||
if (remarks.IsNullOrEmpty())
|
if (remarks.IsNullOrEmpty())
|
||||||
|
|
|
||||||
|
|
@ -105,7 +105,7 @@ public class CoreManager
|
||||||
|
|
||||||
public async Task<ProcessService?> LoadCoreConfigSpeedtest(List<ServerTestItem> selecteds)
|
public async Task<ProcessService?> LoadCoreConfigSpeedtest(List<ServerTestItem> selecteds)
|
||||||
{
|
{
|
||||||
var coreType = selecteds.Any(t => Global.SingboxOnlyConfigType.Contains(t.ConfigType)) ? ECoreType.sing_box : ECoreType.Xray;
|
var coreType = selecteds.FirstOrDefault()?.CoreType == ECoreType.sing_box ? ECoreType.sing_box : ECoreType.Xray;
|
||||||
var fileName = string.Format(Global.CoreSpeedtestConfigFileName, Utils.GetGuid(false));
|
var fileName = string.Format(Global.CoreSpeedtestConfigFileName, Utils.GetGuid(false));
|
||||||
var configPath = Utils.GetBinConfigPath(fileName);
|
var configPath = Utils.GetBinConfigPath(fileName);
|
||||||
var result = await CoreConfigHandler.GenerateClientSpeedtestConfig(_config, configPath, selecteds, coreType);
|
var result = await CoreConfigHandler.GenerateClientSpeedtestConfig(_config, configPath, selecteds, coreType);
|
||||||
|
|
|
||||||
|
|
@ -103,16 +103,7 @@ public class GroupProfileManager
|
||||||
return [];
|
return [];
|
||||||
}
|
}
|
||||||
|
|
||||||
var childProfiles = await AppManager.Instance.GetProfileItemsByIndexIds(childProfileIds);
|
var profileMap = await AppManager.Instance.GetProfileItemsByIndexIdsAsMapAsync(childProfileIds);
|
||||||
if (childProfiles == null || childProfiles.Count == 0)
|
|
||||||
{
|
|
||||||
return [];
|
|
||||||
}
|
|
||||||
|
|
||||||
var profileMap = childProfiles
|
|
||||||
.Where(p => p != null && !p.IndexId.IsNullOrEmpty())
|
|
||||||
.GroupBy(p => p!.IndexId!)
|
|
||||||
.ToDictionary(g => g.Key, g => g.First());
|
|
||||||
|
|
||||||
var ordered = new List<ProfileItem>(childProfileIds.Count);
|
var ordered = new List<ProfileItem>(childProfileIds.Count);
|
||||||
foreach (var id in childProfileIds)
|
foreach (var id in childProfileIds)
|
||||||
|
|
|
||||||
|
|
@ -9,4 +9,6 @@ public class ServerTestItem
|
||||||
public EConfigType ConfigType { get; set; }
|
public EConfigType ConfigType { get; set; }
|
||||||
public bool AllowTest { get; set; }
|
public bool AllowTest { get; set; }
|
||||||
public int QueueNum { get; set; }
|
public int QueueNum { get; set; }
|
||||||
|
public required ProfileItem Profile { get; set; }
|
||||||
|
public ECoreType CoreType { get; set; }
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -149,11 +149,11 @@ public partial class CoreConfigSingboxService(CoreConfigContext context)
|
||||||
|
|
||||||
foreach (var it in selecteds)
|
foreach (var it in selecteds)
|
||||||
{
|
{
|
||||||
if (!Global.SingboxSupportConfigType.Contains(it.ConfigType))
|
if (!(Global.XraySupportConfigType.Contains(it.ConfigType) || it.ConfigType.IsGroupType()))
|
||||||
{
|
{
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
if (it.Port <= 0)
|
if (!it.ConfigType.IsComplexType() && it.Port <= 0)
|
||||||
{
|
{
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -112,11 +112,11 @@ public partial class CoreConfigV2rayService(CoreConfigContext context)
|
||||||
|
|
||||||
foreach (var it in selecteds)
|
foreach (var it in selecteds)
|
||||||
{
|
{
|
||||||
if (!Global.XraySupportConfigType.Contains(it.ConfigType))
|
if (!(Global.XraySupportConfigType.Contains(it.ConfigType) || it.ConfigType.IsGroupType()))
|
||||||
{
|
{
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
if (it.Port <= 0)
|
if (!it.ConfigType.IsComplexType() && it.Port <= 0)
|
||||||
{
|
{
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
@ -180,13 +180,13 @@ public partial class CoreConfigV2rayService(CoreConfigContext context)
|
||||||
//rule
|
//rule
|
||||||
RulesItem4Ray rule = new()
|
RulesItem4Ray rule = new()
|
||||||
{
|
{
|
||||||
inboundTag = new List<string> { inbound.tag },
|
inboundTag = [inbound.tag],
|
||||||
outboundTag = tag,
|
outboundTag = tag,
|
||||||
type = "field"
|
type = "field"
|
||||||
};
|
};
|
||||||
if (isBalancer)
|
if (isBalancer)
|
||||||
{
|
{
|
||||||
rule.balancerTag = tag;
|
rule.balancerTag = tag + Global.BalancerTagSuffix;
|
||||||
rule.outboundTag = null;
|
rule.outboundTag = null;
|
||||||
}
|
}
|
||||||
_coreConfig.routing.rules.Add(rule);
|
_coreConfig.routing.rules.Add(rule);
|
||||||
|
|
|
||||||
|
|
@ -61,26 +61,36 @@ public class SpeedtestService(Config config, Func<SpeedTestResult, Task> updateF
|
||||||
|
|
||||||
private async Task<List<ServerTestItem>> GetClearItem(ESpeedActionType actionType, List<ProfileItem> selecteds)
|
private async Task<List<ServerTestItem>> GetClearItem(ESpeedActionType actionType, List<ProfileItem> selecteds)
|
||||||
{
|
{
|
||||||
var lstSelected = new List<ServerTestItem>();
|
var lstSelected = new List<ServerTestItem>(selecteds.Count);
|
||||||
foreach (var it in selecteds)
|
var ids = selecteds.Where(it => !it.IndexId.IsNullOrEmpty()
|
||||||
|
&& it.ConfigType != EConfigType.Custom
|
||||||
|
&& (it.ConfigType.IsComplexType() || it.Port > 0))
|
||||||
|
.Select(it => it.IndexId)
|
||||||
|
.ToList();
|
||||||
|
var profileMap = await AppManager.Instance.GetProfileItemsByIndexIdsAsMapAsync(ids);
|
||||||
|
for (var i = 0; i < selecteds.Count; i++)
|
||||||
{
|
{
|
||||||
if (it.ConfigType.IsComplexType())
|
var it = selecteds[i];
|
||||||
|
if (it.ConfigType == EConfigType.Custom)
|
||||||
{
|
{
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (it.Port <= 0)
|
if (!it.ConfigType.IsComplexType() && it.Port <= 0)
|
||||||
{
|
{
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
var profile = profileMap.GetValueOrDefault(it.IndexId, it);
|
||||||
lstSelected.Add(new ServerTestItem()
|
lstSelected.Add(new ServerTestItem()
|
||||||
{
|
{
|
||||||
IndexId = it.IndexId,
|
IndexId = it.IndexId,
|
||||||
Address = it.Address,
|
Address = it.Address,
|
||||||
Port = it.Port,
|
Port = it.Port,
|
||||||
ConfigType = it.ConfigType,
|
ConfigType = it.ConfigType,
|
||||||
QueueNum = selecteds.IndexOf(it)
|
QueueNum = i,
|
||||||
|
Profile = profile,
|
||||||
|
CoreType = AppManager.Instance.GetCoreType(profile, it.ConfigType),
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -353,8 +363,8 @@ public class SpeedtestService(Config config, Func<SpeedTestResult, Task> updateF
|
||||||
private List<List<ServerTestItem>> GetTestBatchItem(List<ServerTestItem> lstSelected, int pageSize)
|
private List<List<ServerTestItem>> GetTestBatchItem(List<ServerTestItem> lstSelected, int pageSize)
|
||||||
{
|
{
|
||||||
List<List<ServerTestItem>> lstTest = new();
|
List<List<ServerTestItem>> lstTest = new();
|
||||||
var lst1 = lstSelected.Where(t => Global.XraySupportConfigType.Contains(t.ConfigType)).ToList();
|
var lst1 = lstSelected.Where(t => t.CoreType == ECoreType.Xray).ToList();
|
||||||
var lst2 = lstSelected.Where(t => Global.SingboxOnlyConfigType.Contains(t.ConfigType)).ToList();
|
var lst2 = lstSelected.Where(t => t.CoreType == ECoreType.sing_box).ToList();
|
||||||
|
|
||||||
for (var num = 0; num < (int)Math.Ceiling(lst1.Count * 1.0 / pageSize); num++)
|
for (var num = 0; num < (int)Math.Ceiling(lst1.Count * 1.0 / pageSize); num++)
|
||||||
{
|
{
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue