nextBackoff() {
- retryNumber += 1;
- if (retryNumber > maxNumRetries) {
- return Optional.empty();
- }
-
- int upperBound = (int) Math.pow(2, retryNumber);
- return Optional.of(ONE_SECOND.multipliedBy(random.nextInt(upperBound)));
- }
- }
-}
diff --git a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/core/Stream.java b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/core/Stream.java
deleted file mode 100644
index 3781dcc..0000000
--- a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/core/Stream.java
+++ /dev/null
@@ -1,272 +0,0 @@
-/**
- * This file was auto-generated by Fern from our API Definition.
- */
-package com.pipedream.api.core;
-
-import java.io.Closeable;
-import java.io.IOException;
-import java.io.Reader;
-import java.util.Iterator;
-import java.util.NoSuchElementException;
-import java.util.Scanner;
-
-/**
- * The {@code Stream} class implements {@link Iterable} to provide a simple mechanism for reading and parsing
- * objects of a given type from data streamed via a {@link Reader} using a specified delimiter.
- *
- * {@code Stream} assumes that data is being pushed to the provided {@link Reader} asynchronously and utilizes a
- * {@code Scanner} to block during iteration if the next object is not available.
- * Iterable stream for parsing JSON and Server-Sent Events (SSE) data.
- * Supports both newline-delimited JSON and SSE with optional stream termination.
- *
- * @param The type of objects in the stream.
- */
-public final class Stream implements Iterable, Closeable {
-
- private static final String NEWLINE = "\n";
- private static final String DATA_PREFIX = "data:";
-
- public enum StreamType {
- JSON,
- SSE
- }
-
- private final Class valueType;
- private final Scanner scanner;
- private final StreamType streamType;
- private final String messageTerminator;
- private final String streamTerminator;
- private final Reader sseReader;
- private boolean isClosed = false;
-
- /**
- * Constructs a new {@code Stream} with the specified value type, reader, and delimiter.
- *
- * @param valueType The class of the objects in the stream.
- * @param reader The reader that provides the streamed data.
- * @param delimiter The delimiter used to separate elements in the stream.
- */
- public Stream(Class valueType, Reader reader, String delimiter) {
- this.valueType = valueType;
- this.scanner = new Scanner(reader).useDelimiter(delimiter);
- this.streamType = StreamType.JSON;
- this.messageTerminator = delimiter;
- this.streamTerminator = null;
- this.sseReader = null;
- }
-
- private Stream(Class valueType, StreamType type, Reader reader, String terminator) {
- this.valueType = valueType;
- this.streamType = type;
- if (type == StreamType.JSON) {
- this.scanner = new Scanner(reader).useDelimiter(terminator);
- this.messageTerminator = terminator;
- this.streamTerminator = null;
- this.sseReader = null;
- } else {
- this.scanner = null;
- this.messageTerminator = NEWLINE;
- this.streamTerminator = terminator;
- this.sseReader = reader;
- }
- }
-
- public static Stream fromJson(Class valueType, Reader reader, String delimiter) {
- return new Stream<>(valueType, reader, delimiter);
- }
-
- public static Stream fromJson(Class valueType, Reader reader) {
- return new Stream<>(valueType, reader, NEWLINE);
- }
-
- public static Stream fromSse(Class valueType, Reader sseReader) {
- return new Stream<>(valueType, StreamType.SSE, sseReader, null);
- }
-
- public static Stream fromSse(Class valueType, Reader sseReader, String streamTerminator) {
- return new Stream<>(valueType, StreamType.SSE, sseReader, streamTerminator);
- }
-
- @Override
- public void close() throws IOException {
- if (!isClosed) {
- isClosed = true;
- if (scanner != null) {
- scanner.close();
- }
- if (sseReader != null) {
- sseReader.close();
- }
- }
- }
-
- private boolean isStreamClosed() {
- return isClosed;
- }
-
- /**
- * Returns an iterator over the elements in this stream that blocks during iteration when the next object is
- * not yet available.
- *
- * @return An iterator that can be used to traverse the elements in the stream.
- */
- @Override
- public Iterator iterator() {
- if (streamType == StreamType.SSE) {
- return new SSEIterator();
- } else {
- return new JsonIterator();
- }
- }
-
- private final class JsonIterator implements Iterator {
-
- /**
- * Returns {@code true} if there are more elements in the stream.
- *
- * Will block and wait for input if the stream has not ended and the next object is not yet available.
- *
- * @return {@code true} if there are more elements, {@code false} otherwise.
- */
- @Override
- public boolean hasNext() {
- if (isStreamClosed()) {
- return false;
- }
- return scanner.hasNext();
- }
-
- /**
- * Returns the next element in the stream.
- *
- * Will block and wait for input if the stream has not ended and the next object is not yet available.
- *
- * @return The next element in the stream.
- * @throws NoSuchElementException If there are no more elements in the stream.
- */
- @Override
- public T next() {
- if (isStreamClosed()) {
- throw new NoSuchElementException("Stream is closed");
- }
-
- if (!scanner.hasNext()) {
- throw new NoSuchElementException();
- } else {
- try {
- T parsedResponse =
- ObjectMappers.JSON_MAPPER.readValue(scanner.next().trim(), valueType);
- return parsedResponse;
- } catch (Exception e) {
- throw new RuntimeException(e);
- }
- }
- }
-
- @Override
- public void remove() {
- throw new UnsupportedOperationException();
- }
- }
-
- private final class SSEIterator implements Iterator {
- private Scanner sseScanner;
- private T nextItem;
- private boolean hasNextItem = false;
- private boolean endOfStream = false;
- private StringBuilder buffer = new StringBuilder();
- private boolean prefixSeen = false;
-
- private SSEIterator() {
- if (sseReader != null && !isStreamClosed()) {
- this.sseScanner = new Scanner(sseReader);
- } else {
- this.endOfStream = true;
- }
- }
-
- @Override
- public boolean hasNext() {
- if (isStreamClosed() || endOfStream) {
- return false;
- }
-
- if (hasNextItem) {
- return true;
- }
-
- return readNextMessage();
- }
-
- @Override
- public T next() {
- if (!hasNext()) {
- throw new NoSuchElementException("No more elements in stream");
- }
-
- T result = nextItem;
- nextItem = null;
- hasNextItem = false;
- return result;
- }
-
- @Override
- public void remove() {
- throw new UnsupportedOperationException();
- }
-
- private boolean readNextMessage() {
- if (sseScanner == null || isStreamClosed()) {
- endOfStream = true;
- return false;
- }
-
- try {
- while (sseScanner.hasNextLine()) {
- String chunk = sseScanner.nextLine();
- buffer.append(chunk).append(NEWLINE);
-
- int terminatorIndex;
- while ((terminatorIndex = buffer.indexOf(messageTerminator)) >= 0) {
- String line = buffer.substring(0, terminatorIndex + messageTerminator.length());
- buffer.delete(0, terminatorIndex + messageTerminator.length());
-
- line = line.trim();
- if (line.isEmpty()) {
- continue;
- }
-
- if (!prefixSeen && line.startsWith(DATA_PREFIX)) {
- prefixSeen = true;
- line = line.substring(DATA_PREFIX.length()).trim();
- } else if (!prefixSeen) {
- continue;
- }
-
- if (streamTerminator != null && line.contains(streamTerminator)) {
- endOfStream = true;
- return false;
- }
-
- try {
- nextItem = ObjectMappers.JSON_MAPPER.readValue(line, valueType);
- hasNextItem = true;
- prefixSeen = false;
- return true;
- } catch (Exception parseEx) {
- continue;
- }
- }
- }
-
- endOfStream = true;
- return false;
-
- } catch (Exception e) {
- System.err.println("Failed to parse SSE stream: " + e.getMessage());
- endOfStream = true;
- return false;
- }
- }
- }
-}
diff --git a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/core/Suppliers.java b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/core/Suppliers.java
deleted file mode 100644
index b907552..0000000
--- a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/core/Suppliers.java
+++ /dev/null
@@ -1,23 +0,0 @@
-/**
- * This file was auto-generated by Fern from our API Definition.
- */
-package com.pipedream.api.core;
-
-import java.util.Objects;
-import java.util.concurrent.atomic.AtomicReference;
-import java.util.function.Supplier;
-
-public final class Suppliers {
- private Suppliers() {}
-
- public static Supplier memoize(Supplier delegate) {
- AtomicReference value = new AtomicReference<>();
- return () -> {
- T val = value.get();
- if (val == null) {
- val = value.updateAndGet(cur -> cur == null ? Objects.requireNonNull(delegate.get()) : cur);
- }
- return val;
- };
- }
-}
diff --git a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/core/pagination/BasePage.java b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/core/pagination/BasePage.java
deleted file mode 100644
index ca83fe4..0000000
--- a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/core/pagination/BasePage.java
+++ /dev/null
@@ -1,24 +0,0 @@
-/**
- * This file was auto-generated by Fern from our API Definition.
- */
-package com.pipedream.api.core.pagination;
-
-import java.util.List;
-
-public abstract class BasePage {
- private final boolean hasNext;
- private final List items;
-
- public BasePage(boolean hasNext, List items) {
- this.hasNext = hasNext;
- this.items = items;
- }
-
- public boolean hasNext() {
- return !items.isEmpty() && hasNext;
- }
-
- public List getItems() {
- return items;
- }
-}
diff --git a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/core/pagination/SyncPage.java b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/core/pagination/SyncPage.java
deleted file mode 100644
index 86fc5b7..0000000
--- a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/core/pagination/SyncPage.java
+++ /dev/null
@@ -1,24 +0,0 @@
-/**
- * This file was auto-generated by Fern from our API Definition.
- */
-package com.pipedream.api.core.pagination;
-
-import java.util.List;
-import java.util.NoSuchElementException;
-import java.util.function.Supplier;
-
-public class SyncPage extends BasePage {
- protected final Supplier> nextSupplier;
-
- public SyncPage(boolean hasNext, List items, Supplier> nextSupplier) {
- super(hasNext, items);
- this.nextSupplier = nextSupplier;
- }
-
- public SyncPage nextPage() {
- if (!hasNext()) {
- throw new NoSuchElementException();
- }
- return nextSupplier.get();
- }
-}
diff --git a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/core/pagination/SyncPagingIterable.java b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/core/pagination/SyncPagingIterable.java
deleted file mode 100644
index fd5fca3..0000000
--- a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/core/pagination/SyncPagingIterable.java
+++ /dev/null
@@ -1,61 +0,0 @@
-/**
- * This file was auto-generated by Fern from our API Definition.
- */
-package com.pipedream.api.core.pagination;
-
-import java.util.ArrayList;
-import java.util.Iterator;
-import java.util.List;
-import java.util.NoSuchElementException;
-import java.util.Optional;
-import java.util.function.Supplier;
-import java.util.stream.Stream;
-import java.util.stream.StreamSupport;
-
-public class SyncPagingIterable extends SyncPage implements Iterable {
-
- public SyncPagingIterable(boolean hasNext, List items, Supplier> getNext) {
- super(hasNext, items, getNext);
- }
-
- public SyncPagingIterable(boolean hasNext, Optional> items, Supplier> getNext) {
- super(hasNext, items.orElse(new ArrayList<>()), getNext);
- }
-
- public Stream streamItems() {
- return StreamSupport.stream(this.spliterator(), false);
- }
-
- @Override
- public Iterator iterator() {
- return new Iterator() {
- private Iterator itemsIterator = getItems().iterator();
- private SyncPage currentPage = SyncPagingIterable.this;
-
- @Override
- public boolean hasNext() {
- if (itemsIterator.hasNext()) {
- return true;
- }
- if (currentPage.hasNext()) {
- advancePage();
- return itemsIterator.hasNext();
- }
- return false;
- }
-
- @Override
- public T next() {
- if (!hasNext()) {
- throw new NoSuchElementException();
- }
- return itemsIterator.next();
- }
-
- private void advancePage() {
- currentPage = currentPage.nextPage();
- itemsIterator = currentPage.getItems().iterator();
- }
- };
- }
-}
diff --git a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/accounts/AccountsClient.java b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/accounts/AccountsClient.java
deleted file mode 100644
index 4e8b110..0000000
--- a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/accounts/AccountsClient.java
+++ /dev/null
@@ -1,78 +0,0 @@
-/**
- * This file was auto-generated by Fern from our API Definition.
- */
-package com.pipedream.api.resources.accounts;
-
-import com.pipedream.api.core.ClientOptions;
-import com.pipedream.api.core.RequestOptions;
-import com.pipedream.api.core.pagination.SyncPagingIterable;
-import com.pipedream.api.resources.accounts.requests.AccountsListRequest;
-import com.pipedream.api.resources.accounts.requests.AccountsRetrieveRequest;
-import com.pipedream.api.resources.accounts.requests.CreateAccountOpts;
-import com.pipedream.api.types.Account;
-
-public class AccountsClient {
- protected final ClientOptions clientOptions;
-
- private final RawAccountsClient rawClient;
-
- public AccountsClient(ClientOptions clientOptions) {
- this.clientOptions = clientOptions;
- this.rawClient = new RawAccountsClient(clientOptions);
- }
-
- /**
- * Get responses with HTTP metadata like headers
- */
- public RawAccountsClient withRawResponse() {
- return this.rawClient;
- }
-
- public SyncPagingIterable list() {
- return this.rawClient.list().body();
- }
-
- public SyncPagingIterable list(AccountsListRequest request) {
- return this.rawClient.list(request).body();
- }
-
- public SyncPagingIterable list(AccountsListRequest request, RequestOptions requestOptions) {
- return this.rawClient.list(request, requestOptions).body();
- }
-
- public Account create(CreateAccountOpts request) {
- return this.rawClient.create(request).body();
- }
-
- public Account create(CreateAccountOpts request, RequestOptions requestOptions) {
- return this.rawClient.create(request, requestOptions).body();
- }
-
- public Account retrieve(String accountId) {
- return this.rawClient.retrieve(accountId).body();
- }
-
- public Account retrieve(String accountId, AccountsRetrieveRequest request) {
- return this.rawClient.retrieve(accountId, request).body();
- }
-
- public Account retrieve(String accountId, AccountsRetrieveRequest request, RequestOptions requestOptions) {
- return this.rawClient.retrieve(accountId, request, requestOptions).body();
- }
-
- public void delete(String accountId) {
- this.rawClient.delete(accountId).body();
- }
-
- public void delete(String accountId, RequestOptions requestOptions) {
- this.rawClient.delete(accountId, requestOptions).body();
- }
-
- public void deleteByApp(String appId) {
- this.rawClient.deleteByApp(appId).body();
- }
-
- public void deleteByApp(String appId, RequestOptions requestOptions) {
- this.rawClient.deleteByApp(appId, requestOptions).body();
- }
-}
diff --git a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/accounts/AsyncAccountsClient.java b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/accounts/AsyncAccountsClient.java
deleted file mode 100644
index 34158ac..0000000
--- a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/accounts/AsyncAccountsClient.java
+++ /dev/null
@@ -1,81 +0,0 @@
-/**
- * This file was auto-generated by Fern from our API Definition.
- */
-package com.pipedream.api.resources.accounts;
-
-import com.pipedream.api.core.ClientOptions;
-import com.pipedream.api.core.RequestOptions;
-import com.pipedream.api.core.pagination.SyncPagingIterable;
-import com.pipedream.api.resources.accounts.requests.AccountsListRequest;
-import com.pipedream.api.resources.accounts.requests.AccountsRetrieveRequest;
-import com.pipedream.api.resources.accounts.requests.CreateAccountOpts;
-import com.pipedream.api.types.Account;
-import java.util.concurrent.CompletableFuture;
-
-public class AsyncAccountsClient {
- protected final ClientOptions clientOptions;
-
- private final AsyncRawAccountsClient rawClient;
-
- public AsyncAccountsClient(ClientOptions clientOptions) {
- this.clientOptions = clientOptions;
- this.rawClient = new AsyncRawAccountsClient(clientOptions);
- }
-
- /**
- * Get responses with HTTP metadata like headers
- */
- public AsyncRawAccountsClient withRawResponse() {
- return this.rawClient;
- }
-
- public CompletableFuture> list() {
- return this.rawClient.list().thenApply(response -> response.body());
- }
-
- public CompletableFuture> list(AccountsListRequest request) {
- return this.rawClient.list(request).thenApply(response -> response.body());
- }
-
- public CompletableFuture> list(
- AccountsListRequest request, RequestOptions requestOptions) {
- return this.rawClient.list(request, requestOptions).thenApply(response -> response.body());
- }
-
- public CompletableFuture create(CreateAccountOpts request) {
- return this.rawClient.create(request).thenApply(response -> response.body());
- }
-
- public CompletableFuture create(CreateAccountOpts request, RequestOptions requestOptions) {
- return this.rawClient.create(request, requestOptions).thenApply(response -> response.body());
- }
-
- public CompletableFuture retrieve(String accountId) {
- return this.rawClient.retrieve(accountId).thenApply(response -> response.body());
- }
-
- public CompletableFuture retrieve(String accountId, AccountsRetrieveRequest request) {
- return this.rawClient.retrieve(accountId, request).thenApply(response -> response.body());
- }
-
- public CompletableFuture retrieve(
- String accountId, AccountsRetrieveRequest request, RequestOptions requestOptions) {
- return this.rawClient.retrieve(accountId, request, requestOptions).thenApply(response -> response.body());
- }
-
- public CompletableFuture delete(String accountId) {
- return this.rawClient.delete(accountId).thenApply(response -> response.body());
- }
-
- public CompletableFuture delete(String accountId, RequestOptions requestOptions) {
- return this.rawClient.delete(accountId, requestOptions).thenApply(response -> response.body());
- }
-
- public CompletableFuture deleteByApp(String appId) {
- return this.rawClient.deleteByApp(appId).thenApply(response -> response.body());
- }
-
- public CompletableFuture deleteByApp(String appId, RequestOptions requestOptions) {
- return this.rawClient.deleteByApp(appId, requestOptions).thenApply(response -> response.body());
- }
-}
diff --git a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/accounts/AsyncRawAccountsClient.java b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/accounts/AsyncRawAccountsClient.java
deleted file mode 100644
index ea4f83a..0000000
--- a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/accounts/AsyncRawAccountsClient.java
+++ /dev/null
@@ -1,391 +0,0 @@
-/**
- * This file was auto-generated by Fern from our API Definition.
- */
-package com.pipedream.api.resources.accounts;
-
-import com.pipedream.api.core.BaseClientApiException;
-import com.pipedream.api.core.BaseClientException;
-import com.pipedream.api.core.BaseClientHttpResponse;
-import com.pipedream.api.core.ClientOptions;
-import com.pipedream.api.core.MediaTypes;
-import com.pipedream.api.core.ObjectMappers;
-import com.pipedream.api.core.QueryStringMapper;
-import com.pipedream.api.core.RequestOptions;
-import com.pipedream.api.core.pagination.SyncPagingIterable;
-import com.pipedream.api.resources.accounts.requests.AccountsListRequest;
-import com.pipedream.api.resources.accounts.requests.AccountsRetrieveRequest;
-import com.pipedream.api.resources.accounts.requests.CreateAccountOpts;
-import com.pipedream.api.types.Account;
-import com.pipedream.api.types.ListAccountsResponse;
-import java.io.IOException;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Optional;
-import java.util.concurrent.CompletableFuture;
-import java.util.concurrent.ExecutionException;
-import okhttp3.Call;
-import okhttp3.Callback;
-import okhttp3.Headers;
-import okhttp3.HttpUrl;
-import okhttp3.OkHttpClient;
-import okhttp3.Request;
-import okhttp3.RequestBody;
-import okhttp3.Response;
-import okhttp3.ResponseBody;
-import org.jetbrains.annotations.NotNull;
-
-public class AsyncRawAccountsClient {
- protected final ClientOptions clientOptions;
-
- public AsyncRawAccountsClient(ClientOptions clientOptions) {
- this.clientOptions = clientOptions;
- }
-
- public CompletableFuture>> list() {
- return list(AccountsListRequest.builder().build());
- }
-
- public CompletableFuture>> list(AccountsListRequest request) {
- return list(request, null);
- }
-
- public CompletableFuture>> list(
- AccountsListRequest request, RequestOptions requestOptions) {
- HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
- .newBuilder()
- .addPathSegments("v1/connect")
- .addPathSegment(clientOptions.projectId())
- .addPathSegments("accounts");
- if (request.getAppId().isPresent()) {
- QueryStringMapper.addQueryParameter(
- httpUrl, "app_id", request.getAppId().get(), false);
- }
- if (request.getExternalUserId().isPresent()) {
- QueryStringMapper.addQueryParameter(
- httpUrl, "external_user_id", request.getExternalUserId().get(), false);
- }
- if (request.getOauthAppId().isPresent()) {
- QueryStringMapper.addQueryParameter(
- httpUrl, "oauth_app_id", request.getOauthAppId().get(), false);
- }
- if (request.getAfter().isPresent()) {
- QueryStringMapper.addQueryParameter(
- httpUrl, "after", request.getAfter().get(), false);
- }
- if (request.getBefore().isPresent()) {
- QueryStringMapper.addQueryParameter(
- httpUrl, "before", request.getBefore().get(), false);
- }
- if (request.getLimit().isPresent()) {
- QueryStringMapper.addQueryParameter(
- httpUrl, "limit", request.getLimit().get(), false);
- }
- if (request.getIncludeCredentials().isPresent()) {
- QueryStringMapper.addQueryParameter(
- httpUrl,
- "include_credentials",
- request.getIncludeCredentials().get(),
- false);
- }
- Request.Builder _requestBuilder = new Request.Builder()
- .url(httpUrl.build())
- .method("GET", null)
- .headers(Headers.of(clientOptions.headers(requestOptions)))
- .addHeader("Accept", "application/json");
- Request okhttpRequest = _requestBuilder.build();
- OkHttpClient client = clientOptions.httpClient();
- if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
- client = clientOptions.httpClientWithTimeout(requestOptions);
- }
- 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()) {
- ListAccountsResponse parsedResponse =
- ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), ListAccountsResponse.class);
- Optional startingAfter =
- parsedResponse.getPageInfo().getEndCursor();
- AccountsListRequest nextRequest = AccountsListRequest.builder()
- .from(request)
- .after(startingAfter)
- .build();
- List result = parsedResponse.getData();
- future.complete(new BaseClientHttpResponse<>(
- new SyncPagingIterable(startingAfter.isPresent(), result, () -> {
- try {
- return list(nextRequest, requestOptions)
- .get()
- .body();
- } catch (InterruptedException | ExecutionException e) {
- throw new RuntimeException(e);
- }
- }),
- response));
- return;
- }
- String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- future.completeExceptionally(new BaseClientApiException(
- "Error with status code " + response.code(),
- response.code(),
- ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
- response));
- return;
- } catch (IOException e) {
- future.completeExceptionally(new BaseClientException("Network error executing HTTP request", e));
- }
- }
-
- @Override
- public void onFailure(@NotNull Call call, @NotNull IOException e) {
- future.completeExceptionally(new BaseClientException("Network error executing HTTP request", e));
- }
- });
- return future;
- }
-
- public CompletableFuture> create(CreateAccountOpts request) {
- return create(request, null);
- }
-
- public CompletableFuture> create(
- CreateAccountOpts request, RequestOptions requestOptions) {
- HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
- .newBuilder()
- .addPathSegments("v1/connect")
- .addPathSegment(clientOptions.projectId())
- .addPathSegments("accounts");
- if (request.getAppId().isPresent()) {
- QueryStringMapper.addQueryParameter(
- httpUrl, "app_id", request.getAppId().get(), false);
- }
- if (request.getExternalUserId().isPresent()) {
- QueryStringMapper.addQueryParameter(
- httpUrl, "external_user_id", request.getExternalUserId().get(), false);
- }
- if (request.getOauthAppId().isPresent()) {
- QueryStringMapper.addQueryParameter(
- httpUrl, "oauth_app_id", request.getOauthAppId().get(), false);
- }
- Map properties = new HashMap<>();
- properties.put("app_slug", request.getAppSlug());
- properties.put("cfmap_json", request.getCfmapJson());
- properties.put("connect_token", request.getConnectToken());
- if (request.getName().isPresent()) {
- properties.put("name", request.getName());
- }
- RequestBody body;
- try {
- body = RequestBody.create(
- ObjectMappers.JSON_MAPPER.writeValueAsBytes(properties), MediaTypes.APPLICATION_JSON);
- } catch (Exception e) {
- throw new RuntimeException(e);
- }
- Request.Builder _requestBuilder = new Request.Builder()
- .url(httpUrl.build())
- .method("POST", body)
- .headers(Headers.of(clientOptions.headers(requestOptions)))
- .addHeader("Content-Type", "application/json")
- .addHeader("Accept", "application/json");
- Request okhttpRequest = _requestBuilder.build();
- OkHttpClient client = clientOptions.httpClient();
- if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
- client = clientOptions.httpClientWithTimeout(requestOptions);
- }
- 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 BaseClientHttpResponse<>(
- ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), Account.class), response));
- return;
- }
- String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- future.completeExceptionally(new BaseClientApiException(
- "Error with status code " + response.code(),
- response.code(),
- ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
- response));
- return;
- } catch (IOException e) {
- future.completeExceptionally(new BaseClientException("Network error executing HTTP request", e));
- }
- }
-
- @Override
- public void onFailure(@NotNull Call call, @NotNull IOException e) {
- future.completeExceptionally(new BaseClientException("Network error executing HTTP request", e));
- }
- });
- return future;
- }
-
- public CompletableFuture> retrieve(String accountId) {
- return retrieve(accountId, AccountsRetrieveRequest.builder().build());
- }
-
- public CompletableFuture> retrieve(
- String accountId, AccountsRetrieveRequest request) {
- return retrieve(accountId, request, null);
- }
-
- public CompletableFuture> retrieve(
- String accountId, AccountsRetrieveRequest request, RequestOptions requestOptions) {
- HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
- .newBuilder()
- .addPathSegments("v1/connect")
- .addPathSegment(clientOptions.projectId())
- .addPathSegments("accounts")
- .addPathSegment(accountId);
- if (request.getIncludeCredentials().isPresent()) {
- QueryStringMapper.addQueryParameter(
- httpUrl,
- "include_credentials",
- request.getIncludeCredentials().get(),
- false);
- }
- Request.Builder _requestBuilder = new Request.Builder()
- .url(httpUrl.build())
- .method("GET", null)
- .headers(Headers.of(clientOptions.headers(requestOptions)))
- .addHeader("Accept", "application/json");
- Request okhttpRequest = _requestBuilder.build();
- OkHttpClient client = clientOptions.httpClient();
- if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
- client = clientOptions.httpClientWithTimeout(requestOptions);
- }
- 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 BaseClientHttpResponse<>(
- ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), Account.class), response));
- return;
- }
- String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- future.completeExceptionally(new BaseClientApiException(
- "Error with status code " + response.code(),
- response.code(),
- ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
- response));
- return;
- } catch (IOException e) {
- future.completeExceptionally(new BaseClientException("Network error executing HTTP request", e));
- }
- }
-
- @Override
- public void onFailure(@NotNull Call call, @NotNull IOException e) {
- future.completeExceptionally(new BaseClientException("Network error executing HTTP request", e));
- }
- });
- return future;
- }
-
- public CompletableFuture> delete(String accountId) {
- return delete(accountId, null);
- }
-
- public CompletableFuture> delete(String accountId, RequestOptions requestOptions) {
- HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
- .newBuilder()
- .addPathSegments("v1/connect")
- .addPathSegment(clientOptions.projectId())
- .addPathSegments("accounts")
- .addPathSegment(accountId)
- .build();
- Request okhttpRequest = new Request.Builder()
- .url(httpUrl)
- .method("DELETE", null)
- .headers(Headers.of(clientOptions.headers(requestOptions)))
- .build();
- OkHttpClient client = clientOptions.httpClient();
- if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
- client = clientOptions.httpClientWithTimeout(requestOptions);
- }
- 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 BaseClientHttpResponse<>(null, response));
- return;
- }
- String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- future.completeExceptionally(new BaseClientApiException(
- "Error with status code " + response.code(),
- response.code(),
- ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
- response));
- return;
- } catch (IOException e) {
- future.completeExceptionally(new BaseClientException("Network error executing HTTP request", e));
- }
- }
-
- @Override
- public void onFailure(@NotNull Call call, @NotNull IOException e) {
- future.completeExceptionally(new BaseClientException("Network error executing HTTP request", e));
- }
- });
- return future;
- }
-
- public CompletableFuture> deleteByApp(String appId) {
- return deleteByApp(appId, null);
- }
-
- public CompletableFuture> deleteByApp(String appId, RequestOptions requestOptions) {
- HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
- .newBuilder()
- .addPathSegments("v1/connect")
- .addPathSegment(clientOptions.projectId())
- .addPathSegments("apps")
- .addPathSegment(appId)
- .addPathSegments("accounts")
- .build();
- Request okhttpRequest = new Request.Builder()
- .url(httpUrl)
- .method("DELETE", null)
- .headers(Headers.of(clientOptions.headers(requestOptions)))
- .build();
- OkHttpClient client = clientOptions.httpClient();
- if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
- client = clientOptions.httpClientWithTimeout(requestOptions);
- }
- 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 BaseClientHttpResponse<>(null, response));
- return;
- }
- String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- future.completeExceptionally(new BaseClientApiException(
- "Error with status code " + response.code(),
- response.code(),
- ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
- response));
- return;
- } catch (IOException e) {
- future.completeExceptionally(new BaseClientException("Network error executing HTTP request", e));
- }
- }
-
- @Override
- public void onFailure(@NotNull Call call, @NotNull IOException e) {
- future.completeExceptionally(new BaseClientException("Network error executing HTTP request", e));
- }
- });
- return future;
- }
-}
diff --git a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/accounts/RawAccountsClient.java b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/accounts/RawAccountsClient.java
deleted file mode 100644
index 5fb30da..0000000
--- a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/accounts/RawAccountsClient.java
+++ /dev/null
@@ -1,312 +0,0 @@
-/**
- * This file was auto-generated by Fern from our API Definition.
- */
-package com.pipedream.api.resources.accounts;
-
-import com.pipedream.api.core.BaseClientApiException;
-import com.pipedream.api.core.BaseClientException;
-import com.pipedream.api.core.BaseClientHttpResponse;
-import com.pipedream.api.core.ClientOptions;
-import com.pipedream.api.core.MediaTypes;
-import com.pipedream.api.core.ObjectMappers;
-import com.pipedream.api.core.QueryStringMapper;
-import com.pipedream.api.core.RequestOptions;
-import com.pipedream.api.core.pagination.SyncPagingIterable;
-import com.pipedream.api.resources.accounts.requests.AccountsListRequest;
-import com.pipedream.api.resources.accounts.requests.AccountsRetrieveRequest;
-import com.pipedream.api.resources.accounts.requests.CreateAccountOpts;
-import com.pipedream.api.types.Account;
-import com.pipedream.api.types.ListAccountsResponse;
-import java.io.IOException;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Optional;
-import okhttp3.Headers;
-import okhttp3.HttpUrl;
-import okhttp3.OkHttpClient;
-import okhttp3.Request;
-import okhttp3.RequestBody;
-import okhttp3.Response;
-import okhttp3.ResponseBody;
-
-public class RawAccountsClient {
- protected final ClientOptions clientOptions;
-
- public RawAccountsClient(ClientOptions clientOptions) {
- this.clientOptions = clientOptions;
- }
-
- public BaseClientHttpResponse> list() {
- return list(AccountsListRequest.builder().build());
- }
-
- public BaseClientHttpResponse> list(AccountsListRequest request) {
- return list(request, null);
- }
-
- public BaseClientHttpResponse> list(
- AccountsListRequest request, RequestOptions requestOptions) {
- HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
- .newBuilder()
- .addPathSegments("v1/connect")
- .addPathSegment(clientOptions.projectId())
- .addPathSegments("accounts");
- if (request.getAppId().isPresent()) {
- QueryStringMapper.addQueryParameter(
- httpUrl, "app_id", request.getAppId().get(), false);
- }
- if (request.getExternalUserId().isPresent()) {
- QueryStringMapper.addQueryParameter(
- httpUrl, "external_user_id", request.getExternalUserId().get(), false);
- }
- if (request.getOauthAppId().isPresent()) {
- QueryStringMapper.addQueryParameter(
- httpUrl, "oauth_app_id", request.getOauthAppId().get(), false);
- }
- if (request.getAfter().isPresent()) {
- QueryStringMapper.addQueryParameter(
- httpUrl, "after", request.getAfter().get(), false);
- }
- if (request.getBefore().isPresent()) {
- QueryStringMapper.addQueryParameter(
- httpUrl, "before", request.getBefore().get(), false);
- }
- if (request.getLimit().isPresent()) {
- QueryStringMapper.addQueryParameter(
- httpUrl, "limit", request.getLimit().get(), false);
- }
- if (request.getIncludeCredentials().isPresent()) {
- QueryStringMapper.addQueryParameter(
- httpUrl,
- "include_credentials",
- request.getIncludeCredentials().get(),
- false);
- }
- Request.Builder _requestBuilder = new Request.Builder()
- .url(httpUrl.build())
- .method("GET", null)
- .headers(Headers.of(clientOptions.headers(requestOptions)))
- .addHeader("Accept", "application/json");
- Request okhttpRequest = _requestBuilder.build();
- OkHttpClient client = clientOptions.httpClient();
- if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
- client = clientOptions.httpClientWithTimeout(requestOptions);
- }
- try (Response response = client.newCall(okhttpRequest).execute()) {
- ResponseBody responseBody = response.body();
- if (response.isSuccessful()) {
- ListAccountsResponse parsedResponse =
- ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), ListAccountsResponse.class);
- Optional startingAfter = parsedResponse.getPageInfo().getEndCursor();
- AccountsListRequest nextRequest = AccountsListRequest.builder()
- .from(request)
- .after(startingAfter)
- .build();
- List result = parsedResponse.getData();
- return new BaseClientHttpResponse<>(
- new SyncPagingIterable(
- startingAfter.isPresent(), result, () -> list(nextRequest, requestOptions)
- .body()),
- response);
- }
- String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- throw new BaseClientApiException(
- "Error with status code " + response.code(),
- response.code(),
- ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
- response);
- } catch (IOException e) {
- throw new BaseClientException("Network error executing HTTP request", e);
- }
- }
-
- public BaseClientHttpResponse create(CreateAccountOpts request) {
- return create(request, null);
- }
-
- public BaseClientHttpResponse create(CreateAccountOpts request, RequestOptions requestOptions) {
- HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
- .newBuilder()
- .addPathSegments("v1/connect")
- .addPathSegment(clientOptions.projectId())
- .addPathSegments("accounts");
- if (request.getAppId().isPresent()) {
- QueryStringMapper.addQueryParameter(
- httpUrl, "app_id", request.getAppId().get(), false);
- }
- if (request.getExternalUserId().isPresent()) {
- QueryStringMapper.addQueryParameter(
- httpUrl, "external_user_id", request.getExternalUserId().get(), false);
- }
- if (request.getOauthAppId().isPresent()) {
- QueryStringMapper.addQueryParameter(
- httpUrl, "oauth_app_id", request.getOauthAppId().get(), false);
- }
- Map properties = new HashMap<>();
- properties.put("app_slug", request.getAppSlug());
- properties.put("cfmap_json", request.getCfmapJson());
- properties.put("connect_token", request.getConnectToken());
- if (request.getName().isPresent()) {
- properties.put("name", request.getName());
- }
- RequestBody body;
- try {
- body = RequestBody.create(
- ObjectMappers.JSON_MAPPER.writeValueAsBytes(properties), MediaTypes.APPLICATION_JSON);
- } catch (Exception e) {
- throw new RuntimeException(e);
- }
- Request.Builder _requestBuilder = new Request.Builder()
- .url(httpUrl.build())
- .method("POST", body)
- .headers(Headers.of(clientOptions.headers(requestOptions)))
- .addHeader("Content-Type", "application/json")
- .addHeader("Accept", "application/json");
- Request okhttpRequest = _requestBuilder.build();
- OkHttpClient client = clientOptions.httpClient();
- if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
- client = clientOptions.httpClientWithTimeout(requestOptions);
- }
- try (Response response = client.newCall(okhttpRequest).execute()) {
- ResponseBody responseBody = response.body();
- if (response.isSuccessful()) {
- return new BaseClientHttpResponse<>(
- ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), Account.class), response);
- }
- String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- throw new BaseClientApiException(
- "Error with status code " + response.code(),
- response.code(),
- ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
- response);
- } catch (IOException e) {
- throw new BaseClientException("Network error executing HTTP request", e);
- }
- }
-
- public BaseClientHttpResponse retrieve(String accountId) {
- return retrieve(accountId, AccountsRetrieveRequest.builder().build());
- }
-
- public BaseClientHttpResponse retrieve(String accountId, AccountsRetrieveRequest request) {
- return retrieve(accountId, request, null);
- }
-
- public BaseClientHttpResponse retrieve(
- String accountId, AccountsRetrieveRequest request, RequestOptions requestOptions) {
- HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
- .newBuilder()
- .addPathSegments("v1/connect")
- .addPathSegment(clientOptions.projectId())
- .addPathSegments("accounts")
- .addPathSegment(accountId);
- if (request.getIncludeCredentials().isPresent()) {
- QueryStringMapper.addQueryParameter(
- httpUrl,
- "include_credentials",
- request.getIncludeCredentials().get(),
- false);
- }
- Request.Builder _requestBuilder = new Request.Builder()
- .url(httpUrl.build())
- .method("GET", null)
- .headers(Headers.of(clientOptions.headers(requestOptions)))
- .addHeader("Accept", "application/json");
- Request okhttpRequest = _requestBuilder.build();
- OkHttpClient client = clientOptions.httpClient();
- if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
- client = clientOptions.httpClientWithTimeout(requestOptions);
- }
- try (Response response = client.newCall(okhttpRequest).execute()) {
- ResponseBody responseBody = response.body();
- if (response.isSuccessful()) {
- return new BaseClientHttpResponse<>(
- ObjectMappers.JSON_MAPPER.readValue(responseBody.string(), Account.class), response);
- }
- String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- throw new BaseClientApiException(
- "Error with status code " + response.code(),
- response.code(),
- ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
- response);
- } catch (IOException e) {
- throw new BaseClientException("Network error executing HTTP request", e);
- }
- }
-
- public BaseClientHttpResponse delete(String accountId) {
- return delete(accountId, null);
- }
-
- public BaseClientHttpResponse delete(String accountId, RequestOptions requestOptions) {
- HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
- .newBuilder()
- .addPathSegments("v1/connect")
- .addPathSegment(clientOptions.projectId())
- .addPathSegments("accounts")
- .addPathSegment(accountId)
- .build();
- Request okhttpRequest = new Request.Builder()
- .url(httpUrl)
- .method("DELETE", null)
- .headers(Headers.of(clientOptions.headers(requestOptions)))
- .build();
- OkHttpClient client = clientOptions.httpClient();
- if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
- client = clientOptions.httpClientWithTimeout(requestOptions);
- }
- try (Response response = client.newCall(okhttpRequest).execute()) {
- ResponseBody responseBody = response.body();
- if (response.isSuccessful()) {
- return new BaseClientHttpResponse<>(null, response);
- }
- String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- throw new BaseClientApiException(
- "Error with status code " + response.code(),
- response.code(),
- ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
- response);
- } catch (IOException e) {
- throw new BaseClientException("Network error executing HTTP request", e);
- }
- }
-
- public BaseClientHttpResponse deleteByApp(String appId) {
- return deleteByApp(appId, null);
- }
-
- public BaseClientHttpResponse deleteByApp(String appId, RequestOptions requestOptions) {
- HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
- .newBuilder()
- .addPathSegments("v1/connect")
- .addPathSegment(clientOptions.projectId())
- .addPathSegments("apps")
- .addPathSegment(appId)
- .addPathSegments("accounts")
- .build();
- Request okhttpRequest = new Request.Builder()
- .url(httpUrl)
- .method("DELETE", null)
- .headers(Headers.of(clientOptions.headers(requestOptions)))
- .build();
- OkHttpClient client = clientOptions.httpClient();
- if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
- client = clientOptions.httpClientWithTimeout(requestOptions);
- }
- try (Response response = client.newCall(okhttpRequest).execute()) {
- ResponseBody responseBody = response.body();
- if (response.isSuccessful()) {
- return new BaseClientHttpResponse<>(null, response);
- }
- String responseBodyString = responseBody != null ? responseBody.string() : "{}";
- throw new BaseClientApiException(
- "Error with status code " + response.code(),
- response.code(),
- ObjectMappers.JSON_MAPPER.readValue(responseBodyString, Object.class),
- response);
- } catch (IOException e) {
- throw new BaseClientException("Network error executing HTTP request", e);
- }
- }
-}
diff --git a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/accounts/requests/AccountsListRequest.java b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/accounts/requests/AccountsListRequest.java
deleted file mode 100644
index 2d67f6d..0000000
--- a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/accounts/requests/AccountsListRequest.java
+++ /dev/null
@@ -1,285 +0,0 @@
-/**
- * This file was auto-generated by Fern from our API Definition.
- */
-package com.pipedream.api.resources.accounts.requests;
-
-import com.fasterxml.jackson.annotation.JsonAnyGetter;
-import com.fasterxml.jackson.annotation.JsonAnySetter;
-import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
-import com.fasterxml.jackson.annotation.JsonInclude;
-import com.fasterxml.jackson.annotation.JsonProperty;
-import com.fasterxml.jackson.annotation.JsonSetter;
-import com.fasterxml.jackson.annotation.Nulls;
-import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
-import com.pipedream.api.core.ObjectMappers;
-import java.util.HashMap;
-import java.util.Map;
-import java.util.Objects;
-import java.util.Optional;
-
-@JsonInclude(JsonInclude.Include.NON_ABSENT)
-@JsonDeserialize(builder = AccountsListRequest.Builder.class)
-public final class AccountsListRequest {
- private final Optional appId;
-
- private final Optional externalUserId;
-
- private final Optional oauthAppId;
-
- private final Optional after;
-
- private final Optional before;
-
- private final Optional limit;
-
- private final Optional includeCredentials;
-
- private final Map additionalProperties;
-
- private AccountsListRequest(
- Optional appId,
- Optional externalUserId,
- Optional oauthAppId,
- Optional after,
- Optional before,
- Optional limit,
- Optional includeCredentials,
- Map additionalProperties) {
- this.appId = appId;
- this.externalUserId = externalUserId;
- this.oauthAppId = oauthAppId;
- this.after = after;
- this.before = before;
- this.limit = limit;
- this.includeCredentials = includeCredentials;
- this.additionalProperties = additionalProperties;
- }
-
- /**
- * @return The app slug or ID to filter accounts by.
- */
- @JsonProperty("app_id")
- public Optional getAppId() {
- return appId;
- }
-
- @JsonProperty("external_user_id")
- public Optional getExternalUserId() {
- return externalUserId;
- }
-
- /**
- * @return The OAuth app ID to filter by, if applicable
- */
- @JsonProperty("oauth_app_id")
- public Optional getOauthAppId() {
- return oauthAppId;
- }
-
- /**
- * @return The cursor to start from for pagination
- */
- @JsonProperty("after")
- public Optional getAfter() {
- return after;
- }
-
- /**
- * @return The cursor to end before for pagination
- */
- @JsonProperty("before")
- public Optional getBefore() {
- return before;
- }
-
- /**
- * @return The maximum number of results to return
- */
- @JsonProperty("limit")
- public Optional getLimit() {
- return limit;
- }
-
- /**
- * @return Whether to retrieve the account's credentials or not
- */
- @JsonProperty("include_credentials")
- public Optional getIncludeCredentials() {
- return includeCredentials;
- }
-
- @java.lang.Override
- public boolean equals(Object other) {
- if (this == other) return true;
- return other instanceof AccountsListRequest && equalTo((AccountsListRequest) other);
- }
-
- @JsonAnyGetter
- public Map getAdditionalProperties() {
- return this.additionalProperties;
- }
-
- private boolean equalTo(AccountsListRequest other) {
- return appId.equals(other.appId)
- && externalUserId.equals(other.externalUserId)
- && oauthAppId.equals(other.oauthAppId)
- && after.equals(other.after)
- && before.equals(other.before)
- && limit.equals(other.limit)
- && includeCredentials.equals(other.includeCredentials);
- }
-
- @java.lang.Override
- public int hashCode() {
- return Objects.hash(
- this.appId,
- this.externalUserId,
- this.oauthAppId,
- this.after,
- this.before,
- this.limit,
- this.includeCredentials);
- }
-
- @java.lang.Override
- public String toString() {
- return ObjectMappers.stringify(this);
- }
-
- public static Builder builder() {
- return new Builder();
- }
-
- @JsonIgnoreProperties(ignoreUnknown = true)
- public static final class Builder {
- private Optional appId = Optional.empty();
-
- private Optional externalUserId = Optional.empty();
-
- private Optional oauthAppId = Optional.empty();
-
- private Optional after = Optional.empty();
-
- private Optional before = Optional.empty();
-
- private Optional limit = Optional.empty();
-
- private Optional includeCredentials = Optional.empty();
-
- @JsonAnySetter
- private Map additionalProperties = new HashMap<>();
-
- private Builder() {}
-
- public Builder from(AccountsListRequest other) {
- appId(other.getAppId());
- externalUserId(other.getExternalUserId());
- oauthAppId(other.getOauthAppId());
- after(other.getAfter());
- before(other.getBefore());
- limit(other.getLimit());
- includeCredentials(other.getIncludeCredentials());
- return this;
- }
-
- /**
- * The app slug or ID to filter accounts by.
- */
- @JsonSetter(value = "app_id", nulls = Nulls.SKIP)
- public Builder appId(Optional appId) {
- this.appId = appId;
- return this;
- }
-
- public Builder appId(String appId) {
- this.appId = Optional.ofNullable(appId);
- return this;
- }
-
- @JsonSetter(value = "external_user_id", nulls = Nulls.SKIP)
- public Builder externalUserId(Optional externalUserId) {
- this.externalUserId = externalUserId;
- return this;
- }
-
- public Builder externalUserId(String externalUserId) {
- this.externalUserId = Optional.ofNullable(externalUserId);
- return this;
- }
-
- /**
- * The OAuth app ID to filter by, if applicable
- */
- @JsonSetter(value = "oauth_app_id", nulls = Nulls.SKIP)
- public Builder oauthAppId(Optional oauthAppId) {
- this.oauthAppId = oauthAppId;
- return this;
- }
-
- public Builder oauthAppId(String oauthAppId) {
- this.oauthAppId = Optional.ofNullable(oauthAppId);
- return this;
- }
-
- /**
- * The cursor to start from for pagination
- */
- @JsonSetter(value = "after", nulls = Nulls.SKIP)
- public Builder after(Optional after) {
- this.after = after;
- return this;
- }
-
- public Builder after(String after) {
- this.after = Optional.ofNullable(after);
- return this;
- }
-
- /**
- * The cursor to end before for pagination
- */
- @JsonSetter(value = "before", nulls = Nulls.SKIP)
- public Builder before(Optional before) {
- this.before = before;
- return this;
- }
-
- public Builder before(String before) {
- this.before = Optional.ofNullable(before);
- return this;
- }
-
- /**
- * The maximum number of results to return
- */
- @JsonSetter(value = "limit", nulls = Nulls.SKIP)
- public Builder limit(Optional limit) {
- this.limit = limit;
- return this;
- }
-
- public Builder limit(Integer limit) {
- this.limit = Optional.ofNullable(limit);
- return this;
- }
-
- /**
- * Whether to retrieve the account's credentials or not
- */
- @JsonSetter(value = "include_credentials", nulls = Nulls.SKIP)
- public Builder includeCredentials(Optional includeCredentials) {
- this.includeCredentials = includeCredentials;
- return this;
- }
-
- public Builder includeCredentials(Boolean includeCredentials) {
- this.includeCredentials = Optional.ofNullable(includeCredentials);
- return this;
- }
-
- public AccountsListRequest build() {
- return new AccountsListRequest(
- appId, externalUserId, oauthAppId, after, before, limit, includeCredentials, additionalProperties);
- }
- }
-}
diff --git a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/accounts/requests/AccountsRetrieveRequest.java b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/accounts/requests/AccountsRetrieveRequest.java
deleted file mode 100644
index 3844f9d..0000000
--- a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/accounts/requests/AccountsRetrieveRequest.java
+++ /dev/null
@@ -1,101 +0,0 @@
-/**
- * This file was auto-generated by Fern from our API Definition.
- */
-package com.pipedream.api.resources.accounts.requests;
-
-import com.fasterxml.jackson.annotation.JsonAnyGetter;
-import com.fasterxml.jackson.annotation.JsonAnySetter;
-import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
-import com.fasterxml.jackson.annotation.JsonInclude;
-import com.fasterxml.jackson.annotation.JsonProperty;
-import com.fasterxml.jackson.annotation.JsonSetter;
-import com.fasterxml.jackson.annotation.Nulls;
-import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
-import com.pipedream.api.core.ObjectMappers;
-import java.util.HashMap;
-import java.util.Map;
-import java.util.Objects;
-import java.util.Optional;
-
-@JsonInclude(JsonInclude.Include.NON_ABSENT)
-@JsonDeserialize(builder = AccountsRetrieveRequest.Builder.class)
-public final class AccountsRetrieveRequest {
- private final Optional includeCredentials;
-
- private final Map additionalProperties;
-
- private AccountsRetrieveRequest(Optional includeCredentials, Map additionalProperties) {
- this.includeCredentials = includeCredentials;
- this.additionalProperties = additionalProperties;
- }
-
- /**
- * @return Whether to retrieve the account's credentials or not
- */
- @JsonProperty("include_credentials")
- public Optional getIncludeCredentials() {
- return includeCredentials;
- }
-
- @java.lang.Override
- public boolean equals(Object other) {
- if (this == other) return true;
- return other instanceof AccountsRetrieveRequest && equalTo((AccountsRetrieveRequest) other);
- }
-
- @JsonAnyGetter
- public Map getAdditionalProperties() {
- return this.additionalProperties;
- }
-
- private boolean equalTo(AccountsRetrieveRequest other) {
- return includeCredentials.equals(other.includeCredentials);
- }
-
- @java.lang.Override
- public int hashCode() {
- return Objects.hash(this.includeCredentials);
- }
-
- @java.lang.Override
- public String toString() {
- return ObjectMappers.stringify(this);
- }
-
- public static Builder builder() {
- return new Builder();
- }
-
- @JsonIgnoreProperties(ignoreUnknown = true)
- public static final class Builder {
- private Optional includeCredentials = Optional.empty();
-
- @JsonAnySetter
- private Map additionalProperties = new HashMap<>();
-
- private Builder() {}
-
- public Builder from(AccountsRetrieveRequest other) {
- includeCredentials(other.getIncludeCredentials());
- return this;
- }
-
- /**
- * Whether to retrieve the account's credentials or not
- */
- @JsonSetter(value = "include_credentials", nulls = Nulls.SKIP)
- public Builder includeCredentials(Optional includeCredentials) {
- this.includeCredentials = includeCredentials;
- return this;
- }
-
- public Builder includeCredentials(Boolean includeCredentials) {
- this.includeCredentials = Optional.ofNullable(includeCredentials);
- return this;
- }
-
- public AccountsRetrieveRequest build() {
- return new AccountsRetrieveRequest(includeCredentials, additionalProperties);
- }
- }
-}
diff --git a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/accounts/requests/CreateAccountOpts.java b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/accounts/requests/CreateAccountOpts.java
deleted file mode 100644
index 79cef5e..0000000
--- a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/resources/accounts/requests/CreateAccountOpts.java
+++ /dev/null
@@ -1,354 +0,0 @@
-/**
- * This file was auto-generated by Fern from our API Definition.
- */
-package com.pipedream.api.resources.accounts.requests;
-
-import com.fasterxml.jackson.annotation.JsonAnyGetter;
-import com.fasterxml.jackson.annotation.JsonAnySetter;
-import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
-import com.fasterxml.jackson.annotation.JsonInclude;
-import com.fasterxml.jackson.annotation.JsonProperty;
-import com.fasterxml.jackson.annotation.JsonSetter;
-import com.fasterxml.jackson.annotation.Nulls;
-import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
-import com.pipedream.api.core.ObjectMappers;
-import java.util.HashMap;
-import java.util.Map;
-import java.util.Objects;
-import java.util.Optional;
-import org.jetbrains.annotations.NotNull;
-
-@JsonInclude(JsonInclude.Include.NON_ABSENT)
-@JsonDeserialize(builder = CreateAccountOpts.Builder.class)
-public final class CreateAccountOpts {
- private final Optional appId;
-
- private final Optional externalUserId;
-
- private final Optional oauthAppId;
-
- private final String appSlug;
-
- private final String cfmapJson;
-
- private final String connectToken;
-
- private final Optional name;
-
- private final Map additionalProperties;
-
- private CreateAccountOpts(
- Optional appId,
- Optional externalUserId,
- Optional oauthAppId,
- String appSlug,
- String cfmapJson,
- String connectToken,
- Optional name,
- Map