Skip to content
Merged
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
74 changes: 55 additions & 19 deletions src/main/java/com/getconvoy/models/DatastoreProjectConfig.java
Original file line number Diff line number Diff line change
Expand Up @@ -45,6 +45,7 @@
*/
@JsonPropertyOrder({
DatastoreProjectConfig.JSON_PROPERTY_ADD_EVENT_ID_TRACE_HEADERS,
DatastoreProjectConfig.JSON_PROPERTY_ALLOW_UNMATCHED_DYNAMIC_URLS,
DatastoreProjectConfig.JSON_PROPERTY_CIRCUIT_BREAKER,
DatastoreProjectConfig.JSON_PROPERTY_DISABLE_ENDPOINT,
DatastoreProjectConfig.JSON_PROPERTY_MAX_PAYLOAD_READ_SIZE,
Expand All @@ -57,14 +58,18 @@
DatastoreProjectConfig.JSON_PROPERTY_SIGNATURE,
DatastoreProjectConfig.JSON_PROPERTY_SSL,
DatastoreProjectConfig.JSON_PROPERTY_STRATEGY,
DatastoreProjectConfig.JSON_PROPERTY_SYNC_DYNAMIC_EVENT_ACK
DatastoreProjectConfig.JSON_PROPERTY_VERIFY_DYNAMIC_EVENTS
})
@jakarta.annotation.Generated(value = "org.openapitools.codegen.languages.JavaClientCodegen", comments = "Generator version: 7.23.0")
public class DatastoreProjectConfig {
public static final String JSON_PROPERTY_ADD_EVENT_ID_TRACE_HEADERS = "add_event_id_trace_headers";
@jakarta.annotation.Nullable
private Boolean addEventIdTraceHeaders;

public static final String JSON_PROPERTY_ALLOW_UNMATCHED_DYNAMIC_URLS = "allow_unmatched_dynamic_urls";
@jakarta.annotation.Nullable
private Boolean allowUnmatchedDynamicUrls;

public static final String JSON_PROPERTY_CIRCUIT_BREAKER = "circuit_breaker";
private JsonNullable<DatastoreCircuitBreakerConfiguration> circuitBreaker = JsonNullable.<DatastoreCircuitBreakerConfiguration>undefined();

Expand Down Expand Up @@ -107,9 +112,9 @@ public class DatastoreProjectConfig {
public static final String JSON_PROPERTY_STRATEGY = "strategy";
private JsonNullable<DatastoreStrategyConfiguration> strategy = JsonNullable.<DatastoreStrategyConfiguration>undefined();

public static final String JSON_PROPERTY_SYNC_DYNAMIC_EVENT_ACK = "sync_dynamic_event_ack";
public static final String JSON_PROPERTY_VERIFY_DYNAMIC_EVENTS = "verify_dynamic_events";
@jakarta.annotation.Nullable
private Boolean syncDynamicEventAck;
private Boolean verifyDynamicEvents;

public DatastoreProjectConfig() {
}
Expand Down Expand Up @@ -138,6 +143,30 @@ public void setAddEventIdTraceHeaders(@jakarta.annotation.Nullable Boolean addEv
}


public DatastoreProjectConfig allowUnmatchedDynamicUrls(@jakarta.annotation.Nullable Boolean allowUnmatchedDynamicUrls) {
this.allowUnmatchedDynamicUrls = allowUnmatchedDynamicUrls;
return this;
}

/**
* AllowUnmatchedDynamicURLs lets a dynamic event URL that matches none of the project&#39;s endpoint URL templates auto-create an endpoint. Default false rejects unmatched URLs.
* @return allowUnmatchedDynamicUrls
*/
@jakarta.annotation.Nullable
@JsonProperty(value = JSON_PROPERTY_ALLOW_UNMATCHED_DYNAMIC_URLS, required = false)
@JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
public Boolean getAllowUnmatchedDynamicUrls() {
return allowUnmatchedDynamicUrls;
}


@JsonProperty(value = JSON_PROPERTY_ALLOW_UNMATCHED_DYNAMIC_URLS, required = false)
@JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
public void setAllowUnmatchedDynamicUrls(@jakarta.annotation.Nullable Boolean allowUnmatchedDynamicUrls) {
this.allowUnmatchedDynamicUrls = allowUnmatchedDynamicUrls;
}


public DatastoreProjectConfig circuitBreaker(@jakarta.annotation.Nullable DatastoreCircuitBreakerConfiguration circuitBreaker) {
this.circuitBreaker = JsonNullable.<DatastoreCircuitBreakerConfiguration>of(circuitBreaker);
return this;
Expand Down Expand Up @@ -474,27 +503,27 @@ public void setStrategy(@jakarta.annotation.Nullable DatastoreStrategyConfigurat
}


public DatastoreProjectConfig syncDynamicEventAck(@jakarta.annotation.Nullable Boolean syncDynamicEventAck) {
this.syncDynamicEventAck = syncDynamicEventAck;
public DatastoreProjectConfig verifyDynamicEvents(@jakarta.annotation.Nullable Boolean verifyDynamicEvents) {
this.verifyDynamicEvents = verifyDynamicEvents;
return this;
}

/**
* SyncDynamicEventAck waits for endpoint/subscription resolve before returning 2xx from POST /events/dynamic. Default false keeps 201-on-queue.
* @return syncDynamicEventAck
* VerifyDynamicEvents waits for endpoint/subscription resolve before returning 2xx from POST /events/dynamic. Default false keeps 201-on-queue.
* @return verifyDynamicEvents
*/
@jakarta.annotation.Nullable
@JsonProperty(value = JSON_PROPERTY_SYNC_DYNAMIC_EVENT_ACK, required = false)
@JsonProperty(value = JSON_PROPERTY_VERIFY_DYNAMIC_EVENTS, required = false)
@JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
public Boolean getSyncDynamicEventAck() {
return syncDynamicEventAck;
public Boolean getVerifyDynamicEvents() {
return verifyDynamicEvents;
}


@JsonProperty(value = JSON_PROPERTY_SYNC_DYNAMIC_EVENT_ACK, required = false)
@JsonProperty(value = JSON_PROPERTY_VERIFY_DYNAMIC_EVENTS, required = false)
@JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
public void setSyncDynamicEventAck(@jakarta.annotation.Nullable Boolean syncDynamicEventAck) {
this.syncDynamicEventAck = syncDynamicEventAck;
public void setVerifyDynamicEvents(@jakarta.annotation.Nullable Boolean verifyDynamicEvents) {
this.verifyDynamicEvents = verifyDynamicEvents;
}


Expand All @@ -511,6 +540,7 @@ public boolean equals(Object o) {
}
DatastoreProjectConfig datastoreProjectConfig = (DatastoreProjectConfig) o;
return Objects.equals(this.addEventIdTraceHeaders, datastoreProjectConfig.addEventIdTraceHeaders) &&
Objects.equals(this.allowUnmatchedDynamicUrls, datastoreProjectConfig.allowUnmatchedDynamicUrls) &&
equalsNullable(this.circuitBreaker, datastoreProjectConfig.circuitBreaker) &&
Objects.equals(this.disableEndpoint, datastoreProjectConfig.disableEndpoint) &&
Objects.equals(this.maxPayloadReadSize, datastoreProjectConfig.maxPayloadReadSize) &&
Expand All @@ -523,7 +553,7 @@ public boolean equals(Object o) {
equalsNullable(this.signature, datastoreProjectConfig.signature) &&
equalsNullable(this.ssl, datastoreProjectConfig.ssl) &&
equalsNullable(this.strategy, datastoreProjectConfig.strategy) &&
Objects.equals(this.syncDynamicEventAck, datastoreProjectConfig.syncDynamicEventAck);
Objects.equals(this.verifyDynamicEvents, datastoreProjectConfig.verifyDynamicEvents);
}

private static <T> boolean equalsNullable(JsonNullable<T> a, JsonNullable<T> b) {
Expand All @@ -532,7 +562,7 @@ private static <T> boolean equalsNullable(JsonNullable<T> a, JsonNullable<T> b)

@Override
public int hashCode() {
return Objects.hash(addEventIdTraceHeaders, hashCodeNullable(circuitBreaker), disableEndpoint, maxPayloadReadSize, hashCodeNullable(metaEvent), multipleEndpointSubscriptions, hashCodeNullable(ratelimit), replayAttacksPreventionEnabled, requestIdHeader, searchPolicy, hashCodeNullable(signature), hashCodeNullable(ssl), hashCodeNullable(strategy), syncDynamicEventAck);
return Objects.hash(addEventIdTraceHeaders, allowUnmatchedDynamicUrls, hashCodeNullable(circuitBreaker), disableEndpoint, maxPayloadReadSize, hashCodeNullable(metaEvent), multipleEndpointSubscriptions, hashCodeNullable(ratelimit), replayAttacksPreventionEnabled, requestIdHeader, searchPolicy, hashCodeNullable(signature), hashCodeNullable(ssl), hashCodeNullable(strategy), verifyDynamicEvents);
}

private static <T> int hashCodeNullable(JsonNullable<T> a) {
Expand All @@ -547,6 +577,7 @@ public String toString() {
StringBuilder sb = new StringBuilder();
sb.append("class DatastoreProjectConfig {\n");
sb.append(" addEventIdTraceHeaders: ").append(toIndentedString(addEventIdTraceHeaders)).append("\n");
sb.append(" allowUnmatchedDynamicUrls: ").append(toIndentedString(allowUnmatchedDynamicUrls)).append("\n");
sb.append(" circuitBreaker: ").append(toIndentedString(circuitBreaker)).append("\n");
sb.append(" disableEndpoint: ").append(toIndentedString(disableEndpoint)).append("\n");
sb.append(" maxPayloadReadSize: ").append(toIndentedString(maxPayloadReadSize)).append("\n");
Expand All @@ -559,7 +590,7 @@ public String toString() {
sb.append(" signature: ").append(toIndentedString(signature)).append("\n");
sb.append(" ssl: ").append(toIndentedString(ssl)).append("\n");
sb.append(" strategy: ").append(toIndentedString(strategy)).append("\n");
sb.append(" syncDynamicEventAck: ").append(toIndentedString(syncDynamicEventAck)).append("\n");
sb.append(" verifyDynamicEvents: ").append(toIndentedString(verifyDynamicEvents)).append("\n");
sb.append("}");
return sb.toString();
}
Expand Down Expand Up @@ -609,6 +640,11 @@ public String toUrlQueryString(String prefix) {
joiner.add(String.format(java.util.Locale.ROOT, "%sadd_event_id_trace_headers%s=%s", prefix, suffix, ApiClient.urlEncode(ApiClient.valueToString(getAddEventIdTraceHeaders()))));
}

// add `allow_unmatched_dynamic_urls` to the URL query string
if (getAllowUnmatchedDynamicUrls() != null) {
joiner.add(String.format(java.util.Locale.ROOT, "%sallow_unmatched_dynamic_urls%s=%s", prefix, suffix, ApiClient.urlEncode(ApiClient.valueToString(getAllowUnmatchedDynamicUrls()))));
}

// add `circuit_breaker` to the URL query string
if (getCircuitBreaker() != null) {
joiner.add(getCircuitBreaker().toUrlQueryString(prefix + "circuit_breaker" + suffix));
Expand Down Expand Up @@ -669,9 +705,9 @@ public String toUrlQueryString(String prefix) {
joiner.add(getStrategy().toUrlQueryString(prefix + "strategy" + suffix));
}

// add `sync_dynamic_event_ack` to the URL query string
if (getSyncDynamicEventAck() != null) {
joiner.add(String.format(java.util.Locale.ROOT, "%ssync_dynamic_event_ack%s=%s", prefix, suffix, ApiClient.urlEncode(ApiClient.valueToString(getSyncDynamicEventAck()))));
// add `verify_dynamic_events` to the URL query string
if (getVerifyDynamicEvents() != null) {
joiner.add(String.format(java.util.Locale.ROOT, "%sverify_dynamic_events%s=%s", prefix, suffix, ApiClient.urlEncode(ApiClient.valueToString(getVerifyDynamicEvents()))));
}

return joiner.toString();
Expand Down
74 changes: 55 additions & 19 deletions src/main/java/com/getconvoy/models/ModelsProjectConfig.java
Original file line number Diff line number Diff line change
Expand Up @@ -41,6 +41,7 @@
*/
@JsonPropertyOrder({
ModelsProjectConfig.JSON_PROPERTY_ADD_EVENT_ID_TRACE_HEADERS,
ModelsProjectConfig.JSON_PROPERTY_ALLOW_UNMATCHED_DYNAMIC_URLS,
ModelsProjectConfig.JSON_PROPERTY_CIRCUIT_BREAKER,
ModelsProjectConfig.JSON_PROPERTY_DISABLE_ENDPOINT,
ModelsProjectConfig.JSON_PROPERTY_MAX_PAYLOAD_READ_SIZE,
Expand All @@ -53,14 +54,18 @@
ModelsProjectConfig.JSON_PROPERTY_SIGNATURE,
ModelsProjectConfig.JSON_PROPERTY_SSL,
ModelsProjectConfig.JSON_PROPERTY_STRATEGY,
ModelsProjectConfig.JSON_PROPERTY_SYNC_DYNAMIC_EVENT_ACK
ModelsProjectConfig.JSON_PROPERTY_VERIFY_DYNAMIC_EVENTS
})
@jakarta.annotation.Generated(value = "org.openapitools.codegen.languages.JavaClientCodegen", comments = "Generator version: 7.23.0")
public class ModelsProjectConfig {
public static final String JSON_PROPERTY_ADD_EVENT_ID_TRACE_HEADERS = "add_event_id_trace_headers";
@jakarta.annotation.Nullable
private Boolean addEventIdTraceHeaders;

public static final String JSON_PROPERTY_ALLOW_UNMATCHED_DYNAMIC_URLS = "allow_unmatched_dynamic_urls";
@jakarta.annotation.Nullable
private Boolean allowUnmatchedDynamicUrls;

public static final String JSON_PROPERTY_CIRCUIT_BREAKER = "circuit_breaker";
@jakarta.annotation.Nullable
private DatastoreCircuitBreakerConfiguration circuitBreaker;
Expand Down Expand Up @@ -109,9 +114,9 @@ public class ModelsProjectConfig {
@jakarta.annotation.Nullable
private ModelsStrategyConfiguration strategy;

public static final String JSON_PROPERTY_SYNC_DYNAMIC_EVENT_ACK = "sync_dynamic_event_ack";
public static final String JSON_PROPERTY_VERIFY_DYNAMIC_EVENTS = "verify_dynamic_events";
@jakarta.annotation.Nullable
private Boolean syncDynamicEventAck;
private Boolean verifyDynamicEvents;

public ModelsProjectConfig() {
}
Expand Down Expand Up @@ -140,6 +145,30 @@ public void setAddEventIdTraceHeaders(@jakarta.annotation.Nullable Boolean addEv
}


public ModelsProjectConfig allowUnmatchedDynamicUrls(@jakarta.annotation.Nullable Boolean allowUnmatchedDynamicUrls) {
this.allowUnmatchedDynamicUrls = allowUnmatchedDynamicUrls;
return this;
}

/**
* AllowUnmatchedDynamicURLs lets a dynamic event URL that matches none of the project&#39;s endpoint URL templates auto-create an endpoint instead of failing. When false (the default), a project with templates configured rejects unmatched URLs.
* @return allowUnmatchedDynamicUrls
*/
@jakarta.annotation.Nullable
@JsonProperty(value = JSON_PROPERTY_ALLOW_UNMATCHED_DYNAMIC_URLS, required = false)
@JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
public Boolean getAllowUnmatchedDynamicUrls() {
return allowUnmatchedDynamicUrls;
}


@JsonProperty(value = JSON_PROPERTY_ALLOW_UNMATCHED_DYNAMIC_URLS, required = false)
@JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
public void setAllowUnmatchedDynamicUrls(@jakarta.annotation.Nullable Boolean allowUnmatchedDynamicUrls) {
this.allowUnmatchedDynamicUrls = allowUnmatchedDynamicUrls;
}


public ModelsProjectConfig circuitBreaker(@jakarta.annotation.Nullable DatastoreCircuitBreakerConfiguration circuitBreaker) {
this.circuitBreaker = circuitBreaker;
return this;
Expand Down Expand Up @@ -428,27 +457,27 @@ public void setStrategy(@jakarta.annotation.Nullable ModelsStrategyConfiguration
}


public ModelsProjectConfig syncDynamicEventAck(@jakarta.annotation.Nullable Boolean syncDynamicEventAck) {
this.syncDynamicEventAck = syncDynamicEventAck;
public ModelsProjectConfig verifyDynamicEvents(@jakarta.annotation.Nullable Boolean verifyDynamicEvents) {
this.verifyDynamicEvents = verifyDynamicEvents;
return this;
}

/**
* SyncDynamicEventAck waits for dynamic endpoint/subscription resolve before acknowledging POST /events/dynamic. When false, the handler returns 201 after enqueue.
* @return syncDynamicEventAck
* VerifyDynamicEvents waits for dynamic endpoint/subscription resolve before acknowledging POST /events/dynamic. When false, the handler returns 201 after enqueue.
* @return verifyDynamicEvents
*/
@jakarta.annotation.Nullable
@JsonProperty(value = JSON_PROPERTY_SYNC_DYNAMIC_EVENT_ACK, required = false)
@JsonProperty(value = JSON_PROPERTY_VERIFY_DYNAMIC_EVENTS, required = false)
@JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
public Boolean getSyncDynamicEventAck() {
return syncDynamicEventAck;
public Boolean getVerifyDynamicEvents() {
return verifyDynamicEvents;
}


@JsonProperty(value = JSON_PROPERTY_SYNC_DYNAMIC_EVENT_ACK, required = false)
@JsonProperty(value = JSON_PROPERTY_VERIFY_DYNAMIC_EVENTS, required = false)
@JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
public void setSyncDynamicEventAck(@jakarta.annotation.Nullable Boolean syncDynamicEventAck) {
this.syncDynamicEventAck = syncDynamicEventAck;
public void setVerifyDynamicEvents(@jakarta.annotation.Nullable Boolean verifyDynamicEvents) {
this.verifyDynamicEvents = verifyDynamicEvents;
}


Expand All @@ -465,6 +494,7 @@ public boolean equals(Object o) {
}
ModelsProjectConfig modelsProjectConfig = (ModelsProjectConfig) o;
return Objects.equals(this.addEventIdTraceHeaders, modelsProjectConfig.addEventIdTraceHeaders) &&
Objects.equals(this.allowUnmatchedDynamicUrls, modelsProjectConfig.allowUnmatchedDynamicUrls) &&
Objects.equals(this.circuitBreaker, modelsProjectConfig.circuitBreaker) &&
Objects.equals(this.disableEndpoint, modelsProjectConfig.disableEndpoint) &&
Objects.equals(this.maxPayloadReadSize, modelsProjectConfig.maxPayloadReadSize) &&
Expand All @@ -477,19 +507,20 @@ public boolean equals(Object o) {
Objects.equals(this.signature, modelsProjectConfig.signature) &&
Objects.equals(this.ssl, modelsProjectConfig.ssl) &&
Objects.equals(this.strategy, modelsProjectConfig.strategy) &&
Objects.equals(this.syncDynamicEventAck, modelsProjectConfig.syncDynamicEventAck);
Objects.equals(this.verifyDynamicEvents, modelsProjectConfig.verifyDynamicEvents);
}

@Override
public int hashCode() {
return Objects.hash(addEventIdTraceHeaders, circuitBreaker, disableEndpoint, maxPayloadReadSize, metaEvent, multipleEndpointSubscriptions, ratelimit, replayAttacksPreventionEnabled, requestIdHeader, searchPolicy, signature, ssl, strategy, syncDynamicEventAck);
return Objects.hash(addEventIdTraceHeaders, allowUnmatchedDynamicUrls, circuitBreaker, disableEndpoint, maxPayloadReadSize, metaEvent, multipleEndpointSubscriptions, ratelimit, replayAttacksPreventionEnabled, requestIdHeader, searchPolicy, signature, ssl, strategy, verifyDynamicEvents);
}

@Override
public String toString() {
StringBuilder sb = new StringBuilder();
sb.append("class ModelsProjectConfig {\n");
sb.append(" addEventIdTraceHeaders: ").append(toIndentedString(addEventIdTraceHeaders)).append("\n");
sb.append(" allowUnmatchedDynamicUrls: ").append(toIndentedString(allowUnmatchedDynamicUrls)).append("\n");
sb.append(" circuitBreaker: ").append(toIndentedString(circuitBreaker)).append("\n");
sb.append(" disableEndpoint: ").append(toIndentedString(disableEndpoint)).append("\n");
sb.append(" maxPayloadReadSize: ").append(toIndentedString(maxPayloadReadSize)).append("\n");
Expand All @@ -502,7 +533,7 @@ public String toString() {
sb.append(" signature: ").append(toIndentedString(signature)).append("\n");
sb.append(" ssl: ").append(toIndentedString(ssl)).append("\n");
sb.append(" strategy: ").append(toIndentedString(strategy)).append("\n");
sb.append(" syncDynamicEventAck: ").append(toIndentedString(syncDynamicEventAck)).append("\n");
sb.append(" verifyDynamicEvents: ").append(toIndentedString(verifyDynamicEvents)).append("\n");
sb.append("}");
return sb.toString();
}
Expand Down Expand Up @@ -552,6 +583,11 @@ public String toUrlQueryString(String prefix) {
joiner.add(String.format(java.util.Locale.ROOT, "%sadd_event_id_trace_headers%s=%s", prefix, suffix, ApiClient.urlEncode(ApiClient.valueToString(getAddEventIdTraceHeaders()))));
}

// add `allow_unmatched_dynamic_urls` to the URL query string
if (getAllowUnmatchedDynamicUrls() != null) {
joiner.add(String.format(java.util.Locale.ROOT, "%sallow_unmatched_dynamic_urls%s=%s", prefix, suffix, ApiClient.urlEncode(ApiClient.valueToString(getAllowUnmatchedDynamicUrls()))));
}

// add `circuit_breaker` to the URL query string
if (getCircuitBreaker() != null) {
joiner.add(getCircuitBreaker().toUrlQueryString(prefix + "circuit_breaker" + suffix));
Expand Down Expand Up @@ -612,9 +648,9 @@ public String toUrlQueryString(String prefix) {
joiner.add(getStrategy().toUrlQueryString(prefix + "strategy" + suffix));
}

// add `sync_dynamic_event_ack` to the URL query string
if (getSyncDynamicEventAck() != null) {
joiner.add(String.format(java.util.Locale.ROOT, "%ssync_dynamic_event_ack%s=%s", prefix, suffix, ApiClient.urlEncode(ApiClient.valueToString(getSyncDynamicEventAck()))));
// add `verify_dynamic_events` to the URL query string
if (getVerifyDynamicEvents() != null) {
joiner.add(String.format(java.util.Locale.ROOT, "%sverify_dynamic_events%s=%s", prefix, suffix, ApiClient.urlEncode(ApiClient.valueToString(getVerifyDynamicEvents()))));
}

return joiner.toString();
Expand Down
Loading