loafle/openapi-generator
3
0
Fork 0
forked from loafle/openapi-generator-original
Code Pull Requests Activity

java-native added WithHttpInfo (#6704)

Browse Source 
remove /t
This commit is contained in:
bgong-mdsol
2020-06-22 04:15:11 -04:00
committed by GitHub
parent 1d86d7e3ac
commit 8400d4c6f9
32 changed files with 6251 additions and 1949 deletions
Download Patch File Download Diff File Expand all files Collapse all files

66
samples/client/petstore/java/native-async/src/main/java/org/openapitools/client/api/AnotherFakeApi.java
View File

@@ -66,10 +66,38 @@ public class AnotherFakeApi {
* @return Client
* @throws ApiException if fails to make API call
*/
public CompletableFuture<Client> call123testSpecialTags (Client body) throws ApiException {
public CompletableFuture<Client> call123testSpecialTags(Client body) throws ApiException {
try {
HttpRequest.Builder localVarRequestBuilder = call123testSpecialTagsRequestBuilder(body);
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"call123testSpecialTags call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
try {
return CompletableFuture.completedFuture(
memberVarObjectMapper.readValue(localVarResponse.body(), new TypeReference<Client>() {})
);
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
}
}
});
}
catch (ApiException e) {
return CompletableFuture.failedFuture(e);
}
}
private HttpRequest.Builder call123testSpecialTagsRequestBuilder(Client body) throws ApiException {
// verify the required parameter 'body' is set
if (body == null) {
return CompletableFuture.failedFuture(new ApiException(400, "Missing the required parameter 'body' when calling call123testSpecialTags"));
throw new ApiException(400, "Missing the required parameter 'body' when calling call123testSpecialTags");
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
@@ -84,33 +112,15 @@ public class AnotherFakeApi {
try {
byte[] localVarPostBody = memberVarObjectMapper.writeValueAsBytes(body);
localVarRequestBuilder.method("PATCH", HttpRequest.BodyPublishers.ofByteArray(localVarPostBody));
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"call123testSpecialTags call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
try {
return CompletableFuture.completedFuture(
memberVarObjectMapper.readValue(localVarResponse.body(), new TypeReference<Client>() {})
);
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
}
}
});
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
throw new ApiException(e);
}
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return localVarRequestBuilder;
}
}

857
samples/client/petstore/java/native-async/src/main/java/org/openapitools/client/api/FakeApi.java
View File

File diff suppressed because it is too large Load Diff

66
samples/client/petstore/java/native-async/src/main/java/org/openapitools/client/api/FakeClassnameTags123Api.java
View File

@@ -66,10 +66,38 @@ public class FakeClassnameTags123Api {
* @return Client
* @throws ApiException if fails to make API call
*/
public CompletableFuture<Client> testClassname (Client body) throws ApiException {
public CompletableFuture<Client> testClassname(Client body) throws ApiException {
try {
HttpRequest.Builder localVarRequestBuilder = testClassnameRequestBuilder(body);
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"testClassname call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
try {
return CompletableFuture.completedFuture(
memberVarObjectMapper.readValue(localVarResponse.body(), new TypeReference<Client>() {})
);
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
}
}
});
}
catch (ApiException e) {
return CompletableFuture.failedFuture(e);
}
}
private HttpRequest.Builder testClassnameRequestBuilder(Client body) throws ApiException {
// verify the required parameter 'body' is set
if (body == null) {
return CompletableFuture.failedFuture(new ApiException(400, "Missing the required parameter 'body' when calling testClassname"));
throw new ApiException(400, "Missing the required parameter 'body' when calling testClassname");
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
@@ -84,33 +112,15 @@ public class FakeClassnameTags123Api {
try {
byte[] localVarPostBody = memberVarObjectMapper.writeValueAsBytes(body);
localVarRequestBuilder.method("PATCH", HttpRequest.BodyPublishers.ofByteArray(localVarPostBody));
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"testClassname call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
try {
return CompletableFuture.completedFuture(
memberVarObjectMapper.readValue(localVarResponse.body(), new TypeReference<Client>() {})
);
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
}
}
});
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
throw new ApiException(e);
}
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return localVarRequestBuilder;
}
}

552
samples/client/petstore/java/native-async/src/main/java/org/openapitools/client/api/PetApi.java
View File

