1414import com .pipedream .api .core .RequestOptions ;
1515import com .pipedream .api .core .pagination .SyncPagingIterable ;
1616import com .pipedream .api .errors .TooManyRequestsError ;
17+ import com .pipedream .api .resources .accounts .requests .AccountsListRequest ;
18+ import com .pipedream .api .resources .accounts .requests .AccountsRetrieveRequest ;
1719import com .pipedream .api .resources .accounts .requests .CreateAccountOpts ;
18- import com .pipedream .api .resources .accounts .requests .DeleteAccountsRequest ;
19- import com .pipedream .api .resources .accounts .requests .DeleteByAppAccountsRequest ;
20- import com .pipedream .api .resources .accounts .requests .ListAccountsRequest ;
21- import com .pipedream .api .resources .accounts .requests .RetrieveAccountsRequest ;
2220import com .pipedream .api .types .Account ;
2321import com .pipedream .api .types .ListAccountsResponse ;
2422import java .io .IOException ;
@@ -48,21 +46,21 @@ public AsyncRawAccountsClient(ClientOptions clientOptions) {
4846 * Retrieve all connected accounts for the project with optional filtering
4947 */
5048 public CompletableFuture <BaseClientHttpResponse <SyncPagingIterable <Account >>> list () {
51- return list (ListAccountsRequest .builder ().build ());
49+ return list (AccountsListRequest .builder ().build ());
5250 }
5351
5452 /**
5553 * Retrieve all connected accounts for the project with optional filtering
5654 */
57- public CompletableFuture <BaseClientHttpResponse <SyncPagingIterable <Account >>> list (ListAccountsRequest request ) {
55+ public CompletableFuture <BaseClientHttpResponse <SyncPagingIterable <Account >>> list (AccountsListRequest request ) {
5856 return list (request , null );
5957 }
6058
6159 /**
6260 * Retrieve all connected accounts for the project with optional filtering
6361 */
6462 public CompletableFuture <BaseClientHttpResponse <SyncPagingIterable <Account >>> list (
65- ListAccountsRequest request , RequestOptions requestOptions ) {
63+ AccountsListRequest request , RequestOptions requestOptions ) {
6664 HttpUrl .Builder httpUrl = HttpUrl .parse (this .clientOptions .environment ().getUrl ())
6765 .newBuilder ()
6866 .addPathSegments ("v1/connect" )
@@ -118,7 +116,7 @@ public void onResponse(@NotNull Call call, @NotNull Response response) throws IO
118116 ObjectMappers .JSON_MAPPER .readValue (responseBody .string (), ListAccountsResponse .class );
119117 Optional <String > startingAfter =
120118 parsedResponse .getPageInfo ().getEndCursor ();
121- ListAccountsRequest nextRequest = ListAccountsRequest .builder ()
119+ AccountsListRequest nextRequest = AccountsListRequest .builder ()
122120 .from (request )
123121 .after (startingAfter )
124122 .build ();
@@ -252,22 +250,22 @@ public void onFailure(@NotNull Call call, @NotNull IOException e) {
252250 * Get the details for a specific connected account
253251 */
254252 public CompletableFuture <BaseClientHttpResponse <Account >> retrieve (String accountId ) {
255- return retrieve (accountId , RetrieveAccountsRequest .builder ().build ());
253+ return retrieve (accountId , AccountsRetrieveRequest .builder ().build ());
256254 }
257255
258256 /**
259257 * Get the details for a specific connected account
260258 */
261259 public CompletableFuture <BaseClientHttpResponse <Account >> retrieve (
262- String accountId , RetrieveAccountsRequest request ) {
260+ String accountId , AccountsRetrieveRequest request ) {
263261 return retrieve (accountId , request , null );
264262 }
265263
266264 /**
267265 * Get the details for a specific connected account
268266 */
269267 public CompletableFuture <BaseClientHttpResponse <Account >> retrieve (
270- String accountId , RetrieveAccountsRequest request , RequestOptions requestOptions ) {
268+ String accountId , AccountsRetrieveRequest request , RequestOptions requestOptions ) {
271269 HttpUrl .Builder httpUrl = HttpUrl .parse (this .clientOptions .environment ().getUrl ())
272270 .newBuilder ()
273271 .addPathSegments ("v1/connect" )
@@ -334,34 +332,26 @@ public void onFailure(@NotNull Call call, @NotNull IOException e) {
334332 * Remove a connected account and its associated credentials
335333 */
336334 public CompletableFuture <BaseClientHttpResponse <Void >> delete (String accountId ) {
337- return delete (accountId , DeleteAccountsRequest . builder (). build () );
335+ return delete (accountId , null );
338336 }
339337
340338 /**
341339 * Remove a connected account and its associated credentials
342340 */
343- public CompletableFuture <BaseClientHttpResponse <Void >> delete (String accountId , DeleteAccountsRequest request ) {
344- return delete (accountId , request , null );
345- }
346-
347- /**
348- * Remove a connected account and its associated credentials
349- */
350- public CompletableFuture <BaseClientHttpResponse <Void >> delete (
351- String accountId , DeleteAccountsRequest request , RequestOptions requestOptions ) {
341+ public CompletableFuture <BaseClientHttpResponse <Void >> delete (String accountId , RequestOptions requestOptions ) {
352342 HttpUrl httpUrl = HttpUrl .parse (this .clientOptions .environment ().getUrl ())
353343 .newBuilder ()
354344 .addPathSegments ("v1/connect" )
355345 .addPathSegment (clientOptions .projectId ())
356346 .addPathSegments ("accounts" )
357347 .addPathSegment (accountId )
358348 .build ();
359- Request . Builder _requestBuilder = new Request .Builder ()
349+ Request okhttpRequest = new Request .Builder ()
360350 .url (httpUrl )
361351 .method ("DELETE" , null )
362352 .headers (Headers .of (clientOptions .headers (requestOptions )))
363- .addHeader ("Accept" , "application/json" );
364- Request okhttpRequest = _requestBuilder .build ();
353+ .addHeader ("Accept" , "application/json" )
354+ .build ();
365355 OkHttpClient client = clientOptions .httpClient ();
366356 if (requestOptions != null && requestOptions .getTimeout ().isPresent ()) {
367357 client = clientOptions .httpClientWithTimeout (requestOptions );
@@ -408,22 +398,13 @@ public void onFailure(@NotNull Call call, @NotNull IOException e) {
408398 * Remove all connected accounts for a specific app
409399 */
410400 public CompletableFuture <BaseClientHttpResponse <Void >> deleteByApp (String appId ) {
411- return deleteByApp (appId , DeleteByAppAccountsRequest . builder (). build () );
401+ return deleteByApp (appId , null );
412402 }
413403
414404 /**
415405 * Remove all connected accounts for a specific app
416406 */
417- public CompletableFuture <BaseClientHttpResponse <Void >> deleteByApp (
418- String appId , DeleteByAppAccountsRequest request ) {
419- return deleteByApp (appId , request , null );
420- }
421-
422- /**
423- * Remove all connected accounts for a specific app
424- */
425- public CompletableFuture <BaseClientHttpResponse <Void >> deleteByApp (
426- String appId , DeleteByAppAccountsRequest request , RequestOptions requestOptions ) {
407+ public CompletableFuture <BaseClientHttpResponse <Void >> deleteByApp (String appId , RequestOptions requestOptions ) {
427408 HttpUrl httpUrl = HttpUrl .parse (this .clientOptions .environment ().getUrl ())
428409 .newBuilder ()
429410 .addPathSegments ("v1/connect" )
@@ -432,12 +413,12 @@ public CompletableFuture<BaseClientHttpResponse<Void>> deleteByApp(
432413 .addPathSegment (appId )
433414 .addPathSegments ("accounts" )
434415 .build ();
435- Request . Builder _requestBuilder = new Request .Builder ()
416+ Request okhttpRequest = new Request .Builder ()
436417 .url (httpUrl )
437418 .method ("DELETE" , null )
438419 .headers (Headers .of (clientOptions .headers (requestOptions )))
439- .addHeader ("Accept" , "application/json" );
440- Request okhttpRequest = _requestBuilder .build ();
420+ .addHeader ("Accept" , "application/json" )
421+ .build ();
441422 OkHttpClient client = clientOptions .httpClient ();
442423 if (requestOptions != null && requestOptions .getTimeout ().isPresent ()) {
443424 client = clientOptions .httpClientWithTimeout (requestOptions );
0 commit comments