ProtocolsSource.cs

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using Waher.Events;
using Waher.Runtime.Language;
using Waher.Things;
using Waher.Things.SourceEvents;
 
namespace Waher.Service.IoTBroker.Sources.Protocols
{
    public class ProtocolsSource : IDataSource
    {
        private readonly INode[] nodes;
 
        public ProtocolsSource(params INode[] Nodes)
        {
            this.nodes = Nodes;
        }
 
        public string SourceID => "Protocols";
        public bool HasChildren => false;
        public DateTime LastChanged => DateTime.MinValue;
        public IEnumerable<IDataSource> ChildSources => null;
        public IEnumerable<INode> RootNodes => this.nodes;
        public event EventHandlerAsync<SourceEvent> OnEvent;
 
        public Task<bool> CanViewAsync(RequestOrigin Caller)
        {
            return XmppServerModule.IsAdmin(Caller.From);
        }
 
        public Task<string> GetNameAsync(Language Language)
        {
            return Language.GetStringAsync(typeof(XmppServerModule), 27, "Protocols");
        }
 
        public Task<INode> GetNodeAsync(IThingReference NodeRef)
        {
            foreach (INode Node in this.nodes)
            {
                if (Node.NodeId == NodeRef.NodeId &&
                    Node.SourceId == NodeRef.SourceId &&
                    Node.Partition == NodeRef.Partition)
                {
                    return Task.FromResult<INode>(Node);
                }
            }
 
            return Task.FromResult<INode>(null);
        }
    }
}