SDK regeneration

Author: fern-api[bot]

.fern/metadata.json

@@ -0,0 +1,13 @@
+{
+  "cliVersion": "3.29.1",
+  "generatorName": "fernapi/fern-java-sdk",
+  "generatorVersion": "3.27.4",
+  "generatorConfig": {
+    "publish-to": "central",
+    "client-class-name": "BaseClient",
+    "custom-dependencies": [
+      "api org.apache.commons:commons-text:1.13.1"
+    ]
+  },
+  "sdkVersion": "1.1.6"
+}

README.md

@@ -17,6 +17,7 @@ The Pipedream Java library provides convenient access to the Pipedream APIs from
   - [Retries](#retries)
   - [Timeouts](#timeouts)
   - [Custom Headers](#custom-headers)
+  - [Access Raw Response Data](#access-raw-response-data)
 - [Contributing](#contributing)
 - [Reference](#reference)
 
@@ -40,7 +41,7 @@ Add the dependency in your `pom.xml` file:
 <dependency>
   <groupId>com.pipedream</groupId>
   <artifactId>pipedream</artifactId>
-  <version>1.1.5</version>
+  <version>1.1.6</version>
 </dependency>
 ```
 
@@ -56,12 +57,10 @@ import com.pipedream.api.resources.actions.requests.RunActionOpts;
 
 public class Example {
     public static void main(String[] args) {
-        BaseClient client = BaseClient
-            .builder()
-            .clientId("<clientId>")
-            .clientSecret("<clientSecret>")
+        BaseClient client = BaseClient.withCredentials("<clientId>", "<clientSecret>")
             .projectId("YOUR_PROJECT_ID")
-            .build();
+            .build()
+        ;
 
         client.actions().run(
             RunActionOpts
@@ -73,6 +72,29 @@ public class Example {
     }
 }
 ```
+## Authentication
+
+This SDK supports two authentication methods:
+
+### Option 1: Direct Bearer Token
+
+If you already have a valid access token, you can use it directly:
+
+```java
+BaseClient client = BaseClient.withToken("your-access-token")
+    .url("https://api.example.com")
+    .build();
+```
+
+### Option 2: OAuth Client Credentials
+
+The SDK can automatically handle token acquisition and refresh:
+
+```java
+BaseClient client = BaseClient.withCredentials("client-id", "client-secret")
+    .url("https://api.example.com")
+    .build();
+```
 
 ## Environments
 
@@ -138,7 +160,9 @@ BaseClient client = BaseClient
 
 The SDK is instrumented with automatic retries with exponential backoff. A request will be retried as long
 as the request is deemed retryable and the number of retry attempts has not grown larger than the configured
-retry limit (default: 2).
+retry limit (default: 2). Before defaulting to exponential backoff, the SDK will first attempt to respect
+the `Retry-After` header (as either in seconds or as an HTTP date), and then the `X-RateLimit-Reset` header
+(as a Unix timestamp in epoch seconds); failing both of those, it will fall back to exponential backoff.
 
 A request is deemed retryable when any of the following HTTP status codes is returned:
 
@@ -160,23 +184,22 @@ BaseClient client = BaseClient
 ### Timeouts
 
 The SDK defaults to a 60 second timeout. You can configure this with a timeout option at the client or request level.
-
 ```java
 import com.pipedream.api.BaseClient;
 import com.pipedream.api.core.RequestOptions;
 
 // Client level
 BaseClient client = BaseClient
     .builder()
-    .timeout(10)
+    .timeout(60)
     .build();
 
 // Request level
 client.actions().run(
     ...,
     RequestOptions
         .builder()
-        .timeout(10)
+        .timeout(60)
         .build()
 );
 ```
@@ -207,6 +230,19 @@ client.actions().run(
 );
 ```
 
+### Access Raw Response Data
+
+The SDK provides access to raw response data, including headers, through the `withRawResponse()` method.
+The `withRawResponse()` method returns a raw client that wraps all responses with `body()` and `headers()` methods.
+(A normal client's `response` is identical to a raw client's `response.body()`.)
+
+```java
+RunHttpResponse response = client.actions().withRawResponse().run(...);
+
+System.out.println(response.body());
+System.out.println(response.headers().get("X-My-Header"));
+```
+
 ## Contributing
 
 While we value open-source contributions to this SDK, this library is generated programmatically.

build.gradle

@@ -14,15 +14,14 @@ repositories {
 }
 
 dependencies {
-    api 'com.squareup.okhttp3:okhttp:4.12.0'
-    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 'com.squareup.okhttp3:okhttp:5.2.1'
+    api 'com.fasterxml.jackson.core:jackson-databind:2.18.2'
+    api 'com.fasterxml.jackson.datatype:jackson-datatype-jdk8:2.18.2'
+    api 'com.fasterxml.jackson.datatype:jackson-datatype-jsr310:2.18.2'
     testImplementation 'org.junit.jupiter:junit-jupiter-api:5.8.2'
     testImplementation 'org.junit.jupiter:junit-jupiter-engine:5.8.2'
     testImplementation 'org.junit.jupiter:junit-jupiter-params:5.8.2'
     api 'org.apache.commons:commons-text:1.13.1'
-    testImplementation 'com.squareup.okhttp3:mockwebserver:4.12.0'
 }
 
 
@@ -49,7 +48,7 @@ java {
 
 group = 'com.pipedream'
 
-version = '1.1.5'
+version = '1.1.6'
 
 jar {
     dependsOn(":generatePomFileForMavenPublication")
@@ -80,7 +79,7 @@ publishing {
         maven(MavenPublication) {
             groupId = 'com.pipedream'
             artifactId = 'pipedream'
-            version = '1.1.5'
+            version = '1.1.6'
             from components.java
             pom {
                 name = 'pipedream'

src/main/java/com/pipedream/api/AsyncBaseClient.java

@@ -118,7 +118,22 @@ public AsyncOauthTokensClient oauthTokens() {
         return this.oauthTokensClient.get();
     }
 
-    public static AsyncBaseClientBuilder builder() {
-        return new AsyncBaseClientBuilder();
+    /**
+     * Creates a client builder using a pre-generated access token.
+     * @param token The access token to use for authentication
+     * @return A builder configured for token authentication
+     */
+    public static AsyncBaseClientBuilder._TokenAuth withToken(String token) {
+        return AsyncBaseClientBuilder.withToken(token);
+    }
+
+    /**
+     * Creates a client builder using OAuth client credentials.
+     * @param clientId The OAuth client ID
+     * @param clientSecret The OAuth client secret
+     * @return A builder configured for OAuth authentication
+     */
+    public static AsyncBaseClientBuilder._CredentialsAuth withCredentials(String clientId, String clientSecret) {
+        return AsyncBaseClientBuilder.withCredentials(clientId, clientSecret);
     }
 }

src/main/java/com/pipedream/api/BaseClient.java

@@ -118,7 +118,22 @@ public OauthTokensClient oauthTokens() {
         return this.oauthTokensClient.get();
     }
 
-    public static BaseClientBuilder builder() {
-        return new BaseClientBuilder();
+    /**
+     * Creates a client builder using a pre-generated access token.
+     * @param token The access token to use for authentication
+     * @return A builder configured for token authentication
+     */
+    public static BaseClientBuilder._TokenAuth withToken(String token) {
+        return BaseClientBuilder.withToken(token);
+    }
+
+    /**
+     * Creates a client builder using OAuth client credentials.
+     * @param clientId The OAuth client ID
+     * @param clientSecret The OAuth client secret
+     * @return A builder configured for OAuth authentication
+     */
+    public static BaseClientBuilder._CredentialsAuth withCredentials(String clientId, String clientSecret) {
+        return BaseClientBuilder.withCredentials(clientId, clientSecret);
     }
 }

src/main/java/com/pipedream/api/core/BaseClientApiException.java

@@ -65,9 +65,9 @@ public Map<String, List<String>> headers() {
         return this.headers;
     }
 
-    @java.lang.Override
+    @Override
     public String toString() {
         return "BaseClientApiException{" + "message: " + getMessage() + ", statusCode: " + statusCode + ", body: "
-                + body + "}";
+                + ObjectMappers.stringify(body) + "}";
     }
 }

src/main/java/com/pipedream/api/core/ClientOptions.java

@@ -21,6 +21,8 @@ public final class ClientOptions {
 
     private final int timeout;
 
+    private final int maxRetries;
+
     private String projectId;
 
     private ClientOptions(
@@ -29,21 +31,23 @@ private ClientOptions(
             Map<String, Supplier<String>> headerSuppliers,
             OkHttpClient httpClient,
             int timeout,
+            int maxRetries,
             String projectId) {
         this.environment = environment;
         this.headers = new HashMap<>();
         this.headers.putAll(headers);
         this.headers.putAll(new HashMap<String, String>() {
             {
-                put("User-Agent", "com.pipedream:pipedream/1.1.5");
+                put("User-Agent", "com.pipedream:pipedream/1.1.6");
                 put("X-Fern-Language", "JAVA");
                 put("X-Fern-SDK-Name", "com.pipedream.fern:api-sdk");
-                put("X-Fern-SDK-Version", "1.1.5");
+                put("X-Fern-SDK-Version", "1.1.6");
             }
         });
         this.headerSuppliers = headerSuppliers;
         this.httpClient = httpClient;
         this.timeout = timeout;
+        this.maxRetries = maxRetries;
         this.projectId = projectId;
     }
 
@@ -86,6 +90,10 @@ public OkHttpClient httpClientWithTimeout(RequestOptions requestOptions) {
                 .build();
     }
 
+    public int maxRetries() {
+        return this.maxRetries;
+    }
+
     public String projectId() {
         return this.projectId;
     }
@@ -181,7 +189,13 @@ public ClientOptions build() {
             this.timeout = Optional.of(httpClient.callTimeoutMillis() / 1000);
 
             return new ClientOptions(
-                    environment, headers, headerSuppliers, httpClient, this.timeout.get(), this.projectId);
+                    environment,
+                    headers,
+                    headerSuppliers,
+                    httpClient,
+                    this.timeout.get(),
+                    this.maxRetries,
+                    this.projectId);
         }
 
         /**
@@ -192,6 +206,9 @@ public static Builder from(ClientOptions clientOptions) {
             builder.environment = clientOptions.environment();
             builder.timeout = Optional.of(clientOptions.timeout(null));
             builder.httpClient = clientOptions.httpClient();
+            builder.headers.putAll(clientOptions.headers);
+            builder.headerSuppliers.putAll(clientOptions.headerSuppliers);
+            builder.maxRetries = clientOptions.maxRetries();
             builder.projectId = clientOptions.projectId();
             return builder;
         }

src/main/java/com/pipedream/api/core/NullableNonemptyFilter.java

@@ -14,6 +14,9 @@ public boolean equals(Object o) {
     }
 
     private boolean isOptionalEmpty(Object o) {
-        return o instanceof Optional && !((Optional<?>) o).isPresent();
+        if (o instanceof Optional) {
+            return !((Optional<?>) o).isPresent();
+        }
+        return false;
     }
 }

src/main/java/com/pipedream/api/core/OAuthTokenSupplier.java

@@ -17,15 +17,18 @@ public final class OAuthTokenSupplier implements Supplier<String> {
 
     private final String clientSecret;
 
+    private final String scope;
+
     private final OauthTokensClient authClient;
 
     private String accessToken;
 
     private Instant expiresAt;
 
-    public OAuthTokenSupplier(String clientId, String clientSecret, OauthTokensClient authClient) {
+    public OAuthTokenSupplier(String clientId, String clientSecret, String scope, OauthTokensClient authClient) {
         this.clientId = clientId;
         this.clientSecret = clientSecret;
+        this.scope = scope;
         this.authClient = authClient;
         this.expiresAt = Instant.now();
     }
@@ -34,6 +37,7 @@ public CreateOAuthTokenResponse fetchToken() {
         CreateOAuthTokenOpts getTokenRequest = CreateOAuthTokenOpts.builder()
                 .clientId(clientId)
                 .clientSecret(clientSecret)
+                .scope(scope)
                 .build();
         return authClient.create(getTokenRequest);
     }

src/main/java/com/pipedream/api/core/ObjectMappers.java

@@ -4,6 +4,7 @@
 package com.pipedream.api.core;
 
 import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.DeserializationFeature;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.databind.SerializationFeature;
@@ -33,4 +34,12 @@ public static String stringify(Object o) {
             return o.getClass().getName() + "@" + Integer.toHexString(o.hashCode());
         }
     }
+
+    public static Object parseErrorBody(String responseBodyString) {
+        try {
+            return JSON_MAPPER.readValue(responseBodyString, Object.class);
+        } catch (JsonProcessingException ignored) {
+            return responseBodyString;
+        }
+    }
 }