From e99b3e038ada4cce80935b26ff8fbb029ff0424f Mon Sep 17 00:00:00 2001 From: Clemens Angermann Date: Tue, 17 Mar 2020 09:59:36 +0100 Subject: [PATCH] Adding Response Interceptor (#5500) * added Response interceptor for native clients * added Response interceptor for native clients --- .../Java/libraries/native/ApiClient.mustache | 29 +++++++++++- .../Java/libraries/native/api.mustache | 7 ++- .../org/openapitools/client/ApiClient.java | 29 +++++++++++- .../client/api/AnotherFakeApi.java | 7 ++- .../org/openapitools/client/api/FakeApi.java | 46 ++++++++++++++++++- .../client/api/FakeClassnameTags123Api.java | 7 ++- .../org/openapitools/client/api/PetApi.java | 31 ++++++++++++- .../org/openapitools/client/api/StoreApi.java | 16 ++++++- .../org/openapitools/client/api/UserApi.java | 28 ++++++++++- 9 files changed, 191 insertions(+), 9 deletions(-) diff --git a/modules/openapi-generator/src/main/resources/Java/libraries/native/ApiClient.mustache b/modules/openapi-generator/src/main/resources/Java/libraries/native/ApiClient.mustache index 6bcad4a2f3f..fb83d919b93 100644 --- a/modules/openapi-generator/src/main/resources/Java/libraries/native/ApiClient.mustache +++ b/modules/openapi-generator/src/main/resources/Java/libraries/native/ApiClient.mustache @@ -8,10 +8,12 @@ import com.fasterxml.jackson.databind.SerializationFeature; import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule; import org.openapitools.jackson.nullable.JsonNullableModule; +import java.io.InputStream; import java.net.URI; import java.net.URLEncoder; import java.net.http.HttpClient; import java.net.http.HttpRequest; +import java.net.http.HttpResponse; import java.nio.charset.Charset; import java.time.Duration; import java.util.Collection; @@ -46,6 +48,7 @@ public class ApiClient { private int port; private String basePath; private Consumer interceptor; + private Consumer> responseInterceptor; private Duration readTimeout; private static String valueToString(Object value) { @@ -161,6 +164,7 @@ public class ApiClient { basePath = baseURI.getRawPath(); interceptor = null; readTimeout = null; + responseInterceptor = null; } /** @@ -292,6 +296,29 @@ public class ApiClient { return interceptor; } + /** + * Set a custom response interceptor. + * + *

This is useful for logging, monitoring or extraction of header variables

+ * + * @param interceptor A function invoked before creating each request. A value + * of null resets the interceptor to a no-op. + * @return This object. + */ + public ApiClient setResponseInterceptor(Consumer> interceptor) { + this.responseInterceptor = interceptor; + return this; + } + + /** + * Get the custom response interceptor. + * + * @return The custom interceptor that was set, or null if there isn't any. + */ + public Consumer> getResponseInterceptor() { + return responseInterceptor; + } + /** * Set the read timeout for the http client. * @@ -307,7 +334,7 @@ public class ApiClient { this.readTimeout = readTimeout; return this; } - + /** * Get the read timeout that was set. * diff --git a/modules/openapi-generator/src/main/resources/Java/libraries/native/api.mustache b/modules/openapi-generator/src/main/resources/Java/libraries/native/api.mustache index 8c545a015f4..4c4848ca480 100644 --- a/modules/openapi-generator/src/main/resources/Java/libraries/native/api.mustache +++ b/modules/openapi-generator/src/main/resources/Java/libraries/native/api.mustache @@ -36,7 +36,8 @@ public class {{classname}} { private final String memberVarBaseUri; private final Consumer memberVarInterceptor; private final Duration memberVarReadTimeout; - + private final Consumer> memberVarResponseInterceptor; + public {{classname}}() { this(new ApiClient()); } @@ -47,6 +48,7 @@ public class {{classname}} { memberVarBaseUri = apiClient.getBaseUri(); memberVarInterceptor = apiClient.getRequestInterceptor(); memberVarReadTimeout = apiClient.getReadTimeout(); + memberVarResponseInterceptor = apiClient.getResponseInterceptor(); } {{#operation}} @@ -138,6 +140,9 @@ public class {{classname}} { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "{{operationId}} call received non-success response", diff --git a/samples/client/petstore/java/native/src/main/java/org/openapitools/client/ApiClient.java b/samples/client/petstore/java/native/src/main/java/org/openapitools/client/ApiClient.java index 8652fda47bf..b805d0f4b42 100644 --- a/samples/client/petstore/java/native/src/main/java/org/openapitools/client/ApiClient.java +++ b/samples/client/petstore/java/native/src/main/java/org/openapitools/client/ApiClient.java @@ -19,10 +19,12 @@ import com.fasterxml.jackson.databind.SerializationFeature; import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule; import org.openapitools.jackson.nullable.JsonNullableModule; +import java.io.InputStream; import java.net.URI; import java.net.URLEncoder; import java.net.http.HttpClient; import java.net.http.HttpRequest; +import java.net.http.HttpResponse; import java.nio.charset.Charset; import java.time.Duration; import java.util.Collection; @@ -57,6 +59,7 @@ public class ApiClient { private int port; private String basePath; private Consumer interceptor; + private Consumer> responseInterceptor; private Duration readTimeout; private static String valueToString(Object value) { @@ -172,6 +175,7 @@ public class ApiClient { basePath = baseURI.getRawPath(); interceptor = null; readTimeout = null; + responseInterceptor = null; } /** @@ -303,6 +307,29 @@ public class ApiClient { return interceptor; } + /** + * Set a custom response interceptor. + * + *

This is useful for logging, monitoring or extraction of header variables

+ * + * @param interceptor A function invoked before creating each request. A value + * of null resets the interceptor to a no-op. + * @return This object. + */ + public ApiClient setResponseInterceptor(Consumer> interceptor) { + this.responseInterceptor = interceptor; + return this; + } + + /** + * Get the custom response interceptor. + * + * @return The custom interceptor that was set, or null if there isn't any. + */ + public Consumer> getResponseInterceptor() { + return responseInterceptor; + } + /** * Set the read timeout for the http client. * @@ -318,7 +345,7 @@ public class ApiClient { this.readTimeout = readTimeout; return this; } - + /** * Get the read timeout that was set. * diff --git a/samples/client/petstore/java/native/src/main/java/org/openapitools/client/api/AnotherFakeApi.java b/samples/client/petstore/java/native/src/main/java/org/openapitools/client/api/AnotherFakeApi.java index c0e18967283..e8d4ec925e6 100644 --- a/samples/client/petstore/java/native/src/main/java/org/openapitools/client/api/AnotherFakeApi.java +++ b/samples/client/petstore/java/native/src/main/java/org/openapitools/client/api/AnotherFakeApi.java @@ -42,7 +42,8 @@ public class AnotherFakeApi { private final String memberVarBaseUri; private final Consumer memberVarInterceptor; private final Duration memberVarReadTimeout; - + private final Consumer> memberVarResponseInterceptor; + public AnotherFakeApi() { this(new ApiClient()); } @@ -53,6 +54,7 @@ public class AnotherFakeApi { memberVarBaseUri = apiClient.getBaseUri(); memberVarInterceptor = apiClient.getRequestInterceptor(); memberVarReadTimeout = apiClient.getReadTimeout(); + memberVarResponseInterceptor = apiClient.getResponseInterceptor(); } /** @@ -90,6 +92,9 @@ public class AnotherFakeApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "call123testSpecialTags call received non-success response", diff --git a/samples/client/petstore/java/native/src/main/java/org/openapitools/client/api/FakeApi.java b/samples/client/petstore/java/native/src/main/java/org/openapitools/client/api/FakeApi.java index e6e5956125b..3e301bd1dfb 100644 --- a/samples/client/petstore/java/native/src/main/java/org/openapitools/client/api/FakeApi.java +++ b/samples/client/petstore/java/native/src/main/java/org/openapitools/client/api/FakeApi.java @@ -50,7 +50,8 @@ public class FakeApi { private final String memberVarBaseUri; private final Consumer memberVarInterceptor; private final Duration memberVarReadTimeout; - + private final Consumer> memberVarResponseInterceptor; + public FakeApi() { this(new ApiClient()); } @@ -61,6 +62,7 @@ public class FakeApi { memberVarBaseUri = apiClient.getBaseUri(); memberVarInterceptor = apiClient.getRequestInterceptor(); memberVarReadTimeout = apiClient.getReadTimeout(); + memberVarResponseInterceptor = apiClient.getResponseInterceptor(); } /** @@ -97,6 +99,9 @@ public class FakeApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "createXmlItem call received non-success response", @@ -142,6 +147,9 @@ public class FakeApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "fakeOuterBooleanSerialize call received non-success response", @@ -188,6 +196,9 @@ public class FakeApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "fakeOuterCompositeSerialize call received non-success response", @@ -234,6 +245,9 @@ public class FakeApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "fakeOuterNumberSerialize call received non-success response", @@ -280,6 +294,9 @@ public class FakeApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "fakeOuterStringSerialize call received non-success response", @@ -329,6 +346,9 @@ public class FakeApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "testBodyWithFileSchema call received non-success response", @@ -391,6 +411,9 @@ public class FakeApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "testBodyWithQueryParams call received non-success response", @@ -440,6 +463,9 @@ public class FakeApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "testClientModel call received non-success response", @@ -512,6 +538,9 @@ public class FakeApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "testEndpointParameters call received non-success response", @@ -579,6 +608,9 @@ public class FakeApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "testEnumParameters call received non-success response", @@ -656,6 +688,9 @@ public class FakeApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "testGroupParameters call received non-success response", @@ -704,6 +739,9 @@ public class FakeApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "testInlineAdditionalProperties call received non-success response", @@ -755,6 +793,9 @@ public class FakeApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "testJsonFormData call received non-success response", @@ -834,6 +875,9 @@ public class FakeApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "testQueryParameterCollectionFormat call received non-success response", diff --git a/samples/client/petstore/java/native/src/main/java/org/openapitools/client/api/FakeClassnameTags123Api.java b/samples/client/petstore/java/native/src/main/java/org/openapitools/client/api/FakeClassnameTags123Api.java index 3132d2bcd1e..f687eb0a079 100644 --- a/samples/client/petstore/java/native/src/main/java/org/openapitools/client/api/FakeClassnameTags123Api.java +++ b/samples/client/petstore/java/native/src/main/java/org/openapitools/client/api/FakeClassnameTags123Api.java @@ -42,7 +42,8 @@ public class FakeClassnameTags123Api { private final String memberVarBaseUri; private final Consumer memberVarInterceptor; private final Duration memberVarReadTimeout; - + private final Consumer> memberVarResponseInterceptor; + public FakeClassnameTags123Api() { this(new ApiClient()); } @@ -53,6 +54,7 @@ public class FakeClassnameTags123Api { memberVarBaseUri = apiClient.getBaseUri(); memberVarInterceptor = apiClient.getRequestInterceptor(); memberVarReadTimeout = apiClient.getReadTimeout(); + memberVarResponseInterceptor = apiClient.getResponseInterceptor(); } /** @@ -90,6 +92,9 @@ public class FakeClassnameTags123Api { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "testClassname call received non-success response", diff --git a/samples/client/petstore/java/native/src/main/java/org/openapitools/client/api/PetApi.java b/samples/client/petstore/java/native/src/main/java/org/openapitools/client/api/PetApi.java index 06629c1bf04..678c96814b5 100644 --- a/samples/client/petstore/java/native/src/main/java/org/openapitools/client/api/PetApi.java +++ b/samples/client/petstore/java/native/src/main/java/org/openapitools/client/api/PetApi.java @@ -44,7 +44,8 @@ public class PetApi { private final String memberVarBaseUri; private final Consumer memberVarInterceptor; private final Duration memberVarReadTimeout; - + private final Consumer> memberVarResponseInterceptor; + public PetApi() { this(new ApiClient()); } @@ -55,6 +56,7 @@ public class PetApi { memberVarBaseUri = apiClient.getBaseUri(); memberVarInterceptor = apiClient.getRequestInterceptor(); memberVarReadTimeout = apiClient.getReadTimeout(); + memberVarResponseInterceptor = apiClient.getResponseInterceptor(); } /** @@ -91,6 +93,9 @@ public class PetApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "addPet call received non-success response", @@ -142,6 +147,9 @@ public class PetApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "deletePet call received non-success response", @@ -198,6 +206,9 @@ public class PetApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "findPetsByStatus call received non-success response", @@ -257,6 +268,9 @@ public class PetApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "findPetsByTags call received non-success response", @@ -306,6 +320,9 @@ public class PetApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "getPetById call received non-success response", @@ -355,6 +372,9 @@ public class PetApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "updatePet call received non-success response", @@ -404,6 +424,9 @@ public class PetApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "updatePetWithForm call received non-success response", @@ -454,6 +477,9 @@ public class PetApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "uploadFile call received non-success response", @@ -509,6 +535,9 @@ public class PetApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "uploadFileWithRequiredFile call received non-success response", diff --git a/samples/client/petstore/java/native/src/main/java/org/openapitools/client/api/StoreApi.java b/samples/client/petstore/java/native/src/main/java/org/openapitools/client/api/StoreApi.java index 0e761f29175..44de279bcce 100644 --- a/samples/client/petstore/java/native/src/main/java/org/openapitools/client/api/StoreApi.java +++ b/samples/client/petstore/java/native/src/main/java/org/openapitools/client/api/StoreApi.java @@ -42,7 +42,8 @@ public class StoreApi { private final String memberVarBaseUri; private final Consumer memberVarInterceptor; private final Duration memberVarReadTimeout; - + private final Consumer> memberVarResponseInterceptor; + public StoreApi() { this(new ApiClient()); } @@ -53,6 +54,7 @@ public class StoreApi { memberVarBaseUri = apiClient.getBaseUri(); memberVarInterceptor = apiClient.getRequestInterceptor(); memberVarReadTimeout = apiClient.getReadTimeout(); + memberVarResponseInterceptor = apiClient.getResponseInterceptor(); } /** @@ -88,6 +90,9 @@ public class StoreApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "deleteOrder call received non-success response", @@ -130,6 +135,9 @@ public class StoreApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "getInventory call received non-success response", @@ -179,6 +187,9 @@ public class StoreApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "getOrderById call received non-success response", @@ -229,6 +240,9 @@ public class StoreApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "placeOrder call received non-success response", diff --git a/samples/client/petstore/java/native/src/main/java/org/openapitools/client/api/UserApi.java b/samples/client/petstore/java/native/src/main/java/org/openapitools/client/api/UserApi.java index 8424e4b03a6..e5e75b71987 100644 --- a/samples/client/petstore/java/native/src/main/java/org/openapitools/client/api/UserApi.java +++ b/samples/client/petstore/java/native/src/main/java/org/openapitools/client/api/UserApi.java @@ -42,7 +42,8 @@ public class UserApi { private final String memberVarBaseUri; private final Consumer memberVarInterceptor; private final Duration memberVarReadTimeout; - + private final Consumer> memberVarResponseInterceptor; + public UserApi() { this(new ApiClient()); } @@ -53,6 +54,7 @@ public class UserApi { memberVarBaseUri = apiClient.getBaseUri(); memberVarInterceptor = apiClient.getRequestInterceptor(); memberVarReadTimeout = apiClient.getReadTimeout(); + memberVarResponseInterceptor = apiClient.getResponseInterceptor(); } /** @@ -89,6 +91,9 @@ public class UserApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "createUser call received non-success response", @@ -137,6 +142,9 @@ public class UserApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "createUsersWithArrayInput call received non-success response", @@ -185,6 +193,9 @@ public class UserApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "createUsersWithListInput call received non-success response", @@ -232,6 +243,9 @@ public class UserApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "deleteUser call received non-success response", @@ -280,6 +294,9 @@ public class UserApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "getUserByName call received non-success response", @@ -343,6 +360,9 @@ public class UserApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "loginUser call received non-success response", @@ -385,6 +405,9 @@ public class UserApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "logoutUser call received non-success response", @@ -439,6 +462,9 @@ public class UserApi { HttpResponse localVarResponse = memberVarHttpClient.send( localVarRequestBuilder.build(), HttpResponse.BodyHandlers.ofInputStream()); + if (memberVarResponseInterceptor != null) { + memberVarResponseInterceptor.accept(localVarResponse); + } if (localVarResponse.statusCode()/ 100 != 2) { throw new ApiException(localVarResponse.statusCode(), "updateUser call received non-success response",