ConnectedDevice.cs

using System.Collections.Generic;
using System.Threading.Tasks;
using Waher.Networking.XMPP;
using Waher.Runtime.Language;
using Waher.Things.Attributes;
using Waher.Things.Metering.NodeTypes;
using Waher.Things.Xmpp.Commands;
 
namespace Waher.Things.Xmpp
{
    public class ConnectedDevice : XmppDevice
    {
        public ConnectedDevice()
            : base()
        {
        }
 
        [Page(2, "XMPP", 100)]
        [Header(3, "JID:")]
        [ToolTip(4, "XMPP Address.")]
        public string JID { get; set; }
 
        public override Task<string> GetTypeNameAsync(Language Language)
        {
            return Language.GetStringAsync(typeof(ConcentratorDevice), 56, "XMPP Device");
        }
 
        public override Task<bool> AcceptsParentAsync(INode Parent)
        {
            return Task.FromResult(Parent is Root);
        }
 
        public override Task<bool> AcceptsChildAsync(INode Child)
        {
            return Task.FromResult(false);
        }
 
        public string GetRemoteFullJid(XmppClient Client, out bool HasContact, out bool HasSubscription)
        {
            HasContact = false;
            HasSubscription = false;
 
            RosterItem Contact = Client[this.JID];
            if (Contact is null)
                return null;
                
            HasContact = true;
 
            if (!(Contact.State == SubscriptionState.Both || Contact.State == SubscriptionState.To))
                return null;
 
            HasSubscription = true;
 
            return Contact.LastPresenceFullJid;
        }
 
        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 SubscribeToPresence(this));
            }
 
            return Result.ToArray();
        }
    }
}