Skip to content

Commit 21ae9fb

Browse files
fern-api[bot]fern-api[bot]
committed
SDK regeneration
1 parent a6f5ae3 commit 21ae9fb

File tree

64 files changed

+2768
-11072
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

64 files changed

+2768
-11072
lines changed

‎src/main/java/com/pipedream/api/resources/actions/ActionsClient.java‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -6,12 +6,12 @@
66
import com.pipedream.api.core.ClientOptions;
77
import com.pipedream.api.core.RequestOptions;
88
import com.pipedream.api.core.pagination.SyncPagingIterable;
9+
import com.pipedream.api.resources.actions.requests.ActionsConfigurePropRequest;
910
import com.pipedream.api.resources.actions.requests.ActionsListRequest;
11+
import com.pipedream.api.resources.actions.requests.ActionsReloadPropsRequest;
1012
import com.pipedream.api.resources.actions.requests.RunActionOpts;
1113
import com.pipedream.api.types.Component;
12-
import com.pipedream.api.types.ConfigurePropOpts;
1314
import com.pipedream.api.types.ConfigurePropResponse;
14-
import com.pipedream.api.types.ReloadPropsOpts;
1515
import com.pipedream.api.types.ReloadPropsResponse;
1616
import com.pipedream.api.types.RunActionResponse;
1717

@@ -52,19 +52,19 @@ public Component retrieve(String componentId, RequestOptions requestOptions) {
5252
return this.rawClient.retrieve(componentId, requestOptions).body();
5353
}
5454

