up 6.0

2023-01-01 19:42:01 +08:00
parent b48037b757
commit 020df117c4
197 changed files with 21439 additions and 29147 deletions
--- a/v2rayN/PacLib/PacHandler.cs
+++ b/v2rayN/PacLib/PacHandler.cs
@@ -0,0 +1,112 @@
+using System;
+using System.IO;
+using System.Net.Sockets;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace PacLib;
+
+public class PacHandler
+{
+    private static string _configPath;
+    private static int _httpPort;
+    private static int _pacPort;
+    private static TcpListener? _tcpListener;
+    private static string _pacText;
+    private static bool _isRunning;
+    private static bool _needRestart = true;
+
+
+    public static void Start(string configPath, int httpPort, int pacPort)
+    {
+        if (configPath.Equals(_configPath)
+            && httpPort.Equals(_httpPort)
+            && pacPort.Equals(_pacPort)
+            && _isRunning)
+        {
+            _needRestart = false;
+        }
+
+        _configPath = configPath;
+        _httpPort = httpPort;
+        _pacPort = pacPort;
+
+        InitText();
+
+        if (_needRestart)
+        {
+            Stop();
+            RunListener();
+        }
+    }
+
+    private static void InitText()
+    {
+        var path = Path.Combine(_configPath, "pac.txt");
+        if (!File.Exists(path))
+        {
+            File.AppendAllText(path, Resources.ResourceManager.GetString("pac"));
+        }
+
+        _pacText = File.ReadAllText(path).Replace("__PROXY__", $"PROXY 127.0.0.1:{_httpPort};DIRECT;");
+    }
+
+    private static void RunListener()
+    {
+        _tcpListener = TcpListener.Create(_pacPort);
+        _isRunning = true;
+        _tcpListener.Start();
+        Task.Factory.StartNew(() =>
+        {
+            while (_isRunning)
+            {
+                try
+                {
+                    if (!_tcpListener.Pending())
+                    {
+                        Thread.Sleep(10);
+                        continue;
+                    }
+
+                    var client = _tcpListener.AcceptTcpClient();
+                    Task.Run(() =>
+                    {
+                        var stream = client.GetStream();
+                        var sb = new StringBuilder();
+                        sb.AppendLine("HTTP/1.0 200 OK");
+                        sb.AppendLine("Content-type:application/x-ns-proxy-autoconfig");
+                        sb.AppendLine("Connection:close");
+                        sb.AppendLine("Content-Length:" + Encoding.UTF8.GetByteCount(_pacText));
+                        sb.AppendLine();
+                        sb.Append(_pacText);
+                        var content = Encoding.UTF8.GetBytes(sb.ToString());
+                        stream.Write(content, 0, content.Length);
+                        stream.Flush();
+                    });
+                }
+                catch (Exception e)
+                {
+                }
+            }
+
+        }, TaskCreationOptions.LongRunning);
+
+    }
+
+    public static void Stop()
+    {
+        if (_tcpListener != null)
+        {
+            try
+            {
+                _isRunning = false;
+                _tcpListener.Stop();
+                _tcpListener = null;
+            }
+            catch (Exception e)
+            {
+            }
+        }
+    }
+}