PipedreamHQ · fern-api · Jul 18, 2025
diff --git a/.gradle/8.14.3/checksums/checksums.lock b/.gradle/8.14.3/checksums/checksums.lock
diff --git a/.gradle/8.14.3/checksums/md5-checksums.bin b/.gradle/8.14.3/checksums/md5-checksums.bin
diff --git a/.gradle/8.14.3/checksums/sha1-checksums.bin b/.gradle/8.14.3/checksums/sha1-checksums.bin
diff --git a/.gradle/8.14.3/executionHistory/executionHistory.bin b/.gradle/8.14.3/executionHistory/executionHistory.bin
diff --git a/.gradle/8.14.3/executionHistory/executionHistory.lock b/.gradle/8.14.3/executionHistory/executionHistory.lock
diff --git a/.gradle/8.14.3/fileHashes/fileHashes.bin b/.gradle/8.14.3/fileHashes/fileHashes.bin
diff --git a/.gradle/8.14.3/fileHashes/fileHashes.lock b/.gradle/8.14.3/fileHashes/fileHashes.lock
diff --git a/.gradle/buildOutputCleanup/buildOutputCleanup.lock b/.gradle/buildOutputCleanup/buildOutputCleanup.lock
diff --git a/.gradle/buildOutputCleanup/cache.properties b/.gradle/buildOutputCleanup/cache.properties
@@ -1,2 +1,2 @@
-#Thu Jul 17 23:24:55 UTC 2025
+#Fri Jul 18 18:14:04 UTC 2025
 gradle.version=8.14.3
diff --git a/README.md b/README.md
@@ -25,7 +25,7 @@ Add the dependency in your `pom.xml` file:
 <dependency>
   <groupId>com.pipedream</groupId>
   <artifactId>pipedream</artifactId>
