WebQuery.cs

using System;
using System.Collections.Generic;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Security.Cryptography.X509Certificates;
using System.Threading.Tasks;
using Waher.Content.Getters;
using Waher.Content.Posters;
using Waher.Runtime.Inventory;
 
namespace Waher.Content.Queries
{
    public class WebQuery : QueryBase
    {
        public WebQuery()
        {
        }
 
        public override string[] UriSchemes => new string[] { "http", "https" };
 
        public override bool CanQuery(Uri Uri, out Grade Grade)
        {
            switch (Uri.Scheme.ToLower())
            {
                case "http":
                case "https":
                    Grade = Grade.Ok;
                    return true;
 
                default:
                    Grade = Grade.NotAtAll;
                    return false;
            }
        }
 
        public override async Task<ContentBinaryResponse> QueryAsync(Uri Uri, byte[] EncodedData, string ContentType, 
            X509Certificate Certificate, EventHandler<RemoteCertificateEventArgs> RemoteCertificateValidator, int TimeoutMs, 
            params KeyValuePair<string, string>[] Headers)
        {
            HttpClientHandler Handler = WebGetter.GetClientHandler(Certificate, RemoteCertificateValidator, Uri);
            using (HttpClient HttpClient = new HttpClient(Handler, true)
            {
                Timeout = TimeSpan.FromMilliseconds(TimeoutMs)
            })
            {
                using (HttpRequestMessage Request = new HttpRequestMessage()
                {
                    Method = queryMethod, 
                    Content = new ByteArrayContent(EncodedData)
                })
                {
                    Request.RequestUri = WebGetter.CheckUri(Uri, Request);
                    Request.Content.Headers.ContentType = MediaTypeHeaderValue.Parse(ContentType);
                    WebGetter.PrepareHeaders(Request, Headers, Handler);
 
                    HttpResponseMessage Response = await HttpClient.SendAsync(Request);
 
                    return await WebPoster.ProcessResponse(Response, Uri);
                }
            }
        }
 
        private static readonly HttpMethod queryMethod = new HttpMethod("QUERY");
    }
}