ModBusServer.cs

using System;
using System.Threading.Tasks;
using System.Xml;
using TAG.Simulator.ObjectModel;
using TAG.Simulator.ObjectModel.Actors;
using Waher.Content.Xml;
using Waher.Networking.Modbus;
using Waher.Networking.Sniffers;
 
namespace TAG.Simulator.ModBus.Actors
{
    public class ModBusServer : SimulationNodeChildren, IActors
    {
        private ModBusTcpServer server;
        private ISniffer sniffer;
        private int port;
 
        public ModBusServer(ISimulationNode Parent, Model Model)
            : base(Parent, Model)
        {
        }
 
        public override string Namespace => ModBusActor.ComSimModBusNamespace;
 
        public override string SchemaResource => ModBusActor.ComSimModBusSchema;
 
        public override string LocalName => nameof(ModBusServer);
 
        public ModBusTcpServer Server => this.server;
 
        public override ISimulationNode Create(ISimulationNode Parent, Model Model)
        {
            return new ModBusServer(Parent, Model);
        }
 
        public override Task FromXml(XmlElement Definition)
        {
            this.port = XML.Attribute(Definition, "port", 502);
 
            return base.FromXml(Definition);
        }
 
        public void Register(IActor Actor)
        {
            if (this.Parent is IActors Actors)
                Actors.Register(Actor);
        }
 
        public override async Task Initialize()
        {
            this.sniffer = this.Model.GetSniffer("ModBus" + this.port.ToString(), BinaryPresentationMethod.Hexadecimal);
            this.server = await ModBusTcpServer.CreateAsync(this.port, this.sniffer);
 
            await base.Initialize();
        }
 
        public override Task Start()
        {
            return base.Start();
        }
 
        public override Task Finalize()
        {
            this.server.Dispose();
            this.server = null;
 
            if (!(this.sniffer is null))
            {
                if (this.sniffer is IDisposable Disposable)
                    Disposable.Dispose();
 
                this.sniffer = null;
            }
 
            return base.Finalize();
        }
    }
}