-  <version>0.0.202</version>
+  <version>0.0.215</version>
 </dependency>
 ```
 
@@ -52,6 +52,8 @@ public class Example {
             CreateAccountRequest
                 .builder()
                 .appSlug("app_slug")
+                .cfmapJson("cfmap_json")
+                .connectToken("connect_token")
                 .build()
         );
     }

diff --git a/build.gradle b/build.gradle
@@ -18,7 +18,7 @@ dependencies {
     api 'com.fasterxml.jackson.core:jackson-databind:2.17.2'
     api 'com.fasterxml.jackson.datatype:jackson-datatype-jdk8:2.17.2'
     api 'com.fasterxml.jackson.datatype:jackson-datatype-jsr310:2.17.2'
-    api 'org.apache.commons:commons-text:1.11.0'
+    api 'org.apache.commons:commons-text:1.13.1'
     testImplementation 'org.junit.jupiter:junit-jupiter-api:5.8.2'
     testImplementation 'org.junit.jupiter:junit-jupiter-engine:5.8.2'
 }
@@ -47,7 +47,7 @@ java {
 
 group = 'com.pipedream'
 
-version = '0.0.202'
+version = '0.0.215'
 
 jar {
     dependsOn(":generatePomFileForMavenPublication")
@@ -78,7 +78,7 @@ publishing {
         maven(MavenPublication) {
             groupId = 'com.pipedream'
             artifactId = 'pipedream'
-            version = '0.0.202'
+            version = '0.0.215'
             from components.java
             pom {
                 name = 'pipedream'

diff --git a/build/spotless/spotlessJava/src/main/java/com/pipedream/api/core/ClientOptions.java b/build/spotless/spotlessJava/src/main/java/com/pipedream/api/core/ClientOptions.java
@@ -37,7 +37,7 @@ private ClientOptions(
             {
                 put("X-Fern-Language", "JAVA");
                 put("X-Fern-SDK-Name", "com.pipedream.fern:api-sdk");
-                put("X-Fern-SDK-Version", "0.0.202");
+                put("X-Fern-SDK-Version", "0.0.215");
             }
         });
         this.headerSuppliers = headerSuppliers;

diff --git a/...am/api/core/PipedreamApiApiException.java → .../core/PipedreamApiClientApiException.java b/...am/api/core/PipedreamApiApiException.java → .../core/PipedreamApiClientApiException.java
@@ -12,7 +12,7 @@
 /**
  * This exception type will be thrown for any non-2XX API responses.
  */
-public class PipedreamApiApiException extends PipedreamApiException {
+public class PipedreamApiClientApiException extends PipedreamApiClientException {
     /**
      * The error code of the response that triggered the exception.
      */
@@ -25,14 +25,14 @@ public class PipedreamApiApiException extends PipedreamApiException {
 
     private final Map<String, List<String>> headers;
 
-    public PipedreamApiApiException(String message, int statusCode, Object body) {
+    public PipedreamApiClientApiException(String message, int statusCode, Object body) {
         super(message);
         this.statusCode = statusCode;
         this.body = body;
         this.headers = new HashMap<>();
     }
 
-    public PipedreamApiApiException(String message, int statusCode, Object body, Response rawResponse) {
+    public PipedreamApiClientApiException(String message, int statusCode, Object body, Response rawResponse) {
         super(message);
         this.statusCode = statusCode;
         this.body = body;
@@ -67,7 +67,7 @@ public Map<String, List<String>> headers() {
 
     @java.lang.Override
     public String toString() {
-        return "PipedreamApiApiException{" + "message: " + getMessage() + ", statusCode: " + statusCode + ", body: "
-                + body + "}";
+        return "PipedreamApiClientApiException{" + "message: " + getMessage() + ", statusCode: " + statusCode
+                + ", body: " + body + "}";
     }
 }
diff --git a/...dream/api/core/PipedreamApiException.java → ...api/core/PipedreamApiClientException.java b/...dream/api/core/PipedreamApiException.java → ...api/core/PipedreamApiClientException.java
@@ -6,12 +6,12 @@
 /**
  * This class serves as the base exception for all errors in the SDK.
  */
-public class PipedreamApiException extends RuntimeException {
-    public PipedreamApiException(String message) {
+public class PipedreamApiClientException extends RuntimeException {
+    public PipedreamApiClientException(String message) {
         super(message);
     }
 
-    public PipedreamApiException(String message, Exception e) {
+    public PipedreamApiClientException(String message, Exception e) {
         super(message, e);
     }
 }
diff --git a/...am/api/core/PipedreamApiHttpResponse.java → .../core/PipedreamApiClientHttpResponse.java b/...am/api/core/PipedreamApiHttpResponse.java → .../core/PipedreamApiClientHttpResponse.java
@@ -9,13 +9,13 @@
 import java.util.Map;
 import okhttp3.Response;
 
-public final class PipedreamApiHttpResponse<T> {
+public final class PipedreamApiClientHttpResponse<T> {
 
     private final T body;
 
     private final Map<String, List<String>> headers;
 
-    public PipedreamApiHttpResponse(T body, Response rawResponse) {
+    public PipedreamApiClientHttpResponse(T body, Response rawResponse) {
         this.body = body;
 
         Map<String, List<String>> headers = new HashMap<>();

diff --git a/...otlessJava/src/main/java/com/pipedream/api/resources/accounts/AsyncRawAccountsClient.java b/...otlessJava/src/main/java/com/pipedream/api/resources/accounts/AsyncRawAccountsClient.java
diff --git a/...ss/spotlessJava/src/main/java/com/pipedream/api/resources/accounts/RawAccountsClient.java b/...ss/spotlessJava/src/main/java/com/pipedream/api/resources/accounts/RawAccountsClient.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;
@@ -37,15 +37,15 @@ public RawAccountsClient(ClientOptions clientOptions) {
         this.clientOptions = clientOptions;
     }
 
-    public PipedreamApiHttpResponse<SyncPagingIterable<Account>> list() {
+    public PipedreamApiClientHttpResponse<SyncPagingIterable<Account>> list() {
         return list(AccountsListRequest.builder().build());
     }
 
-    public PipedreamApiHttpResponse<SyncPagingIterable<Account>> list(AccountsListRequest request) {
+    public PipedreamApiClientHttpResponse<SyncPagingIterable<Account>> list(AccountsListRequest request) {
         return list(request, null);
     }
 
-    public PipedreamApiHttpResponse<SyncPagingIterable<Account>> list(
+    public PipedreamApiClientHttpResponse<SyncPagingIterable<Account>> list(
             AccountsListRequest request, RequestOptions requestOptions) {
         HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
                 .newBuilder()
@@ -104,28 +104,28 @@ public PipedreamApiHttpResponse<SyncPagingIterable<Account>> list(
                         .after(startingAfter)
                         .build();
                 List<Account> result = parsedResponse.getData();
-                return new PipedreamApiHttpResponse<>(
+                return new PipedreamApiClientHttpResponse<>(
                         new SyncPagingIterable<Account>(
                                 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<Account> create(CreateAccountRequest request) {
+    public PipedreamApiClientHttpResponse<Account> create(CreateAccountRequest request) {
         return create(request, null);
     }
 
-    public PipedreamApiHttpResponse<Account> create(CreateAccountRequest request, RequestOptions requestOptions) {
+    public PipedreamApiClientHttpResponse<Account> create(CreateAccountRequest request, RequestOptions requestOptions) {
         HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
                 .newBuilder()
                 .addPathSegments("v1/connect")
@@ -145,9 +145,8 @@ public PipedreamApiHttpResponse<Account> create(CreateAccountRequest request, Re
         }
         Map<String, Object> properties = new HashMap<>();
         properties.put("app_slug", request.getAppSlug());
-        if (request.getCfmapJson().isPresent()) {
-            properties.put("cfmap_json", request.getCfmapJson());
-        }
+        properties.put("cfmap_json", request.getCfmapJson());
+        properties.put("connect_token", request.getConnectToken());
         if (request.getName().isPresent()) {
             properties.put("name", request.getName());
         }
@@ -172,29 +171,29 @@ public PipedreamApiHttpResponse<Account> create(CreateAccountRequest 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(), Account.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<Account> retrieve(String accountId) {
+    public PipedreamApiClientHttpResponse<Account> retrieve(String accountId) {
         return retrieve(accountId, AccountsRetrieveRequest.builder().build());
     }
 
-    public PipedreamApiHttpResponse<Account> retrieve(String accountId, AccountsRetrieveRequest request) {
+    public PipedreamApiClientHttpResponse<Account> retrieve(String accountId, AccountsRetrieveRequest request) {
         return retrieve(accountId, request, null);
     }
 
-    public PipedreamApiHttpResponse<Account> retrieve(
+    public PipedreamApiClientHttpResponse<Account> retrieve(
             String accountId, AccountsRetrieveRequest request, RequestOptions requestOptions) {
         HttpUrl.Builder httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
                 .newBuilder()
@@ -222,25 +221,25 @@ public PipedreamApiHttpResponse<Account> retrieve(
         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(), Account.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<Void> delete(String accountId) {
+    public PipedreamApiClientHttpResponse<Void> delete(String accountId) {
         return delete(accountId, null);
     }
 
-    public PipedreamApiHttpResponse<Void> delete(String accountId, RequestOptions requestOptions) {
+    public PipedreamApiClientHttpResponse<Void> delete(String accountId, RequestOptions requestOptions) {
         HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
                 .newBuilder()
                 .addPathSegments("v1/connect")
@@ -260,24 +259,24 @@ public PipedreamApiHttpResponse<Void> delete(String accountId, RequestOptions re
         try (Response response = client.newCall(okhttpRequest).execute()) {
             ResponseBody responseBody = response.body();
             if (response.isSuccessful()) {
-                return new PipedreamApiHttpResponse<>(null, response);
+                return new PipedreamApiClientHttpResponse<>(null, 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<Void> deleteByApp(String appId) {
+    public PipedreamApiClientHttpResponse<Void> deleteByApp(String appId) {
         return deleteByApp(appId, null);
     }
 
-    public PipedreamApiHttpResponse<Void> deleteByApp(String appId, RequestOptions requestOptions) {
+    public PipedreamApiClientHttpResponse<Void> deleteByApp(String appId, RequestOptions requestOptions) {
         HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
                 .newBuilder()
                 .addPathSegments("v1/connect")
@@ -298,16 +297,16 @@ public PipedreamApiHttpResponse<Void> deleteByApp(String appId, RequestOptions r
         try (Response response = client.newCall(okhttpRequest).execute()) {
             ResponseBody responseBody = response.body();
             if (response.isSuccessful()) {
-                return new PipedreamApiHttpResponse<>(null, response);
+                return new PipedreamApiClientHttpResponse<>(null, 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);
         }
     }
 }