PushNotificationClient.cs

using System;
using System.Text;
using System.Threading.Tasks;
using Waher.Content.Xml;
using Waher.Events;
using Waher.Networking.XMPP.Events;
 
namespace Waher.Networking.XMPP.Push
{
    public class PushNotificationClient : XmppExtension
    {
        public const string MessagePushNamespace = "http://waher.se/Schema/PushNotification.xsd";
 
        public PushNotificationClient(XmppClient Client)
            : base(Client)
        {
        }
 
        public override void Dispose()
        {
            base.Dispose();
        }
 
        public override string[] Extensions => new string[0];
 
        #region New Token
 
        public Task NewToken(string Token, PushMessagingService Service, ClientType ClientType, EventHandlerAsync<IqResultEventArgs> Callback, object State)
        {
            StringBuilder Xml = new StringBuilder();
 
            Xml.Append("<newToken xmlns='");
            Xml.Append(MessagePushNamespace);
            Xml.Append("' service='");
            Xml.Append(Service.ToString());
            Xml.Append("' clientType='");
            Xml.Append(ClientType.ToString());
            Xml.Append("' token='");
            Xml.Append(XML.Encode(Token));
            Xml.Append("'/>");
 
            return this.client.SendIqSet(string.Empty, Xml.ToString(), Callback, State);
        }
 
        public async Task NewTokenAsync(string Token, PushMessagingService Service, ClientType ClientType)
        {
            TaskCompletionSource<bool> Result = new TaskCompletionSource<bool>();
 
            await this.NewToken(Token, Service, ClientType, (Sender, e) =>
            {
                if (e.Ok)
                    Result.TrySetResult(true);
                else
                    Result.TrySetException(e.StanzaError ?? new Exception("Unable to report new token."));
 
                return Task.CompletedTask;
            }, null);
 
            await Result.Task;
        }
 
        #endregion
 
        #region Remove Token
 
        public Task RemoveToken(EventHandlerAsync<IqResultEventArgs> Callback, object State)
        {
            StringBuilder Xml = new StringBuilder();
 
            Xml.Append("<removeToken xmlns='");
            Xml.Append(MessagePushNamespace);
            Xml.Append("'/>");
 
            return this.client.SendIqSet(string.Empty, Xml.ToString(), Callback, State);
        }
 
        public async Task RemoveTokenAsync()
        {
            TaskCompletionSource<bool> Result = new TaskCompletionSource<bool>();
 
            await this.RemoveToken((Sender, e) =>
            {
                if (e.Ok)
                    Result.TrySetResult(true);
                else
                    Result.TrySetException(e.StanzaError ?? new Exception("Unable to remove token."));
 
                return Task.CompletedTask;
            }, null);
 
            await Result.Task;
        }
 
        #endregion
 
        #region Clear Rules
 
        public Task ClearRules(EventHandlerAsync<IqResultEventArgs> Callback, object State)
        {
            StringBuilder Xml = new StringBuilder();
 
            Xml.Append("<clearRules xmlns='");
            Xml.Append(MessagePushNamespace);
            Xml.Append("'/>");
 
            return this.client.SendIqSet(string.Empty, Xml.ToString(), Callback, State);
        }
 
        public async Task ClearRulesAsync()
        {
            TaskCompletionSource<bool> Result = new TaskCompletionSource<bool>();
 
            await this.ClearRules((Sender, e) =>
            {
                if (e.Ok)
                    Result.TrySetResult(true);
                else
                    Result.TrySetException(e.StanzaError ?? new Exception("Unable to clear available rules."));
 
                return Task.CompletedTask;
            }, null);
 
            await Result.Task;
        }
 
        #endregion
 
        #region Add Push Notification Rule
 
        public Task AddRule(MessageType MessageType, string LocalName, string Namespace, string Channel, string MessageVariable,
            string PatternMatchingScript, string ContentScript, EventHandlerAsync<IqResultEventArgs> Callback, object State)
        {
            StringBuilder Xml = new StringBuilder();
 
            Xml.Append("<addRule xmlns='");
            Xml.Append(MessagePushNamespace);
            Xml.Append("' type='");
 
            if (MessageType != MessageType.Normal)
                Xml.Append(MessageType.ToString().ToLower());
 
            Xml.Append("' localName='");
            Xml.Append(XML.Encode(LocalName));
            Xml.Append("' namespace='");
            Xml.Append(XML.Encode(Namespace));
            Xml.Append("' channel='");
            Xml.Append(XML.Encode(Channel));
            Xml.Append("' variable='");
            Xml.Append(XML.Encode(MessageVariable));
            Xml.Append("'>");
 
            if (!string.IsNullOrEmpty(PatternMatchingScript))
            {
                Xml.Append("<PatternMatching>");
                Xml.Append(XML.Encode(PatternMatchingScript));
                Xml.Append("</PatternMatching>");
            }
 
            if (!string.IsNullOrEmpty(ContentScript))
            {
                Xml.Append("<Content>");
                Xml.Append(XML.Encode(ContentScript));
                Xml.Append("</Content>");
            }
 
            Xml.Append("</addRule>");
 
            return this.client.SendIqSet(string.Empty, Xml.ToString(), Callback, State);
        }
 
        public async Task AddRuleAsync(MessageType MessageType, string LocalName, string Namespace, string Channel, string MessageVariable,
            string PatternMatchingScript, string ContentScript)
        {
            TaskCompletionSource<bool> Result = new TaskCompletionSource<bool>();
 
            await this.AddRule(MessageType, LocalName, Namespace, Channel, MessageVariable, PatternMatchingScript, ContentScript, (Sender, e) =>
            {
                if (e.Ok)
                    Result.TrySetResult(true);
                else
                    Result.TrySetException(e.StanzaError ?? new Exception("Unable to add push notification rule."));
 
                return Task.CompletedTask;
            }, null);
 
            await Result.Task;
        }
 
        #endregion
 
        #region Remove Push Notification Rule
 
        public Task RemoveRule(MessageType MessageType, string LocalName, string Namespace, EventHandlerAsync<IqResultEventArgs> Callback, object State)
        {
            StringBuilder Xml = new StringBuilder();
 
            Xml.Append("<removeRule xmlns='");
            Xml.Append(MessagePushNamespace);
            Xml.Append("' type='");
 
            if (MessageType != MessageType.Normal)
                Xml.Append(MessageType.ToString().ToLower());
 
            Xml.Append("' localName='");
            Xml.Append(XML.Encode(LocalName));
            Xml.Append("' namespace='");
            Xml.Append(XML.Encode(Namespace));
            Xml.Append("'/>");
 
            return this.client.SendIqSet(string.Empty, Xml.ToString(), Callback, State);
        }
 
        public async Task RemoveRuleAsync(MessageType MessageType, string LocalName, string Namespace)
        {
            TaskCompletionSource<bool> Result = new TaskCompletionSource<bool>();
 
            await this.RemoveRule(MessageType, LocalName, Namespace, (Sender, e) =>
            {
                if (e.Ok)
                    Result.TrySetResult(true);
                else
                    Result.TrySetException(e.StanzaError ?? new Exception("Unable to remove push notification rule."));
 
                return Task.CompletedTask;
            }, null);
 
            await Result.Task;
        }
 
        #endregion
 
    }
}