XmppDevice.cs

using System;
using System.Threading.Tasks;
using Waher.Networking.XMPP;
using Waher.Runtime.Inventory;
using Waher.Things.Metering;
 
namespace Waher.Things.Xmpp
{
    public abstract class XmppDevice : ProvisionedMeteringNode
    {
        public XmppDevice()
            : base()
        {
        }
 
        public Task<XmppBrokerNode> GetBrokerNode()
        {
            return this.GetAncestor<XmppBrokerNode>();
        }
 
        public async Task<XmppClient> GetClient()
        {
            XmppBrokerNode BrokerNode = await this.GetBrokerNode();
 
            if (!(BrokerNode is null))
                return (await BrokerNode.GetBroker()).Client;
            else if (Types.TryGetModuleParameter("XMPP", out object Obj) && Obj is XmppClient Client)
                return Client;
            else
                throw new Exception("No XMPP Client associated with node.");
        }
    }
}