LocalWebServerNode.cs

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using Waher.Networking;
using Waher.Networking.Sniffers;
using Waher.Runtime.Language;
using Waher.Things.Metering;
using Waher.Things.Metering.NodeTypes;
 
namespace Waher.Things.Http
{
    public class LocalWebServerNode : MeteringNode, ICommunicationLayer
    {
        public LocalWebServerNode()
            : base()
        {
        }
 
        public override Task<string> GetTypeNameAsync(Language Language)
        {
            return Language.GetStringAsync(typeof(LocalWebServerNode), 1, "Local Web Server");
        }
 
        public override Task<bool> AcceptsChildAsync(INode Child)
        {
            return Task.FromResult(Child is ExternalWebNode);
        }
 
        public override Task<bool> AcceptsParentAsync(INode Parent)
        {
            return Task.FromResult(Parent is Root);
        }
 
        #region ICommunicationLayer
 
        public bool DecoupledEvents => HttpModule.WebServer?.DecoupledEvents ?? false;
 
        public void Add(ISniffer Sniffer)
        {
            HttpModule.WebServer?.Add(Sniffer);
            HttpModule.Scheduler.Add(
                DateTime.Now.AddHours(1),
                (_) => this.Remove(Sniffer),
                null);
        }
 
        public void AddRange(IEnumerable<ISniffer> Sniffers)
        {
            HttpModule.WebServer?.AddRange(Sniffers);
            HttpModule.Scheduler.Add(
                DateTime.Now.AddHours(1),
                (_) =>
                {
                    foreach (ISniffer Sniffer in Sniffers)
                        this.Remove(Sniffer);
                }, 
                null);
        }
 
        public bool Remove(ISniffer Sniffer) => HttpModule.WebServer?.Remove(Sniffer) ?? false;
 
        public ISniffer[] Sniffers => HttpModule.WebServer?.Sniffers ?? Array.Empty<ISniffer>();
 
        public bool HasSniffers => HttpModule.WebServer?.HasSniffers ?? false;
 
        public IEnumerator<ISniffer> GetEnumerator() => HttpModule.WebServer?.GetEnumerator() ?? ((IEnumerable<ISniffer>)(Array.Empty<ISniffer>())).GetEnumerator();
 
        System.Collections.IEnumerator System.Collections.IEnumerable.GetEnumerator() => HttpModule.WebServer?.GetEnumerator() ?? (Array.Empty<ISniffer>()).GetEnumerator();
 
        public void ReceiveBinary(int Count) => HttpModule.WebServer?.ReceiveBinary(Count);
 
        public void ReceiveBinary(bool ConstantBuffer, byte[] Data) => HttpModule.WebServer?.ReceiveBinary(ConstantBuffer, Data);
 
        public void ReceiveBinary(bool ConstantBuffer, byte[] Data, int Offset, int Count) => HttpModule.WebServer?.ReceiveBinary(ConstantBuffer, Data, Offset, Count);
 
        public void TransmitBinary(int Count) => HttpModule.WebServer?.TransmitBinary(Count);
 
        public void TransmitBinary(bool ConstantBuffer, byte[] Data) => HttpModule.WebServer?.TransmitBinary(ConstantBuffer, Data);
 
        public void TransmitBinary(bool ConstantBuffer, byte[] Data, int Offset, int Count) => HttpModule.WebServer?.TransmitBinary(ConstantBuffer, Data, Offset, Count);
 
        public void ReceiveText(string Text) => HttpModule.WebServer?.ReceiveText(Text);
 
        public void TransmitText(string Text) => HttpModule.WebServer?.TransmitText(Text);
 
        public void Information(string Comment) => HttpModule.WebServer?.Information(Comment);
 
        public void Warning(string Warning) => HttpModule.WebServer?.Warning(Warning);
 
        public void Error(string Error) => HttpModule.WebServer?.Error(Error);
 
        public void Exception(Exception Exception) => HttpModule.WebServer?.Exception(Exception);
 
        public void Exception(string Exception) => HttpModule.WebServer?.Exception(Exception);
 
        public void ReceiveBinary(DateTime Timestamp, int Count) => HttpModule.WebServer?.ReceiveBinary(Timestamp, Count);
 
        public void ReceiveBinary(DateTime Timestamp, bool ConstantBuffer, byte[] Data) => HttpModule.WebServer?.ReceiveBinary(Timestamp, ConstantBuffer, Data);
 
        public void ReceiveBinary(DateTime Timestamp, bool ConstantBuffer, byte[] Data, int Offset, int Count) => HttpModule.WebServer?.ReceiveBinary(Timestamp, ConstantBuffer, Data, Offset, Count);
 
        public void TransmitBinary(DateTime Timestamp, int Count) => HttpModule.WebServer?.TransmitBinary(Timestamp, Count);
 
        public void TransmitBinary(DateTime Timestamp, bool ConstantBuffer, byte[] Data) => HttpModule.WebServer?.TransmitBinary(Timestamp, ConstantBuffer, Data);
 
        public void TransmitBinary(DateTime Timestamp, bool ConstantBuffer, byte[] Data, int Offset, int Count) => HttpModule.WebServer?.TransmitBinary(Timestamp, ConstantBuffer, Data, Offset, Count);
 
        public void ReceiveText(DateTime Timestamp, string Text) => HttpModule.WebServer?.ReceiveText(Timestamp, Text);
 
        public void TransmitText(DateTime Timestamp, string Text) => HttpModule.WebServer?.TransmitText(Timestamp, Text);
 
        public void Information(DateTime Timestamp, string Comment) => HttpModule.WebServer?.Information(Timestamp, Comment);
 
        public void Warning(DateTime Timestamp, string Warning) => HttpModule.WebServer?.Warning(Timestamp, Warning);
 
        public void Error(DateTime Timestamp, string Error) => HttpModule.WebServer?.Error(Timestamp, Error);
 
        public void Exception(DateTime Timestamp, string Exception) => HttpModule.WebServer?.Exception(Timestamp, Exception);
 
        public void Exception(DateTime Timestamp, Exception Exception) => HttpModule.WebServer?.Exception(Timestamp, Exception);
 
        #endregion
    }
}