Merging internal commits for release/9.0

NuGet.config

@@ -6,8 +6,10 @@
     <!--  Begin: Package sources from dotnet-extensions -->
     <!--  End: Package sources from dotnet-extensions -->
     <!--  Begin: Package sources from dotnet-runtime -->
+    <add key="darc-int-dotnet-runtime-f2c8152" value="https://pkgs.dev.azure.com/dnceng/internal/_packaging/darc-int-dotnet-runtime-f2c8152e/nuget/v3/index.json" />
     <!--  End: Package sources from dotnet-runtime -->
     <!--  Begin: Package sources from dotnet-efcore -->
+    <add key="darc-int-dotnet-efcore-46c88f8" value="https://pkgs.dev.azure.com/dnceng/internal/_packaging/darc-int-dotnet-efcore-46c88f8c/nuget/v3/index.json" />
     <!--  End: Package sources from dotnet-efcore -->
     <!--End: Package sources managed by Dependency Flow automation. Do not edit the sources above.-->
     <add key="dotnet-eng" value="https://pkgs.dev.azure.com/dnceng/public/_packaging/dotnet-eng/nuget/v3/index.json" />
@@ -30,8 +32,10 @@
     <clear />
     <!--Begin: Package sources managed by Dependency Flow automation. Do not edit the sources below.-->
     <!--  Begin: Package sources from dotnet-efcore -->
+    <add key="darc-int-dotnet-efcore-46c88f8" value="true" />
     <!--  End: Package sources from dotnet-efcore -->
     <!--  Begin: Package sources from dotnet-runtime -->
+    <add key="darc-int-dotnet-runtime-f2c8152" value="true" />
     <!--  End: Package sources from dotnet-runtime -->
     <!--End: Package sources managed by Dependency Flow automation. Do not edit the sources above.-->
   </disabledPackageSources>

global.json

