mirror of
https://github.com/2dust/v2rayN.git
synced 2025-08-28 05:46:19 +00:00
Compare commits
1 commit
dbf12af3a0
...
11c0de87e5
| Author | SHA1 | Date | |
|---|---|---|---|
|
11c0de87e5 |
5 changed files with 114 additions and 206 deletions
|
|
@ -464,11 +464,9 @@ public class Global
|
||||||
public static readonly List<int> TunMtus =
|
public static readonly List<int> TunMtus =
|
||||||
[
|
[
|
||||||
1280,
|
1280,
|
||||||
1408,
|
1408,
|
||||||
1500,
|
1500,
|
||||||
4064,
|
9000
|
||||||
9000,
|
|
||||||
65535
|
|
||||||
];
|
];
|
||||||
|
|
||||||
public static readonly List<string> TunStacks =
|
public static readonly List<string> TunStacks =
|
||||||
|
|
|
||||||
|
|
@ -1412,11 +1412,6 @@ public class ConfigHandler
|
||||||
{
|
{
|
||||||
profileItem = V2rayFmt.ResolveFull(strData, subRemarks);
|
profileItem = V2rayFmt.ResolveFull(strData, subRemarks);
|
||||||
}
|
}
|
||||||
//Is Html Page
|
|
||||||
if (profileItem is null && HtmlPageFmt.IsHtmlPage(strData))
|
|
||||||
{
|
|
||||||
return -1;
|
|
||||||
}
|
|
||||||
//Is Clash configuration
|
//Is Clash configuration
|
||||||
if (profileItem is null)
|
if (profileItem is null)
|
||||||
{
|
{
|
||||||
|
|
|
||||||
|
|
@ -220,7 +220,14 @@ public class BaseFmt
|
||||||
|
|
||||||
protected static bool Contains(string str, params string[] s)
|
protected static bool Contains(string str, params string[] s)
|
||||||
{
|
{
|
||||||
return s.All(item => str.Contains(item, StringComparison.OrdinalIgnoreCase));
|
foreach (var item in s)
|
||||||
|
{
|
||||||
|
if (str.Contains(item, StringComparison.OrdinalIgnoreCase))
|
||||||
|
{
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
protected static string WriteAllText(string strData, string ext = "json")
|
protected static string WriteAllText(string strData, string ext = "json")
|
||||||
|
|
|
||||||
|
|
@ -1,11 +0,0 @@
|
||||||
using SkiaSharp;
|
|
||||||
|
|
||||||
namespace ServiceLib.Handler.Fmt;
|
|
||||||
|
|
||||||
public class HtmlPageFmt : BaseFmt
|
|
||||||
{
|
|
||||||
public static bool IsHtmlPage(string strData)
|
|
||||||
{
|
|
||||||
return Contains(strData, "<html", "<!doctype html", "<head");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -15,200 +15,119 @@ public class SubscriptionHandler
|
||||||
|
|
||||||
foreach (var item in subItem)
|
foreach (var item in subItem)
|
||||||
{
|
{
|
||||||
try
|
var id = item.Id.TrimEx();
|
||||||
|
var url = item.Url.TrimEx();
|
||||||
|
var userAgent = item.UserAgent.TrimEx();
|
||||||
|
var hashCode = $"{item.Remarks}->";
|
||||||
|
if (id.IsNullOrEmpty() || url.IsNullOrEmpty() || (subId.IsNotEmpty() && item.Id != subId))
|
||||||
{
|
{
|
||||||
if (!IsValidSubscription(item, subId))
|
//_updateFunc?.Invoke(false, $"{hashCode}{ResUI.MsgNoValidSubscription}");
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
if (!url.StartsWith(Global.HttpsProtocol) && !url.StartsWith(Global.HttpProtocol))
|
||||||
|
{
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
if (item.Enabled == false)
|
||||||
|
{
|
||||||
|
updateFunc?.Invoke(false, $"{hashCode}{ResUI.MsgSkipSubscriptionUpdate}");
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
var downloadHandle = new DownloadService();
|
||||||
|
downloadHandle.Error += (sender2, args) =>
|
||||||
|
{
|
||||||
|
updateFunc?.Invoke(false, $"{hashCode}{args.GetException().Message}");
|
||||||
|
};
|
||||||
|
|
||||||
|
updateFunc?.Invoke(false, $"{hashCode}{ResUI.MsgStartGettingSubscriptions}");
|
||||||
|
|
||||||
|
//one url
|
||||||
|
url = Utils.GetPunycode(url);
|
||||||
|
//convert
|
||||||
|
if (item.ConvertTarget.IsNotEmpty())
|
||||||
|
{
|
||||||
|
var subConvertUrl = config.ConstItem.SubConvertUrl.IsNullOrEmpty() ? Global.SubConvertUrls.FirstOrDefault() : config.ConstItem.SubConvertUrl;
|
||||||
|
url = string.Format(subConvertUrl!, Utils.UrlEncode(url));
|
||||||
|
if (!url.Contains("target="))
|
||||||
{
|
{
|
||||||
continue;
|
url += string.Format("&target={0}", item.ConvertTarget);
|
||||||
|
}
|
||||||
|
if (!url.Contains("config="))
|
||||||
|
{
|
||||||
|
url += string.Format("&config={0}", Global.SubConvertConfig.FirstOrDefault());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
var result = await downloadHandle.TryDownloadString(url, blProxy, userAgent);
|
||||||
|
if (blProxy && result.IsNullOrEmpty())
|
||||||
|
{
|
||||||
|
result = await downloadHandle.TryDownloadString(url, false, userAgent);
|
||||||
|
}
|
||||||
|
|
||||||
|
//more url
|
||||||
|
if (item.ConvertTarget.IsNullOrEmpty() && item.MoreUrl.TrimEx().IsNotEmpty())
|
||||||
|
{
|
||||||
|
if (result.IsNotEmpty() && Utils.IsBase64String(result))
|
||||||
|
{
|
||||||
|
result = Utils.Base64Decode(result);
|
||||||
}
|
}
|
||||||
|
|
||||||
var hashCode = $"{item.Remarks}->";
|
var lstUrl = item.MoreUrl.TrimEx().Split(",") ?? [];
|
||||||
if (item.Enabled == false)
|
foreach (var it in lstUrl)
|
||||||
{
|
{
|
||||||
updateFunc?.Invoke(false, $"{hashCode}{ResUI.MsgSkipSubscriptionUpdate}");
|
var url2 = Utils.GetPunycode(it);
|
||||||
continue;
|
if (url2.IsNullOrEmpty())
|
||||||
|
{
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
var result2 = await downloadHandle.TryDownloadString(url2, blProxy, userAgent);
|
||||||
|
if (blProxy && result2.IsNullOrEmpty())
|
||||||
|
{
|
||||||
|
result2 = await downloadHandle.TryDownloadString(url2, false, userAgent);
|
||||||
|
}
|
||||||
|
if (result2.IsNotEmpty())
|
||||||
|
{
|
||||||
|
if (Utils.IsBase64String(result2))
|
||||||
|
{
|
||||||
|
result += Environment.NewLine + Utils.Base64Decode(result2);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
result += Environment.NewLine + result2;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (result.IsNullOrEmpty())
|
||||||
|
{
|
||||||
|
updateFunc?.Invoke(false, $"{hashCode}{ResUI.MsgSubscriptionDecodingFailed}");
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
updateFunc?.Invoke(false, $"{hashCode}{ResUI.MsgGetSubscriptionSuccessfully}");
|
||||||
|
if (result?.Length < 99)
|
||||||
|
{
|
||||||
|
updateFunc?.Invoke(false, $"{hashCode}{result}");
|
||||||
}
|
}
|
||||||
|
|
||||||
// Create download handler
|
var ret = await ConfigHandler.AddBatchServers(config, result, id, true);
|
||||||
var downloadHandle = CreateDownloadHandler(hashCode, updateFunc);
|
if (ret <= 0)
|
||||||
updateFunc?.Invoke(false, $"{hashCode}{ResUI.MsgStartGettingSubscriptions}");
|
{
|
||||||
|
Logging.SaveLog("FailedImportSubscription");
|
||||||
// Get all subscription content (main subscription + additional subscriptions)
|
Logging.SaveLog(result);
|
||||||
var result = await DownloadAllSubscriptions(config, item, blProxy, downloadHandle);
|
}
|
||||||
|
updateFunc?.Invoke(false,
|
||||||
// Process download result
|
ret > 0
|
||||||
await ProcessDownloadResult(config, item.Id, result, hashCode, updateFunc);
|
? $"{hashCode}{ResUI.MsgUpdateSubscriptionEnd}"
|
||||||
|
: $"{hashCode}{ResUI.MsgFailedImportSubscription}");
|
||||||
updateFunc?.Invoke(false, "-------------------------------------------------------");
|
|
||||||
}
|
|
||||||
catch (Exception ex)
|
|
||||||
{
|
|
||||||
var hashCode = $"{item.Remarks}->";
|
|
||||||
Logging.SaveLog("UpdateSubscription", ex);
|
|
||||||
updateFunc?.Invoke(false, $"{hashCode}{ResUI.MsgFailedImportSubscription}: {ex.Message}");
|
|
||||||
updateFunc?.Invoke(false, "-------------------------------------------------------");
|
|
||||||
}
|
}
|
||||||
|
updateFunc?.Invoke(false, "-------------------------------------------------------");
|
||||||
|
|
||||||
|
//await ConfigHandler.DedupServerList(config, id);
|
||||||
}
|
}
|
||||||
|
|
||||||
updateFunc?.Invoke(true, $"{ResUI.MsgUpdateSubscriptionEnd}");
|
updateFunc?.Invoke(true, $"{ResUI.MsgUpdateSubscriptionEnd}");
|
||||||
}
|
}
|
||||||
|
|
||||||
private static bool IsValidSubscription(SubItem item, string subId)
|
|
||||||
{
|
|
||||||
var id = item.Id.TrimEx();
|
|
||||||
var url = item.Url.TrimEx();
|
|
||||||
|
|
||||||
if (id.IsNullOrEmpty() || url.IsNullOrEmpty())
|
|
||||||
{
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (subId.IsNotEmpty() && item.Id != subId)
|
|
||||||
{
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!url.StartsWith(Global.HttpsProtocol) && !url.StartsWith(Global.HttpProtocol))
|
|
||||||
{
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
private static DownloadService CreateDownloadHandler(string hashCode, Action<bool, string> updateFunc)
|
|
||||||
{
|
|
||||||
var downloadHandle = new DownloadService();
|
|
||||||
downloadHandle.Error += (sender2, args) =>
|
|
||||||
{
|
|
||||||
updateFunc?.Invoke(false, $"{hashCode}{args.GetException().Message}");
|
|
||||||
};
|
|
||||||
return downloadHandle;
|
|
||||||
}
|
|
||||||
|
|
||||||
private static async Task<string> DownloadSubscriptionContent(DownloadService downloadHandle, string url, bool blProxy, string userAgent)
|
|
||||||
{
|
|
||||||
var result = await downloadHandle.TryDownloadString(url, blProxy, userAgent);
|
|
||||||
|
|
||||||
// If download with proxy fails, try direct connection
|
|
||||||
if (blProxy && result.IsNullOrEmpty())
|
|
||||||
{
|
|
||||||
result = await downloadHandle.TryDownloadString(url, false, userAgent);
|
|
||||||
}
|
|
||||||
|
|
||||||
return result ?? string.Empty;
|
|
||||||
}
|
|
||||||
|
|
||||||
private static async Task<string> DownloadAllSubscriptions(Config config, SubItem item, bool blProxy, DownloadService downloadHandle)
|
|
||||||
{
|
|
||||||
// Download main subscription content
|
|
||||||
var result = await DownloadMainSubscription(config, item, blProxy, downloadHandle);
|
|
||||||
|
|
||||||
// Process additional subscription links (if any)
|
|
||||||
if (item.ConvertTarget.IsNullOrEmpty() && item.MoreUrl.TrimEx().IsNotEmpty())
|
|
||||||
{
|
|
||||||
result = await DownloadAdditionalSubscriptions(item, result, blProxy, downloadHandle);
|
|
||||||
}
|
|
||||||
|
|
||||||
return result;
|
|
||||||
}
|
|
||||||
|
|
||||||
private static async Task<string> DownloadMainSubscription(Config config, SubItem item, bool blProxy, DownloadService downloadHandle)
|
|
||||||
{
|
|
||||||
// Prepare subscription URL and download directly
|
|
||||||
var url = Utils.GetPunycode(item.Url.TrimEx());
|
|
||||||
|
|
||||||
// If conversion is needed
|
|
||||||
if (item.ConvertTarget.IsNotEmpty())
|
|
||||||
{
|
|
||||||
var subConvertUrl = config.ConstItem.SubConvertUrl.IsNullOrEmpty()
|
|
||||||
? Global.SubConvertUrls.FirstOrDefault()
|
|
||||||
: config.ConstItem.SubConvertUrl;
|
|
||||||
|
|
||||||
url = string.Format(subConvertUrl!, Utils.UrlEncode(url));
|
|
||||||
|
|
||||||
if (!url.Contains("target="))
|
|
||||||
{
|
|
||||||
url += string.Format("&target={0}", item.ConvertTarget);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!url.Contains("config="))
|
|
||||||
{
|
|
||||||
url += string.Format("&config={0}", Global.SubConvertConfig.FirstOrDefault());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Download and return result directly
|
|
||||||
return await DownloadSubscriptionContent(downloadHandle, url, blProxy, item.UserAgent);
|
|
||||||
}
|
|
||||||
|
|
||||||
private static async Task<string> DownloadAdditionalSubscriptions(SubItem item, string mainResult, bool blProxy, DownloadService downloadHandle)
|
|
||||||
{
|
|
||||||
var result = mainResult;
|
|
||||||
|
|
||||||
// If main subscription result is Base64 encoded, decode it first
|
|
||||||
if (result.IsNotEmpty() && Utils.IsBase64String(result))
|
|
||||||
{
|
|
||||||
result = Utils.Base64Decode(result);
|
|
||||||
}
|
|
||||||
|
|
||||||
// Process additional URL list
|
|
||||||
var lstUrl = item.MoreUrl.TrimEx().Split(",") ?? [];
|
|
||||||
foreach (var it in lstUrl)
|
|
||||||
{
|
|
||||||
var url2 = Utils.GetPunycode(it);
|
|
||||||
if (url2.IsNullOrEmpty())
|
|
||||||
{
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
|
|
||||||
var additionalResult = await DownloadSubscriptionContent(downloadHandle, url2, blProxy, item.UserAgent);
|
|
||||||
|
|
||||||
if (additionalResult.IsNotEmpty())
|
|
||||||
{
|
|
||||||
// Process additional subscription results, add to main result
|
|
||||||
if (Utils.IsBase64String(additionalResult))
|
|
||||||
{
|
|
||||||
result += Environment.NewLine + Utils.Base64Decode(additionalResult);
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
result += Environment.NewLine + additionalResult;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return result;
|
|
||||||
}
|
|
||||||
|
|
||||||
private static async Task ProcessDownloadResult(Config config, string id, string result, string hashCode, Action<bool, string> updateFunc)
|
|
||||||
{
|
|
||||||
if (result.IsNullOrEmpty())
|
|
||||||
{
|
|
||||||
updateFunc?.Invoke(false, $"{hashCode}{ResUI.MsgSubscriptionDecodingFailed}");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
updateFunc?.Invoke(false, $"{hashCode}{ResUI.MsgGetSubscriptionSuccessfully}");
|
|
||||||
|
|
||||||
// If result is too short, display content directly
|
|
||||||
if (result.Length < 99)
|
|
||||||
{
|
|
||||||
updateFunc?.Invoke(false, $"{hashCode}{result}");
|
|
||||||
}
|
|
||||||
|
|
||||||
// Add servers to configuration
|
|
||||||
var ret = await ConfigHandler.AddBatchServers(config, result, id, true);
|
|
||||||
if (ret <= 0)
|
|
||||||
{
|
|
||||||
Logging.SaveLog("FailedImportSubscription");
|
|
||||||
Logging.SaveLog(result);
|
|
||||||
}
|
|
||||||
|
|
||||||
// Update completion message
|
|
||||||
updateFunc?.Invoke(false,
|
|
||||||
ret > 0
|
|
||||||
? $"{hashCode}{ResUI.MsgUpdateSubscriptionEnd}"
|
|
||||||
: $"{hashCode}{ResUI.MsgFailedImportSubscription}");
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue