| | | 1 | | // Copyright (c) ZeroC, Inc. |
| | | 2 | | |
| | | 3 | | using System.Collections.Immutable; |
| | | 4 | | |
| | | 5 | | namespace IceRpc.Internal; |
| | | 6 | | |
| | | 7 | | /// <summary>The Ice protocol class.</summary> |
| | | 8 | | internal sealed class IceProtocol : Protocol |
| | | 9 | | { |
| | | 10 | | /// <summary>Gets the Ice protocol singleton.</summary> |
| | 5634 | 11 | | internal static IceProtocol Instance { get; } = new(); |
| | | 12 | | |
| | | 13 | | /// <summary>Checks if this absolute path is well-formed.</summary> |
| | | 14 | | /// <remarks>This check is more lenient than the check performed when encoding a service address with Ice because |
| | | 15 | | /// we want the default path (`/`) to be a valid path for all protocols. Sending a request to a null/empty identity |
| | | 16 | | /// is in itself ok and can succeed with an IceRPC server. With an Ice server, it will result in a dispatch |
| | | 17 | | /// exception with a <see cref="StatusCode.NotFound" /> status code.</remarks> |
| | | 18 | | internal override void CheckPath(string uriPath) |
| | 248 | 19 | | { |
| | 248 | 20 | | string workingPath = uriPath[1..]; // removes leading /. |
| | 248 | 21 | | int firstSlash = workingPath.IndexOf('/', StringComparison.Ordinal); |
| | | 22 | | |
| | | 23 | | // We can have at most one slash in the working path. |
| | 248 | 24 | | if (firstSlash != -1 && firstSlash != workingPath.LastIndexOf('/')) |
| | 2 | 25 | | { |
| | 2 | 26 | | throw new FormatException($"Too many slashes in path '{uriPath}'."); |
| | | 27 | | } |
| | 246 | 28 | | } |
| | | 29 | | |
| | | 30 | | /// <summary>Checks if the service address parameters are valid. The only valid parameter is adapter-id with a |
| | | 31 | | /// non-empty value.</summary> |
| | | 32 | | internal override void CheckServiceAddressParams(ImmutableDictionary<string, string> serviceAddressParams) |
| | 81 | 33 | | { |
| | 314 | 34 | | foreach ((string name, string value) in serviceAddressParams) |
| | 37 | 35 | | { |
| | 37 | 36 | | if (name == "adapter-id") |
| | 36 | 37 | | { |
| | 36 | 38 | | if (value.Length == 0) |
| | 2 | 39 | | { |
| | 2 | 40 | | throw new FormatException("The value of the adapter-id parameter cannot be empty."); |
| | | 41 | | } |
| | 34 | 42 | | } |
| | | 43 | | else |
| | 1 | 44 | | { |
| | 1 | 45 | | throw new FormatException($"Invalid service address parameter name '{name}'."); |
| | | 46 | | } |
| | 34 | 47 | | } |
| | 78 | 48 | | } |
| | | 49 | | |
| | | 50 | | private IceProtocol() |
| | 10 | 51 | | : base( |
| | 10 | 52 | | name: "ice", |
| | 10 | 53 | | defaultPort: 4061, |
| | 10 | 54 | | hasFields: false, |
| | 10 | 55 | | hasFragment: true, |
| | 10 | 56 | | hasPayloadContinuation: false, |
| | 10 | 57 | | supportsPayloadWriterInterceptors: false, |
| | 10 | 58 | | byteValue: 1) |
| | 10 | 59 | | { |
| | 10 | 60 | | } |
| | | 61 | | } |