Refactor: Create ModeFeature Enum

This commit is contained in:
ChsBuffer
2021-07-23 00:43:29 +08:00
parent 3e5a4fc102
commit c12122f7d0
7 changed files with 55 additions and 60 deletions

View File

@@ -2,8 +2,11 @@ using System;
using System.IO;
using System.Threading.Tasks;
using Microsoft.VisualStudio.Threading;
using Netch.Enums;
using Netch.Interfaces;
using Netch.Models;
using Netch.Servers;
using Netch.Servers.Shadowsocks;
using Netch.Utils;
using Serilog;
using Serilog.Events;
@@ -20,6 +23,8 @@ namespace Netch.Controllers
public static IModeController? ModeController { get; private set; }
public static ModeFeature ModeFeatures { get; private set; }
public static async Task StartAsync(Server server, Mode mode)
{
Log.Information("Start MainController: {Server} {Mode}", $"{server.Type}", $"[{(int)mode.Type}]{mode.Remark}");
@@ -44,10 +49,24 @@ namespace Netch.Controllers
try
{
if (!ModeHelper.SkipServerController(server, mode))
server = await StartServerAsync(server);
(ModeController, ModeFeatures) = ModeHelper.GetModeControllerByType(mode.Type, out var modePort, out var portName);
await StartModeAsync(server, mode);
if (modePort != null)
TryReleaseTcpPort((ushort)modePort, portName);
switch (server)
{
case Socks5 socks5 when !socks5.Auth() || socks5.Auth() && ModeFeatures.HasFlag(ModeFeature.SupportSocks5Auth):
case Shadowsocks shadowsocks when !shadowsocks.HasPlugin() && ModeFeatures.HasFlag(ModeFeature.SupportShadowsocks) &&
Global.Settings.Redirector.RedirectorSS:
break;
default:
server = await StartServerAsync(server);
break;
}
Global.MainForm.StatusText(i18N.TranslateFormat("Starting {0}", ModeController.Name));
await ModeController.StartAsync(server, mode);
}
catch (Exception e)
{
@@ -77,24 +96,12 @@ namespace Netch.Controllers
Global.MainForm.StatusText(i18N.TranslateFormat("Starting {0}", ServerController.Name));
Log.Debug("Server Information: {Data}", $"{server.Type} {server.MaskedData()}");
var socks5 = await ServerController.StartAsync(server);
var socks5Bridge = await ServerController.StartAsync(server);
StatusPortInfoText.Socks5Port = socks5.Port;
StatusPortInfoText.Socks5Port = socks5Bridge.Port;
StatusPortInfoText.UpdateShareLan();
return socks5;
}
private static async Task StartModeAsync(Server server, Mode mode)
{
ModeController = ModeHelper.GetModeControllerByType(mode.Type, out var port, out var portName);
if (port != null)
TryReleaseTcpPort((ushort)port, portName);
Global.MainForm.StatusText(i18N.TranslateFormat("Starting {0}", ModeController.Name));
await ModeController.StartAsync(server, mode);
return socks5Bridge;
}
public static async Task StopAsync()
@@ -122,8 +129,9 @@ namespace Netch.Controllers
Log.Error(e, "MainController Stop Error");
}
ModeController = null;
ServerController = null;
ModeController = null;
ModeFeatures = 0;
}
public static void PortCheck(ushort port, string portName, PortType portType = PortType.Both)

View File

@@ -0,0 +1,16 @@
using System;
namespace Netch.Enums
{
[Flags]
public enum ModeFeature
{
SupportSocks5 = 0,
SupportIPv4 = 0,
SupportSocks5Auth = 0b_0001,
[Obsolete]
SupportShadowsocks = 0b_0010,
SupportIPv6 = 0b_0100,
RequireTestNat = 0b_1000
}
}

View File

@@ -1158,7 +1158,7 @@ namespace Netch.Forms
/// </summary>
private async Task NatTestAsync()
{
if (!MainController.Mode!.TestNatRequired())
if (!MainController.ModeFeatures.HasFlag(ModeFeature.RequireTestNat))
return;
if (NatTestLock.CurrentCount == 0)

View File

@@ -120,14 +120,4 @@ namespace Netch.Models
return $"[{(int)Type + 1}] {i18N.Translate(Remark)}";
}
}
public static class ModeExtension
{
/// 是否会转发 UDP
public static bool TestNatRequired(this Mode mode)
{
return mode.Type is ModeType.Process && Global.Settings.Redirector.FilterProtocol.HasFlag(PortType.UDP) ||
mode.Type is ModeType.BypassRuleIPs;
}
}
}

View File

@@ -1,3 +1,4 @@
using System;
using System.Threading.Tasks;
using Netch.Models;
@@ -10,10 +11,10 @@ namespace Netch.Servers
public override async Task<Socks5> StartAsync(Server s)
{
var server = (Socks5)s;
if (server.Auth())
await base.StartAsync(s);
if (!server.Auth())
throw new ArgumentException();
return server;
return await base.StartAsync(s);
}
}
}

View File

@@ -6,8 +6,6 @@ using Netch.Controllers;
using Netch.Enums;
using Netch.Interfaces;
using Netch.Models;
using Netch.Servers;
using Netch.Servers.Shadowsocks;
using Serilog;
namespace Netch.Utils
@@ -126,38 +124,20 @@ namespace Netch.Utils
File.Delete(mode.FullName);
}
public static bool SkipServerController(Server server, Mode mode)
{
switch (mode.Type)
{
case ModeType.Process:
return server switch
{
Socks5 => true,
Shadowsocks shadowsocks when !shadowsocks.HasPlugin() && Global.Settings.Redirector.RedirectorSS => true,
_ => false
};
case ModeType.ProxyRuleIPs:
case ModeType.BypassRuleIPs:
return server is Socks5;
default:
return false;
}
}
public static IModeController GetModeControllerByType(ModeType type, out ushort? port, out string portName)
public static (IModeController, ModeFeature) GetModeControllerByType(ModeType type, out ushort? port, out string portName)
{
port = null;
portName = string.Empty;
switch (type)
{
case ModeType.Process:
return new NFController();
return (new NFController(), ModeFeature.SupportIPv6 | ModeFeature.SupportSocks5Auth | ModeFeature.RequireTestNat);
case ModeType.ProxyRuleIPs:
return (new TUNController(), ModeFeature.SupportSocks5Auth);
case ModeType.BypassRuleIPs:
return new TUNController();
return (new TUNController(), ModeFeature.SupportSocks5Auth | ModeFeature.RequireTestNat);
case ModeType.Pcap2Socks:
return new PcapController();
return (new PcapController(), 0);
default:
Log.Error("未知模式类型");
throw new MessageException("未知模式类型");

View File

@@ -195,8 +195,8 @@ namespace Netch.Utils
[Flags]
public enum PortType
{
TCP = 0x01,
UDP = 0x10,
TCP = 0b_01,
UDP = 0b_10,
Both = TCP | UDP
}