cleanup drop http support

This commit is contained in:
ChsBuffer
2021-03-26 18:21:59 +08:00
parent 4ab844e31c
commit 415c7705ac
3 changed files with 1 additions and 161 deletions

View File

@@ -1,77 +0,0 @@
using System;
using System.Net;
using System.Text;
namespace Netch.Utils.HttpProxyHandler
{
public class HttpWebServer
{
private readonly Func<HttpListenerRequest, string>? _responderMethod;
private HttpListener? _listener;
public HttpWebServer(string[] prefixes, Func<HttpListenerRequest, string> method)
{
_listener = new HttpListener();
// URI prefixes are required, for example
// "http://localhost:8080/index/".
if (prefixes == null || prefixes.Length == 0)
throw new ArgumentException("prefixes");
// A responder method is required
if (method == null)
throw new ArgumentException("method");
foreach (var s in prefixes)
_listener.Prefixes.Add(s);
_responderMethod = method;
_listener.Start();
}
public HttpWebServer(Func<HttpListenerRequest, string> method, params string[] prefixes) : this(prefixes, method)
{
}
public void StartWaitingRequest()
{
Logging.Info("Webserver running...");
while (_listener?.IsListening ?? false)
{
HttpListenerContext ctx;
try
{
ctx = _listener.GetContext();
}
catch
{
break;
}
try
{
var rstr = _responderMethod!(ctx.Request);
var buf = Encoding.UTF8.GetBytes(rstr);
ctx.Response.StatusCode = 200;
ctx.Response.ContentType = "application/x-ns-proxy-autoconfig";
ctx.Response.ContentLength64 = buf.Length;
ctx.Response.OutputStream.Write(buf, 0, buf.Length);
}
finally
{
ctx.Response.OutputStream.Close();
}
}
}
public void Stop()
{
if (_listener != null)
{
_listener.Stop();
_listener.Close();
_listener = null;
}
}
}
}

View File

@@ -1,83 +0,0 @@
using System;
using System.IO;
using System.Net;
using System.Text;
using System.Threading.Tasks;
using Netch.Controllers;
namespace Netch.Utils.HttpProxyHandler
{
/// <summary>
/// 提供PAC功能支持
/// </summary>
internal static class PACServerHandle
{
private static HttpWebServer? _httpWebServer;
private static string? _pacContent;
public static readonly string PacPrefix= $"http://127.0.0.1:{Global.Settings.Pac_Port}/pac/";
public static string InitPACServer()
{
try
{
_pacContent = GetPacList("127.0.0.1");
_httpWebServer = new HttpWebServer(SendResponse, PacPrefix);
Task.Run(() => _httpWebServer.StartWaitingRequest());
var pacUrl = GetPacUrl();
Logging.Info($"Webserver InitServer OK: {pacUrl}");
return pacUrl;
}
catch
{
Logging.Error("Webserver InitServer Failed");
throw;
}
}
public static string SendResponse(HttpListenerRequest request)
{
return _pacContent!;
}
public static void Stop()
{
try
{
_httpWebServer?.Stop();
}
catch
{
// ignored
}
_httpWebServer = null;
}
private static string GetPacList(string address)
{
try
{
var proxy = $"PROXY {address}:{Global.Settings.HTTPLocalPort};";
var pacfile = Path.Combine(Global.NetchDir, "bin\\pac.txt");
var pac = File.ReadAllText(pacfile, Encoding.UTF8).Replace("__PROXY__", proxy);
return pac;
}
catch
{
throw new MessageException("Pac file not found!");
}
}
/// <summary>
/// 获取PAC地址
/// </summary>
/// <returns></returns>
public static string GetPacUrl()
{
return PacPrefix + $"?t={DateTime.Now:yyyyMMddHHmmssfff}";
}
}
}