| | | 1 | | // Copyright (c) ZeroC, Inc. |
| | | 2 | | |
| | | 3 | | using IceRpc.Internal; |
| | | 4 | | using System.Collections.Immutable; |
| | | 5 | | using System.Diagnostics.CodeAnalysis; |
| | | 6 | | using System.Net.Security; |
| | | 7 | | |
| | | 8 | | namespace IceRpc; |
| | | 9 | | |
| | | 10 | | /// <summary>Represents an RPC protocol supported by IceRPC.</summary> |
| | | 11 | | public class Protocol |
| | | 12 | | { |
| | | 13 | | /// <summary>Gets the ice protocol.</summary> |
| | | 14 | | /// <value>The <see cref="Protocol" /> instance for the ice protocol.</value> |
| | 5624 | 15 | | public static Protocol Ice => IceProtocol.Instance; |
| | | 16 | | |
| | | 17 | | /// <summary>Gets the icerpc protocol.</summary> |
| | | 18 | | /// <value>The <see cref="Protocol" /> instance for the icerpc protocol.</value> |
| | 5957 | 19 | | public static Protocol IceRpc => IceRpcProtocol.Instance; |
| | | 20 | | |
| | | 21 | | /// <summary>Gets the default port for this protocol.</summary> |
| | | 22 | | /// <value>The default port value. Defaults to <c>4061</c> for the ice protocol and <c>4062</c> for the icerpc |
| | | 23 | | /// protocol.</value> |
| | 1072 | 24 | | public ushort DefaultPort { get; } |
| | | 25 | | |
| | | 26 | | /// <summary>Gets a value indicating whether or not this protocol supports arbitrary application-defined fields in |
| | | 27 | | /// request and response headers.</summary> |
| | | 28 | | /// <value><see langword="true" /> if the protocol supports arbitrary fields; otherwise, <see langword="false" />. |
| | | 29 | | /// </value> |
| | 47 | 30 | | public bool HasFields { get; } |
| | | 31 | | |
| | | 32 | | /// <summary>Gets the name of this protocol.</summary> |
| | | 33 | | /// <value>The protocol name.</value> |
| | 2482 | 34 | | public string Name { get; } |
| | | 35 | | |
| | | 36 | | /// <summary>Gets the ALPN protocol identifier for this protocol.</summary> |
| | 15 | 37 | | internal SslApplicationProtocol AlpnProtocol { get; } |
| | | 38 | | |
| | | 39 | | /// <summary>Gets the byte value for this protocol.</summary> |
| | | 40 | | /// <value>The protocol byte value. It's used as the "protocol major" with the Ice encoding.</value> |
| | 115 | 41 | | internal byte ByteValue { get; } |
| | | 42 | | |
| | | 43 | | /// <summary>Gets a value indicating whether or not this protocol supports fragments in service addresses.</summary> |
| | | 44 | | /// <value><see langword="true" /> if the protocol supports fragments; otherwise, <see langword="false" />.</value> |
| | 482 | 45 | | internal bool HasFragment { get; } |
| | | 46 | | |
| | | 47 | | /// <summary>Gets a value indicating whether or not this protocol supports payload continuations.</summary> |
| | | 48 | | /// <value><see langword="true" /> if the protocol supports payload continuations; otherwise, |
| | | 49 | | /// <see langword="false" />.</value> |
| | 200 | 50 | | internal bool HasPayloadContinuation { get; } |
| | | 51 | | |
| | | 52 | | /// <summary>Gets a value indicating whether or not the implementation of the protocol connection supports payload |
| | | 53 | | /// writer interceptors.</summary> |
| | | 54 | | /// <value><see langword="true" /> if the implementation of the protocol connection supports payload writer |
| | | 55 | | /// interceptors; otherwise, <see langword="false" />.</value> |
| | 13 | 56 | | internal bool SupportsPayloadWriterInterceptors { get; } |
| | | 57 | | |
| | | 58 | | /// <summary>Parses a string into a protocol.</summary> |
| | | 59 | | /// <param name="name">The name of the protocol.</param> |
| | | 60 | | /// <returns>A protocol with the given name in lowercase.</returns> |
| | | 61 | | /// <exception cref="FormatException">Thrown when <paramref name="name" /> is not ice or icerpc.</exception> |
| | | 62 | | public static Protocol Parse(string name) => |
| | 19 | 63 | | TryParse(name, out Protocol? protocol) ? protocol : throw new FormatException($"unknown protocol '{name}'"); |
| | | 64 | | |
| | | 65 | | /// <summary>Tries to parse a string into a protocol.</summary> |
| | | 66 | | /// <param name="name">The name of the protocol.</param> |
| | | 67 | | /// <param name="protocol">The protocol parsed from the name.</param> |
| | | 68 | | /// <returns><see langword="true" /> when <paramref name="name" /> was successfully parsed into a protocol; |
| | | 69 | | /// otherwise, <see langword="false" />.</returns> |
| | | 70 | | public static bool TryParse(string name, [NotNullWhen(true)] out Protocol? protocol) |
| | 1368 | 71 | | { |
| | 1368 | 72 | | name = name.ToLowerInvariant(); |
| | 1368 | 73 | | protocol = name == IceRpc.Name ? IceRpc : (name == Ice.Name ? Ice : null); |
| | 1368 | 74 | | return protocol is not null; |
| | 1368 | 75 | | } |
| | | 76 | | |
| | | 77 | | /// <summary>Converts this protocol into a string.</summary> |
| | | 78 | | /// <returns>The name of the protocol.</returns> |
| | 201 | 79 | | public override string ToString() => Name; |
| | | 80 | | |
| | | 81 | | internal static Protocol FromByteValue(byte value) => |
| | 44 | 82 | | value == Ice.ByteValue ? Ice : |
| | 44 | 83 | | (value == IceRpc.ByteValue ? IceRpc : |
| | 44 | 84 | | throw new NotSupportedException($"Cannot convert '{value}' into a protocol.")); |
| | | 85 | | |
| | | 86 | | /// <summary>Checks if a path is valid for this protocol.</summary> |
| | | 87 | | /// <param name="uriPath">The absolute path to check. The caller guarantees it's a valid URI absolute path. |
| | | 88 | | /// </param> |
| | | 89 | | /// <exception cref="FormatException">Thrown if the path is not valid.</exception> |
| | | 90 | | internal virtual void CheckPath(string uriPath) |
| | 270 | 91 | | { |
| | | 92 | | // by default, any URI absolute path is ok |
| | 270 | 93 | | } |
| | | 94 | | |
| | | 95 | | /// <summary>Checks if these service address parameters are valid for this protocol.</summary> |
| | | 96 | | /// <param name="serviceAddressParams">The service address parameters to check.</param> |
| | | 97 | | /// <exception cref="FormatException">Thrown if the service address parameters are not valid.</exception> |
| | | 98 | | /// <remarks>This method does not and should not check if the parameter names and values are properly escaped; |
| | | 99 | | /// it does not check for the invalid empty and alt-server parameter names either.</remarks> |
| | | 100 | | internal virtual void CheckServiceAddressParams(ImmutableDictionary<string, string> serviceAddressParams) |
| | 64 | 101 | | { |
| | | 102 | | // by default, any dictionary is ok |
| | 64 | 103 | | } |
| | | 104 | | |
| | | 105 | | /// <summary>Constructs a protocol.</summary> |
| | 27 | 106 | | private protected Protocol( |
| | 27 | 107 | | string name, |
| | 27 | 108 | | ushort defaultPort, |
| | 27 | 109 | | bool hasFields, |
| | 27 | 110 | | bool hasFragment, |
| | 27 | 111 | | bool hasPayloadContinuation, |
| | 27 | 112 | | bool supportsPayloadWriterInterceptors, |
| | 27 | 113 | | byte byteValue) |
| | 27 | 114 | | { |
| | 27 | 115 | | Name = name; |
| | 27 | 116 | | AlpnProtocol = new SslApplicationProtocol(name); |
| | 27 | 117 | | DefaultPort = defaultPort; |
| | 27 | 118 | | HasFields = hasFields; |
| | 27 | 119 | | HasFragment = hasFragment; |
| | 27 | 120 | | HasPayloadContinuation = hasPayloadContinuation; |
| | 27 | 121 | | SupportsPayloadWriterInterceptors = supportsPayloadWriterInterceptors; |
| | 27 | 122 | | ByteValue = byteValue; |
| | 27 | 123 | | } |
| | | 124 | | } |