Introduce "quarkus.rest.exception-mapping.disable-mapper-for"

Relates to #36155

Author: geoand

extensions/resteasy-reactive/rest-common/runtime/src/main/java/io/quarkus/resteasy/reactive/common/runtime/ResteasyReactiveConfig.java

@@ -1,5 +1,8 @@
 package io.quarkus.resteasy.reactive.common.runtime;
 
+import java.util.List;
+import java.util.Optional;
+
 import io.quarkus.runtime.annotations.ConfigPhase;
 import io.quarkus.runtime.annotations.ConfigRoot;
 import io.quarkus.runtime.configuration.MemorySize;
@@ -11,6 +14,11 @@
 @ConfigRoot(phase = ConfigPhase.BUILD_AND_RUN_TIME_FIXED)
 public interface ResteasyReactiveConfig {
 
+    /**
+     * Exception mapping configuration.
+     */
+    ExceptionMappingConfig exceptionMapping();
+
     /**
      * The amount of memory that can be used to buffer input before switching to
      * blocking IO, up to {@code Long.MAX_VALUE} bytes.
@@ -81,4 +89,18 @@ public interface ResteasyReactiveConfig {
      */
     @WithDefault("true")
     boolean removesTrailingSlash();
+
+    /**
+     * Configuration for exception mapping.
+     */
+    interface ExceptionMappingConfig {
+        /**
+         * A list of exception mapper classes that should be disabled.
+         * This allows users to override the default built-in exception mappers provided by Quarkus extensions.
+         * <p>
+         * For example, to disable the built-in Jackson MismatchedInputException mapper:
+         * {@code quarkus.rest.exception-mapping.disable-mapper-for=io.quarkus.resteasy.reactive.jackson.runtime.mappers.BuiltinMismatchedInputExceptionMapper}
+         */
+        Optional<List<String>> disableMapperFor();
+    }
 }

extensions/resteasy-reactive/rest-jackson/deployment/src/test/java/io/quarkus/resteasy/reactive/jackson/deployment/test/ExceptionInReaderWithDisabledBuiltInMapperTest.java

@@ -0,0 +1,55 @@
+package io.quarkus.resteasy.reactive.jackson.deployment.test;
+
+import java.util.function.Supplier;
+
+import jakarta.ws.rs.core.Response;
+import jakarta.ws.rs.ext.ExceptionMapper;
+import jakarta.ws.rs.ext.Provider;
+
+import org.jboss.shrinkwrap.api.ShrinkWrap;
+import org.jboss.shrinkwrap.api.spec.JavaArchive;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.RegisterExtension;
+
+import com.fasterxml.jackson.databind.JsonMappingException;
+
+import io.quarkus.test.QuarkusUnitTest;
+import io.restassured.RestAssured;
+
+/**
+ * Tests that disabling BuiltinMismatchedInputExceptionMapper allows a custom mapper
+ * for JsonMappingException (superclass of MismatchedInputException) to handle the exception.
+ * Without the disable-mapper-for config, the built-in mapper would take precedence.
+ */
+public class ExceptionInReaderWithDisabledBuiltInMapperTest {
+
+    @RegisterExtension
+    static QuarkusUnitTest test = new QuarkusUnitTest()
+            .setArchiveProducer(new Supplier<>() {
+                @Override
+                public JavaArchive get() {
+                    return ShrinkWrap.create(JavaArchive.class)
+                            .addClasses(FroMage.class, FroMageEndpoint.class, CustomJsonMappingExceptionMapper.class);
+                }
+            }).overrideConfigKey("quarkus.rest.exception-mapping.disable-mapper-for",
+                    "io.quarkus.resteasy.reactive.jackson.runtime.mappers.BuiltinMismatchedInputExceptionMapper");
+
+    @Test
+    public void test() {
+        // Send invalid JSON that triggers MismatchedInputException (price should be Integer, not String)
+        // With BuiltinMismatchedInputExceptionMapper disabled, our custom JsonMappingException mapper
+        // (which handles the superclass) should catch it and return 888.
+        // Without the config, the built-in mapper would return 400.
+        RestAssured.with().contentType("application/json").body("{\"price\": \"ten\"}").put("/fromage")
+                .then().statusCode(888); // Custom mapper returns 888
+    }
+
+    @Provider
+    public static class CustomJsonMappingExceptionMapper implements ExceptionMapper<JsonMappingException> {
+
+        @Override
+        public Response toResponse(JsonMappingException exception) {
+            return Response.status(888).entity("Custom mapper handled: " + exception.getMessage()).build();
+        }
+    }
+}

extensions/resteasy-reactive/rest/deployment/src/main/java/io/quarkus/resteasy/reactive/server/deployment/ResteasyReactiveScanningProcessor.java

