PubSubExtension.cs

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using System.Xml;
using TAG.Simulator.ObjectModel.Actors;
using Waher.Content.Xml;
using Waher.Networking.XMPP.PubSub;
 
namespace TAG.Simulator.XMPP.Extensions
{
    public class PubSubExtension : XmppExtension
    {
        private string componentAddress;
 
        public PubSubExtension(ISimulationNode Parent, Model Model)
            : base(Parent, Model)
        {
        }
 
        public override string LocalName => nameof(PubSubExtension);
 
        public override ISimulationNode Create(ISimulationNode Parent, Model Model)
        {
            return new PubSubExtension(Parent, Model);
        }
 
        public override Task FromXml(XmlElement Definition)
        {
            this.componentAddress = XML.Attribute(Definition, "componentAddress");
 
            return base.FromXml(Definition);
        }
 
        public override Task<object> Add(IActor Instance, Waher.Networking.XMPP.XmppClient Client)
        {
            PubSubClient Extension = new PubSubClient(Client, this.componentAddress);
            Client.SetTag("PubSub", Extension);
 
            Extension.AffiliationNotification += (Sender, e) =>
            {
                this.Model.ExternalEvent(Instance, "AffiliationNotification",
                    new KeyValuePair<string, object>("e", e),
                    new KeyValuePair<string, object>("Client", Client));
 
                return Task.CompletedTask;
            };
 
            Extension.ItemNotification += (Sender, e) =>
            {
                this.Model.ExternalEvent(Instance, "ItemNotification",
                    new KeyValuePair<string, object>("e", e),
                    new KeyValuePair<string, object>("Client", Client));
 
                return Task.CompletedTask;
            };
 
            Extension.ItemRetracted += (Sender, e) =>
            {
                this.Model.ExternalEvent(Instance, "ItemRetracted",
                    new KeyValuePair<string, object>("e", e),
                    new KeyValuePair<string, object>("Client", Client));
 
                return Task.CompletedTask;
            };
 
            Extension.NodePurged += (Sender, e) =>
            {
                this.Model.ExternalEvent(Instance, "NodePurged",
                    new KeyValuePair<string, object>("e", e),
                    new KeyValuePair<string, object>("Client", Client));
 
                return Task.CompletedTask;
            };
 
            Extension.SubscriptionRequest += (Sender, e) =>
            {
                this.Model.ExternalEvent(Instance, "SubscriptionRequest",
                    new KeyValuePair<string, object>("e", e),
                    new KeyValuePair<string, object>("Client", Client));
 
                return Task.CompletedTask;
            };
 
            Extension.SubscriptionStatusChanged += (Sender, e) =>
            {
                this.Model.ExternalEvent(Instance, "SubscriptionStatusChanged",
                    new KeyValuePair<string, object>("e", e),
                    new KeyValuePair<string, object>("Client", Client));
 
                return Task.CompletedTask;
            };
 
            return Task.FromResult<object>(Extension);
        }
 
    }
}