sdks/csnet/BaSys40.Utils/Server/SimpleLocalHttpServer.cs

using NLog;
using System;
using System.Collections.Generic;
using System.Collections.Specialized;
using System.IO;
using System.Net;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace BaSys40.Utils.Server
{
    public class SimpleLocalHttpServer
    {
        public Uri Endpoint { get; }

        private HttpListener listener;
        private CancellationTokenSource cancellationToken;
        private Action<HttpListenerRequest> messageReception = null;
        private Action<HttpListenerResponse> messageResponse = null;
        private Action<HttpListenerContext> messageHandler = null;

        private static Logger logger = LogManager.GetCurrentClassLogger();

        public SimpleLocalHttpServer(string endpoint)
        {
            Endpoint = new Uri(endpoint);
        }


        public void Start()
        {
            listener = new HttpListener();
            listener.Prefixes.Add(Endpoint.OriginalString + "/");
            cancellationToken = new CancellationTokenSource();

            if (!listener.IsListening)
            {
                listener.Start();

                Task.Factory.StartNew(async () =>
                {
                    while (!cancellationToken.IsCancellationRequested)
                        await Listen(listener);
                }, cancellationToken.Token, TaskCreationOptions.LongRunning, TaskScheduler.Current);

                logger.Info("Http-Listener started");
            }
        }

        public void Start(Action<HttpListenerRequest> receiveMessageMethod)
        {
            messageReception = receiveMessageMethod;
            Start();
        }

        public void Start(Action<HttpListenerRequest> receiveMessageMethod, Action<HttpListenerResponse> responseMessageMethod)
        {
            messageReception = receiveMessageMethod;
            messageResponse = responseMessageMethod;
            Start();
        }

        public void Start(Action<HttpListenerContext> messageHandlerMethod)
        {
            messageHandler = messageHandlerMethod;
            Start();
        }
        private async Task Listen(HttpListener listener)
        {
            try
            {
                HttpListenerContext context = await listener.GetContextAsync();
                if (messageHandler != null)
                    messageHandler.Invoke(context);
                else
                {
                    if (messageReception != null)
                        messageReception.Invoke(context.Request);
                    if (messageResponse != null)
                        messageResponse.Invoke(context.Response);
                }
            }
            catch (Exception e)
            {
                logger.Error(e, "Http-Listener Exception: " + e.Message);
            }
        }

        public void Stop()
        {
            if (listener.IsListening)
            {
                cancellationToken.Cancel();
                listener.Stop();
                logger.Info("Http-Listener stopped");
            }
        }

        public static List<string> GetLocalIpAddresses()
        {
            var host = System.Net.Dns.GetHostEntry(System.Net.Dns.GetHostName());
            List<string> ipAddresses = new List<string>();
            foreach (var ip in host.AddressList)
            {
                if (ip.AddressFamily == System.Net.Sockets.AddressFamily.InterNetwork)
                    ipAddresses.Add(ip.ToString());
            }
            return ipAddresses;
        }

        /// <summary>
        /// Formats the entire response, e.g. suitable for a MessageBox
        /// </summary>
        /// <param name="request"></param>
        /// <returns>Beautiful formatted response</returns>
        public static string GetCompleteResponseAsString(HttpListenerRequest request)
        {
            StringBuilder sb = new StringBuilder();
            sb.AppendLine("URI: " + request.Url.AbsoluteUri);
            sb.AppendLine("-----------HEADER-----------");

            NameValueCollection headers = request.Headers;
            for (int i = 0; i < headers.Count; i++)
            {
                string key = headers.GetKey(i);
                string value = headers.Get(i);
                sb.AppendLine(key + " = " + value);
            }

            sb.AppendLine("---------HEADER-END--------");

            sb.AppendLine("-----------BODY-----------");
            string body = new StreamReader(request.InputStream).ReadToEnd();
            sb.AppendLine(body);
            sb.AppendLine("---------BODY-END--------");

            return sb.ToString();
        }
    }
}