PersistedDataSource.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.PersistedData
{
    public class PersistedDataSource : IDataSource
    {
        private readonly EventLog eventLog;
        private readonly INode[] nodes;
 
        public PersistedDataSource()
        {
            this.nodes = new INode[]
            {
                this.eventLog = new EventLog()
            };
        }
 
        public string SourceID => "Data";
        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), 26, "Persisted Data");
        }
 
        public Task<INode> GetNodeAsync(IThingReference NodeRef)
        {
            switch (NodeRef.Partition)
            {
                default:
                    foreach (INode Node in this.nodes)
                    {
                        if (Node.NodeId == NodeRef.NodeId &&
                            Node.SourceId == NodeRef.SourceId &&
                            Node.Partition == NodeRef.Partition)
                        {
                            return Task.FromResult<INode>(Node);
                        }
                    }
                    break;
            }
 
 
            return Task.FromResult<INode>(null);
        }
    }
}