EvilBeaver/OneScript: Исполняющая среда скриптов на языке 1С

src/OneScript.StandardLibrary/Http/HttpConnectionContext.cs
527 строк22 KB
Andrei Ovsiankin
Merge branch 'develop' into feature/breaking-refactory
14 май 2020, 20:53
14 май 2020, 20:536ea1471
/*----------------------------------------------------------
This Source Code Form is subject to the terms of the 
Mozilla Public License, v.2.0. If a copy of the MPL 
was not distributed with this file, You can obtain one 
at http://mozilla.org/MPL/2.0/.
----------------------------------------------------------*/

using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Text;
using OneScript.StandardLibrary.Collections;
using RegExp = System.Text.RegularExpressions;
using ScriptEngine.Machine;
using ScriptEngine.Machine.Contexts;

namespace OneScript.StandardLibrary.Http
{
    /// <summary>
    /// Объект доступа к протоколу HTTP/HTTPS.
    /// Использует семантику методов, реализованных в платформе 1С:Предприятие 8.2.18 и старше.
    /// Синтаксис методов, применявшийся в более младших версиях не поддерживается.
    /// Средства работы с HTTP находятся в статусе experimental.
    /// </summary>
    [ContextClass("HTTPСоединение", "HTTPConnection")]
    public class HttpConnectionContext : AutoContext<HttpConnectionContext>
    {
        readonly InternetProxyContext _proxy;

        readonly Uri _hostUri;

        const string HTTP_SCHEME = "http";
        const string HTTPS_SCHEME = "https";

        public HttpConnectionContext(string host,
            int port = 0,
            string user = null,
            string password = null,
            InternetProxyContext proxy = null,
            int timeout = 0,
            IValue ssl = null,
            bool useOSAuth = false)
        {
            if (ssl != null && !(ssl.DataType == ScriptEngine.Machine.DataType.Undefined || ssl.DataType == ScriptEngine.Machine.DataType.NotAValidValue))
                throw new RuntimeException("Защищенное соединение по произвольным сертификатам не поддерживается. Если необходим доступ по https, просто укажите протокол https в адресе хоста.");
            
            var uriBuilder = new UriBuilder(host);
            if (port != 0)
                uriBuilder.Port = port;

            if (uriBuilder.Scheme != HTTP_SCHEME && uriBuilder.Scheme != HTTPS_SCHEME)
                throw RuntimeException.InvalidArgumentValue();

            _hostUri = uriBuilder.Uri;

            Host = _hostUri.Host;
            Port = _hostUri.Port;

            User = user == null ? String.Empty : user;
            Password = password == null ? String.Empty : password;

            Timeout = timeout;
            _proxy = proxy;
            UseOSAuthentication = useOSAuth;
            AllowAutoRedirect = true;
        }

        [ContextProperty("ИспользоватьАутентификациюОС", "UseOSAuthentication", CanWrite=false)]
        public bool UseOSAuthentication
        {
            get;
            set;
        }

        [ContextProperty("Пользователь","User")]
        public string User 
        { 
            get; private set;
        }

        [ContextProperty("Пароль", "Password")]
        public string Password
        {
            get; private set;
            
        }

        [ContextProperty("Сервер", "Host")]
        public string Host
        {
            get; private set;
        }

        [ContextProperty("Порт", "Port")]
        public int Port
        {
            get; private set;
        }

        [ContextProperty("Прокси", "Proxy")]
        public IValue Proxy
        {
            get
            {
                if (_proxy == null)
                    return ValueFactory.Create();

                return _proxy;
            }
        }

        [ContextProperty("Таймаут", "Timeout")]
        public int Timeout
        {
            get; private set;
        }

        [ContextProperty("РазрешитьАвтоматическоеПеренаправление", "AllowAutoRedirect")]
        public bool AllowAutoRedirect { get; set; }

        /// <summary>
        /// Получить данные методом GET
        /// </summary>
        /// <param name="request">HTTPЗапрос. Данные и заголовки запроса http</param>
        /// <param name="output">Строка. Имя файла, в который нужно записать ответ. Необязательный параметр.</param>
        /// <returns>HTTPОтвет. Ответ сервера.</returns>
        [ContextMethod("Получить", "Get")]
        public HttpResponseContext Get(HttpRequestContext request, string output = null)
        {
            return GetResponse(request, "GET", output);
        }

