| | | 1 | | using System; |
| | | 2 | | using System.Collections.Generic; |
| | | 3 | | using System.Globalization; |
| | | 4 | | using System.Linq; |
| | | 5 | | using Grpc.Core; |
| | | 6 | | |
| | | 7 | | namespace dotnet_etcd; |
| | | 8 | | |
| | | 9 | | /// <summary> |
| | | 10 | | /// Handles parsing of connection strings for etcd client |
| | | 11 | | /// </summary> |
| | | 12 | | public class ConnectionStringParser |
| | | 13 | | { |
| | | 14 | | private const string InsecurePrefix = "http://"; |
| | | 15 | | private const string SecurePrefix = "https://"; |
| | | 16 | | private const string StaticHostsPrefix = "static://"; |
| | | 17 | | private const string DnsPrefix = "dns://"; |
| | | 18 | | private const string AlternateDnsPrefix = "discovery-srv://"; |
| | | 19 | | |
| | | 20 | | /// <summary> |
| | | 21 | | /// Parses a connection string and returns the appropriate URI and connection type |
| | | 22 | | /// </summary> |
| | | 23 | | /// <param name="connectionString">The connection string to parse</param> |
| | | 24 | | /// <param name="port">The port to use if not specified in the connection string</param> |
| | | 25 | | /// <param name="credentials">The credentials to use for the connection</param> |
| | | 26 | | /// <returns>A tuple containing the parsed URI and whether it's a DNS connection</returns> |
| | | 27 | | public (Uri[] Uris, bool IsDnsConnection) ParseConnectionString(string connectionString, int port, ChannelCredential |
| | 117 | 28 | | { |
| | 117 | 29 | | if (string.IsNullOrWhiteSpace(connectionString)) |
| | 2 | 30 | | { |
| | 2 | 31 | | throw new ArgumentNullException(nameof(connectionString)); |
| | | 32 | | } |
| | | 33 | | |
| | 115 | 34 | | if (connectionString.StartsWith(AlternateDnsPrefix, StringComparison.InvariantCultureIgnoreCase)) |
| | 1 | 35 | | { |
| | 1 | 36 | | connectionString = connectionString.Substring(AlternateDnsPrefix.Length); |
| | 1 | 37 | | connectionString = DnsPrefix + connectionString; |
| | 1 | 38 | | } |
| | | 39 | | |
| | 115 | 40 | | if (connectionString.StartsWith(DnsPrefix, StringComparison.InvariantCultureIgnoreCase)) |
| | 3 | 41 | | { |
| | 3 | 42 | | return (new[] { new Uri(connectionString) }, true); |
| | | 43 | | } |
| | | 44 | | |
| | 112 | 45 | | string[] hosts = connectionString.Split(','); |
| | 112 | 46 | | List<Uri> nodes = new(); |
| | | 47 | | |
| | 568 | 48 | | foreach (string host in hosts) |
| | 116 | 49 | | { |
| | 116 | 50 | | string processedHost = host.Trim(); |
| | | 51 | | |
| | | 52 | | // Only append port if no port is specified and it's not a full URL |
| | 116 | 53 | | if (!processedHost.Contains(':') && |
| | 116 | 54 | | !processedHost.StartsWith(InsecurePrefix, StringComparison.InvariantCultureIgnoreCase) && |
| | 116 | 55 | | !processedHost.StartsWith(SecurePrefix, StringComparison.InvariantCultureIgnoreCase)) |
| | 9 | 56 | | { |
| | 9 | 57 | | processedHost += $":{Convert.ToString(port, CultureInfo.InvariantCulture)}"; |
| | 9 | 58 | | } |
| | | 59 | | |
| | 116 | 60 | | if (!(processedHost.StartsWith(InsecurePrefix, StringComparison.InvariantCultureIgnoreCase) || |
| | 116 | 61 | | processedHost.StartsWith(SecurePrefix, StringComparison.InvariantCultureIgnoreCase))) |
| | 84 | 62 | | { |
| | 84 | 63 | | processedHost = credentials == ChannelCredentials.Insecure |
| | 84 | 64 | | ? $"{InsecurePrefix}{processedHost}" |
| | 84 | 65 | | : $"{SecurePrefix}{processedHost}"; |
| | 84 | 66 | | } |
| | | 67 | | |
| | 116 | 68 | | nodes.Add(new Uri(processedHost)); |
| | 116 | 69 | | } |
| | | 70 | | |
| | 112 | 71 | | return (nodes.ToArray(), false); |
| | 115 | 72 | | } |
| | | 73 | | } |