XmppBrokers.cs

using System.Collections.Generic;
using System.Text;
using System.Threading.Tasks;
using Waher.Security;
 
namespace Waher.Things.Xmpp.Model
{
    public static class XmppBrokers
    {
        private static readonly Dictionary<string, XmppBroker> brokers = new Dictionary<string, XmppBroker>();
 
        public static string GetKey(string Host, int Port, bool Tls, string UserName, string Password, string PasswordMechanism)
        {
            StringBuilder sb = new StringBuilder();
 
            sb.AppendLine(Host);
            sb.AppendLine(Port.ToString());
            sb.AppendLine(Tls.ToString());
            sb.AppendLine(UserName);
            sb.AppendLine(Password);
            sb.AppendLine(PasswordMechanism);
 
            return Hashes.ComputeSHA1HashString(Encoding.UTF8.GetBytes(sb.ToString()));
        }
 
        public static XmppBroker GetCachedBroker(string Key)
        {
            lock (brokers)
            {
                if (brokers.TryGetValue(Key, out XmppBroker Broker))
                    return Broker;
                else
                    return null;
            }
        }
 
        public static async Task<XmppBroker> GetBroker(XmppBrokerNode Node, string Key, string Host, int Port, bool Tls, 
            string UserName, string Password, string PasswordMechanism, bool TrustServer, bool AllowInsecureMechanisms)
        {
            XmppBroker Broker;
 
            lock (brokers)
            {
                if (brokers.TryGetValue(Key, out Broker))
                    return Broker;
            }
 
            Broker = await XmppBroker.Create(Node, Host, Port, Tls, UserName, Password, PasswordMechanism, TrustServer, AllowInsecureMechanisms);
 
            lock (brokers)
            {
                if (brokers.ContainsKey(Key))
                {
                    Broker.Dispose();
                    return brokers[Key];
                }
                else
                {
                    brokers[Key] = Broker;
                    return Broker;
                }
            }
        }
 
        public static void DestroyBroker(string Key)
        {
            XmppBroker Broker;
 
            lock (brokers)
            {
                if (!brokers.TryGetValue(Key, out Broker))
                    return;
 
                brokers.Remove(Key);
            }
 
            Broker.Dispose();
        }
 
    }
}