        /// <summary>
        /// Передача данных методом PUT
        /// </summary>
        /// <param name="request">HTTPЗапрос. Данные и заголовки запроса http</param>
        /// <returns>HTTPОтвет. Ответ сервера.</returns>
        [ContextMethod("Записать", "Put")]
        public HttpResponseContext Put(HttpRequestContext request)
        {
            return GetResponse(request, "PUT");
        }

        /// <summary>
        /// Передача данных методом POST
        /// </summary>
        /// <param name="request">HTTPЗапрос. Данные и заголовки запроса http</param>
        /// <param name="output">Строка. Имя файла, в который нужно записать ответ. Необязательный параметр.</param>
        /// <returns>HTTPОтвет. Ответ сервера.</returns>
        [ContextMethod("ОтправитьДляОбработки", "Post")]
        public HttpResponseContext Post(HttpRequestContext request, string output = null)
        {
            return GetResponse(request, "POST", output);
        }

        /// <summary>
        /// Удалить данные методом DELETE
        /// </summary>
        /// <param name="request">HTTPЗапрос. Данные и заголовки запроса http</param>
        /// <returns>HTTPОтвет. Ответ сервера.</returns>
        [ContextMethod("Удалить", "Delete")]
        public HttpResponseContext Delete(HttpRequestContext request)
        {
            return GetResponse(request, "DELETE");
        }

        /// <summary>
        /// Изменяет данные на сервере при помощи PATCH-запроса
        /// </summary>
        /// <param name="request">HTTPЗапрос. Данные и заголовки запроса http</param>
        /// <returns>HTTPОтвет. Ответ сервера.</returns>
        [ContextMethod("Изменить", "Patch")]
        public HttpResponseContext Patch(HttpRequestContext request)
        {
            return GetResponse(request, "PATCH");
        }

        /// <summary>
        /// Получает при помощи HEAD-запроса информацию о запрошиваемых данных, содержащуюся в заголовках, не получая сами данные.
        /// </summary>
        /// <param name="request">HTTPЗапрос. Данные и заголовки запроса http</param>
        /// <returns>HTTPОтвет. Ответ сервера.</returns>
        [ContextMethod("ПолучитьЗаголовки", "Head")]
        public HttpResponseContext Head(HttpRequestContext request)
        {
            return GetResponse(request, "HEAD");
        }

        /// <summary>
        /// Вызвать произвольный HTTP-метод
        /// </summary>
        /// <param name="method">Строка. Имя метода HTTP</param>
        /// <param name="request">HTTPЗапрос. Данные и заголовки запроса http</param>
        /// <param name="output">Строка. Имя выходного файла</param>
        /// <returns>HTTPОтвет. Ответ сервера.</returns>
        [ContextMethod("ВызватьHTTPМетод", "CallHTTPMethod")]
        public HttpResponseContext Patch(string method, HttpRequestContext request, string output = null)
        {
            return GetResponse(request, method, output);
        }

        private HttpWebRequest CreateRequest(string resource)
        {
            var uriBuilder = new UriBuilder(_hostUri);
            if(Port != 0)
                uriBuilder.Port = Port;
            
            var resourceUri = new Uri(uriBuilder.Uri, resource);

            // http://qaru.site/questions/45913/the-request-was-aborted-could-not-create-ssltls-secure-channel
            // Убедитесь, что настройки ServicePointManager заданы до создания HttpWebRequest, 
            // иначе он не будет работать
            if (uriBuilder.Scheme == HTTPS_SCHEME)
            {
                ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls | SecurityProtocolType.Tls11 | SecurityProtocolType.Tls12;
            }

            var request = (HttpWebRequest)HttpWebRequest.Create(resourceUri);
            if (User != "" || Password != "")
            {
                request.Credentials = new NetworkCredential(User, Password);
                //request.PreAuthenticate = true;
                // Авторизация на сервере 1С:Предприятие, например, не работает без явного указания заголовка.
                // http://blog.kowalczyk.info/article/at3/Forcing-basic-http-authentication-for-HttpWebReq.html
                string authInfo = User + ":" + Password;
                // Для 1С работает только UTF-8, хотя стандарт требует ISO-8859-1
                var basicAuthEncoding = Encoding.GetEncoding("UTF-8");
                authInfo = Convert.ToBase64String(basicAuthEncoding.GetBytes(authInfo));
                request.Headers["Authorization"] = "Basic " + authInfo;
            }
            else if(UseOSAuthentication)
            {
                request.Credentials = CredentialCache.DefaultNetworkCredentials;
            }

            if(_proxy != null)
                request.Proxy = _proxy.GetProxy(uriBuilder.Scheme);

            if (Timeout == 0)
            {
                request.Timeout = System.Threading.Timeout.Infinite;
            }
            else
            {
                request.Timeout = Timeout * 1000;
            }

            if (uriBuilder.Scheme == HTTPS_SCHEME)
            {
                request.ServerCertificateValidationCallback = delegate { return true; };
            }

            return request;
            
        }

