WIP

HTTPServer.cs

@@ -81,18 +81,18 @@ namespace ln.http
             lock (this)
             {
                 this.shutdown = true;
+            }
 
-                foreach (TcpListener tcpListener in tcpListeners.Values)
+            foreach (TcpListener tcpListener in tcpListeners.Values)
-                {
+            {
-                    tcpListener.Stop();
+                tcpListener.Stop();
-                }
+            }
 
-                threadPool.NumThreads = 0;
+            threadPool.NumThreads = 0;
 
-                while (IsRunning)
+            while (IsRunning)
-                {
+            {
-                    Thread.Sleep(50);
+                Thread.Sleep(50);
-                }
             }
         }
 

HttpRequest.cs

@@ -32,6 +32,21 @@ namespace ln.http
 
         public Session Session { get; private set; }
 
+        public MemoryStream ContentStream { get; }
+        public TextReader ContentReader
+        {
+            get
+            {
+                if (contentReader == null)
+                    contentReader = new StreamReader(ContentStream);
+                return contentReader;
+            }
+        }
+
+
+        StreamReader contentReader;
+        byte[] requestBody;
+
         public HttpRequest(HttpReader httpReader,IPEndPoint localEndpoint)
         {
             LocalEndpoint = localEndpoint;
@@ -44,6 +59,19 @@ namespace ln.http
             requestCookies = new Dictionary<string, string>();
 
             Setup();
+
+
+            int clength = int.Parse(GetRequestHeader("content-length", "0"));
+            requestBody = new byte[clength];
+
+            if (clength > 0)
+            {
+                int nread = httpReader.ReadRequestBody(requestBody, 0, clength);
+                if (nread != clength)
+                    throw new HttpException(500,"failed to read request content");
+            }
+
+            ContentStream = new MemoryStream(requestBody);
         }
 
         private void Setup()
@@ -140,7 +168,10 @@ namespace ln.http
             return requestCookies[name];
         }
 
-
+        public string self()
+        {
+            return BaseURI.ToString();
+        }