ConcentratorServerExtension.cs

using System;
using System.Threading.Tasks;
using TAG.Simulator.ObjectModel.Actors;
using Waher.Networking.XMPP.Provisioning;
using Waher.Networking.XMPP.Concentrator;
 
namespace TAG.Simulator.XMPP.IoT.Extensions
{
    public class ConcentratorServerExtension : IoTXmppExtension
    {
        public ConcentratorServerExtension(ISimulationNode Parent, Model Model)
            : base(Parent, Model)
        {
        }
 
        public override string LocalName => nameof(ConcentratorServerExtension);
 
        public override ISimulationNode Create(ISimulationNode Parent, Model Model)
        {
            return new ConcentratorServerExtension(Parent, Model);
        }
 
        public override async Task<object> Add(IActor Instance, Waher.Networking.XMPP.XmppClient Client)
        {
            ConcentratorServer Extension;
 
            if (!Client.TryGetTag("ProvisioningClient", out object Obj) || !(Obj is ProvisioningClient ProvisioningClient))
                ProvisioningClient = null;
 
            if (!Client.TryGetTag("ThingRegistryClient", out Obj) || !(Obj is ThingRegistryClient ThingRegistryClient))
                ThingRegistryClient = null;
 
            Extension = await ConcentratorServer.Create(Client, ThingRegistryClient, ProvisioningClient);
 
            Client.SetTag("ConcentratorServer", Extension);
 
            return Extension;
        }
 
    }
}