Сырая альфа HTTPСоединения

EvilBeaver · EvilBeaver · commit 579d119c0f5a · 2015-02-20T18:32:16.000+03:00
diff --git a/src/ScriptEngine.HostedScript/Library/Http/HttpConnectionContext.cs b/src/ScriptEngine.HostedScript/Library/Http/HttpConnectionContext.cs
@@ -101,16 +101,21 @@ public HttpResponseContext Put(HttpRequestContext request)
         [ContextMethod("&#1054;&#1090;&#1087;&#1088;&#1072;&#1074;&#1080;&#1090;&#1100;&#1044;&#1083;&#1103;&#1054;&#1073;&#1088;&#1072;&#1073;&#1086;&#1090;&#1082;&#1080;", "Post")]
         public HttpResponseContext Post(HttpRequestContext request, string output = null)
         {
-            return GetResponse(request, "POST");
+            return GetResponse(request, "POST", output);
+        }
+
+        [ContextMethod("&#1059;&#1076;&#1072;&#1083;&#1080;&#1090;&#1100;", "Delete")]
+        public HttpResponseContext Delete(HttpRequestContext request, string output = null)
+        {
+            return GetResponse(request, "DELETE");
         }
 
         private HttpWebRequest CreateRequest(string resource)
         {
             var uriBuilder = new UriBuilder(_hostUri);
             if(Port != 0)
                 uriBuilder.Port = Port;
-            uriBuilder.Scheme = "http";
-
+            
             var resourceUri = new Uri(uriBuilder.Uri, resource);
 
             var request = (HttpWebRequest)HttpWebRequest.Create(resourceUri);
@@ -131,6 +136,7 @@ private HttpResponseContext GetResponse(HttpRequestContext request, string metho
         {
             var webRequest = CreateRequest(request.ResourceAddress);
             webRequest.Method = method;
+            webRequest.KeepAlive = false;
             SetRequestHeaders(request, webRequest);
             SetRequestBody(request, webRequest);
 
@@ -169,7 +175,18 @@ private static void SetRequestBody(HttpRequestContext request, HttpWebRequest we
 
                 using(var requestStream = webRequest.GetRequestStream())
                 {
-                    stream.CopyTo(requestStream);
+                    const int CHUNK_SIZE = 4096;
+                    byte[] buf = new byte[CHUNK_SIZE];
+                    
+                    while(true)
+                    {
+                        int bytesRead = stream.Read(buf, 0, CHUNK_SIZE);
+                        if (bytesRead == 0)
+                            break;
+
+                        requestStream.Write(buf, 0, bytesRead);
+
+                    }
                 }
             }
         }
@@ -182,8 +199,74 @@ private static void SetRequestHeaders(HttpRequestContext request, HttpWebRequest
 
                 var key = item.Key.AsString();
                 var value = item.Value.AsString();
+
+                switch(key.ToUpperInvariant())
+                {
+                    case "CONTENT-TYPE":
+                        webRequest.ContentType = value;
+                        break;
+                    case "CONTENT-LENGTH":
+                        try
+                        {
+                            webRequest.ContentLength = Int32.Parse(value);
+                        }
+                        catch (FormatException)
+                        {
+                            throw new RuntimeException("&#1047;&#1072;&#1075;&#1086;&#1083;&#1086;&#1074;&#1086;&#1082; Content-Length &#1079;&#1072;&#1076;&#1072;&#1085; &#1085;&#1077;&#1087;&#1088;&#1072;&#1074;&#1080;&#1083;&#1100;&#1085;&#1086;");
+                        }
+                        break;
+                    case "ACCEPT":
+                        webRequest.Accept = value;
+                        break;
+                    case "EXPECT":
+                        webRequest.Expect = value;
+                        break;
+                    case "TRANSFER-ENCODING":
+                        webRequest.TransferEncoding = value;
+                        break;
+                    case "CONNECTION":
+                        webRequest.Connection = value;
+                        break;
+                    case "DATE":
+                        try 
+	                    {	        
+		                    webRequest.Date = DateTime.Parse(value);
+	                    }
+	                    catch (FormatException)
+	                    {
+		                    throw new RuntimeException("&#1047;&#1072;&#1075;&#1086;&#1083;&#1086;&#1074;&#1086;&#1082; Date &#1079;&#1072;&#1076;&#1072;&#1085; &#1085;&#1077;&#1087;&#1088;&#1072;&#1074;&#1080;&#1083;&#1100;&#1085;&#1086;");
+	                    }
+                        break;
+                    case "HOST":
+                        webRequest.Host = value;
+                        break;
+                    case "IF-MODIFIED-SINCE":
+                        try
+                        {
+                            webRequest.IfModifiedSince = DateTime.Parse(value);
+                        }
+                        catch (FormatException)
+                        {
+                            throw new RuntimeException("&#1047;&#1072;&#1075;&#1086;&#1083;&#1086;&#1074;&#1086;&#1082; If-Modified-Since &#1079;&#1072;&#1076;&#1072;&#1085; &#1085;&#1077;&#1087;&#1088;&#1072;&#1074;&#1080;&#1083;&#1100;&#1085;&#1086;");
+                        }
+                        break;
+                    case "RANGE":
+                        throw new NotImplementedException();
+                    case "REFERER":
+                        webRequest.Referer = value;
+                        break;
+                    case "USER-AGENT":
+                        webRequest.UserAgent = value;
+                        break;
+                    case "PROXY-CONNECTION":
+                        throw new NotImplementedException();
+                    default:
+                        webRequest.Headers.Set(key, value);
+                        break;
+                           
+                }
+                
                 
-                webRequest.Headers.Set(key, value);
 
             }
         }
diff --git a/src/ScriptEngine.HostedScript/Library/Http/HttpResponseContext.cs b/src/ScriptEngine.HostedScript/Library/Http/HttpResponseContext.cs
@@ -82,7 +82,12 @@ public IValue GetBodyAsString(IValue encoding = null)
 
             Encoding enc;
             if (encoding == null)
+            {
+                if (String.IsNullOrEmpty(_defaultCharset))
+                    _defaultCharset = "utf-8";
+
                 enc = Encoding.GetEncoding(_defaultCharset);
+            }
             else
                 enc = TextEncodingEnum.GetEncoding(encoding);
 
