forked from quarkusio/quarkus
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
issue-42851: port resteasy fix for sub-resources from resteasy/restea…
…sy-microprofile PR quarkusio#241
- Loading branch information
1 parent
092aaf0
commit 6d505cd
Showing
3 changed files
with
269 additions
and
17 deletions.
There are no files selected for viewing
172 changes: 172 additions & 0 deletions
172
...easy-client/deployment/src/test/java/io/quarkus/restclient/exception/SubResourceTest.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,172 @@ | ||
| package io.quarkus.restclient.exception; | ||
|
|
||
| import static org.junit.jupiter.api.Assertions.assertEquals; | ||
| import static org.junit.jupiter.api.Assertions.fail; | ||
|
|
||
| import jakarta.inject.Inject; | ||
| import jakarta.ws.rs.GET; | ||
| import jakarta.ws.rs.HeaderParam; | ||
| import jakarta.ws.rs.Path; | ||
| import jakarta.ws.rs.Produces; | ||
| import jakarta.ws.rs.core.MediaType; | ||
| import jakarta.ws.rs.core.Response; | ||
| import jakarta.ws.rs.ext.Provider; | ||
|
|
||
| import org.eclipse.microprofile.rest.client.annotation.ClientHeaderParam; | ||
| import org.eclipse.microprofile.rest.client.annotation.RegisterProvider; | ||
| import org.eclipse.microprofile.rest.client.ext.ResponseExceptionMapper; | ||
| import org.eclipse.microprofile.rest.client.inject.RegisterRestClient; | ||
| import org.eclipse.microprofile.rest.client.inject.RestClient; | ||
| import org.jboss.shrinkwrap.api.asset.StringAsset; | ||
| import org.junit.jupiter.api.Test; | ||
| import org.junit.jupiter.api.extension.RegisterExtension; | ||
|
|
||
| import io.quarkus.arc.Unremovable; | ||
| import io.quarkus.test.QuarkusUnitTest; | ||
|
|
||
| /** | ||
| * Tests client sub-resources | ||
| * | ||
| * @author <a href="mailto:[email protected]">James R. Perkins</a> | ||
| */ | ||
| public class SubResourceTest { | ||
|
|
||
| @RegisterExtension | ||
| static final QuarkusUnitTest config = new QuarkusUnitTest() | ||
| .withApplicationRoot((jar) -> jar | ||
| .addClasses(SubResourceTest.class, ClientRootResource.class, ClientSubResource.class, | ||
| ServerResource.class, TestExceptionMapper.class, TestException.class) | ||
| .addAsResource(new StringAsset(ClientRootResource.class.getName() + "/mp-rest/url=${test.url}\n"), | ||
| "application.properties")); | ||
|
|
||
| @Inject | ||
| @RestClient | ||
| ClientRootResource clientRootResource; | ||
|
|
||
| /** | ||
| * Creates a REST client with an attached exception mapper. The exception mapper will throw a {@link TestException}. | ||
| * This test invokes a call to the root resource. | ||
| * | ||
| */ | ||
| @Test | ||
| public void rootResourceExceptionMapper() { | ||
| try (final Response ignored = clientRootResource.fromRoot()) { | ||
| fail("fromRoot() should have thrown a TestException"); | ||
| } catch (TestException expected) { | ||
| assertEquals("RootResource failed on purpose", expected.getMessage()); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * Creates a REST client with an attached exception mapper. The exception mapper will throw a {@link TestException}. | ||
| * This test invokes a call to the sub-resource. The sub-resource then invokes an additional call which should also | ||
| * result in a {@link TestException} thrown. | ||
| * | ||
| * @throws Exception if a test error occurs | ||
| */ | ||
| @Test | ||
| public void subResourceExceptionMapper() throws Exception { | ||
| try (final Response ignored = clientRootResource.subResource().fromSub()) { | ||
| fail("fromSub() should have thrown a TestException"); | ||
| } catch (TestException expected) { | ||
| assertEquals("SubResource failed on purpose", expected.getMessage()); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * This test invokes a call to the sub-resource. The sub-resource then invokes an additional call which should | ||
| * return the header value for {@code test-header}. | ||
| * | ||
| */ | ||
| @Test | ||
| public void subResourceWithHeader() { | ||
| try (final Response response = clientRootResource.subResource().withHeader()) { | ||
| assertEquals(Response.Status.OK, response.getStatusInfo()); | ||
| assertEquals("SubResourceHeader", response.readEntity(String.class)); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * This test invokes a call to the sub-resource. The sub-resource then invokes an additional call which should | ||
| * return the header value for {@code test-global-header}. | ||
| * | ||
| * @throws Exception if a test error occurs | ||
| */ | ||
| @Test | ||
| public void subResourceWithGlobalHeader() throws Exception { | ||
| try (final Response response = clientRootResource.subResource().withGlobalHeader()) { | ||
| assertEquals(Response.Status.OK, response.getStatusInfo()); | ||
| assertEquals("GlobalSubResourceHeader", response.readEntity(String.class)); | ||
| } | ||
| } | ||
|
|
||
| @RegisterRestClient | ||
| @RegisterProvider(TestExceptionMapper.class) | ||
| @Path("/root") | ||
| public interface ClientRootResource { | ||
| @Path("/sub") | ||
| ClientSubResource subResource(); | ||
|
|
||
| @GET | ||
| Response fromRoot() throws TestException; | ||
| } | ||
|
|
||
| @ClientHeaderParam(name = "test-global-header", value = "GlobalSubResourceHeader") | ||
| @Produces(MediaType.TEXT_PLAIN) | ||
| public interface ClientSubResource { | ||
| @GET | ||
| Response fromSub() throws TestException; | ||
|
|
||
| @GET | ||
| @ClientHeaderParam(name = "test-header", value = "SubResourceHeader") | ||
| @Path("/header") | ||
| Response withHeader(); | ||
|
|
||
| @GET | ||
| @Path("/global/header") | ||
| Response withGlobalHeader(); | ||
| } | ||
|
|
||
| @Path("/root") | ||
| public static class ServerResource { | ||
| @GET | ||
| public Response fromRoot() { | ||
| return Response.serverError().entity("RootResource failed on purpose").build(); | ||
| } | ||
|
|
||
| @GET | ||
| @Path("/sub") | ||
| public Response fromSub() { | ||
| return Response.serverError().entity("SubResource failed on purpose").build(); | ||
| } | ||
|
|
||
| @GET | ||
| @Path("/sub/header") | ||
| @Produces(MediaType.TEXT_PLAIN) | ||
| public Response subHeader(@HeaderParam("test-header") final String value) { | ||
| return Response.ok(value).build(); | ||
| } | ||
|
|
||
| @GET | ||
| @Path("/sub/global/header") | ||
| @Produces(MediaType.TEXT_PLAIN) | ||
| public Response subGlobalHeader(@HeaderParam("test-global-header") final String value) { | ||
| return Response.ok(value).build(); | ||
| } | ||
| } | ||
|
|
||
| @Provider | ||
| @Unremovable | ||
| public static class TestExceptionMapper implements ResponseExceptionMapper<TestException> { | ||
| @Override | ||
| public TestException toThrowable(final Response response) { | ||
| return new TestException(response.readEntity(String.class)); | ||
| } | ||
| } | ||
|
|
||
| public static class TestException extends RuntimeException { | ||
| public TestException(final String msg) { | ||
| super(msg); | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters