oauthAppId = Optional.empty();
@@ -202,6 +231,7 @@ public Builder from(CreateAccountRequest other) {
oauthAppId(other.getOauthAppId());
appSlug(other.getAppSlug());
cfmapJson(other.getCfmapJson());
+ connectToken(other.getConnectToken());
name(other.getName());
return this;
}
@@ -213,48 +243,52 @@ public Builder from(CreateAccountRequest other) {
*/
@java.lang.Override
@JsonSetter("app_slug")
- public _FinalStage appSlug(@NotNull String appSlug) {
+ public CfmapJsonStage appSlug(@NotNull String appSlug) {
this.appSlug = Objects.requireNonNull(appSlug, "appSlug must not be null");
return this;
}
/**
- * Optional name for the account
+ * JSON string containing the custom fields mapping
+ * JSON string containing the custom fields mapping
* @return Reference to {@code this} so that method calls can be chained together.
*/
@java.lang.Override
- public _FinalStage name(String name) {
- this.name = Optional.ofNullable(name);
+ @JsonSetter("cfmap_json")
+ public ConnectTokenStage cfmapJson(@NotNull String cfmapJson) {
+ this.cfmapJson = Objects.requireNonNull(cfmapJson, "cfmapJson must not be null");
return this;
}
/**
- * Optional name for the account
+ * The connect token for authentication
+ * The connect token for authentication
+ * @return Reference to {@code this} so that method calls can be chained together.
*/
@java.lang.Override
- @JsonSetter(value = "name", nulls = Nulls.SKIP)
- public _FinalStage name(Optional name) {
- this.name = name;
+ @JsonSetter("connect_token")
+ public _FinalStage connectToken(@NotNull String connectToken) {
+ this.connectToken = Objects.requireNonNull(connectToken, "connectToken must not be null");
return this;
}
/**
- * JSON string containing the custom fields mapping
+ * Optional name for the account
* @return Reference to {@code this} so that method calls can be chained together.
*/
@java.lang.Override
- public _FinalStage cfmapJson(String cfmapJson) {
- this.cfmapJson = Optional.ofNullable(cfmapJson);
+ public _FinalStage name(String name) {
+ this.name = Optional.ofNullable(name);
return this;
}
/**
- * JSON string containing the custom fields mapping
+ * Optional name for the account
*/
@java.lang.Override
- @JsonSetter(value = "cfmap_json", nulls = Nulls.SKIP)
- public _FinalStage cfmapJson(Optional cfmapJson) {
- this.cfmapJson = cfmapJson;
+ @JsonSetter(value = "name", nulls = Nulls.SKIP)
+ public _FinalStage name(Optional name) {
+ this.name = name;
return this;
}
@@ -314,7 +348,7 @@ public _FinalStage appId(Optional appId) {
@java.lang.Override
public CreateAccountRequest build() {
return new CreateAccountRequest(
- appId, externalUserId, oauthAppId, appSlug, cfmapJson, name, additionalProperties);
+ appId, externalUserId, oauthAppId, appSlug, cfmapJson, connectToken, name, additionalProperties);
}
}
}
diff --git a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/actions/AsyncRawActionsClient.java b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/actions/AsyncRawActionsClient.java
index 9686990..b260c12 100644
--- a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/actions/AsyncRawActionsClient.java
+++ b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/actions/AsyncRawActionsClient.java
@@ -6,9 +6,9 @@
import com.pipedream.api.core.ClientOptions;
import com.pipedream.api.core.MediaTypes;
import com.pipedream.api.core.ObjectMappers;
-import com.pipedream.api.core.PipedreamApiApiException;
-import com.pipedream.api.core.PipedreamApiException;
-import com.pipedream.api.core.PipedreamApiHttpResponse;
+import com.pipedream.api.core.PipedreamApiClientApiException;
+import com.pipedream.api.core.PipedreamApiClientException;
+import com.pipedream.api.core.PipedreamApiClientHttpResponse;
import com.pipedream.api.core.QueryStringMapper;
import com.pipedream.api.core.RequestOptions;
import com.pipedream.api.core.pagination.SyncPagingIterable;
@@ -47,15 +47,16 @@ public AsyncRawActionsClient(ClientOptions clientOptions) {
this.clientOptions = clientOptions;
}
- public CompletableFuture>> list() {
+ public CompletableFuture>> list() {
return list(ActionsListRequest.builder().build());
}
- public CompletableFuture>> list(ActionsListRequest request) {
+ public CompletableFuture>> list(
+ ActionsListRequest request) {
return list(request, null);
}
- public CompletableFuture>> list(
+ public CompletableFuture>> list(
ActionsListRequest request, RequestOptions requestOptions) {
HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
.newBuilder()
@@ -90,7 +91,8 @@ public CompletableFuture>
if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
client = clientOptions.httpClientWithTimeout(requestOptions);
}
- CompletableFuture>> future = new CompletableFuture<>();
+ CompletableFuture>> future =
+ new CompletableFuture<>();
client.newCall(okhttpRequest).enqueue(new Callback() {
@Override
public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {
@@ -105,7 +107,7 @@ public void onResponse(@NotNull Call call, @NotNull Response response) throws IO
.after(startingAfter)
.build();
List result = parsedResponse.getData();
- future.complete(new PipedreamApiHttpResponse<>(
+ future.complete(new PipedreamApiClientHttpResponse<>(
new SyncPagingIterable(startingAfter.isPresent(), result, () -> {
try {
return list(nextRequest, requestOptions)
@@ -119,30 +121,32 @@ public void onResponse(@NotNull Call call, @NotNull Response response) throws IO
return;
}
String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- future.completeExceptionally(new PipedreamApiApiException(
+ future.completeExceptionally(new PipedreamApiClientApiException(
"Error with status code " + response.code(),
response.code(),
ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
response));
return;
} catch (IOException e) {
- future.completeExceptionally(new PipedreamApiException("Network error executing HTTP request", e));
+ future.completeExceptionally(
+ new PipedreamApiClientException("Network error executing HTTP request", e));
}
}
@Override
public void onFailure(@NotNull Call call, @NotNull IOException e) {
- future.completeExceptionally(new PipedreamApiException("Network error executing HTTP request", e));
+ future.completeExceptionally(
+ new PipedreamApiClientException("Network error executing HTTP request", e));
}
});
return future;
}
- public CompletableFuture> retrieve(String componentId) {
+ public CompletableFuture> retrieve(String componentId) {
return retrieve(componentId, null);
}
- public CompletableFuture> retrieve(
+ public CompletableFuture> retrieve(
String componentId, RequestOptions requestOptions) {
HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
.newBuilder()
@@ -161,7 +165,7 @@ public CompletableFuture> retrieve(
if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
client = clientOptions.httpClientWithTimeout(requestOptions);
}
- CompletableFuture> future = new CompletableFuture<>();
+ CompletableFuture> future = new CompletableFuture<>();
client.newCall(okhttpRequest).enqueue(new Callback() {
@Override
public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {
@@ -169,35 +173,37 @@ public void onResponse(@NotNull Call call, @NotNull Response response) throws IO
if (response.isSuccessful()) {
GetComponentResponse parsedResponse =
ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), GetComponentResponse.class);
- future.complete(new PipedreamApiHttpResponse<>(parsedResponse.getData(), response));
+ future.complete(new PipedreamApiClientHttpResponse<>(parsedResponse.getData(), response));
return;
}
String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- future.completeExceptionally(new PipedreamApiApiException(
+ future.completeExceptionally(new PipedreamApiClientApiException(
"Error with status code " + response.code(),
response.code(),
ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
response));
return;
} catch (IOException e) {
- future.completeExceptionally(new PipedreamApiException("Network error executing HTTP request", e));
+ future.completeExceptionally(
+ new PipedreamApiClientException("Network error executing HTTP request", e));
}
}
@Override
public void onFailure(@NotNull Call call, @NotNull IOException e) {
- future.completeExceptionally(new PipedreamApiException("Network error executing HTTP request", e));
+ future.completeExceptionally(
+ new PipedreamApiClientException("Network error executing HTTP request", e));
}
});
return future;
}
- public CompletableFuture> configureProp(
+ public CompletableFuture> configureProp(
ActionsConfigurePropRequest request) {
return configureProp(request, null);
}
- public CompletableFuture> configureProp(
+ public CompletableFuture> configureProp(
ActionsConfigurePropRequest request, RequestOptions requestOptions) {
HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
.newBuilder()
@@ -226,43 +232,45 @@ public CompletableFuture> config
if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
client = clientOptions.httpClientWithTimeout(requestOptions);
}
- CompletableFuture> future = new CompletableFuture<>();
+ CompletableFuture> future = new CompletableFuture<>();
client.newCall(okhttpRequest).enqueue(new Callback() {
@Override
public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {
try (ResponseBody responseBody = response.body()) {
if (response.isSuccessful()) {
- future.complete(new PipedreamApiHttpResponse<>(
+ future.complete(new PipedreamApiClientHttpResponse<>(
ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), ConfigurePropResponse.class),
response));
return;
}
String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- future.completeExceptionally(new PipedreamApiApiException(
+ future.completeExceptionally(new PipedreamApiClientApiException(
"Error with status code " + response.code(),
response.code(),
ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
response));
return;
} catch (IOException e) {
- future.completeExceptionally(new PipedreamApiException("Network error executing HTTP request", e));
+ future.completeExceptionally(
+ new PipedreamApiClientException("Network error executing HTTP request", e));
}
}
@Override
public void onFailure(@NotNull Call call, @NotNull IOException e) {
- future.completeExceptionally(new PipedreamApiException("Network error executing HTTP request", e));
+ future.completeExceptionally(
+ new PipedreamApiClientException("Network error executing HTTP request", e));
}
});
return future;
}
- public CompletableFuture> reloadProps(
+ public CompletableFuture> reloadProps(
ActionsReloadPropsRequest request) {
return reloadProps(request, null);
}
- public CompletableFuture> reloadProps(
+ public CompletableFuture> reloadProps(
ActionsReloadPropsRequest request, RequestOptions requestOptions) {
HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
.newBuilder()
@@ -291,42 +299,44 @@ public CompletableFuture> reloadPr
if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
client = clientOptions.httpClientWithTimeout(requestOptions);
}
- CompletableFuture> future = new CompletableFuture<>();
+ CompletableFuture> future = new CompletableFuture<>();
client.newCall(okhttpRequest).enqueue(new Callback() {
@Override
public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {
try (ResponseBody responseBody = response.body()) {
if (response.isSuccessful()) {
- future.complete(new PipedreamApiHttpResponse<>(
+ future.complete(new PipedreamApiClientHttpResponse<>(
ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), ReloadPropsResponse.class),
response));
return;
}
String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- future.completeExceptionally(new PipedreamApiApiException(
+ future.completeExceptionally(new PipedreamApiClientApiException(
"Error with status code " + response.code(),
response.code(),
ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
response));
return;
} catch (IOException e) {
- future.completeExceptionally(new PipedreamApiException("Network error executing HTTP request", e));
+ future.completeExceptionally(
+ new PipedreamApiClientException("Network error executing HTTP request", e));
}
}
@Override
public void onFailure(@NotNull Call call, @NotNull IOException e) {
- future.completeExceptionally(new PipedreamApiException("Network error executing HTTP request", e));
+ future.completeExceptionally(
+ new PipedreamApiClientException("Network error executing HTTP request", e));
}
});
return future;
}
- public CompletableFuture> run(RunActionOpts request) {
+ public CompletableFuture> run(RunActionOpts request) {
return run(request, null);
}
- public CompletableFuture> run(
+ public CompletableFuture> run(
RunActionOpts request, RequestOptions requestOptions) {
HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
.newBuilder()
@@ -364,32 +374,34 @@ public CompletableFuture> run(
if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
client = clientOptions.httpClientWithTimeout(requestOptions);
}
- CompletableFuture> future = new CompletableFuture<>();
+ CompletableFuture> future = new CompletableFuture<>();
client.newCall(okhttpRequest).enqueue(new Callback() {
@Override
public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {
try (ResponseBody responseBody = response.body()) {
if (response.isSuccessful()) {
- future.complete(new PipedreamApiHttpResponse<>(
+ future.complete(new PipedreamApiClientHttpResponse<>(
ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), RunActionResponse.class),
response));
return;
}
String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- future.completeExceptionally(new PipedreamApiApiException(
+ future.completeExceptionally(new PipedreamApiClientApiException(
"Error with status code " + response.code(),
response.code(),
ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
response));
return;
} catch (IOException e) {
- future.completeExceptionally(new PipedreamApiException("Network error executing HTTP request", e));
+ future.completeExceptionally(
+ new PipedreamApiClientException("Network error executing HTTP request", e));
}
}
@Override
public void onFailure(@NotNull Call call, @NotNull IOException e) {
- future.completeExceptionally(new PipedreamApiException("Network error executing HTTP request", e));
+ future.completeExceptionally(
+ new PipedreamApiClientException("Network error executing HTTP request", e));
}
});
return future;
diff --git a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/actions/RawActionsClient.java b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/actions/RawActionsClient.java
index eee1aa6..4739375 100644
--- a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/actions/RawActionsClient.java
+++ b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/actions/RawActionsClient.java
@@ -6,9 +6,9 @@
import com.pipedream.api.core.ClientOptions;
import com.pipedream.api.core.MediaTypes;
import com.pipedream.api.core.ObjectMappers;
-import com.pipedream.api.core.PipedreamApiApiException;
-import com.pipedream.api.core.PipedreamApiException;
-import com.pipedream.api.core.PipedreamApiHttpResponse;
+import com.pipedream.api.core.PipedreamApiClientApiException;
+import com.pipedream.api.core.PipedreamApiClientException;
+import com.pipedream.api.core.PipedreamApiClientHttpResponse;
import com.pipedream.api.core.QueryStringMapper;
import com.pipedream.api.core.RequestOptions;
import com.pipedream.api.core.pagination.SyncPagingIterable;
@@ -42,15 +42,15 @@ public RawActionsClient(ClientOptions clientOptions) {
this.clientOptions = clientOptions;
}
- public PipedreamApiHttpResponse> list() {
+ public PipedreamApiClientHttpResponse> list() {
return list(ActionsListRequest.builder().build());
}
- public PipedreamApiHttpResponse> list(ActionsListRequest request) {
+ public PipedreamApiClientHttpResponse> list(ActionsListRequest request) {
return list(request, null);
}
- public PipedreamApiHttpResponse> list(
+ public PipedreamApiClientHttpResponse> list(
ActionsListRequest request, RequestOptions requestOptions) {
HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
.newBuilder()
@@ -96,28 +96,28 @@ public PipedreamApiHttpResponse> list(
.after(startingAfter)
.build();
List result = parsedResponse.getData();
- return new PipedreamApiHttpResponse<>(
+ return new PipedreamApiClientHttpResponse<>(
new SyncPagingIterable(
startingAfter.isPresent(), result, () -> list(nextRequest, requestOptions)
.body()),
response);
}
String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- throw new PipedreamApiApiException(
+ throw new PipedreamApiClientApiException(
"Error with status code " + response.code(),
response.code(),
ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
response);
} catch (IOException e) {
- throw new PipedreamApiException("Network error executing HTTP request", e);
+ throw new PipedreamApiClientException("Network error executing HTTP request", e);
}
}
- public PipedreamApiHttpResponse retrieve(String componentId) {
+ public PipedreamApiClientHttpResponse retrieve(String componentId) {
return retrieve(componentId, null);
}
- public PipedreamApiHttpResponse retrieve(String componentId, RequestOptions requestOptions) {
+ public PipedreamApiClientHttpResponse retrieve(String componentId, RequestOptions requestOptions) {
HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
.newBuilder()
.addPathSegments("v1/connect")
@@ -140,24 +140,24 @@ public PipedreamApiHttpResponse retrieve(String componentId, RequestO
if (response.isSuccessful()) {
GetComponentResponse parsedResponse =
ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), GetComponentResponse.class);
- return new PipedreamApiHttpResponse<>(parsedResponse.getData(), response);
+ return new PipedreamApiClientHttpResponse<>(parsedResponse.getData(), response);
}
String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- throw new PipedreamApiApiException(
+ throw new PipedreamApiClientApiException(
"Error with status code " + response.code(),
response.code(),
ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
response);
} catch (IOException e) {
- throw new PipedreamApiException("Network error executing HTTP request", e);
+ throw new PipedreamApiClientException("Network error executing HTTP request", e);
}
}
- public PipedreamApiHttpResponse configureProp(ActionsConfigurePropRequest request) {
+ public PipedreamApiClientHttpResponse configureProp(ActionsConfigurePropRequest request) {
return configureProp(request, null);
}
- public PipedreamApiHttpResponse configureProp(
+ public PipedreamApiClientHttpResponse configureProp(
ActionsConfigurePropRequest request, RequestOptions requestOptions) {
HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
.newBuilder()
@@ -189,26 +189,26 @@ public PipedreamApiHttpResponse configureProp(
try (Response response = client.newCall(okhttpRequest).execute()) {
ResponseBody responseBody = response.body();
if (response.isSuccessful()) {
- return new PipedreamApiHttpResponse<>(
+ return new PipedreamApiClientHttpResponse<>(
ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), ConfigurePropResponse.class),
response);
}
String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- throw new PipedreamApiApiException(
+ throw new PipedreamApiClientApiException(
"Error with status code " + response.code(),
response.code(),
ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
response);
} catch (IOException e) {
- throw new PipedreamApiException("Network error executing HTTP request", e);
+ throw new PipedreamApiClientException("Network error executing HTTP request", e);
}
}
- public PipedreamApiHttpResponse reloadProps(ActionsReloadPropsRequest request) {
+ public PipedreamApiClientHttpResponse reloadProps(ActionsReloadPropsRequest request) {
return reloadProps(request, null);
}
- public PipedreamApiHttpResponse reloadProps(
+ public PipedreamApiClientHttpResponse reloadProps(
ActionsReloadPropsRequest request, RequestOptions requestOptions) {
HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
.newBuilder()
@@ -240,26 +240,26 @@ public PipedreamApiHttpResponse reloadProps(
try (Response response = client.newCall(okhttpRequest).execute()) {
ResponseBody responseBody = response.body();
if (response.isSuccessful()) {
- return new PipedreamApiHttpResponse<>(
+ return new PipedreamApiClientHttpResponse<>(
ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), ReloadPropsResponse.class),
response);
}
String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- throw new PipedreamApiApiException(
+ throw new PipedreamApiClientApiException(
"Error with status code " + response.code(),
response.code(),
ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
response);
} catch (IOException e) {
- throw new PipedreamApiException("Network error executing HTTP request", e);
+ throw new PipedreamApiClientException("Network error executing HTTP request", e);
}
}
- public PipedreamApiHttpResponse run(RunActionOpts request) {
+ public PipedreamApiClientHttpResponse run(RunActionOpts request) {
return run(request, null);
}
- public PipedreamApiHttpResponse run(RunActionOpts request, RequestOptions requestOptions) {
+ public PipedreamApiClientHttpResponse run(RunActionOpts request, RequestOptions requestOptions) {
HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
.newBuilder()
.addPathSegments("v1/connect")
@@ -299,17 +299,17 @@ public PipedreamApiHttpResponse run(RunActionOpts request, Re
try (Response response = client.newCall(okhttpRequest).execute()) {
ResponseBody responseBody = response.body();
if (response.isSuccessful()) {
- return new PipedreamApiHttpResponse<>(
+ return new PipedreamApiClientHttpResponse<>(
ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), RunActionResponse.class), response);
}
String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- throw new PipedreamApiApiException(
+ throw new PipedreamApiClientApiException(
"Error with status code " + response.code(),
response.code(),
ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
response);
} catch (IOException e) {
- throw new PipedreamApiException("Network error executing HTTP request", e);
+ throw new PipedreamApiClientException("Network error executing HTTP request", e);
}
}
}
diff --git a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/appcategories/AsyncRawAppCategoriesClient.java b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/appcategories/AsyncRawAppCategoriesClient.java
index c7a7bf5..3bdfe9c 100644
--- a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/appcategories/AsyncRawAppCategoriesClient.java
+++ b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/appcategories/AsyncRawAppCategoriesClient.java
@@ -6,9 +6,9 @@
import com.fasterxml.jackson.core.type.TypeReference;
import com.pipedream.api.core.ClientOptions;
import com.pipedream.api.core.ObjectMappers;
-import com.pipedream.api.core.PipedreamApiApiException;
-import com.pipedream.api.core.PipedreamApiException;
-import com.pipedream.api.core.PipedreamApiHttpResponse;
+import com.pipedream.api.core.PipedreamApiClientApiException;
+import com.pipedream.api.core.PipedreamApiClientException;
+import com.pipedream.api.core.PipedreamApiClientHttpResponse;
import com.pipedream.api.core.RequestOptions;
import com.pipedream.api.types.AppCategory;
import java.io.IOException;
@@ -31,11 +31,11 @@ public AsyncRawAppCategoriesClient(ClientOptions clientOptions) {
this.clientOptions = clientOptions;
}
- public CompletableFuture>> list() {
+ public CompletableFuture>> list() {
return list(null);
}
- public CompletableFuture>> list(RequestOptions requestOptions) {
+ public CompletableFuture>> list(RequestOptions requestOptions) {
HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
.newBuilder()
.addPathSegments("v1/connect/app_categories")
@@ -50,43 +50,46 @@ public CompletableFuture>> list(Reque
if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
client = clientOptions.httpClientWithTimeout(requestOptions);
}
- CompletableFuture>> future = new CompletableFuture<>();
+ CompletableFuture>> future = new CompletableFuture<>();
client.newCall(okhttpRequest).enqueue(new Callback() {
@Override
public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {
try (ResponseBody responseBody = response.body()) {
if (response.isSuccessful()) {
- future.complete(new PipedreamApiHttpResponse<>(
+ future.complete(new PipedreamApiClientHttpResponse<>(
ObjectMappers.JSON_MAPPER.readValue(
responseBody.string(), new TypeReference>() {}),
response));
return;
}
String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- future.completeExceptionally(new PipedreamApiApiException(
+ future.completeExceptionally(new PipedreamApiClientApiException(
"Error with status code " + response.code(),
response.code(),
ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
response));
return;
} catch (IOException e) {
- future.completeExceptionally(new PipedreamApiException("Network error executing HTTP request", e));
+ future.completeExceptionally(
+ new PipedreamApiClientException("Network error executing HTTP request", e));
}
}
@Override
public void onFailure(@NotNull Call call, @NotNull IOException e) {
- future.completeExceptionally(new PipedreamApiException("Network error executing HTTP request", e));
+ future.completeExceptionally(
+ new PipedreamApiClientException("Network error executing HTTP request", e));
}
});
return future;
}
- public CompletableFuture> retrieve(String id) {
+ public CompletableFuture> retrieve(String id) {
return retrieve(id, null);
}
- public CompletableFuture> retrieve(String id, RequestOptions requestOptions) {
+ public CompletableFuture> retrieve(
+ String id, RequestOptions requestOptions) {
HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
.newBuilder()
.addPathSegments("v1/connect/app_categories")
@@ -102,32 +105,34 @@ public CompletableFuture> retrieve(String
if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
client = clientOptions.httpClientWithTimeout(requestOptions);
}
- CompletableFuture> future = new CompletableFuture<>();
+ CompletableFuture> future = new CompletableFuture<>();
client.newCall(okhttpRequest).enqueue(new Callback() {
@Override
public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {
try (ResponseBody responseBody = response.body()) {
if (response.isSuccessful()) {
- future.complete(new PipedreamApiHttpResponse<>(
+ future.complete(new PipedreamApiClientHttpResponse<>(
ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), AppCategory.class),
response));
return;
}
String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- future.completeExceptionally(new PipedreamApiApiException(
+ future.completeExceptionally(new PipedreamApiClientApiException(
"Error with status code " + response.code(),
response.code(),
ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
response));
return;
} catch (IOException e) {
- future.completeExceptionally(new PipedreamApiException("Network error executing HTTP request", e));
+ future.completeExceptionally(
+ new PipedreamApiClientException("Network error executing HTTP request", e));
}
}
@Override
public void onFailure(@NotNull Call call, @NotNull IOException e) {
- future.completeExceptionally(new PipedreamApiException("Network error executing HTTP request", e));
+ future.completeExceptionally(
+ new PipedreamApiClientException("Network error executing HTTP request", e));
}
});
return future;
diff --git a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/appcategories/RawAppCategoriesClient.java b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/appcategories/RawAppCategoriesClient.java
index 497bd77..46fa62f 100644
--- a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/appcategories/RawAppCategoriesClient.java
+++ b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/appcategories/RawAppCategoriesClient.java
@@ -6,9 +6,9 @@
import com.fasterxml.jackson.core.type.TypeReference;
import com.pipedream.api.core.ClientOptions;
import com.pipedream.api.core.ObjectMappers;
-import com.pipedream.api.core.PipedreamApiApiException;
-import com.pipedream.api.core.PipedreamApiException;
-import com.pipedream.api.core.PipedreamApiHttpResponse;
+import com.pipedream.api.core.PipedreamApiClientApiException;
+import com.pipedream.api.core.PipedreamApiClientException;
+import com.pipedream.api.core.PipedreamApiClientHttpResponse;
import com.pipedream.api.core.RequestOptions;
import com.pipedream.api.types.AppCategory;
import java.io.IOException;
@@ -27,11 +27,11 @@ public RawAppCategoriesClient(ClientOptions clientOptions) {
this.clientOptions = clientOptions;
}
- public PipedreamApiHttpResponse> list() {
+ public PipedreamApiClientHttpResponse> list() {
return list(null);
}
- public PipedreamApiHttpResponse> list(RequestOptions requestOptions) {
+ public PipedreamApiClientHttpResponse> list(RequestOptions requestOptions) {
HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
.newBuilder()
.addPathSegments("v1/connect/app_categories")
@@ -49,27 +49,27 @@ public PipedreamApiHttpResponse> list(RequestOptions requestOp
try (Response response = client.newCall(okhttpRequest).execute()) {
ResponseBody responseBody = response.body();
if (response.isSuccessful()) {
- return new PipedreamApiHttpResponse<>(
+ return new PipedreamApiClientHttpResponse<>(
ObjectMappers.JSON_MAPPER.readValue(
responseBody.string(), new TypeReference>() {}),
response);
}
String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- throw new PipedreamApiApiException(
+ throw new PipedreamApiClientApiException(
"Error with status code " + response.code(),
response.code(),
ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
response);
} catch (IOException e) {
- throw new PipedreamApiException("Network error executing HTTP request", e);
+ throw new PipedreamApiClientException("Network error executing HTTP request", e);
}
}
- public PipedreamApiHttpResponse retrieve(String id) {
+ public PipedreamApiClientHttpResponse retrieve(String id) {
return retrieve(id, null);
}
- public PipedreamApiHttpResponse retrieve(String id, RequestOptions requestOptions) {
+ public PipedreamApiClientHttpResponse retrieve(String id, RequestOptions requestOptions) {
HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
.newBuilder()
.addPathSegments("v1/connect/app_categories")
@@ -88,17 +88,17 @@ public PipedreamApiHttpResponse retrieve(String id, RequestOptions
try (Response response = client.newCall(okhttpRequest).execute()) {
ResponseBody responseBody = response.body();
if (response.isSuccessful()) {
- return new PipedreamApiHttpResponse<>(
+ return new PipedreamApiClientHttpResponse<>(
ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), AppCategory.class), response);
}
String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- throw new PipedreamApiApiException(
+ throw new PipedreamApiClientApiException(
"Error with status code " + response.code(),
response.code(),
ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
response);
} catch (IOException e) {
- throw new PipedreamApiException("Network error executing HTTP request", e);
+ throw new PipedreamApiClientException("Network error executing HTTP request", e);
}
}
}
diff --git a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/apps/AsyncRawAppsClient.java b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/apps/AsyncRawAppsClient.java
index 42967c0..9146023 100644
--- a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/apps/AsyncRawAppsClient.java
+++ b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/apps/AsyncRawAppsClient.java
@@ -5,9 +5,9 @@
import com.pipedream.api.core.ClientOptions;
import com.pipedream.api.core.ObjectMappers;
-import com.pipedream.api.core.PipedreamApiApiException;
-import com.pipedream.api.core.PipedreamApiException;
-import com.pipedream.api.core.PipedreamApiHttpResponse;
+import com.pipedream.api.core.PipedreamApiClientApiException;
+import com.pipedream.api.core.PipedreamApiClientException;
+import com.pipedream.api.core.PipedreamApiClientHttpResponse;
import com.pipedream.api.core.QueryStringMapper;
import com.pipedream.api.core.RequestOptions;
import com.pipedream.api.core.pagination.SyncPagingIterable;
@@ -37,15 +37,15 @@ public AsyncRawAppsClient(ClientOptions clientOptions) {
this.clientOptions = clientOptions;
}
- public CompletableFuture>> list() {
+ public CompletableFuture>> list() {
return list(AppsListRequest.builder().build());
}
- public CompletableFuture>> list(AppsListRequest request) {
+ public CompletableFuture>> list(AppsListRequest request) {
return list(request, null);
}
- public CompletableFuture>> list(
+ public CompletableFuture>> list(
AppsListRequest request, RequestOptions requestOptions) {
HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
.newBuilder()
@@ -87,7 +87,7 @@ public CompletableFuture>> list
if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
client = clientOptions.httpClientWithTimeout(requestOptions);
}
- CompletableFuture>> future = new CompletableFuture<>();
+ CompletableFuture>> future = new CompletableFuture<>();
client.newCall(okhttpRequest).enqueue(new Callback() {
@Override
public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {
@@ -102,7 +102,7 @@ public void onResponse(@NotNull Call call, @NotNull Response response) throws IO
.after(startingAfter)
.build();
List result = parsedResponse.getData();
- future.complete(new PipedreamApiHttpResponse<>(
+ future.complete(new PipedreamApiClientHttpResponse<>(
new SyncPagingIterable(startingAfter.isPresent(), result, () -> {
try {
return list(nextRequest, requestOptions)
@@ -116,30 +116,32 @@ public void onResponse(@NotNull Call call, @NotNull Response response) throws IO
return;
}
String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- future.completeExceptionally(new PipedreamApiApiException(
+ future.completeExceptionally(new PipedreamApiClientApiException(
"Error with status code " + response.code(),
response.code(),
ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
response));
return;
} catch (IOException e) {
- future.completeExceptionally(new PipedreamApiException("Network error executing HTTP request", e));
+ future.completeExceptionally(
+ new PipedreamApiClientException("Network error executing HTTP request", e));
}
}
@Override
public void onFailure(@NotNull Call call, @NotNull IOException e) {
- future.completeExceptionally(new PipedreamApiException("Network error executing HTTP request", e));
+ future.completeExceptionally(
+ new PipedreamApiClientException("Network error executing HTTP request", e));
}
});
return future;
}
- public CompletableFuture> retrieve(String appId) {
+ public CompletableFuture> retrieve(String appId) {
return retrieve(appId, null);
}
- public CompletableFuture> retrieve(
+ public CompletableFuture> retrieve(
String appId, RequestOptions requestOptions) {
HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
.newBuilder()
@@ -156,32 +158,34 @@ public CompletableFuture> retrieve(
if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
client = clientOptions.httpClientWithTimeout(requestOptions);
}
- CompletableFuture> future = new CompletableFuture<>();
+ CompletableFuture> future = new CompletableFuture<>();
client.newCall(okhttpRequest).enqueue(new Callback() {
@Override
public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {
try (ResponseBody responseBody = response.body()) {
if (response.isSuccessful()) {
- future.complete(new PipedreamApiHttpResponse<>(
+ future.complete(new PipedreamApiClientHttpResponse<>(
ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), GetAppResponse.class),
response));
return;
}
String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- future.completeExceptionally(new PipedreamApiApiException(
+ future.completeExceptionally(new PipedreamApiClientApiException(
"Error with status code " + response.code(),
response.code(),
ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
response));
return;
} catch (IOException e) {
- future.completeExceptionally(new PipedreamApiException("Network error executing HTTP request", e));
+ future.completeExceptionally(
+ new PipedreamApiClientException("Network error executing HTTP request", e));
}
}
@Override
public void onFailure(@NotNull Call call, @NotNull IOException e) {
- future.completeExceptionally(new PipedreamApiException("Network error executing HTTP request", e));
+ future.completeExceptionally(
+ new PipedreamApiClientException("Network error executing HTTP request", e));
}
});
return future;
diff --git a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/apps/RawAppsClient.java b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/apps/RawAppsClient.java
index 37619d9..a65d416 100644
--- a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/apps/RawAppsClient.java
+++ b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/apps/RawAppsClient.java
@@ -5,9 +5,9 @@
import com.pipedream.api.core.ClientOptions;
import com.pipedream.api.core.ObjectMappers;
-import com.pipedream.api.core.PipedreamApiApiException;
-import com.pipedream.api.core.PipedreamApiException;
-import com.pipedream.api.core.PipedreamApiHttpResponse;
+import com.pipedream.api.core.PipedreamApiClientApiException;
+import com.pipedream.api.core.PipedreamApiClientException;
+import com.pipedream.api.core.PipedreamApiClientHttpResponse;
import com.pipedream.api.core.QueryStringMapper;
import com.pipedream.api.core.RequestOptions;
import com.pipedream.api.core.pagination.SyncPagingIterable;
@@ -32,15 +32,15 @@ public RawAppsClient(ClientOptions clientOptions) {
this.clientOptions = clientOptions;
}
- public PipedreamApiHttpResponse> list() {
+ public PipedreamApiClientHttpResponse> list() {
return list(AppsListRequest.builder().build());
}
- public PipedreamApiHttpResponse> list(AppsListRequest request) {
+ public PipedreamApiClientHttpResponse> list(AppsListRequest request) {
return list(request, null);
}
- public PipedreamApiHttpResponse> list(
+ public PipedreamApiClientHttpResponse> list(
AppsListRequest request, RequestOptions requestOptions) {
HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
.newBuilder()
@@ -93,28 +93,28 @@ public PipedreamApiHttpResponse> list(
.after(startingAfter)
.build();
List result = parsedResponse.getData();
- return new PipedreamApiHttpResponse<>(
+ return new PipedreamApiClientHttpResponse<>(
new SyncPagingIterable(
startingAfter.isPresent(), result, () -> list(nextRequest, requestOptions)
.body()),
response);
}
String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- throw new PipedreamApiApiException(
+ throw new PipedreamApiClientApiException(
"Error with status code " + response.code(),
response.code(),
ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
response);
} catch (IOException e) {
- throw new PipedreamApiException("Network error executing HTTP request", e);
+ throw new PipedreamApiClientException("Network error executing HTTP request", e);
}
}
- public PipedreamApiHttpResponse retrieve(String appId) {
+ public PipedreamApiClientHttpResponse retrieve(String appId) {
return retrieve(appId, null);
}
- public PipedreamApiHttpResponse retrieve(String appId, RequestOptions requestOptions) {
+ public PipedreamApiClientHttpResponse retrieve(String appId, RequestOptions requestOptions) {
HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
.newBuilder()
.addPathSegments("v1/connect/apps")
@@ -133,17 +133,17 @@ public PipedreamApiHttpResponse retrieve(String appId, RequestOp
try (Response response = client.newCall(okhttpRequest).execute()) {
ResponseBody responseBody = response.body();
if (response.isSuccessful()) {
- return new PipedreamApiHttpResponse<>(
+ return new PipedreamApiClientHttpResponse<>(
ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), GetAppResponse.class), response);
}
String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- throw new PipedreamApiApiException(
+ throw new PipedreamApiClientApiException(
"Error with status code " + response.code(),
response.code(),
ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
response);
} catch (IOException e) {
- throw new PipedreamApiException("Network error executing HTTP request", e);
+ throw new PipedreamApiClientException("Network error executing HTTP request", e);
}
}
}
diff --git a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/components/AsyncRawComponentsClient.java b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/components/AsyncRawComponentsClient.java
index 43e8178..677e973 100644
--- a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/components/AsyncRawComponentsClient.java
+++ b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/components/AsyncRawComponentsClient.java
@@ -6,9 +6,9 @@
import com.pipedream.api.core.ClientOptions;
import com.pipedream.api.core.MediaTypes;
import com.pipedream.api.core.ObjectMappers;
-import com.pipedream.api.core.PipedreamApiApiException;
-import com.pipedream.api.core.PipedreamApiException;
-import com.pipedream.api.core.PipedreamApiHttpResponse;
+import com.pipedream.api.core.PipedreamApiClientApiException;
+import com.pipedream.api.core.PipedreamApiClientException;
+import com.pipedream.api.core.PipedreamApiClientHttpResponse;
import com.pipedream.api.core.QueryStringMapper;
import com.pipedream.api.core.RequestOptions;
import com.pipedream.api.core.pagination.SyncPagingIterable;
@@ -43,16 +43,16 @@ public AsyncRawComponentsClient(ClientOptions clientOptions) {
this.clientOptions = clientOptions;
}
- public CompletableFuture>> list() {
+ public CompletableFuture>> list() {
return list(ComponentsListRequest.builder().build());
}
- public CompletableFuture>> list(
+ public CompletableFuture>> list(
ComponentsListRequest request) {
return list(request, null);
}
- public CompletableFuture>> list(
+ public CompletableFuture>> list(
ComponentsListRequest request, RequestOptions requestOptions) {
HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
.newBuilder()
@@ -87,7 +87,8 @@ public CompletableFuture>
if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
client = clientOptions.httpClientWithTimeout(requestOptions);
}
- CompletableFuture>> future = new CompletableFuture<>();
+ CompletableFuture>> future =
+ new CompletableFuture<>();
client.newCall(okhttpRequest).enqueue(new Callback() {
@Override
public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {
@@ -102,7 +103,7 @@ public void onResponse(@NotNull Call call, @NotNull Response response) throws IO
.after(startingAfter)
.build();
List result = parsedResponse.getData();
- future.complete(new PipedreamApiHttpResponse<>(
+ future.complete(new PipedreamApiClientHttpResponse<>(
new SyncPagingIterable(startingAfter.isPresent(), result, () -> {
try {
return list(nextRequest, requestOptions)
@@ -116,30 +117,32 @@ public void onResponse(@NotNull Call call, @NotNull Response response) throws IO
return;
}
String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- future.completeExceptionally(new PipedreamApiApiException(
+ future.completeExceptionally(new PipedreamApiClientApiException(
"Error with status code " + response.code(),
response.code(),
ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
response));
return;
} catch (IOException e) {
- future.completeExceptionally(new PipedreamApiException("Network error executing HTTP request", e));
+ future.completeExceptionally(
+ new PipedreamApiClientException("Network error executing HTTP request", e));
}
}
@Override
public void onFailure(@NotNull Call call, @NotNull IOException e) {
- future.completeExceptionally(new PipedreamApiException("Network error executing HTTP request", e));
+ future.completeExceptionally(
+ new PipedreamApiClientException("Network error executing HTTP request", e));
}
});
return future;
}
- public CompletableFuture> retrieve(String componentId) {
+ public CompletableFuture> retrieve(String componentId) {
return retrieve(componentId, null);
}
- public CompletableFuture> retrieve(
+ public CompletableFuture> retrieve(
String componentId, RequestOptions requestOptions) {
HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
.newBuilder()
@@ -158,7 +161,7 @@ public CompletableFuture> retrieve(
if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
client = clientOptions.httpClientWithTimeout(requestOptions);
}
- CompletableFuture> future = new CompletableFuture<>();
+ CompletableFuture> future = new CompletableFuture<>();
client.newCall(okhttpRequest).enqueue(new Callback() {
@Override
public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {
@@ -166,35 +169,37 @@ public void onResponse(@NotNull Call call, @NotNull Response response) throws IO
if (response.isSuccessful()) {
GetComponentResponse parsedResponse =
ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), GetComponentResponse.class);
- future.complete(new PipedreamApiHttpResponse<>(parsedResponse.getData(), response));
+ future.complete(new PipedreamApiClientHttpResponse<>(parsedResponse.getData(), response));
return;
}
String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- future.completeExceptionally(new PipedreamApiApiException(
+ future.completeExceptionally(new PipedreamApiClientApiException(
"Error with status code " + response.code(),
response.code(),
ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
response));
return;
} catch (IOException e) {
- future.completeExceptionally(new PipedreamApiException("Network error executing HTTP request", e));
+ future.completeExceptionally(
+ new PipedreamApiClientException("Network error executing HTTP request", e));
}
}
@Override
public void onFailure(@NotNull Call call, @NotNull IOException e) {
- future.completeExceptionally(new PipedreamApiException("Network error executing HTTP request", e));
+ future.completeExceptionally(
+ new PipedreamApiClientException("Network error executing HTTP request", e));
}
});
return future;
}
- public CompletableFuture> configureProp(
+ public CompletableFuture> configureProp(
ComponentsConfigurePropRequest request) {
return configureProp(request, null);
}
- public CompletableFuture> configureProp(
+ public CompletableFuture> configureProp(
ComponentsConfigurePropRequest request, RequestOptions requestOptions) {
HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
.newBuilder()
@@ -223,43 +228,45 @@ public CompletableFuture> config
if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
client = clientOptions.httpClientWithTimeout(requestOptions);
}
- CompletableFuture> future = new CompletableFuture<>();
+ CompletableFuture> future = new CompletableFuture<>();
client.newCall(okhttpRequest).enqueue(new Callback() {
@Override
public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException {
try (ResponseBody responseBody = response.body()) {
if (response.isSuccessful()) {
- future.complete(new PipedreamApiHttpResponse<>(
+ future.complete(new PipedreamApiClientHttpResponse<>(
ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), ConfigurePropResponse.class),
response));
return;
}
String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- future.completeExceptionally(new PipedreamApiApiException(
+ future.completeExceptionally(new PipedreamApiClientApiException(
"Error with status code " + response.code(),
response.code(),
ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
response));
return;
} catch (IOException e) {
- future.completeExceptionally(new PipedreamApiException("Network error executing HTTP request", e));
+ future.completeExceptionally(
+ new PipedreamApiClientException("Network error executing HTTP request", e));
}
}
@Override
public void onFailure(@NotNull Call call, @NotNull IOException e) {
- future.completeExceptionally(new PipedreamApiException("Network error executing HTTP request", e));
+ future.completeExceptionally(
+ new PipedreamApiClientException("Network error executing HTTP request", e));
}
});
return future;
}
- public CompletableFuture> reloadProps(
+ public CompletableFuture> reloadProps(
ComponentsReloadPropsRequest request) {
return reloadProps(request, null);
}
- public CompletableFuture> reloadProps(
+ public CompletableFuture> reloadProps(
ComponentsReloadPropsRequest request, RequestOptions requestOptions) {
HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
.newBuilder()
@@ -288,32 +295,34 @@ public CompletableFuture