ControlServerExtension.cs

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using System.Xml;
using TAG.Simulator.ObjectModel.Actors;
using TAG.Simulator.XMPP.IoT.Extensions.ControlParameters;
using Waher.Networking.XMPP.Provisioning;
using Waher.Networking.XMPP.Control;
using Waher.Things.ControlParameters;
 
namespace TAG.Simulator.XMPP.IoT.Extensions
{
    public class ControlServerExtension : IoTXmppExtension
    {
        private ControlParameterNode[] parameters;
 
        public ControlServerExtension(ISimulationNode Parent, Model Model)
            : base(Parent, Model)
        {
        }
 
        public override string LocalName => nameof(ControlServerExtension);
 
        public override ISimulationNode Create(ISimulationNode Parent, Model Model)
        {
            return new ControlServerExtension(Parent, Model);
        }
 
        public override async Task FromXml(XmlElement Definition)
        {
            await base.FromXml(Definition);
 
            List<ControlParameterNode> Parameters = new List<ControlParameterNode>();
 
            foreach (ISimulationNode Node in this.Children)
            {
                if (Node is ControlParameterNode Parameter)
                    Parameters.Add(Parameter);
            }
 
            this.parameters = Parameters.ToArray();
        }
 
        public override Task<object> Add(IActor Instance, Waher.Networking.XMPP.XmppClient Client)
        {
            ControlServer Extension;
 
            if (Client.TryGetTag("ProvisioningClient", out object Obj) && Obj is ProvisioningClient ProvisioningClient)
                Extension = new ControlServer(Client, ProvisioningClient);
            else
                Extension = new ControlServer(Client);
 
            Client.SetTag("ControlServer", Extension);
 
            Extension.OnGetControlParameters += (Node) =>
            {
                this.Model.ExternalEvent(Instance, "OnGetControlParameters",
                    new KeyValuePair<string, object>("Node", Node),
                    new KeyValuePair<string, object>("Client", Client));
 
                List<ControlParameter> Parameters = new List<ControlParameter>();
 
                foreach (ControlParameterNode Parameter in this.parameters)
                    Parameter.AddParameters(Parameters, Instance);
 
                return Task.FromResult<ControlParameter[]>(Parameters.ToArray());
            };
 
            return Task.FromResult<object>(Extension);
        }
 
    }
}