@@ -68,10 +68,32 @@ public class PetApi {
* @param body Pet object that needs to be added to the store (required)
* @throws ApiException if fails to make API call
*/
public CompletableFuture<Void> addPet (Pet body) throws ApiException {
public CompletableFuture<Void> addPet(Pet body) throws ApiException {
try {
HttpRequest.Builder localVarRequestBuilder = addPetRequestBuilder(body);
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"addPet call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
return CompletableFuture.completedFuture(null);
}
});
}
catch (ApiException e) {
return CompletableFuture.failedFuture(e);
}
}
private HttpRequest.Builder addPetRequestBuilder(Pet body) throws ApiException {
// verify the required parameter 'body' is set
if (body == null) {
return CompletableFuture.failedFuture(new ApiException(400, "Missing the required parameter 'body' when calling addPet"));
throw new ApiException(400, "Missing the required parameter 'body' when calling addPet");
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
@@ -86,29 +108,16 @@ public class PetApi {
try {
byte[] localVarPostBody = memberVarObjectMapper.writeValueAsBytes(body);
localVarRequestBuilder.method("POST", HttpRequest.BodyPublishers.ofByteArray(localVarPostBody));
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"addPet call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
return CompletableFuture.completedFuture(null);
}
});
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
throw new ApiException(e);
}
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return localVarRequestBuilder;
}
/**
* Deletes a pet
@@ -117,10 +126,32 @@ public class PetApi {
* @param apiKey (optional)
* @throws ApiException if fails to make API call
*/
public CompletableFuture<Void> deletePet (Long petId, String apiKey) throws ApiException {
public CompletableFuture<Void> deletePet(Long petId, String apiKey) throws ApiException {
try {
HttpRequest.Builder localVarRequestBuilder = deletePetRequestBuilder(petId, apiKey);
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"deletePet call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
return CompletableFuture.completedFuture(null);
}
});
}
catch (ApiException e) {
return CompletableFuture.failedFuture(e);
}
}
private HttpRequest.Builder deletePetRequestBuilder(Long petId, String apiKey) throws ApiException {
// verify the required parameter 'petId' is set
if (petId == null) {
return CompletableFuture.failedFuture(new ApiException(400, "Missing the required parameter 'petId' when calling deletePet"));
throw new ApiException(400, "Missing the required parameter 'petId' when calling deletePet");
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
@@ -135,27 +166,14 @@ public class PetApi {
}
localVarRequestBuilder.header("Accept", "application/json");
localVarRequestBuilder.method("DELETE", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"deletePet call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
return CompletableFuture.completedFuture(null);
}
});
localVarRequestBuilder.method("DELETE", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return localVarRequestBuilder;
}
/**
* Finds Pets by status
@@ -164,10 +182,38 @@ public class PetApi {
* @return List&lt;Pet&gt;
* @throws ApiException if fails to make API call
*/
public CompletableFuture<List<Pet>> findPetsByStatus (List<String> status) throws ApiException {
public CompletableFuture<List<Pet>> findPetsByStatus(List<String> status) throws ApiException {
try {
HttpRequest.Builder localVarRequestBuilder = findPetsByStatusRequestBuilder(status);
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"findPetsByStatus call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
try {
return CompletableFuture.completedFuture(
memberVarObjectMapper.readValue(localVarResponse.body(), new TypeReference<List<Pet>>() {})
);
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
}
}
});
}
catch (ApiException e) {
return CompletableFuture.failedFuture(e);
}
}
private HttpRequest.Builder findPetsByStatusRequestBuilder(List<String> status) throws ApiException {
// verify the required parameter 'status' is set
if (status == null) {
return CompletableFuture.failedFuture(new ApiException(400, "Missing the required parameter 'status' when calling findPetsByStatus"));
throw new ApiException(400, "Missing the required parameter 'status' when calling findPetsByStatus");
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
@@ -187,32 +233,14 @@ public class PetApi {
localVarRequestBuilder.header("Accept", "application/json");
localVarRequestBuilder.method("GET", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"findPetsByStatus call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
try {
return CompletableFuture.completedFuture(
memberVarObjectMapper.readValue(localVarResponse.body(), new TypeReference<List<Pet>>() {})
);
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
}
}
});
localVarRequestBuilder.method("GET", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return localVarRequestBuilder;
}
/**
* Finds Pets by tags
@@ -223,10 +251,38 @@ public class PetApi {
* @deprecated
*/
@Deprecated
public CompletableFuture<Set<Pet>> findPetsByTags (Set<String> tags) throws ApiException {
public CompletableFuture<Set<Pet>> findPetsByTags(Set<String> tags) throws ApiException {
try {
HttpRequest.Builder localVarRequestBuilder = findPetsByTagsRequestBuilder(tags);
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"findPetsByTags call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
try {
return CompletableFuture.completedFuture(
memberVarObjectMapper.readValue(localVarResponse.body(), new TypeReference<Set<Pet>>() {})
);
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
}
}
});
}
catch (ApiException e) {
return CompletableFuture.failedFuture(e);
}
}
private HttpRequest.Builder findPetsByTagsRequestBuilder(Set<String> tags) throws ApiException {
// verify the required parameter 'tags' is set
if (tags == null) {
return CompletableFuture.failedFuture(new ApiException(400, "Missing the required parameter 'tags' when calling findPetsByTags"));
throw new ApiException(400, "Missing the required parameter 'tags' when calling findPetsByTags");
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
@@ -246,32 +302,14 @@ public class PetApi {
localVarRequestBuilder.header("Accept", "application/json");
localVarRequestBuilder.method("GET", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"findPetsByTags call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
try {
return CompletableFuture.completedFuture(
memberVarObjectMapper.readValue(localVarResponse.body(), new TypeReference<Set<Pet>>() {})
);
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
}
}
});
localVarRequestBuilder.method("GET", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return localVarRequestBuilder;
}
/**
* Find pet by ID
@@ -280,28 +318,9 @@ public class PetApi {
* @return Pet
* @throws ApiException if fails to make API call
*/
public CompletableFuture<Pet> getPetById (Long petId) throws ApiException {
// verify the required parameter 'petId' is set
if (petId == null) {
return CompletableFuture.failedFuture(new ApiException(400, "Missing the required parameter 'petId' when calling getPetById"));
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
String localVarPath = "/pet/{petId}"
.replace("{petId}", ApiClient.urlEncode(petId.toString()));
localVarRequestBuilder.uri(URI.create(memberVarBaseUri + localVarPath));
localVarRequestBuilder.header("Accept", "application/json");
localVarRequestBuilder.method("GET", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
public CompletableFuture<Pet> getPetById(Long petId) throws ApiException {
try {
HttpRequest.Builder localVarRequestBuilder = getPetByIdRequestBuilder(petId);
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
@@ -313,14 +332,43 @@ public class PetApi {
);
} else {
try {
return CompletableFuture.completedFuture(
memberVarObjectMapper.readValue(localVarResponse.body(), new TypeReference<Pet>() {})
);
return CompletableFuture.completedFuture(
memberVarObjectMapper.readValue(localVarResponse.body(), new TypeReference<Pet>() {})
);
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
return CompletableFuture.failedFuture(new ApiException(e));
}
}
}
});
}
catch (ApiException e) {
return CompletableFuture.failedFuture(e);
}
}
private HttpRequest.Builder getPetByIdRequestBuilder(Long petId) throws ApiException {
// verify the required parameter 'petId' is set
if (petId == null) {
throw new ApiException(400, "Missing the required parameter 'petId' when calling getPetById");
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
String localVarPath = "/pet/{petId}"
.replace("{petId}", ApiClient.urlEncode(petId.toString()));
localVarRequestBuilder.uri(URI.create(memberVarBaseUri + localVarPath));
localVarRequestBuilder.header("Accept", "application/json");
localVarRequestBuilder.method("GET", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return localVarRequestBuilder;
}
/**
* Update an existing pet
@@ -328,10 +376,32 @@ public class PetApi {
* @param body Pet object that needs to be added to the store (required)
* @throws ApiException if fails to make API call
*/
public CompletableFuture<Void> updatePet (Pet body) throws ApiException {
public CompletableFuture<Void> updatePet(Pet body) throws ApiException {
try {
HttpRequest.Builder localVarRequestBuilder = updatePetRequestBuilder(body);
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"updatePet call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
return CompletableFuture.completedFuture(null);
}
});
}
catch (ApiException e) {
return CompletableFuture.failedFuture(e);
}
}
private HttpRequest.Builder updatePetRequestBuilder(Pet body) throws ApiException {
// verify the required parameter 'body' is set
if (body == null) {
return CompletableFuture.failedFuture(new ApiException(400, "Missing the required parameter 'body' when calling updatePet"));
throw new ApiException(400, "Missing the required parameter 'body' when calling updatePet");
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
@@ -346,29 +416,16 @@ public class PetApi {
try {
byte[] localVarPostBody = memberVarObjectMapper.writeValueAsBytes(body);
localVarRequestBuilder.method("PUT", HttpRequest.BodyPublishers.ofByteArray(localVarPostBody));
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"updatePet call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
return CompletableFuture.completedFuture(null);
}
});
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
throw new ApiException(e);
}
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return localVarRequestBuilder;
}
/**
* Updates a pet in the store with form data
@@ -378,10 +435,32 @@ public class PetApi {
* @param status Updated status of the pet (optional)
* @throws ApiException if fails to make API call
*/
public CompletableFuture<Void> updatePetWithForm (Long petId, String name, String status) throws ApiException {
public CompletableFuture<Void> updatePetWithForm(Long petId, String name, String status) throws ApiException {
try {
HttpRequest.Builder localVarRequestBuilder = updatePetWithFormRequestBuilder(petId, name, status);
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"updatePetWithForm call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
return CompletableFuture.completedFuture(null);
}
});
}
catch (ApiException e) {
return CompletableFuture.failedFuture(e);
}
}
private HttpRequest.Builder updatePetWithFormRequestBuilder(Long petId, String name, String status) throws ApiException {
// verify the required parameter 'petId' is set
if (petId == null) {
return CompletableFuture.failedFuture(new ApiException(400, "Missing the required parameter 'petId' when calling updatePetWithForm"));
throw new ApiException(400, "Missing the required parameter 'petId' when calling updatePetWithForm");
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
@@ -393,27 +472,14 @@ public class PetApi {
localVarRequestBuilder.header("Accept", "application/json");
localVarRequestBuilder.method("POST", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"updatePetWithForm call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
return CompletableFuture.completedFuture(null);
}
});
localVarRequestBuilder.method("POST", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return localVarRequestBuilder;
}
/**
* uploads an image
@@ -424,28 +490,9 @@ public class PetApi {
* @return ModelApiResponse
* @throws ApiException if fails to make API call
*/
public CompletableFuture<ModelApiResponse> uploadFile (Long petId, String additionalMetadata, File file) throws ApiException {
// verify the required parameter 'petId' is set
if (petId == null) {
return CompletableFuture.failedFuture(new ApiException(400, "Missing the required parameter 'petId' when calling uploadFile"));
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
String localVarPath = "/pet/{petId}/uploadImage"
.replace("{petId}", ApiClient.urlEncode(petId.toString()));
localVarRequestBuilder.uri(URI.create(memberVarBaseUri + localVarPath));
localVarRequestBuilder.header("Accept", "application/json");
localVarRequestBuilder.method("POST", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
public CompletableFuture<ModelApiResponse> uploadFile(Long petId, String additionalMetadata, File file) throws ApiException {
try {
HttpRequest.Builder localVarRequestBuilder = uploadFileRequestBuilder(petId, additionalMetadata, file);
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
@@ -457,14 +504,43 @@ public class PetApi {
);
} else {
try {
return CompletableFuture.completedFuture(
memberVarObjectMapper.readValue(localVarResponse.body(), new TypeReference<ModelApiResponse>() {})
);
return CompletableFuture.completedFuture(
memberVarObjectMapper.readValue(localVarResponse.body(), new TypeReference<ModelApiResponse>() {})
);
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
return CompletableFuture.failedFuture(new ApiException(e));
}
}
}
});
}
catch (ApiException e) {
return CompletableFuture.failedFuture(e);
}
}
private HttpRequest.Builder uploadFileRequestBuilder(Long petId, String additionalMetadata, File file) throws ApiException {
// verify the required parameter 'petId' is set
if (petId == null) {
throw new ApiException(400, "Missing the required parameter 'petId' when calling uploadFile");
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
String localVarPath = "/pet/{petId}/uploadImage"
.replace("{petId}", ApiClient.urlEncode(petId.toString()));
localVarRequestBuilder.uri(URI.create(memberVarBaseUri + localVarPath));
localVarRequestBuilder.header("Accept", "application/json");
localVarRequestBuilder.method("POST", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return localVarRequestBuilder;
}
/**
* uploads an image (required)
@@ -475,32 +551,9 @@ public class PetApi {
* @return ModelApiResponse
* @throws ApiException if fails to make API call
*/
public CompletableFuture<ModelApiResponse> uploadFileWithRequiredFile (Long petId, File requiredFile, String additionalMetadata) throws ApiException {
// verify the required parameter 'petId' is set
if (petId == null) {
return CompletableFuture.failedFuture(new ApiException(400, "Missing the required parameter 'petId' when calling uploadFileWithRequiredFile"));
}
// verify the required parameter 'requiredFile' is set
if (requiredFile == null) {
return CompletableFuture.failedFuture(new ApiException(400, "Missing the required parameter 'requiredFile' when calling uploadFileWithRequiredFile"));
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
String localVarPath = "/fake/{petId}/uploadImageWithRequiredFile"
.replace("{petId}", ApiClient.urlEncode(petId.toString()));
localVarRequestBuilder.uri(URI.create(memberVarBaseUri + localVarPath));
localVarRequestBuilder.header("Accept", "application/json");
localVarRequestBuilder.method("POST", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
public CompletableFuture<ModelApiResponse> uploadFileWithRequiredFile(Long petId, File requiredFile, String additionalMetadata) throws ApiException {
try {
HttpRequest.Builder localVarRequestBuilder = uploadFileWithRequiredFileRequestBuilder(petId, requiredFile, additionalMetadata);
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
@@ -512,13 +565,46 @@ public class PetApi {
);
} else {
try {
return CompletableFuture.completedFuture(
memberVarObjectMapper.readValue(localVarResponse.body(), new TypeReference<ModelApiResponse>() {})
);
return CompletableFuture.completedFuture(
memberVarObjectMapper.readValue(localVarResponse.body(), new TypeReference<ModelApiResponse>() {})
);
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
return CompletableFuture.failedFuture(new ApiException(e));
}
}
}
});
}
catch (ApiException e) {
return CompletableFuture.failedFuture(e);
}
}
private HttpRequest.Builder uploadFileWithRequiredFileRequestBuilder(Long petId, File requiredFile, String additionalMetadata) throws ApiException {
// verify the required parameter 'petId' is set
if (petId == null) {
throw new ApiException(400, "Missing the required parameter 'petId' when calling uploadFileWithRequiredFile");
}
// verify the required parameter 'requiredFile' is set
if (requiredFile == null) {
throw new ApiException(400, "Missing the required parameter 'requiredFile' when calling uploadFileWithRequiredFile");
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
String localVarPath = "/fake/{petId}/uploadImageWithRequiredFile"
.replace("{petId}", ApiClient.urlEncode(petId.toString()));
localVarRequestBuilder.uri(URI.create(memberVarBaseUri + localVarPath));
localVarRequestBuilder.header("Accept", "application/json");
localVarRequestBuilder.method("POST", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return localVarRequestBuilder;
}
}

239
samples/client/petstore/java/native-async/src/main/java/org/openapitools/client/api/StoreApi.java
View File

@@ -65,10 +65,32 @@ public class StoreApi {
* @param orderId ID of the order that needs to be deleted (required)
* @throws ApiException if fails to make API call
*/
public CompletableFuture<Void> deleteOrder (String orderId) throws ApiException {
public CompletableFuture<Void> deleteOrder(String orderId) throws ApiException {
try {
HttpRequest.Builder localVarRequestBuilder = deleteOrderRequestBuilder(orderId);
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"deleteOrder call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
return CompletableFuture.completedFuture(null);
}
});
}
catch (ApiException e) {
return CompletableFuture.failedFuture(e);
}
}
private HttpRequest.Builder deleteOrderRequestBuilder(String orderId) throws ApiException {
// verify the required parameter 'orderId' is set
if (orderId == null) {
return CompletableFuture.failedFuture(new ApiException(400, "Missing the required parameter 'orderId' when calling deleteOrder"));
throw new ApiException(400, "Missing the required parameter 'orderId' when calling deleteOrder");
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
@@ -80,27 +102,14 @@ public class StoreApi {
localVarRequestBuilder.header("Accept", "application/json");
localVarRequestBuilder.method("DELETE", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"deleteOrder call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
return CompletableFuture.completedFuture(null);
}
});
localVarRequestBuilder.method("DELETE", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return localVarRequestBuilder;
}
/**
* Returns pet inventories by status
@@ -108,23 +117,9 @@ public class StoreApi {
* @return Map&lt;String, Integer&gt;
* @throws ApiException if fails to make API call
*/
public CompletableFuture<Map<String, Integer>> getInventory () throws ApiException {
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
String localVarPath = "/store/inventory";
localVarRequestBuilder.uri(URI.create(memberVarBaseUri + localVarPath));
localVarRequestBuilder.header("Accept", "application/json");
localVarRequestBuilder.method("GET", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
public CompletableFuture<Map<String, Integer>> getInventory() throws ApiException {
try {
HttpRequest.Builder localVarRequestBuilder = getInventoryRequestBuilder();
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
@@ -136,14 +131,38 @@ public class StoreApi {
);
} else {
try {
return CompletableFuture.completedFuture(
memberVarObjectMapper.readValue(localVarResponse.body(), new TypeReference<Map<String, Integer>>() {})
);
return CompletableFuture.completedFuture(
memberVarObjectMapper.readValue(localVarResponse.body(), new TypeReference<Map<String, Integer>>() {})
);
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
return CompletableFuture.failedFuture(new ApiException(e));
}
}
}
});
}
catch (ApiException e) {
return CompletableFuture.failedFuture(e);
}
}
private HttpRequest.Builder getInventoryRequestBuilder() throws ApiException {
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
String localVarPath = "/store/inventory";
localVarRequestBuilder.uri(URI.create(memberVarBaseUri + localVarPath));
localVarRequestBuilder.header("Accept", "application/json");
localVarRequestBuilder.method("GET", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return localVarRequestBuilder;
}
/**
* Find purchase order by ID
@@ -152,28 +171,9 @@ public class StoreApi {
* @return Order
* @throws ApiException if fails to make API call
*/
public CompletableFuture<Order> getOrderById (Long orderId) throws ApiException {
// verify the required parameter 'orderId' is set
if (orderId == null) {
return CompletableFuture.failedFuture(new ApiException(400, "Missing the required parameter 'orderId' when calling getOrderById"));
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
String localVarPath = "/store/order/{order_id}"
.replace("{order_id}", ApiClient.urlEncode(orderId.toString()));
localVarRequestBuilder.uri(URI.create(memberVarBaseUri + localVarPath));
localVarRequestBuilder.header("Accept", "application/json");
localVarRequestBuilder.method("GET", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
public CompletableFuture<Order> getOrderById(Long orderId) throws ApiException {
try {
HttpRequest.Builder localVarRequestBuilder = getOrderByIdRequestBuilder(orderId);
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
@@ -185,14 +185,43 @@ public class StoreApi {
);
} else {
try {
return CompletableFuture.completedFuture(
memberVarObjectMapper.readValue(localVarResponse.body(), new TypeReference<Order>() {})
);
return CompletableFuture.completedFuture(
memberVarObjectMapper.readValue(localVarResponse.body(), new TypeReference<Order>() {})
);
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
return CompletableFuture.failedFuture(new ApiException(e));
}
}
}
});
}
catch (ApiException e) {
return CompletableFuture.failedFuture(e);
}
}
private HttpRequest.Builder getOrderByIdRequestBuilder(Long orderId) throws ApiException {
// verify the required parameter 'orderId' is set
if (orderId == null) {
throw new ApiException(400, "Missing the required parameter 'orderId' when calling getOrderById");
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
String localVarPath = "/store/order/{order_id}"
.replace("{order_id}", ApiClient.urlEncode(orderId.toString()));
localVarRequestBuilder.uri(URI.create(memberVarBaseUri + localVarPath));
localVarRequestBuilder.header("Accept", "application/json");
localVarRequestBuilder.method("GET", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return localVarRequestBuilder;
}
/**
* Place an order for a pet
@@ -201,10 +230,38 @@ public class StoreApi {
* @return Order
* @throws ApiException if fails to make API call
*/
public CompletableFuture<Order> placeOrder (Order body) throws ApiException {
public CompletableFuture<Order> placeOrder(Order body) throws ApiException {
try {
HttpRequest.Builder localVarRequestBuilder = placeOrderRequestBuilder(body);
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"placeOrder call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
try {
return CompletableFuture.completedFuture(
memberVarObjectMapper.readValue(localVarResponse.body(), new TypeReference<Order>() {})
);
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
}
}
});
}
catch (ApiException e) {
return CompletableFuture.failedFuture(e);
}
}
private HttpRequest.Builder placeOrderRequestBuilder(Order body) throws ApiException {
// verify the required parameter 'body' is set
if (body == null) {
return CompletableFuture.failedFuture(new ApiException(400, "Missing the required parameter 'body' when calling placeOrder"));
throw new ApiException(400, "Missing the required parameter 'body' when calling placeOrder");
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
@@ -219,33 +276,15 @@ public class StoreApi {
try {
byte[] localVarPostBody = memberVarObjectMapper.writeValueAsBytes(body);
localVarRequestBuilder.method("POST", HttpRequest.BodyPublishers.ofByteArray(localVarPostBody));
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"placeOrder call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
try {
return CompletableFuture.completedFuture(
memberVarObjectMapper.readValue(localVarResponse.body(), new TypeReference<Order>() {})
);
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
}
}
});
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
throw new ApiException(e);
}
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return localVarRequestBuilder;
}
}

