Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
17 changes: 16 additions & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,21 @@

The Pipedream Java library provides convenient access to the Pipedream APIs from Java.

## Table of Contents

- [Installation](#installation)
- [Usage](#usage)
- [Environments](#environments)
- [Base Url](#base-url)
- [Exception Handling](#exception-handling)
- [Advanced](#advanced)
- [Custom Client](#custom-client)
- [Retries](#retries)
- [Timeouts](#timeouts)
- [Custom Headers](#custom-headers)
- [Contributing](#contributing)
- [Reference](#reference)

## Installation

### Gradle
Expand All @@ -25,7 +40,7 @@ Add the dependency in your `pom.xml` file:
<dependency>
<groupId>com.pipedream</groupId>
<artifactId>pipedream</artifactId>
<version>1.1.0</version>
<version>1.1.1</version>
</dependency>
```

Expand Down
4 changes: 2 additions & 2 deletions build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@ java {

group = 'com.pipedream'

version = '1.1.0'
version = '1.1.1'

jar {
dependsOn(":generatePomFileForMavenPublication")
Expand Down Expand Up @@ -80,7 +80,7 @@ publishing {
maven(MavenPublication) {
groupId = 'com.pipedream'
artifactId = 'pipedream'
version = '1.1.0'
version = '1.1.1'
from components.java
pom {
name = 'pipedream'
Expand Down
4 changes: 2 additions & 2 deletions src/main/java/com/pipedream/api/core/ClientOptions.java
Original file line number Diff line number Diff line change
Expand Up @@ -35,10 +35,10 @@ private ClientOptions(
this.headers.putAll(headers);
this.headers.putAll(new HashMap<String, String>() {
{
put("User-Agent", "com.pipedream:pipedream/1.1.0");
put("User-Agent", "com.pipedream:pipedream/1.1.1");
put("X-Fern-Language", "JAVA");
put("X-Fern-SDK-Name", "com.pipedream.fern:api-sdk");
put("X-Fern-SDK-Version", "1.1.0");
put("X-Fern-SDK-Version", "1.1.1");
}
});
this.headerSuppliers = headerSuppliers;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,18 +30,22 @@ public final class UpdateTriggerOpts {

private final Optional<String> name;

private final Optional<Boolean> emitOnDeploy;

private final Map<String, Object> additionalProperties;

private UpdateTriggerOpts(
String externalUserId,
Optional<Boolean> active,
Optional<Map<String, ConfiguredPropValue>> configuredProps,
Optional<String> name,
Optional<Boolean> emitOnDeploy,
Map<String, Object> additionalProperties) {
this.externalUserId = externalUserId;
this.active = active;
this.configuredProps = configuredProps;
this.name = name;
this.emitOnDeploy = emitOnDeploy;
this.additionalProperties = additionalProperties;
}

Expand Down Expand Up @@ -74,6 +78,14 @@ public Optional<String> getName() {
return name;
}

/**
* @return Whether the trigger should emit events during deployment
*/
@JsonProperty("emit_on_deploy")
public Optional<Boolean> getEmitOnDeploy() {
return emitOnDeploy;
}

@java.lang.Override
public boolean equals(Object other) {
if (this == other) return true;
Expand All @@ -89,12 +101,13 @@ private boolean equalTo(UpdateTriggerOpts other) {
return externalUserId.equals(other.externalUserId)
&& active.equals(other.active)
&& configuredProps.equals(other.configuredProps)
&& name.equals(other.name);
&& name.equals(other.name)
&& emitOnDeploy.equals(other.emitOnDeploy);
}

@java.lang.Override
public int hashCode() {
return Objects.hash(this.externalUserId, this.active, this.configuredProps, this.name);
return Objects.hash(this.externalUserId, this.active, this.configuredProps, this.name, this.emitOnDeploy);
}

@java.lang.Override
Expand Down Expand Up @@ -135,12 +148,21 @@ public interface _FinalStage {
_FinalStage name(Optional<String> name);

_FinalStage name(String name);

/**
* <p>Whether the trigger should emit events during deployment</p>
*/
_FinalStage emitOnDeploy(Optional<Boolean> emitOnDeploy);

_FinalStage emitOnDeploy(Boolean emitOnDeploy);
}

@JsonIgnoreProperties(ignoreUnknown = true)
public static final class Builder implements ExternalUserIdStage, _FinalStage {
private String externalUserId;

private Optional<Boolean> emitOnDeploy = Optional.empty();

private Optional<String> name = Optional.empty();

private Optional<Map<String, ConfiguredPropValue>> configuredProps = Optional.empty();
Expand All @@ -158,6 +180,7 @@ public Builder from(UpdateTriggerOpts other) {
active(other.getActive());
configuredProps(other.getConfiguredProps());
name(other.getName());
emitOnDeploy(other.getEmitOnDeploy());
return this;
}

Expand All @@ -173,6 +196,26 @@ public _FinalStage externalUserId(@NotNull String externalUserId) {
return this;
}

/**
* <p>Whether the trigger should emit events during deployment</p>
* @return Reference to {@code this} so that method calls can be chained together.
*/
@java.lang.Override
public _FinalStage emitOnDeploy(Boolean emitOnDeploy) {
this.emitOnDeploy = Optional.ofNullable(emitOnDeploy);
return this;
}

/**
* <p>Whether the trigger should emit events during deployment</p>
*/
@java.lang.Override
@JsonSetter(value = "emit_on_deploy", nulls = Nulls.SKIP)
public _FinalStage emitOnDeploy(Optional<Boolean> emitOnDeploy) {
this.emitOnDeploy = emitOnDeploy;
return this;
}

/**
* <p>The name of the trigger</p>
* @return Reference to {@code this} so that method calls can be chained together.
Expand Down Expand Up @@ -228,7 +271,8 @@ public _FinalStage active(Optional<Boolean> active) {

@java.lang.Override
public UpdateTriggerOpts build() {
return new UpdateTriggerOpts(externalUserId, active, configuredProps, name, additionalProperties);
return new UpdateTriggerOpts(
externalUserId, active, configuredProps, name, emitOnDeploy, additionalProperties);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -36,6 +36,8 @@ public final class DeployTriggerOpts {

private final Optional<String> webhookUrl;

private final Optional<Boolean> emitOnDeploy;

private final Map<String, Object> additionalProperties;

private DeployTriggerOpts(
Expand All @@ -46,6 +48,7 @@ private DeployTriggerOpts(
Optional<String> dynamicPropsId,
Optional<String> workflowId,
Optional<String> webhookUrl,
Optional<Boolean> emitOnDeploy,
Map<String, Object> additionalProperties) {
this.id = id;
this.version = version;
Expand All @@ -54,6 +57,7 @@ private DeployTriggerOpts(
this.dynamicPropsId = dynamicPropsId;
this.workflowId = workflowId;
this.webhookUrl = webhookUrl;
this.emitOnDeploy = emitOnDeploy;
this.additionalProperties = additionalProperties;
}

Expand Down Expand Up @@ -110,6 +114,14 @@ public Optional<String> getWebhookUrl() {
return webhookUrl;
}

/**
* @return Whether the trigger should emit events during the deploy hook execution. Defaults to true if not specified.
*/
@JsonProperty("emit_on_deploy")
public Optional<Boolean> getEmitOnDeploy() {
return emitOnDeploy;
}

@java.lang.Override
public boolean equals(Object other) {
if (this == other) return true;
Expand All @@ -128,7 +140,8 @@ private boolean equalTo(DeployTriggerOpts other) {
&& configuredProps.equals(other.configuredProps)
&& dynamicPropsId.equals(other.dynamicPropsId)
&& workflowId.equals(other.workflowId)
&& webhookUrl.equals(other.webhookUrl);
&& webhookUrl.equals(other.webhookUrl)
&& emitOnDeploy.equals(other.emitOnDeploy);
}

@java.lang.Override
Expand All @@ -140,7 +153,8 @@ public int hashCode() {
this.configuredProps,
this.dynamicPropsId,
this.workflowId,
this.webhookUrl);
this.webhookUrl,
this.emitOnDeploy);
}

@java.lang.Override
Expand Down Expand Up @@ -202,6 +216,13 @@ public interface _FinalStage {
_FinalStage webhookUrl(Optional<String> webhookUrl);

_FinalStage webhookUrl(String webhookUrl);

/**
* <p>Whether the trigger should emit events during the deploy hook execution. Defaults to true if not specified.</p>
*/
_FinalStage emitOnDeploy(Optional<Boolean> emitOnDeploy);

_FinalStage emitOnDeploy(Boolean emitOnDeploy);
}

@JsonIgnoreProperties(ignoreUnknown = true)
Expand All @@ -210,6 +231,8 @@ public static final class Builder implements IdStage, ExternalUserIdStage, _Fina

private String externalUserId;

private Optional<Boolean> emitOnDeploy = Optional.empty();

private Optional<String> webhookUrl = Optional.empty();

private Optional<String> workflowId = Optional.empty();
Expand All @@ -234,6 +257,7 @@ public Builder from(DeployTriggerOpts other) {
dynamicPropsId(other.getDynamicPropsId());
workflowId(other.getWorkflowId());
webhookUrl(other.getWebhookUrl());
emitOnDeploy(other.getEmitOnDeploy());
return this;
}

Expand Down Expand Up @@ -261,6 +285,26 @@ public _FinalStage externalUserId(@NotNull String externalUserId) {
return this;
}

/**
* <p>Whether the trigger should emit events during the deploy hook execution. Defaults to true if not specified.</p>
* @return Reference to {@code this} so that method calls can be chained together.
*/
@java.lang.Override
public _FinalStage emitOnDeploy(Boolean emitOnDeploy) {
this.emitOnDeploy = Optional.ofNullable(emitOnDeploy);
return this;
}

/**
* <p>Whether the trigger should emit events during the deploy hook execution. Defaults to true if not specified.</p>
*/
@java.lang.Override
@JsonSetter(value = "emit_on_deploy", nulls = Nulls.SKIP)
public _FinalStage emitOnDeploy(Optional<Boolean> emitOnDeploy) {
this.emitOnDeploy = emitOnDeploy;
return this;
}

/**
* <p>Optional webhook URL to receive trigger events</p>
* @return Reference to {@code this} so that method calls can be chained together.
Expand Down Expand Up @@ -364,6 +408,7 @@ public DeployTriggerOpts build() {
dynamicPropsId,
workflowId,
webhookUrl,
emitOnDeploy,
additionalProperties);
}
}
Expand Down
Loading
Loading