RosterItemNode.cs

using System.Collections.Generic;
using System.Threading.Tasks;
using Waher.Networking.XMPP;
using Waher.Runtime.Language;
using Waher.Things.Attributes;
using Waher.Things.DisplayableParameters;
using Waher.Things.Metering;
using Waher.Things.Xmpp.Model;
 
namespace Waher.Things.Xmpp
{
    public class RosterItemNode : ProvisionedMeteringNode
    {
        public RosterItemNode()
            : base()
        {
        }
 
        [Page(28, "Roster", 110)]
        [Header(29, "Bare JID:")]
        [ToolTip(30, "Bare JID of roster item.")]
        public string BareJID { get; set; }
 
        [Page(28, "Roster", 110)]
        [Header(34, "Subscription State:")]
        [ToolTip(35, "State of presence subscription for roster item.")]
        [Option(SubscriptionState.None, 36, "None")]
        [Option(SubscriptionState.To, 37, "To")]
        [Option(SubscriptionState.From, 38, "From")]
        [Option(SubscriptionState.Both, 39, "Both")]
        [Option(SubscriptionState.Remove, 40, "Remove")]
        [Option(SubscriptionState.Unknown, 41, "Unknown")]
        public SubscriptionState SubscriptionState { get; set; }
 
        [Page(28, "Roster", 110)]
        [Header(42, "Name:")]
        [ToolTip(43, "Name of contact.")]
        public string ContactName { get; set; }
 
        [Page(28, "Roster", 110)]
        [Header(44, "Pending Subscription:")]
        [ToolTip(47, "If a pending subscription request exists.")]
        [Option(PendingSubscription.None, 36, "None")]
        [Option(PendingSubscription.Subscribe, 45, "Subscribe")]
        [Option(PendingSubscription.Unsubscribe, 46, "Unsubscribe")]
        public PendingSubscription PendingSubscription { get; set; }
 
        [Page(28, "Roster", 110)]
        [Header(48, "Groups:")]
        [ToolTip(49, "Groups to which the roster item belongs.")]
        public string[] Groups { get; set; }
 
        public override string LocalId => this.BareJID;
 
        public override Task<string> GetTypeNameAsync(Language Language)
        {
            return Language.GetStringAsync(typeof(ConcentratorDevice), 31, "Roster Item");
        }
 
        public override Task<bool> AcceptsParentAsync(INode Parent)
        {
            return Task.FromResult(Parent is XmppBrokerNode);
        }
 
        public override Task<bool> AcceptsChildAsync(INode Child)
        {
            return Task.FromResult(false);
        }
 
        public async override Task<IEnumerable<Parameter>> GetDisplayableParametersAsync(Language Language, RequestOrigin Caller)
        {
            LinkedList<Parameter> Result = await base.GetDisplayableParametersAsync(Language, Caller) as LinkedList<Parameter>;
 
            if (await this.GetParent() is XmppBrokerNode BrokerNode)
            {
                XmppBroker Broker = await BrokerNode.GetBroker();
                XmppClient Client = Broker.Client;
                Namespace Namespace = await Language.GetNamespaceAsync(typeof(XmppBrokerNode).Namespace);
 
                RosterItem Item = Client[this.BareJID];
                if (!(Item is null))
                    Result.AddLast(new StringParameter("SubscriptionState", await Namespace.GetStringAsync(51, "Subscription State"), Item.State.ToString()));
                
                Result.AddLast(new StringParameter("ContactName", await Namespace.GetStringAsync(50, "Contact Name"), this.ContactName));
            }
 
            return Result;
        }
 
        public override async Task DestroyAsync()
        {
            await base.DestroyAsync();
 
            if (await this.GetParent() is XmppBrokerNode BrokerNode)
            {
                XmppBroker Broker = await BrokerNode.GetBroker();
                XmppClient Client = Broker.Client;
                RosterItem Item = Client[this.BareJID];
 
                if (!(Item is null))
                    await Client.RemoveRosterItem(this.BareJID);
            }
        }
    }
}