        private static bool ContentBodyAllowed(string method)
        {
            var methods = new List<string> {"GET", "CONNECT", "HEAD"};
            return !methods.Contains(method, StringComparer.OrdinalIgnoreCase);
        }
        
        private class Range
        {
            public string RangeSpecifier
            {
                get; private set;
            }
            public Int64 From
            {
                get; private set;
            }
            public Int64 To
            {
                get; private set;
            }

            public Range(string rangeSpecifier, Int64 from, Int64 to)
            {
                RangeSpecifier = rangeSpecifier;
                From = from;
                To = to;

            }
        }

        private static List<Range> ParseRange(string rangeHeader)
        {
            
            List<Range> range = new List<Range>();

            if (rangeHeader.Length == 0)
                return range;

            RegExp.MatchCollection matches = RegExp.Regex.Matches(rangeHeader, @"^(.+)=([^;]+)");

            string rangeSpecifier = matches[0].Groups[1].Value;

            string stringrange = matches[0].Groups[2].Value;

            string[] ranges = stringrange.Split(',');

            for (int i = 0; i < ranges.Length; i++)
            {
                string range_spec = ranges[i].Trim();
                
                Int64 from = 0;
                Int64 to = 0;
                RegExp.MatchCollection fromMatches = RegExp.Regex.Matches(range_spec, @"^(\d+)\-$");
                RegExp.MatchCollection fromToMatches = RegExp.Regex.Matches(range_spec, @"^(\d+)\-(\d+)$");
                RegExp.MatchCollection toMatches = RegExp.Regex.Matches(range_spec, @"^\-(\d+)$");

                if (fromMatches.Count > 0)
                {
                    from = Int64.Parse(fromMatches[0].Groups[1].Value);
                    to = 0;
                }
                else if (fromToMatches.Count > 0)
                {
                    from = Int64.Parse(fromToMatches[0].Groups[1].Value);
                    to = Int64.Parse(fromToMatches[0].Groups[2].Value);
                }
                else if (toMatches.Count > 0)
                {
                    from = Int64.Parse(toMatches[0].Groups[1].Value);
                    to = 0;
                }
                range.Add(new Range(rangeSpecifier, from, to));
            }
            return range;
        }

    private HttpResponseContext GetResponse(HttpRequestContext request, string method, string output = null)
        {
            var webRequest = CreateRequest(request.ResourceAddress);
            webRequest.AllowAutoRedirect = AllowAutoRedirect;
            webRequest.Method = method;
            SetRequestHeaders(request, webRequest);
            
            if (ContentBodyAllowed(method)) 
                SetRequestBody(request, webRequest);

            HttpWebResponse response;

            try
            {
                response = (HttpWebResponse)webRequest.GetResponse();
            }
            catch (WebException ex)
            {
                if (ex.Status == WebExceptionStatus.ProtocolError && ex.Response != null)
                    response = (HttpWebResponse)ex.Response;
                else
                    throw;
            }

            var responseContext = new HttpResponseContext(response, output);
            
            return responseContext;

        }

        private static void SetRequestBody(HttpRequestContext request, HttpWebRequest webRequest)
        {
            var stream = request.Body;
            if (stream == null)
            {
                return; // тело не установлено
            }

            using(stream)
            {
                if (stream.CanSeek)
                    webRequest.ContentLength = stream.Length;

                using(var requestStream = webRequest.GetRequestStream())
                {
                    stream.CopyTo(requestStream);
                }
            }
        }

