Properly implement priority of ContainerResponseFilter

Closes: #44229
quarkusio · Oct 31, 2024 · 295a37d · 295a37d
1 parent 0411238
commit 295a37d
Show file tree

Hide file tree

Showing 2 changed files with 124 additions and 7 deletions.
diff --git a/...n/runtime/src/main/java/org/jboss/resteasy/reactive/common/model/ResourceInterceptor.java b/...n/runtime/src/main/java/org/jboss/resteasy/reactive/common/model/ResourceInterceptor.java
@@ -95,7 +95,6 @@ public void setRuntimeType(RuntimeType runtimeType) {
         this.runtimeType = runtimeType;
     }
 
-    // spec says that writer interceptors are sorted in ascending order
     @Override
     public int compareTo(ResourceInterceptor<T> o) {
         return this.priority().compareTo(o.priority());
@@ -105,12 +104,8 @@ public int compareTo(ResourceInterceptor<T> o) {
     public static class Reversed<T> extends ResourceInterceptor<T> {
 
         @Override
-        public Integer priority() {
-            Integer p = super.priority();
-            if (p == null) {
-                return null;
-            }
-            return -p;
+        public int compareTo(ResourceInterceptor<T> o) {
+            return o.priority().compareTo(this.priority());
         }
     }
 }
diff --git a/...resteasy/reactive/server/vertx/test/simple/MultipleResponseFiltersWithPrioritiesTest.java b/...resteasy/reactive/server/vertx/test/simple/MultipleResponseFiltersWithPrioritiesTest.java
@@ -0,0 +1,122 @@
+package org.jboss.resteasy.reactive.server.vertx.test.simple;
+
+import static io.restassured.RestAssured.*;
+import static io.restassured.RestAssured.when;
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.hamcrest.Matchers.is;
+
+import java.io.IOException;
+
+import jakarta.annotation.Priority;
+import jakarta.ws.rs.GET;
+import jakarta.ws.rs.Path;
+import jakarta.ws.rs.container.ContainerRequestContext;
+import jakarta.ws.rs.container.ContainerResponseContext;
+import jakarta.ws.rs.container.ContainerResponseFilter;
+import jakarta.ws.rs.ext.Provider;
+
+import org.jboss.resteasy.reactive.server.vertx.test.CookiesSetInFilterTest;
+import org.jboss.resteasy.reactive.server.vertx.test.framework.ResteasyReactiveUnitTest;
+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 io.restassured.http.Headers;
+
+public class MultipleResponseFiltersWithPrioritiesTest {
+
+    @RegisterExtension
+    static ResteasyReactiveUnitTest test = new ResteasyReactiveUnitTest()
+            .setArchiveProducer(() -> ShrinkWrap.create(JavaArchive.class)
+                    .addClasses(CookiesSetInFilterTest.TestResource.class, CookiesSetInFilterTest.Filters.class));
+
+    @Test
+    void requestDoesNotContainCookie() {
+        when().get("/test")
+                .then()
+                .statusCode(200)
+                .body(is("foo"));
+    }
+
+    @Test
+    void test() {
+        Headers headers = get("/hello")
+                .then()
+                .statusCode(200)
+                .extract().headers();
+        assertThat(headers.getValues("filter-response")).containsOnly("max-default-0-minPlus1-min");
+    }
+
+    @Path("hello")
+    public static class TestResource {
+
+        @GET
+        public String get() {
+            return "hello";
+        }
+    }
+
+    @Provider
+    @Priority(Integer.MAX_VALUE)
+    public static class FilterMax implements ContainerResponseFilter {
+
+        @Override
+        public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext)
+                throws IOException {
+            responseContext.getHeaders().putSingle("filter-response", "max");
+        }
+
+    }
+
+    @Provider
+    public static class FilterDefault implements ContainerResponseFilter {
+
+        @Override
+        public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext)
+                throws IOException {
+            String previousFilterHeaderValue = (String) responseContext.getHeaders().getFirst("filter-response");
+            responseContext.getHeaders().putSingle("filter-response", previousFilterHeaderValue + "-default");
+        }
+
+    }
+
+    @Provider
+    @Priority(0)
+    public static class Filter0 implements ContainerResponseFilter {
+
+        @Override
+        public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext)
+                throws IOException {
+            String previousFilterHeaderValue = (String) responseContext.getHeaders().getFirst("filter-response");
+            responseContext.getHeaders().putSingle("filter-response", previousFilterHeaderValue + "-0");
+        }
+
+    }
+
+    @Provider
+    @Priority(Integer.MIN_VALUE + 1)
+    public static class FilterMinPlus1 implements ContainerResponseFilter {
+
+        @Override
+        public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext)
+                throws IOException {
+            String previousFilterHeaderValue = (String) responseContext.getHeaders().getFirst("filter-response");
+            responseContext.getHeaders().putSingle("filter-response", previousFilterHeaderValue + "-minPlus1");
+        }
+
+    }
+
+    @Provider
+    @Priority(Integer.MIN_VALUE)
+    public static class FilterMin implements ContainerResponseFilter {
+
+        @Override
+        public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext)
+                throws IOException {
+            String previousFilterHeaderValue = (String) responseContext.getHeaders().getFirst("filter-response");
+            responseContext.getHeaders().putSingle("filter-response", previousFilterHeaderValue + "-min");
+        }
+
+    }
+}