RelayToPrimary.cs

using System.Text;
using System.Threading.Tasks;
using Waher.Content.Xml;
using Waher.Networking.XMPP.Server;
using Waher.Persistence;
using Waher.Service.IoTBroker.EDaler.Uris;
using Waher.Service.IoTBroker.EDaler.Uris.States;
 
namespace Waher.Service.IoTBroker.EDaler.Transactions
{
    public class RelayToPrimary : EDalerTransaction
    {
        private CaseInsensitiveString componentAddress;
        private IqResultEventArgs result = null;
 
        public RelayToPrimary(EDalerUri Uri)
            : base(Uri)
        {
        }
 
        protected override async Task<bool> DoPrepare()
        {
            this.componentAddress = await this.Uri.EDaler.Server.FindComponentAsync(this.Uri.PrincipalDomain, EDalerComponent.NamespaceEDaler);
            return true;
        }
 
        protected override async Task<bool> DoExecute()
        {
            StringBuilder Xml = new StringBuilder();
            TaskCompletionSource<bool> Result = new TaskCompletionSource<bool>();
 
            Xml.Append("<uri xmlns=\"");
            Xml.Append(EDalerComponent.NamespaceEDaler);
            Xml.Append("\" for=\"");
            Xml.Append(XML.Encode(this.Uri.State.Sender));
            Xml.Append("\">");
            Xml.Append(XML.Encode(this.Uri.UriString));
            Xml.Append("</uri>");
 
            if (!await this.Uri.EDaler.Server.SendIqRequest("set",
                new XmppAddress(this.Uri.EDaler.Server.Domain),
                new XmppAddress(this.componentAddress),
                string.Empty, Xml.ToString(), (sender2, e2) =>
                {
                    this.result = e2;
 
                    if (!e2.Ok)
                        this.Uri.State.Error(e2.ErrorType.ToString().ToLower(), string.Empty, this.Uri.PrincipalDomain + " reports: " + e2.ErrorText);
 
                    Result.TrySetResult(e2.Ok);
 
                    return Task.CompletedTask;
 
                }, null))
            {
                this.Uri.State.Error(EDalerUriErrorType.ServiceUnavailable, "Unable to relay URI to principal domain.", false);
                return false;
            }
 
            return await Result.Task;
        }
 
        protected override Task<bool> DoCommit()
        {
            this.Uri.State.Result(this.result.FirstElement?.OuterXml ?? string.Empty);
            
            return Task.FromResult(true);
        }
 
        protected override Task<bool> DoRollback()
        {
            this.Uri.State.Error(EDalerUriErrorType.Conflict, "Transaction rejected and rolled back.", false);
            return Task.FromResult(true);
        }
    }
}