        private static void SetRequestHeaders(HttpRequestContext request, HttpWebRequest webRequest)
        {
            foreach (var item in request.Headers.Select(x => x.GetRawValue() as KeyAndValueImpl))
            {
                System.Diagnostics.Trace.Assert(item != null);

                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("Заголовок Content-Length задан неправильно");
                        }
                        break;
                    case "ACCEPT":
                        webRequest.Accept = value;
                        break;
                    case "EXPECT":
                        webRequest.Expect = value;
                        break;
                    case "TRANSFER-ENCODING":
                        webRequest.TransferEncoding = value;
                        break;
                    case "CONNECTION":
                        if (value.Equals("KEEP-ALIVE", StringComparison.OrdinalIgnoreCase))
                        {
                            webRequest.KeepAlive = true;
                        }
                        else if (value.Equals("CLOSE", StringComparison.OrdinalIgnoreCase))
                        {
                            webRequest.KeepAlive = false;
                        }
                        else
                        {
                            webRequest.Connection = value;
                        }
                        break;
                    case "DATE":
                        try 
	                    {	        
		                    webRequest.Date = DateTime.Parse(value);
	                    }
	                    catch (FormatException)
	                    {
		                    throw new RuntimeException("Заголовок Date задан неправильно");
	                    }
                        break;
                    case "HOST":
                        webRequest.Host = value;
                        break;
                    case "IF-MODIFIED-SINCE":
                        try
                        {
                            webRequest.IfModifiedSince = DateTime.Parse(value);
                        }
                        catch (FormatException)
                        {
                            throw new RuntimeException("Заголовок If-Modified-Since задан неправильно");
                        }
                        break;
                    case "RANGE":
                        try
                        {
                            List<Range> range_list = ParseRange(value);
                            foreach (Range range in range_list)
                            {
                                if (range.To == 0)
                                    webRequest.AddRange(range.RangeSpecifier, range.From);
                                else
                                    webRequest.AddRange(range.RangeSpecifier, range.From, range.To);
                            }
                        }
                        catch
                        {
                            throw new RuntimeException("Заголовок Range задан неправильно");
                        }
                        break;
                    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;
                           
                }
                
                

            }
        }

        /// <summary>
        /// Стандартный конструктор. Поддержка клиентских сертификатов HTTPS в текущей версии не реализована.
        /// Для доступа к серверу по протоколу HTTPS указывайте схему https:// в URL.
        /// </summary>
        /// <param name="host">Адрес сервера (можно указать URL-схему http или https)</param>
        /// <param name="port">Порт сервера</param>
        /// <param name="user">Пользователь</param>
        /// <param name="password">Пароль</param>
        /// <param name="proxy">ИнтернетПрокси. Настройки прокси-сервера</param>
        /// <param name="timeout">Таймаут ожидания.</param>
        /// <param name="ssl">Объект ЗащищенноеСоединение. На данный момент данная механика работы с SSL не поддерживается. 
        /// Обращение к https возможно, если в адресе хоста указать протокол https. В этом случае будут использованы сертификаты из хранилища ОС.
        /// Указание произвольных клиентских и серверных сертификатов в текущей версии не поддерживается.</param>
        /// <param name="useOSAuthentication">Использовать аутентификацию ОС.</param>
        /// <returns></returns>
        [ScriptConstructor(Name = "По указанному серверу")]
        public static HttpConnectionContext Constructor(IValue host, 
            IValue port = null, 
            IValue user = null, 
            IValue password = null,
            IValue proxy = null,
            IValue timeout = null,
            IValue ssl = null,
            IValue useOSAuthentication = null)
        {
            return new HttpConnectionContext(host.AsString(),
                ContextValuesMarshaller.ConvertParam<int>(port),
                ContextValuesMarshaller.ConvertParam<string>(user),
                ContextValuesMarshaller.ConvertParam<string>(password),
                ContextValuesMarshaller.ConvertParam<InternetProxyContext>(proxy),
                ContextValuesMarshaller.ConvertParam<int>(timeout),
                ContextValuesMarshaller.ConvertParam<IValue>(ssl),
                ContextValuesMarshaller.ConvertParam<bool>(useOSAuthentication)
                );
        }

    }
}