PutterBase.cs

using System;
using System.Collections.Generic;
using System.Security.Cryptography.X509Certificates;
using System.Threading.Tasks;
using Waher.Runtime.Inventory;
 
namespace Waher.Content.Putters
{
    public abstract class PutterBase : IContentPutter
    {
        public PutterBase()
        {
        }
 
        public abstract string[] UriSchemes
        {
            get;
        }
 
        public abstract bool CanPut(Uri Uri, out Grade Grade);
 
        public virtual Task<object> PutAsync(Uri Uri, object Data, X509Certificate Certificate,
            RemoteCertificateEventHandler RemoteCertificateValidator, params KeyValuePair<string, string>[] Headers)
        {
            return this.PutAsync(Uri, Data, Certificate, RemoteCertificateValidator, 60000, Headers);
        }
 
        public virtual async Task<object> PutAsync(Uri Uri, object Data, X509Certificate Certificate,
            RemoteCertificateEventHandler RemoteCertificateValidator, int TimeoutMs, params KeyValuePair<string, string>[] Headers)
        {
            KeyValuePair<byte[], string> P = await InternetContent.EncodeAsync(Data, System.Text.Encoding.UTF8);
            KeyValuePair<byte[], string> Result = await this.PutAsync(Uri, P.Key, P.Value, Certificate,
                RemoteCertificateValidator, TimeoutMs, Headers);
 
            return await InternetContent.DecodeAsync(Result.Value, Result.Key, Uri);
        }
 
        public virtual Task<KeyValuePair<byte[], string>> PutAsync(Uri Uri, byte[] EncodedData, string ContentType, 
            X509Certificate Certificate, RemoteCertificateEventHandler RemoteCertificateValidator, params KeyValuePair<string, string>[] Headers)
        {
            return this.PutAsync(Uri, EncodedData, ContentType, Certificate, RemoteCertificateValidator, 60000, Headers);
        }
 
        public abstract Task<KeyValuePair<byte[], string>> PutAsync(Uri Uri, byte[] EncodedData, string ContentType, 
            X509Certificate Certificate, RemoteCertificateEventHandler RemoteCertificateValidator, int TimeoutMs, params KeyValuePair<string, string>[] Headers);
 
    }
}