30 references to NativeRpcProtocol
Aspire.Hosting.Native.Core.Tests (21)
NativeProtocolParsingTests.cs (21)
25Assert.Throws<InvalidDataException>(() => NativeRpcProtocol.ParseResponse(document.RootElement)); 36Assert.Throws<InvalidDataException>(() => NativeRpcProtocol.ValidateResponseError(document.RootElement)); 52result = NativeRpcProtocol.ToNode(document.RootElement); 65request = NativeRpcProtocol.ParseRequest(document.RootElement); 226var request = NativeRpcProtocol.ParseRequest(Encoding.UTF8.GetBytes(json)); 248Assert.Throws<RpcFault>(() => NativeRpcProtocol.ParseRequest(Encoding.UTF8.GetBytes(json))); 255Assert.NotNull(NativeRpcProtocol.ReadTraceContext(valid, 1024)); 256Assert.Null(NativeRpcProtocol.ReadTraceContext(valid, 1)); 258Assert.Null(NativeRpcProtocol.ReadTraceContext(duplicate, 1024)); 259Assert.Null(NativeRpcProtocol.ReadTraceContext("""{"traceparent":true}"""u8.ToArray(), 1024)); 260Assert.Null(NativeRpcProtocol.ReadTraceContext("""{"traceparent":"invalid"}"""u8.ToArray(), 1024)); 262Assert.Null(NativeRpcProtocol.ReadTraceContext(malformedState, 1024)); 264Assert.True(NativeRpcProtocol.ReadTraceContext(escapedParent, 1024)!.Value.IsRemote); 273Assert.Equal(method, NativeRpcProtocol.ParseRequest(Encoding.UTF8.GetBytes(valid)).Method); 274Assert.Throws<RpcFault>(() => NativeRpcProtocol.ParseRequest( 276Assert.Throws<RpcFault>(() => NativeRpcProtocol.ParseRequest( 280Assert.Equal(method, NativeRpcProtocol.ParseRequest(Encoding.UTF8.GetBytes(padded)).Method); 281Assert.Throws<RpcFault>(() => NativeRpcProtocol.ParseRequest(Encoding.UTF8.GetBytes(padded + " "))); 282Assert.Throws<RpcFault>(() => NativeRpcProtocol.ParseRequest( 284Assert.Throws<RpcFault>(() => NativeRpcProtocol.ParseRequest( 286Assert.ThrowsAny<JsonException>(() => NativeRpcProtocol.ParseRequest(
Aspire.Hosting.Native.Server (9)
NativeServerConfiguration.cs (1)
44NativeRpcProtocol.ValidateAuthenticationToken(token);
Rpc\NativeRpcConnection.cs (3)
264NativeRpcProtocol.ValidateAuthenticationToken(token); 334request = NativeRpcProtocol.ParseRequest(envelope); 462if (NativeRpcProtocol.ReadTraceContext(envelope) is { } context)
Rpc\NativeRpcListener.cs (1)
73NativeRpcProtocol.ValidateAuthenticationToken(token);
Rpc\NativeRpcPeer.cs (4)
93NativeRpcProtocol.ValidateUniqueProperties(document.RootElement); 158var envelope = NativeRpcProtocol.ParseResponse(response); 168NativeRpcProtocol.ValidateResponseError(error); 181completion.TrySetResult(NativeRpcProtocol.ToNode(envelope.Result));