@@ -65,6 +65,7 @@
 import io.quarkus.resteasy.reactive.common.deployment.ApplicationResultBuildItem;
 import io.quarkus.resteasy.reactive.common.deployment.ResourceInterceptorsContributorBuildItem;
 import io.quarkus.resteasy.reactive.common.deployment.ResourceScanningResultBuildItem;
+import io.quarkus.resteasy.reactive.common.runtime.ResteasyReactiveConfig;
 import io.quarkus.resteasy.reactive.server.spi.MethodScannerBuildItem;
 import io.quarkus.resteasy.reactive.server.spi.UnwrappedExceptionBuildItem;
 import io.quarkus.resteasy.reactive.spi.ContainerRequestFilterBuildItem;
@@ -189,11 +190,21 @@ public ExceptionMappersBuildItem scanForExceptionMappers(CombinedIndexBuildItem
             BuildProducer<AdditionalBeanBuildItem> additionalBeanBuildItemBuildProducer,
             BuildProducer<ReflectiveClassBuildItem> reflectiveClassBuildItemBuildProducer,
             List<ExceptionMapperBuildItem> mappers, List<UnwrappedExceptionBuildItem> unwrappedExceptions,
-            Capabilities capabilities) {
+            Capabilities capabilities,
+            ResteasyReactiveConfig config) {
         AdditionalBeanBuildItem.Builder beanBuilder = AdditionalBeanBuildItem.builder().setUnremovable();
         ExceptionMapping exceptions = ResteasyReactiveExceptionMappingScanner
                 .scanForExceptionMappers(combinedIndexBuildItem.getComputingIndex(), applicationResultBuildItem.getResult());
 
+        // Populate disabled mappers from configuration
+        if (config.exceptionMapping().disableMapperFor().isPresent()) {
+            for (String disabledMapper : config.exceptionMapping().disableMapperFor().get()) {
+                if (disabledMapper != null && !disabledMapper.isEmpty()) {
+                    exceptions.addDisabledMapper(disabledMapper);
+                }
+            }
+        }
+
         exceptions.addBlockingProblem(BlockingOperationNotAllowedException.class);
         exceptions.addBlockingProblem(BlockingNotAllowedException.class);
         for (UnwrappedExceptionBuildItem bi : unwrappedExceptions) {

independent-projects/resteasy-reactive/server/runtime/src/main/java/org/jboss/resteasy/reactive/server/core/ExceptionMapping.java

@@ -3,8 +3,10 @@
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.HashMap;
+import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
+import java.util.Set;
 import java.util.function.Function;
 import java.util.function.Predicate;
 import java.util.function.Supplier;
@@ -31,6 +33,11 @@ public class ExceptionMapping {
     // this is going to be used when there are mappers that are removable at runtime
     final Map<String, List<ResourceExceptionMapper<? extends Throwable>>> runtimeCheckMappers = new HashMap<>();
 
+    /**
+     * Exception mapper class names that should be disabled.
+     */
+    final Set<String> disabledMappers = new HashSet<>();
+
     /**
      * Exceptions that indicate an blocking operation was performed on an IO thread.
      * <p>
@@ -126,9 +133,17 @@ public Map<String, List<ResourceExceptionMapper<? extends Throwable>>> getRuntim
         return runtimeCheckMappers;
     }
 
+    public Set<String> getDisabledMappers() {
+        return disabledMappers;
+    }
+
+    public void addDisabledMapper(String mapperClassName) {
+        disabledMappers.add(mapperClassName);
+    }
+
     public Map<String, ResourceExceptionMapper<? extends Throwable>> effectiveMappers() {
         if (runtimeCheckMappers.isEmpty()) {
-            return mappers;
+            return filterDisabledMappers(mappers);
         }
         Map<String, ResourceExceptionMapper<? extends Throwable>> result = new HashMap<>();
         for (var entry : runtimeCheckMappers.entrySet()) {
@@ -147,6 +162,20 @@ public Map<String, ResourceExceptionMapper<? extends Throwable>> effectiveMapper
             }
         }
         result.putAll(mappers);
+        return filterDisabledMappers(result);
+    }
+
+    private Map<String, ResourceExceptionMapper<? extends Throwable>> filterDisabledMappers(
+            Map<String, ResourceExceptionMapper<? extends Throwable>> mappers) {
+        if (disabledMappers.isEmpty()) {
+            return mappers;
+        }
+        Map<String, ResourceExceptionMapper<? extends Throwable>> result = new HashMap<>();
+        for (Map.Entry<String, ResourceExceptionMapper<? extends Throwable>> entry : mappers.entrySet()) {
+            if (!disabledMappers.contains(entry.getValue().getClassName())) {
+                result.put(entry.getKey(), entry.getValue());
+            }
+        }
         return result;
     }