@@ -1,9 +1,9 @@
 {
   "sdk": {
-    "version": "9.0.116"
+    "version": "9.0.118"
   },
   "tools": {
-    "dotnet": "9.0.116",
+    "dotnet": "9.0.118",
     "runtimes": {
       "dotnet/x86": [
         "$(MicrosoftNETCoreBrowserDebugHostTransportVersion)"

src/Grpc/JsonTranscoding/src/Microsoft.AspNetCore.Grpc.JsonTranscoding/Internal/CallHandlers/CallHandlerDescriptorInfo.cs

@@ -24,7 +24,14 @@ public CallHandlerDescriptorInfo(
         BodyFieldDescriptor = bodyFieldDescriptor;
         RouteParameterDescriptors = routeParameterDescriptors;
         RouteAdapter = routeAdapter;
-        PathDescriptorsCache = new ConcurrentDictionary<string, List<FieldDescriptor>?>();
+        PathDescriptorsCache = new ConcurrentDictionary<string, List<FieldDescriptor>>();
+
+        var jsonPaths = new HashSet<string>(StringComparer.Ordinal);
+        foreach (var routeParameter in routeParameterDescriptors.Values)
+        {
+            jsonPaths.Add(routeParameter.JsonPath);
+        }
+        RouteParameterJsonPaths = jsonPaths;
     }
 
     public FieldDescriptor? ResponseBodyDescriptor { get; }
@@ -34,5 +41,6 @@ public CallHandlerDescriptorInfo(
     public FieldDescriptor? BodyFieldDescriptor { get; }
     public Dictionary<string, RouteParameter> RouteParameterDescriptors { get; }
     public JsonTranscodingRouteAdapter RouteAdapter { get; }
-    public ConcurrentDictionary<string, List<FieldDescriptor>?> PathDescriptorsCache { get; }
+    public HashSet<string> RouteParameterJsonPaths { get; }
+    public ConcurrentDictionary<string, List<FieldDescriptor>> PathDescriptorsCache { get; }
 }

src/Grpc/JsonTranscoding/src/Microsoft.AspNetCore.Grpc.JsonTranscoding/Internal/JsonRequestHelpers.cs

@@ -361,11 +361,18 @@ private static async ValueTask<byte[]> ReadDataAsync(JsonTranscodingServerCallCo
 
     private static List<FieldDescriptor>? GetPathDescriptors(JsonTranscodingServerCallContext serverCallContext, IMessage requestMessage, string path)
     {
-        return serverCallContext.DescriptorInfo.PathDescriptorsCache.GetOrAdd(path, p =>
+        // Must not add null values for paths that don't resolve to a descriptor
+        var cache = serverCallContext.DescriptorInfo.PathDescriptorsCache;
+        if (cache.TryGetValue(path, out var pathDescriptors))
         {
-            ServiceDescriptorHelpers.TryResolveDescriptors(requestMessage.Descriptor, p.Split('.'), allowJsonName: true, out var pathDescriptors);
             return pathDescriptors;
-        });
+        }
+        if (ServiceDescriptorHelpers.TryResolveDescriptors(requestMessage.Descriptor, path.Split('.'), allowJsonName: true, out pathDescriptors))
+        {
+            cache.TryAdd(path, pathDescriptors);
+            return pathDescriptors;
+        }
+        return null;
     }
 
     public static async ValueTask SendMessage<TResponse>(JsonTranscodingServerCallContext serverCallContext, JsonSerializerOptions serializerOptions, TResponse message, CancellationToken cancellationToken) where TResponse : class
@@ -408,24 +415,25 @@ private static bool CanBindQueryStringVariable(JsonTranscodingServerCallContext
     {
         if (serverCallContext.DescriptorInfo.BodyDescriptor != null)
         {
-            var bodyFieldName = serverCallContext.DescriptorInfo.BodyFieldDescriptor?.Name;
+            var bodyFieldDescriptor = serverCallContext.DescriptorInfo.BodyFieldDescriptor;
 
-            // Null field name indicates "*" which means the entire message is bound to the body.
-            if (bodyFieldName == null)
+            // Null field descriptor indicates "*" which means the entire message is bound to the body.
+            if (bodyFieldDescriptor?.Name is null)
             {
                 return false;
             }
 
-            // Exact match
-            if (variable == bodyFieldName)
+            var bodyFieldName = bodyFieldDescriptor.Name;
+            var bodyFieldJsonName = bodyFieldDescriptor.JsonName;
+
+            // Exact match (proto name or JSON name)
+            if (variable == bodyFieldName || variable == bodyFieldJsonName)
             {
                 return false;
             }
 
-            // Nested field of field name.
-            if (bodyFieldName.Length + 1 < variable.Length &&
-                variable.StartsWith(bodyFieldName, StringComparison.Ordinal) &&
-                variable[bodyFieldName.Length] == '.')
+            // Nested field of body field (proto name prefix or JSON name prefix).
+            if (IsNestedBodyField(variable, bodyFieldName) || IsNestedBodyField(variable, bodyFieldJsonName))
             {
                 return false;
             }
@@ -436,6 +444,20 @@ private static bool CanBindQueryStringVariable(JsonTranscodingServerCallContext
             return false;
         }
 
+        // Also check JSON name aliases. Route parameter keys use proto names (e.g. "user_id"),
+        // but query parameters can use JSON names (e.g. "userId") which resolve to the same field.
+        if (serverCallContext.DescriptorInfo.RouteParameterJsonPaths.Contains(variable))
+        {
+            return false;
+        }
+
         return true;
     }
+
+    private static bool IsNestedBodyField(string variable, string bodyFieldName)
+    {
+        return bodyFieldName.Length + 1 < variable.Length &&
+            variable.StartsWith(bodyFieldName, StringComparison.Ordinal) &&
+            variable[bodyFieldName.Length] == '.';
+    }
 }

src/Grpc/JsonTranscoding/test/Microsoft.AspNetCore.Grpc.JsonTranscoding.IntegrationTests/RouteTests.cs

@@ -105,6 +105,37 @@ Task<HelloReply> UnaryMethod(ComplextHelloRequest request, ServerCallContext con
         Assert.Equal("Hello complex_greeter/test2/b last_name!", result.RootElement.GetProperty("message").GetString());
     }
 
+    [Fact]
+    public async Task ComplexParameter_NestedJsonNameQueryString_DoesNotOverwriteRouteValue()
+    {
+        // Arrange
+        Task<HelloReply> UnaryMethod(ComplextHelloRequest request, ServerCallContext context)
+        {
+            return Task.FromResult(new HelloReply { Message = $"Hello {request.Name.FirstName} {request.Name.LastName}!" });
+        }
+        var method = Fixture.DynamicGrpc.AddUnaryMethod<ComplextHelloRequest, HelloReply>(
+            UnaryMethod,
+            Greeter.Descriptor.FindMethodByName("SayHelloComplexCatchAll3"));
+
+        var client = new HttpClient(Fixture.Handler) { BaseAddress = new Uri("http://localhost") };
+
+        // route.binding sets
+        // request.Name.LastName = "last_name";
+        // request.Name.FirstName = "complex_greeter/test2/b"
+        // ----
+        // query binding tries to overwrite with
+        // name.firstName=query_first
+        // name.lastName=query_last
+
+        // Act
+        var response = await client.GetAsync("/v1/last_name/complex_greeter/test2/b/c/d/two?name.firstName=query_first&name.lastName=query_last").DefaultTimeout();
+        var responseStream = await response.Content.ReadAsStreamAsync();
+        using var result = await JsonDocument.ParseAsync(responseStream);
+
+        // Assert
+        Assert.Equal("Hello complex_greeter/test2/b last_name!", result.RootElement.GetProperty("message").GetString());
+    }
+
     [Fact]
     public async Task SimpleCatchAllParameter_PrefixSuffixSlashes_MatchUrl_SuccessResult()
     {

src/Grpc/JsonTranscoding/test/Microsoft.AspNetCore.Grpc.JsonTranscoding.Tests/Proto/transcoding.proto

@@ -218,6 +218,7 @@ message HelloRequest {
   string hiding_field_name = 24 [json_name="field_name"];
   repeated SubMessage repeated_messages = 25;
   map<int32, int32> map_keyint_valueint = 26;
+  SubMessage sub_data = 27;
 }
 
 message HelloReply {