442
samples/client/petstore/java/native-async/src/main/java/org/openapitools/client/api/UserApi.java
View File

@@ -65,10 +65,32 @@ public class UserApi {
* @param body Created user object (required)
* @throws ApiException if fails to make API call
*/
public CompletableFuture<Void> createUser (User body) throws ApiException {
public CompletableFuture<Void> createUser(User body) throws ApiException {
try {
HttpRequest.Builder localVarRequestBuilder = createUserRequestBuilder(body);
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"createUser call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
return CompletableFuture.completedFuture(null);
}
});
}
catch (ApiException e) {
return CompletableFuture.failedFuture(e);
}
}
private HttpRequest.Builder createUserRequestBuilder(User body) throws ApiException {
// verify the required parameter 'body' is set
if (body == null) {
return CompletableFuture.failedFuture(new ApiException(400, "Missing the required parameter 'body' when calling createUser"));
throw new ApiException(400, "Missing the required parameter 'body' when calling createUser");
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
@@ -83,29 +105,16 @@ public class UserApi {
try {
byte[] localVarPostBody = memberVarObjectMapper.writeValueAsBytes(body);
localVarRequestBuilder.method("POST", HttpRequest.BodyPublishers.ofByteArray(localVarPostBody));
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"createUser call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
return CompletableFuture.completedFuture(null);
}
});
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
throw new ApiException(e);
}
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return localVarRequestBuilder;
}
/**
* Creates list of users with given input array
@@ -113,10 +122,32 @@ public class UserApi {
* @param body List of user object (required)
* @throws ApiException if fails to make API call
*/
public CompletableFuture<Void> createUsersWithArrayInput (List<User> body) throws ApiException {
public CompletableFuture<Void> createUsersWithArrayInput(List<User> body) throws ApiException {
try {
HttpRequest.Builder localVarRequestBuilder = createUsersWithArrayInputRequestBuilder(body);
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"createUsersWithArrayInput call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
return CompletableFuture.completedFuture(null);
}
});
}
catch (ApiException e) {
return CompletableFuture.failedFuture(e);
}
}
private HttpRequest.Builder createUsersWithArrayInputRequestBuilder(List<User> body) throws ApiException {
// verify the required parameter 'body' is set
if (body == null) {
return CompletableFuture.failedFuture(new ApiException(400, "Missing the required parameter 'body' when calling createUsersWithArrayInput"));
throw new ApiException(400, "Missing the required parameter 'body' when calling createUsersWithArrayInput");
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
@@ -131,29 +162,16 @@ public class UserApi {
try {
byte[] localVarPostBody = memberVarObjectMapper.writeValueAsBytes(body);
localVarRequestBuilder.method("POST", HttpRequest.BodyPublishers.ofByteArray(localVarPostBody));
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"createUsersWithArrayInput call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
return CompletableFuture.completedFuture(null);
}
});
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
throw new ApiException(e);
}
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return localVarRequestBuilder;
}
/**
* Creates list of users with given input array
@@ -161,10 +179,32 @@ public class UserApi {
* @param body List of user object (required)
* @throws ApiException if fails to make API call
*/
public CompletableFuture<Void> createUsersWithListInput (List<User> body) throws ApiException {
public CompletableFuture<Void> createUsersWithListInput(List<User> body) throws ApiException {
try {
HttpRequest.Builder localVarRequestBuilder = createUsersWithListInputRequestBuilder(body);
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"createUsersWithListInput call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
return CompletableFuture.completedFuture(null);
}
});
}
catch (ApiException e) {
return CompletableFuture.failedFuture(e);
}
}
private HttpRequest.Builder createUsersWithListInputRequestBuilder(List<User> body) throws ApiException {
// verify the required parameter 'body' is set
if (body == null) {
return CompletableFuture.failedFuture(new ApiException(400, "Missing the required parameter 'body' when calling createUsersWithListInput"));
throw new ApiException(400, "Missing the required parameter 'body' when calling createUsersWithListInput");
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
@@ -179,29 +219,16 @@ public class UserApi {
try {
byte[] localVarPostBody = memberVarObjectMapper.writeValueAsBytes(body);
localVarRequestBuilder.method("POST", HttpRequest.BodyPublishers.ofByteArray(localVarPostBody));
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"createUsersWithListInput call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
return CompletableFuture.completedFuture(null);
}
});
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
throw new ApiException(e);
}
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return localVarRequestBuilder;
}
/**
* Delete user
@@ -209,28 +236,9 @@ public class UserApi {
* @param username The name that needs to be deleted (required)
* @throws ApiException if fails to make API call
*/
public CompletableFuture<Void> deleteUser (String username) throws ApiException {
// verify the required parameter 'username' is set
if (username == null) {
return CompletableFuture.failedFuture(new ApiException(400, "Missing the required parameter 'username' when calling deleteUser"));
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
String localVarPath = "/user/{username}"
.replace("{username}", ApiClient.urlEncode(username.toString()));
localVarRequestBuilder.uri(URI.create(memberVarBaseUri + localVarPath));
localVarRequestBuilder.header("Accept", "application/json");
localVarRequestBuilder.method("DELETE", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
public CompletableFuture<Void> deleteUser(String username) throws ApiException {
try {
HttpRequest.Builder localVarRequestBuilder = deleteUserRequestBuilder(username);
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
@@ -241,22 +249,19 @@ public class UserApi {
localVarResponse.body())
);
} else {
return CompletableFuture.completedFuture(null);
}
});
}
catch (ApiException e) {
return CompletableFuture.failedFuture(e);
}
}
/**
* Get user by user name
*
* @param username The name that needs to be fetched. Use user1 for testing. (required)
* @return User
* @throws ApiException if fails to make API call
*/
public CompletableFuture<User> getUserByName (String username) throws ApiException {
private HttpRequest.Builder deleteUserRequestBuilder(String username) throws ApiException {
// verify the required parameter 'username' is set
if (username == null) {
return CompletableFuture.failedFuture(new ApiException(400, "Missing the required parameter 'username' when calling getUserByName"));
throw new ApiException(400, "Missing the required parameter 'username' when calling deleteUser");
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
@@ -268,13 +273,25 @@ public class UserApi {
localVarRequestBuilder.header("Accept", "application/json");
localVarRequestBuilder.method("GET", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
localVarRequestBuilder.method("DELETE", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return localVarRequestBuilder;
}
/**
* Get user by user name
*
* @param username The name that needs to be fetched. Use user1 for testing. (required)
* @return User
* @throws ApiException if fails to make API call
*/
public CompletableFuture<User> getUserByName(String username) throws ApiException {
try {
HttpRequest.Builder localVarRequestBuilder = getUserByNameRequestBuilder(username);
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
@@ -286,14 +303,43 @@ public class UserApi {
);
} else {
try {
return CompletableFuture.completedFuture(
memberVarObjectMapper.readValue(localVarResponse.body(), new TypeReference<User>() {})
);
return CompletableFuture.completedFuture(
memberVarObjectMapper.readValue(localVarResponse.body(), new TypeReference<User>() {})
);
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
return CompletableFuture.failedFuture(new ApiException(e));
}
}
}
});
}
catch (ApiException e) {
return CompletableFuture.failedFuture(e);
}
}
private HttpRequest.Builder getUserByNameRequestBuilder(String username) throws ApiException {
// verify the required parameter 'username' is set
if (username == null) {
throw new ApiException(400, "Missing the required parameter 'username' when calling getUserByName");
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
String localVarPath = "/user/{username}"
.replace("{username}", ApiClient.urlEncode(username.toString()));
localVarRequestBuilder.uri(URI.create(memberVarBaseUri + localVarPath));
localVarRequestBuilder.header("Accept", "application/json");
localVarRequestBuilder.method("GET", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return localVarRequestBuilder;
}
/**
* Logs user into the system
@@ -303,14 +349,42 @@ public class UserApi {
* @return String
* @throws ApiException if fails to make API call
*/
public CompletableFuture<String> loginUser (String username, String password) throws ApiException {
public CompletableFuture<String> loginUser(String username, String password) throws ApiException {
try {
HttpRequest.Builder localVarRequestBuilder = loginUserRequestBuilder(username, password);
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"loginUser call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
try {
return CompletableFuture.completedFuture(
memberVarObjectMapper.readValue(localVarResponse.body(), new TypeReference<String>() {})
);
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
}
}
});
}
catch (ApiException e) {
return CompletableFuture.failedFuture(e);
}
}
private HttpRequest.Builder loginUserRequestBuilder(String username, String password) throws ApiException {
// verify the required parameter 'username' is set
if (username == null) {
return CompletableFuture.failedFuture(new ApiException(400, "Missing the required parameter 'username' when calling loginUser"));
throw new ApiException(400, "Missing the required parameter 'username' when calling loginUser");
}
// verify the required parameter 'password' is set
if (password == null) {
return CompletableFuture.failedFuture(new ApiException(400, "Missing the required parameter 'password' when calling loginUser"));
throw new ApiException(400, "Missing the required parameter 'password' when calling loginUser");
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
@@ -331,55 +405,23 @@ public class UserApi {
localVarRequestBuilder.header("Accept", "application/json");
localVarRequestBuilder.method("GET", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"loginUser call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
try {
return CompletableFuture.completedFuture(
memberVarObjectMapper.readValue(localVarResponse.body(), new TypeReference<String>() {})
);
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
}
}
});
localVarRequestBuilder.method("GET", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return localVarRequestBuilder;
}
/**
* Logs out current logged in user session
*
* @throws ApiException if fails to make API call
*/
public CompletableFuture<Void> logoutUser () throws ApiException {
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
String localVarPath = "/user/logout";
localVarRequestBuilder.uri(URI.create(memberVarBaseUri + localVarPath));
localVarRequestBuilder.header("Accept", "application/json");
localVarRequestBuilder.method("GET", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
public CompletableFuture<Void> logoutUser() throws ApiException {
try {
HttpRequest.Builder localVarRequestBuilder = logoutUserRequestBuilder();
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
@@ -390,10 +432,33 @@ public class UserApi {
localVarResponse.body())
);
} else {
return CompletableFuture.completedFuture(null);
}
});
}
catch (ApiException e) {
return CompletableFuture.failedFuture(e);
}
}
private HttpRequest.Builder logoutUserRequestBuilder() throws ApiException {
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
String localVarPath = "/user/logout";
localVarRequestBuilder.uri(URI.create(memberVarBaseUri + localVarPath));
localVarRequestBuilder.header("Accept", "application/json");
localVarRequestBuilder.method("GET", HttpRequest.BodyPublishers.noBody());
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return localVarRequestBuilder;
}
/**
* Updated user
@@ -402,14 +467,36 @@ public class UserApi {
* @param body Updated user object (required)
* @throws ApiException if fails to make API call
*/
public CompletableFuture<Void> updateUser (String username, User body) throws ApiException {
public CompletableFuture<Void> updateUser(String username, User body) throws ApiException {
try {
HttpRequest.Builder localVarRequestBuilder = updateUserRequestBuilder(username, body);
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"updateUser call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
return CompletableFuture.completedFuture(null);
}
});
}
catch (ApiException e) {
return CompletableFuture.failedFuture(e);
}
}
private HttpRequest.Builder updateUserRequestBuilder(String username, User body) throws ApiException {
// verify the required parameter 'username' is set
if (username == null) {
return CompletableFuture.failedFuture(new ApiException(400, "Missing the required parameter 'username' when calling updateUser"));
throw new ApiException(400, "Missing the required parameter 'username' when calling updateUser");
}
// verify the required parameter 'body' is set
if (body == null) {
return CompletableFuture.failedFuture(new ApiException(400, "Missing the required parameter 'body' when calling updateUser"));
throw new ApiException(400, "Missing the required parameter 'body' when calling updateUser");
}
HttpRequest.Builder localVarRequestBuilder = HttpRequest.newBuilder();
@@ -425,28 +512,15 @@ public class UserApi {
try {
byte[] localVarPostBody = memberVarObjectMapper.writeValueAsBytes(body);
localVarRequestBuilder.method("PUT", HttpRequest.BodyPublishers.ofByteArray(localVarPostBody));
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return memberVarHttpClient.sendAsync(
localVarRequestBuilder.build(),
HttpResponse.BodyHandlers.ofString()).thenComposeAsync(localVarResponse -> {
if (localVarResponse.statusCode()/ 100 != 2) {
return CompletableFuture.failedFuture(new ApiException(localVarResponse.statusCode(),
"updateUser call received non-success response",
localVarResponse.headers(),
localVarResponse.body())
);
} else {
return CompletableFuture.completedFuture(null);
}
});
} catch (IOException e) {
return CompletableFuture.failedFuture(new ApiException(e));
throw new ApiException(e);
}
if (memberVarReadTimeout != null) {
localVarRequestBuilder.timeout(memberVarReadTimeout);
}
if (memberVarInterceptor != null) {
memberVarInterceptor.accept(localVarRequestBuilder);
}
return localVarRequestBuilder;
}
}