ConcentratorDevice.cs

using System.Collections.Generic;
using System.Threading.Tasks;
using Waher.Networking.XMPP;
using Waher.Networking.XMPP.Concentrator;
using Waher.Runtime.Language;
using Waher.Things.Xmpp.Commands;
 
namespace Waher.Things.Xmpp
{
    public class ConcentratorDevice : ConnectedDevice
    {
        public ConcentratorDevice()
            : base()
        {
        }
 
        public override Task<string> GetTypeNameAsync(Language Language)
        {
            return Language.GetStringAsync(typeof(ConcentratorDevice), 1, "XMPP Concentrator");
        }
 
        public override Task<bool> AcceptsChildAsync(INode Child)
        {
            return Task.FromResult(
                Child is ConcentratorSourceNode || 
                Child is ConcentratorNode);
        }
 
        public override Task<IEnumerable<ICommand>> Commands => this.GetCommands();
 
        private async Task<IEnumerable<ICommand>> GetCommands()
        {
            List<ICommand> Result = new List<ICommand>();
            Result.AddRange(await base.Commands);
 
            XmppClient Client = await this.GetClient();
            if (!(Client is null))
            {
                this.GetRemoteFullJid(Client, out bool HasContact, out bool HasSubscription);
 
                if (HasContact && HasSubscription)
                    Result.Add(new ScanRootSources(this));
            }
 
            return Result.ToArray();
        }
 
        public async Task<ConcentratorClient> GetConcentratorClient()
        {
            XmppClient Client = await this.GetClient();
            if (Client is null)
                return null;
 
            if (!Client.TryGetExtension(out ConcentratorClient ConcentratorClient))
                return null;
 
            return ConcentratorClient;
        }
    }
}