SensorServerExtension.cs

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using TAG.Simulator.ObjectModel.Actors;
using Waher.Networking.XMPP.Provisioning;
using Waher.Networking.XMPP.Sensor;
using Waher.Things;
 
namespace TAG.Simulator.XMPP.IoT.Extensions
{
    public class SensorServerExtension : IoTXmppExtension
    {
        public SensorServerExtension(ISimulationNode Parent, Model Model)
            : base(Parent, Model)
        {
        }
 
        public override string LocalName => nameof(SensorServerExtension);
 
        public override ISimulationNode Create(ISimulationNode Parent, Model Model)
        {
            return new SensorServerExtension(Parent, Model);
        }
 
        public override Task<object> Add(IActor Instance, Waher.Networking.XMPP.XmppClient Client)
        {
            SensorServer Extension;
 
            if (Client.TryGetTag("ProvisioningClient", out object Obj) && Obj is ProvisioningClient ProvisioningClient)
                Extension = new SensorServer(Client, ProvisioningClient, true);
            else
                Extension = new SensorServer(Client, true);
 
            Client.SetTag("SensorServer", Extension);
 
            Extension.OnExecuteReadoutRequest += (Sender, e) =>
            {
                if (!this.Model.ExternalEvent(Instance, "OnExecuteReadoutRequest",
                    new KeyValuePair<string, object>("e", e),
                    new KeyValuePair<string, object>("Client", Client)))
                {
                    e.ReportErrors(true, new ThingError(ThingReference.Empty, "No event handler registered on sensor."));
                }
 
                return Task.CompletedTask;
            };
 
            return Task.FromResult<object>(Extension);
        }
 
    }
}