HttpPost.cs

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using System.Xml;
using Waher.Content;
using Waher.Content.Xml;
using Waher.IoTGateway;
using Waher.Persistence.Attributes;
 
namespace Waher.Service.IoTBroker.StateMachines.Model.Actions.Outbound
{
    public class HttpPost : ActionNode
    {
        private Header[] headers;
        private Resource resource;
        private Notes.Content content;
 
        public HttpPost()
            : base()
        {
        }
 
        public Resource Resource => this.resource;
 
        [DefaultValueNull]
        public Notes.Content Content => this.content;
 
        [DefaultValueNull]
        public Header[] Headers => this.headers;
 
        [DefaultValueNull]
        public string ResponseVariable { get; set; }
 
        public override string LocalName => nameof(HttpPost);
 
        public override IStateMachineNode Create()
        {
            return new HttpPost();
        }
 
        public override async Task Parse(XmlElement Xml)
        {
            this.ResponseVariable = XML.Attribute(Xml, "responseVariable");
 
            await base.Parse(Xml);
 
            this.ConvertValueAttributesToElements(Xml,
                new Type[]
                {
                    typeof(Resource),
                    typeof(Notes.Content)
                },
                new bool[]
                {
                    true,
                    true
                });
        }
 
        protected override void OnChildNodesUpdated()
        {
            base.OnChildNodesUpdated();
 
            this.resource = this.GetValueElement<Resource>();
            this.content = this.GetValueElement<Notes.Content>();
            this.headers = this.GetChildElements<Header>();
        }
 
        public override async Task Execute(EvaluationArguments Arguments)
        {
            string Resource = (await this.resource.Evaluate(Arguments))?.ToString();
            Uri ResourceUri = new Uri(Resource);
 
            object Content = await this.content.Evaluate(Arguments);
            List<KeyValuePair<string, string>> Headers = new List<KeyValuePair<string, string>>();
 
            if (!(this.headers is null))
            {
                foreach (Header Header in this.headers)
                {
                    Headers.Add(new KeyValuePair<string, string>(
                        (await Header.Key.Evaluate(Arguments))?.ToString() ?? string.Empty,
                        (await Header.Value.Evaluate(Arguments))?.ToString() ?? string.Empty));
                }
            }
 
            ContentResponse Response = await InternetContent.PostAsync(ResourceUri, Content,
                Gateway.Certificate, Headers.ToArray());
 
            if (Response.HasError)
                throw Response.Error;
 
            if (!string.IsNullOrEmpty(this.ResponseVariable))
                Arguments.Variables[this.ResponseVariable] = Response.Decoded;
        }
    }
}