ProxyPorts.cs

using System.Collections.Generic;
using System.Text;
using System.Threading.Tasks;
using Waher.Runtime.IO;
using Waher.Security;
 
namespace Waher.Things.Ip.Model
{
    public static class ProxyPorts
    {
        private static readonly Dictionary<string, ProxyPort> proxies = new Dictionary<string, ProxyPort>();
 
        public static string GetKey(string Host, int Port, bool Tls, bool TrustServer, int ListeningPort, bool AuthorizedAccess, IpCidr[] RemoteIps)
        {
            StringBuilder sb = new StringBuilder();
 
            sb.AppendLine(Host);
            sb.AppendLine(Port.ToString());
            sb.AppendLine(Tls.ToString());
            sb.AppendLine(TrustServer.ToString());
            sb.AppendLine(ListeningPort.ToString());
            sb.AppendLine(AuthorizedAccess.ToString());
 
            if (!(RemoteIps is null))
            {
                foreach (IpCidr Range in RemoteIps)
                {
                    sb.AppendLine(Range.Address.ToString());
                    sb.AppendLine(Range.Range.ToString());
                }
            }
 
            return Hashes.ComputeSHA1HashString(Encoding.UTF8.GetBytes(sb.ToString()));
        }
 
        public static async Task<ProxyPort> GetProxy(IpHostPortProxy Node, string Key, string Host, int Port, bool Tls, bool TrustServer, int ListeningPort, 
            bool AuthorizedAccess, IpCidr[] RemoteIps)
        {
            ProxyPort Proxy;
 
            lock (proxies)
            {
                if (!proxies.TryGetValue(Key, out Proxy))
                    Proxy = null;
            }
 
            if (!(Proxy is null))
                return Proxy;
            else
            {
                Proxy = await ProxyPort.Create(Node, Host, Port, Tls, TrustServer, ListeningPort, AuthorizedAccess, RemoteIps);
 
                lock (proxies)
                {
                    if (proxies.ContainsKey(Key))
                    {
                        Proxy.Dispose();
                        return proxies[Key];
                    }
                    else
                    {
                        proxies[Key] = Proxy;
                        return Proxy;
                    }
                }
            }
        }
 
        public static void DestroyProxy(string Key)
        {
            ProxyPort Proxy;
 
            lock (proxies)
            {
                if (!proxies.TryGetValue(Key, out Proxy))
                    return;
 
                proxies.Remove(Key);
            }
 
            Proxy.Dispose();
        }
 
    }
}