using System; using System.Collections.Generic; using System.Net; using System.Text; using System.Threading; using UnityEngine; namespace AllocsFixes.NetConnections.Servers.Web { public class Web : IServer { private readonly HttpListener _listener = new HttpListener (); private Dictionary handlers = new Dictionary (); public Web (int port) { try { if (!HttpListener.IsSupported) throw new NotSupportedException ("Needs Windows XP SP2, Server 2003 or later."); handlers.Add ("/index.", new SimpleRedirectHandler ("/static/index.html")); handlers.Add ("/static/", new StaticHandler ("/static/", Application.dataPath + "/../webserver", true, true)); handlers.Add ("/map/", new StaticHandler ("/map/", StaticDirectories.GetSaveGameDir () + "/map", false, false)); _listener.Prefixes.Add (String.Format ("http://*:{0}/", port)); //_listener.AuthenticationSchemes = AuthenticationSchemes.Basic; _listener.Start (); ThreadPool.QueueUserWorkItem ((o) => { try { while (_listener.IsListening) { ThreadPool.QueueUserWorkItem ((c) => { HttpListenerContext ctx = c as HttpListenerContext; HandleRequest (ctx); }, _listener.GetContext ()); } } catch { } } ); Log.Out ("Started Webserver on " + port); } catch (Exception e) { Log.Out ("Error in Web.ctor: " + e); } } private void HandleRequest (HttpListenerContext ctx) { try { ctx.Response.ProtocolVersion = new Version ("1.1"); HttpListenerBasicIdentity user; if (Authorize (ctx, out user)) { if (ctx.Request.Url.AbsolutePath.Length < 2) { handlers ["/index."].HandleRequest (ctx.Request, ctx.Response, user); return; } else { foreach (KeyValuePair kvp in handlers) { if (ctx.Request.Url.AbsolutePath.StartsWith (kvp.Key)) { kvp.Value.HandleRequest (ctx.Request, ctx.Response, user); return; } } } Log.Out ("Error in Web.HandleRequest(): No handler found for path \"" + ctx.Request.Url.AbsolutePath + "\""); ctx.Response.StatusCode = (int)HttpStatusCode.NotFound; } else { ctx.Response.StatusCode = (int)HttpStatusCode.Unauthorized; ctx.Response.AddHeader("WWW-Authenticate", "Basic realm=\"\""); } // byte[] buf = Encoding.UTF8.GetBytes ("Hello World"); // resp.ContentLength64 = buf.Length; // resp.ContentType = "text/html"; // resp.ContentEncoding = Encoding.UTF8; // resp.OutputStream.Write (buf, 0, buf.Length); } catch (Exception e) { Log.Out ("Error in Web.HandleRequest(): " + e); } finally { ctx.Response.Close (); } } private bool Authorize (HttpListenerContext ctx, out HttpListenerBasicIdentity user) { user = null; return true; try { user = (HttpListenerBasicIdentity)ctx.User.Identity; return user.Name.Equals ("admin") && user.Password.Equals (GamePrefs.GetString (EnumGamePrefs.ControlPanelPassword)); } catch (NullReferenceException) { user = null; return false; } } public void Disconnect () { try { _listener.Stop (); _listener.Close (); } catch (Exception e) { Log.Out ("Error in Web.Disconnect: " + e); } } public void WriteToClient (string line) { try { //Log.Out ("NOT IMPLEMENTED: Web.WriteToClient"); } catch (Exception e) { Log.Out ("Error in Web.WriteToClient: " + e); } } public void WriteToClient_Single (string line, IConnection client) { try { //Log.Out ("NOT IMPLEMENTED: Web.WriteToClient_Single"); } catch (Exception e) { Log.Out ("Error in Web.WriteToClient_Single: " + e); } } } }