55-
public ConfigurePropResponse configureProp(ConfigurePropOpts request) {
55+
public ConfigurePropResponse configureProp(ActionsConfigurePropRequest request) {
5656
return this.rawClient.configureProp(request).body();
5757
}
5858

59-
public ConfigurePropResponse configureProp(ConfigurePropOpts request, RequestOptions requestOptions) {
59+
public ConfigurePropResponse configureProp(ActionsConfigurePropRequest request, RequestOptions requestOptions) {
6060
return this.rawClient.configureProp(request, requestOptions).body();
6161
}
6262

63-
public ReloadPropsResponse reloadProps(ReloadPropsOpts request) {
63+
public ReloadPropsResponse reloadProps(ActionsReloadPropsRequest request) {
6464
return this.rawClient.reloadProps(request).body();
6565
}
6666

67-
public ReloadPropsResponse reloadProps(ReloadPropsOpts request, RequestOptions requestOptions) {
67+
public ReloadPropsResponse reloadProps(ActionsReloadPropsRequest request, RequestOptions requestOptions) {
6868
return this.rawClient.reloadProps(request, requestOptions).body();
6969
}
7070

‎src/main/java/com/pipedream/api/resources/actions/AsyncActionsClient.java‎

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -6,12 +6,12 @@
66
import com.pipedream.api.core.ClientOptions;
77
import com.pipedream.api.core.RequestOptions;
88
import com.pipedream.api.core.pagination.SyncPagingIterable;
9+
import com.pipedream.api.resources.actions.requests.ActionsConfigurePropRequest;
910
import com.pipedream.api.resources.actions.requests.ActionsListRequest;
11+
import com.pipedream.api.resources.actions.requests.ActionsReloadPropsRequest;
1012
import com.pipedream.api.resources.actions.requests.RunActionOpts;
1113
import com.pipedream.api.types.Component;
12-
import com.pipedream.api.types.ConfigurePropOpts;
1314
import com.pipedream.api.types.ConfigurePropResponse;
14-
import com.pipedream.api.types.ReloadPropsOpts;
1515
import com.pipedream.api.types.ReloadPropsResponse;
1616
import com.pipedream.api.types.RunActionResponse;
1717
import java.util.concurrent.CompletableFuture;
@@ -54,20 +54,21 @@ public CompletableFuture<Component> retrieve(String componentId, RequestOptions
5454
return this.rawClient.retrieve(componentId, requestOptions).thenApply(response -> response.body());
5555
}
5656

57-
public CompletableFuture<ConfigurePropResponse> configureProp(ConfigurePropOpts request) {
57+
public CompletableFuture<ConfigurePropResponse> configureProp(ActionsConfigurePropRequest request) {
5858
return this.rawClient.configureProp(request).thenApply(response -> response.body());
5959
}
6060

6161
public CompletableFuture<ConfigurePropResponse> configureProp(
62-
ConfigurePropOpts request, RequestOptions requestOptions) {
62+
ActionsConfigurePropRequest request, RequestOptions requestOptions) {
6363
return this.rawClient.configureProp(request, requestOptions).thenApply(response -> response.body());
6464
}
6565

66-
public CompletableFuture<ReloadPropsResponse> reloadProps(ReloadPropsOpts request) {
66+
public CompletableFuture<ReloadPropsResponse> reloadProps(ActionsReloadPropsRequest request) {
6767
return this.rawClient.reloadProps(request).thenApply(response -> response.body());
6868
}
6969

70-
public CompletableFuture<ReloadPropsResponse> reloadProps(ReloadPropsOpts request, RequestOptions requestOptions) {
70+
public CompletableFuture<ReloadPropsResponse> reloadProps(
71+
ActionsReloadPropsRequest request, RequestOptions requestOptions) {
7172
return this.rawClient.reloadProps(request, requestOptions).thenApply(response -> response.body());
7273
}
7374

‎src/main/java/com/pipedream/api/resources/actions/AsyncRawActionsClient.java‎

Lines changed: 46 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,6 @@
33
*/
44
package com.pipedream.api.resources.actions;
55

6-
import com.fasterxml.jackson.core.JsonProcessingException;
76
import com.pipedream.api.core.BaseClientApiException;
87
import com.pipedream.api.core.BaseClientException;
98
import com.pipedream.api.core.BaseClientHttpResponse;
@@ -13,18 +12,20 @@
1312
import com.pipedream.api.core.QueryStringMapper;
1413
import com.pipedream.api.core.RequestOptions;
1514
import com.pipedream.api.core.pagination.SyncPagingIterable;
15+
import com.pipedream.api.resources.actions.requests.ActionsConfigurePropRequest;
1616
import com.pipedream.api.resources.actions.requests.ActionsListRequest;
17+
import com.pipedream.api.resources.actions.requests.ActionsReloadPropsRequest;
1718
import com.pipedream.api.resources.actions.requests.RunActionOpts;
1819
import com.pipedream.api.types.Component;
19-
import com.pipedream.api.types.ConfigurePropOpts;
2020
import com.pipedream.api.types.ConfigurePropResponse;
2121
import com.pipedream.api.types.GetComponentResponse;
2222
import com.pipedream.api.types.GetComponentsResponse;
23-
import com.pipedream.api.types.ReloadPropsOpts;
2423
import com.pipedream.api.types.ReloadPropsResponse;
2524
import com.pipedream.api.types.RunActionResponse;
2625
import java.io.IOException;
26+
import java.util.HashMap;
2727
import java.util.List;
28+
import java.util.Map;
2829
import java.util.Optional;
2930
import java.util.concurrent.CompletableFuture;
3031
import java.util.concurrent.ExecutionException;
@@ -191,12 +192,13 @@ public void onFailure(@NotNull Call call, @NotNull IOException e) {
191192
return future;
192193
}
193194

194-
public CompletableFuture<BaseClientHttpResponse<ConfigurePropResponse>> configureProp(ConfigurePropOpts request) {
195+
public CompletableFuture<BaseClientHttpResponse<ConfigurePropResponse>> configureProp(
196+
ActionsConfigurePropRequest request) {
195197
return configureProp(request, null);
196198
}
197199

198200
public CompletableFuture<BaseClientHttpResponse<ConfigurePropResponse>> configureProp(
199-
ConfigurePropOpts request, RequestOptions requestOptions) {
201+
ActionsConfigurePropRequest request, RequestOptions requestOptions) {
200202
HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
201203
.newBuilder()
202204
.addPathSegments("v1/connect")
@@ -206,17 +208,20 @@ public CompletableFuture<BaseClientHttpResponse<ConfigurePropResponse>> configur
206208
RequestBody body;
207209
try {
208210
body = RequestBody.create(
209-
ObjectMappers.JSON_MAPPER.writeValueAsBytes(request), MediaTypes.APPLICATION_JSON);
210-
} catch (JsonProcessingException e) {
211-
throw new BaseClientException("Failed to serialize request", e);
211+
ObjectMappers.JSON_MAPPER.writeValueAsBytes(request.getBody()), MediaTypes.APPLICATION_JSON);
212+
} catch (Exception e) {
213+
throw new RuntimeException(e);
212214
}
213-
Request okhttpRequest = new Request.Builder()
215+
Request.Builder _requestBuilder = new Request.Builder()
214216
.url(httpUrl)
215217
.method("POST", body)
216218
.headers(Headers.of(clientOptions.headers(requestOptions)))
217219
.addHeader("Content-Type", "application/json")
218-
.addHeader("Accept", "application/json")
219-
.build();
220+
.addHeader("Accept", "application/json");
221+
if (request.getAsyncHandle().isPresent()) {
222+
_requestBuilder.addHeader("x-async-handle", request.getAsyncHandle().get());
223+
}
224+
Request okhttpRequest = _requestBuilder.build();
220225
OkHttpClient client = clientOptions.httpClient();
221226
if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
222227
client = clientOptions.httpClientWithTimeout(requestOptions);
@@ -252,12 +257,13 @@ public void onFailure(@NotNull Call call, @NotNull IOException e) {
252257
return future;
253258
}
254259

255-
public CompletableFuture<BaseClientHttpResponse<ReloadPropsResponse>> reloadProps(ReloadPropsOpts request) {
260+
public CompletableFuture<BaseClientHttpResponse<ReloadPropsResponse>> reloadProps(
261+
ActionsReloadPropsRequest request) {
256262
return reloadProps(request, null);
257263
}
258264

259265
public CompletableFuture<BaseClientHttpResponse<ReloadPropsResponse>> reloadProps(
260-
ReloadPropsOpts request, RequestOptions requestOptions) {
266+
ActionsReloadPropsRequest request, RequestOptions requestOptions) {
261267
HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
262268
.newBuilder()
263269
.addPathSegments("v1/connect")
@@ -267,17 +273,20 @@ public CompletableFuture<BaseClientHttpResponse<ReloadPropsResponse>> reloadProp
267273
RequestBody body;
268274
try {
269275
body = RequestBody.create(
270-
ObjectMappers.JSON_MAPPER.writeValueAsBytes(request), MediaTypes.APPLICATION_JSON);
271-
} catch (JsonProcessingException e) {
272-
throw new BaseClientException("Failed to serialize request", e);
276+
ObjectMappers.JSON_MAPPER.writeValueAsBytes(request.getBody()), MediaTypes.APPLICATION_JSON);
277+
} catch (Exception e) {
278+
throw new RuntimeException(e);
273279
}
274-
Request okhttpRequest = new Request.Builder()
280+
Request.Builder _requestBuilder = new Request.Builder()
275281
.url(httpUrl)
276282
.method("POST", body)
277283
.headers(Headers.of(clientOptions.headers(requestOptions)))
278284
.addHeader("Content-Type", "application/json")
279-
.addHeader("Accept", "application/json")
280-
.build();
285+
.addHeader("Accept", "application/json");
286+
if (request.getAsyncHandle().isPresent()) {
287+
_requestBuilder.addHeader("x-async-handle", request.getAsyncHandle().get());
288+
}
289+
Request okhttpRequest = _requestBuilder.build();
281290
OkHttpClient client = clientOptions.httpClient();
282291
if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
283292
client = clientOptions.httpClientWithTimeout(requestOptions);
@@ -325,20 +334,32 @@ public CompletableFuture<BaseClientHttpResponse<RunActionResponse>> run(
325334
.addPathSegment(clientOptions.projectId())
326335
.addPathSegments("actions/run")
327336
.build();
337+
Map<String, Object> properties = new HashMap<>();
338+
properties.put("id", request.getId());
339+
properties.put("external_user_id", request.getExternalUserId());
340+
if (request.getConfiguredProps().isPresent()) {
341+
properties.put("configured_props", request.getConfiguredProps());
342+
}
343+
if (request.getDynamicPropsId().isPresent()) {
344+
properties.put("dynamic_props_id", request.getDynamicPropsId());
345+
}
328346
RequestBody body;
329347
try {
330348
body = RequestBody.create(
331-
ObjectMappers.JSON_MAPPER.writeValueAsBytes(request), MediaTypes.APPLICATION_JSON);
332-
} catch (JsonProcessingException e) {
333-
throw new BaseClientException("Failed to serialize request", e);
349+
ObjectMappers.JSON_MAPPER.writeValueAsBytes(properties), MediaTypes.APPLICATION_JSON);
350+
} catch (Exception e) {
351+
throw new RuntimeException(e);
334352
}
335-
Request okhttpRequest = new Request.Builder()
353+
Request.Builder _requestBuilder = new Request.Builder()
336354
.url(httpUrl)
337355
.method("POST", body)
338356
.headers(Headers.of(clientOptions.headers(requestOptions)))
339357
.addHeader("Content-Type", "application/json")
340-
.addHeader("Accept", "application/json")
341-
.build();
358+
.addHeader("Accept", "application/json");
359+
if (request.getAsyncHandle().isPresent()) {
360+
_requestBuilder.addHeader("x-async-handle", request.getAsyncHandle().get());
361+
}
362+
Request okhttpRequest = _requestBuilder.build();
342363
OkHttpClient client = clientOptions.httpClient();
343364
if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
344365
client = clientOptions.httpClientWithTimeout(requestOptions);

0 commit comments

Comments
 (0)