Skip to content

Commit ad1a05c

Browse files
polytomic-sdk-botpolytomic-sdk-bot
committed
Release 1.9.0
1 parent 887469e commit ad1a05c

15 files changed

Lines changed: 660 additions & 189 deletions

‎build.gradle‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ publishing {
4646
maven(MavenPublication) {
4747
groupId = 'com.polytomic'
4848
artifactId = 'polytomic-java'
49-
version = '1.8.0'
49+
version = '1.9.0'
5050
from components.java
5151
pom {
5252
licenses {

‎src/main/java/com/polytomic/api/core/ClientOptions.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ private ClientOptions(
3030
{
3131
put("X-Fern-Language", "JAVA");
3232
put("X-Fern-SDK-Name", "com.polytomic.fern:api-sdk");
33-
put("X-Fern-SDK-Version", "1.8.0");
33+
put("X-Fern-SDK-Version", "1.9.0");
3434
}
3535
});
3636
this.headerSuppliers = headerSuppliers;

‎src/main/java/com/polytomic/api/resources/bulksync/requests/CreateBulkSyncRequest.java‎

Lines changed: 26 additions & 31 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@
1515
import com.polytomic.api.resources.bulksync.types.V2CreateBulkSyncRequestSchemasItem;
1616
import com.polytomic.api.types.BulkDiscover;
1717
import com.polytomic.api.types.BulkSchedule;
18+
import com.polytomic.api.types.SyncMode;
1819
import java.util.HashMap;
1920
import java.util.List;
2021
import java.util.Map;
@@ -38,7 +39,7 @@ public final class CreateBulkSyncRequest {
3839

3940
private final Optional<Boolean> discover;
4041

41-
private final String mode;
42+
private final Optional<SyncMode> mode;
4243

4344
private final String name;
4445

@@ -64,7 +65,7 @@ private CreateBulkSyncRequest(
6465
String destinationConnectionId,
6566
Optional<Boolean> disableRecordTimestamps,
6667
Optional<Boolean> discover,
67-
String mode,
68+
Optional<SyncMode> mode,
6869
String name,
6970
Optional<String> organizationId,
7071
Optional<List<String>> policies,
@@ -129,11 +130,8 @@ public Optional<Boolean> getDiscover() {
129130
return discover;
130131
}
131132

132-
/**
133-
* @return Either 'replicate' or 'snapshot'.
134-
*/
135133
@JsonProperty("mode")
136-
public String getMode() {
134+
public Optional<SyncMode> getMode() {
137135
return mode;
138136
}
139137

@@ -234,15 +232,11 @@ public static DestinationConnectionIdStage builder() {
234232
}
235233

236234
public interface DestinationConnectionIdStage {
237-
ModeStage destinationConnectionId(String destinationConnectionId);
235+
NameStage destinationConnectionId(String destinationConnectionId);
238236

239237
Builder from(CreateBulkSyncRequest other);
240238
}
241239

242-
public interface ModeStage {
243-
NameStage mode(String mode);
244-
}
245-
246240
public interface NameStage {
247241
ScheduleStage name(String name);
248242
}
@@ -282,6 +276,10 @@ public interface _FinalStage {
282276

283277
_FinalStage discover(Boolean discover);
284278

279+
_FinalStage mode(Optional<SyncMode> mode);
280+
281+
_FinalStage mode(SyncMode mode);
282+
285283
_FinalStage organizationId(Optional<String> organizationId);
286284

287285
_FinalStage organizationId(String organizationId);
@@ -301,16 +299,9 @@ public interface _FinalStage {
301299

302300
@JsonIgnoreProperties(ignoreUnknown = true)
303301
public static final class Builder
304-
implements DestinationConnectionIdStage,
305-
ModeStage,
306-
NameStage,
307-
ScheduleStage,
308-
SourceConnectionIdStage,
309-
_FinalStage {
302+
implements DestinationConnectionIdStage, NameStage, ScheduleStage, SourceConnectionIdStage, _FinalStage {
310303
private String destinationConnectionId;
311304

312-
private String mode;
313-
314305
private String name;
315306

316307
private BulkSchedule schedule;
@@ -325,6 +316,8 @@ public static final class Builder
325316

326317
private Optional<String> organizationId = Optional.empty();
327318

319+
private Optional<SyncMode> mode = Optional.empty();
320+
328321
private Optional<Boolean> discover = Optional.empty();
329322

330323
private Optional<Boolean> disableRecordTimestamps = Optional.empty();
@@ -364,22 +357,11 @@ public Builder from(CreateBulkSyncRequest other) {
364357

365358
@java.lang.Override
366359
@JsonSetter("destination_connection_id")
367-
public ModeStage destinationConnectionId(String destinationConnectionId) {
360+
public NameStage destinationConnectionId(String destinationConnectionId) {
368361
this.destinationConnectionId = destinationConnectionId;
369362
return this;
370363
}
371364

372-
/**
373-
* <p>Either 'replicate' or 'snapshot'.</p>
374-
* @return Reference to {@code this} so that method calls can be chained together.
375-
*/
376-
@java.lang.Override
377-
@JsonSetter("mode")
378-
public NameStage mode(String mode) {
379-
this.mode = mode;
380-
return this;
381-
}
382-
383365
@java.lang.Override
384366
@JsonSetter("name")
385367
public ScheduleStage name(String name) {
@@ -457,6 +439,19 @@ public _FinalStage organizationId(Optional<String> organizationId) {
457439
return this;
458440
}
459441

442+
@java.lang.Override
443+
public _FinalStage mode(SyncMode mode) {
444+
this.mode = Optional.of(mode);
445+
return this;
446+
}
447+
448+
@java.lang.Override
449+
@JsonSetter(value = "mode", nulls = Nulls.SKIP)
450+
public _FinalStage mode(Optional<SyncMode> mode) {
451+
this.mode = mode;
452+
return this;
453+
}
454+
460455
/**
461456
* <p>DEPRECATED: Use automatically_add_new_objects/automatically_add_new_fields instead</p>
462457
* @return Reference to {@code this} so that method calls can be chained together.

‎src/main/java/com/polytomic/api/resources/bulksync/requests/UpdateBulkSyncRequest.java‎

Lines changed: 26 additions & 31 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@
1515
import com.polytomic.api.resources.bulksync.types.V2UpdateBulkSyncRequestSchemasItem;
1616
import com.polytomic.api.types.BulkDiscover;
1717
import com.polytomic.api.types.BulkSchedule;
18+
import com.polytomic.api.types.SyncMode;
1819
import java.util.HashMap;
1920
import java.util.List;
2021
import java.util.Map;
@@ -38,7 +39,7 @@ public final class UpdateBulkSyncRequest {
3839

3940
private final Optional<Boolean> discover;
4041

41-
private final String mode;
42+
private final Optional<SyncMode> mode;
4243

4344
private final String name;
4445

@@ -64,7 +65,7 @@ private UpdateBulkSyncRequest(
6465
String destinationConnectionId,
6566
Optional<Boolean> disableRecordTimestamps,
6667
Optional<Boolean> discover,
67-
String mode,
68+
Optional<SyncMode> mode,
6869
String name,
6970
Optional<String> organizationId,
7071
Optional<List<String>> policies,
@@ -129,11 +130,8 @@ public Optional<Boolean> getDiscover() {
129130
return discover;
130131
}
131132

132-
/**
133-
* @return Either 'replicate' or 'snapshot'.
134-
*/
135133
@JsonProperty("mode")
136-
public String getMode() {
134+
public Optional<SyncMode> getMode() {
137135
return mode;
138136
}
139137

@@ -234,15 +232,11 @@ public static DestinationConnectionIdStage builder() {
234232
}
235233

236234
public interface DestinationConnectionIdStage {
237-
ModeStage destinationConnectionId(String destinationConnectionId);
235+
NameStage destinationConnectionId(String destinationConnectionId);
238236

239237
Builder from(UpdateBulkSyncRequest other);
240238
}
241239

242-
public interface ModeStage {
243-
NameStage mode(String mode);
244-
}
245-
246240
public interface NameStage {
247241
ScheduleStage name(String name);
248242
}
@@ -282,6 +276,10 @@ public interface _FinalStage {
282276

283277
_FinalStage discover(Boolean discover);
284278

279+
_FinalStage mode(Optional<SyncMode> mode);
280+
281+
_FinalStage mode(SyncMode mode);
282+
285283
_FinalStage organizationId(Optional<String> organizationId);
286284

287285
_FinalStage organizationId(String organizationId);
@@ -301,16 +299,9 @@ public interface _FinalStage {
301299

302300
@JsonIgnoreProperties(ignoreUnknown = true)
303301
public static final class Builder
304-
implements DestinationConnectionIdStage,
305-
ModeStage,
306-
NameStage,
307-
ScheduleStage,
308-
SourceConnectionIdStage,
309-
_FinalStage {
302+
implements DestinationConnectionIdStage, NameStage, ScheduleStage, SourceConnectionIdStage, _FinalStage {
310303
private String destinationConnectionId;
311304

312-
private String mode;
313-
314305
private String name;
315306

316307
private BulkSchedule schedule;
@@ -325,6 +316,8 @@ public static final class Builder
325316

326317
private Optional<String> organizationId = Optional.empty();
327318

319+
private Optional<SyncMode> mode = Optional.empty();
320+
328321
private Optional<Boolean> discover = Optional.empty();
329322

330323
private Optional<Boolean> disableRecordTimestamps = Optional.empty();
@@ -364,22 +357,11 @@ public Builder from(UpdateBulkSyncRequest other) {
364357

365358
@java.lang.Override
366359
@JsonSetter("destination_connection_id")
367-
public ModeStage destinationConnectionId(String destinationConnectionId) {
360+
public NameStage destinationConnectionId(String destinationConnectionId) {
368361
this.destinationConnectionId = destinationConnectionId;
369362
return this;
370363
}
371364

372-
/**
373-
* <p>Either 'replicate' or 'snapshot'.</p>
374-
* @return Reference to {@code this} so that method calls can be chained together.
375-
*/
376-
@java.lang.Override
377-
@JsonSetter("mode")
378-
public NameStage mode(String mode) {
379-
this.mode = mode;
380-
return this;
381-
}
382-
383365
@java.lang.Override
384366
@JsonSetter("name")
385367
public ScheduleStage name(String name) {
@@ -457,6 +439,19 @@ public _FinalStage organizationId(Optional<String> organizationId) {
457439
return this;
458440
}
459441

442+
@java.lang.Override
443+
public _FinalStage mode(SyncMode mode) {
444+
this.mode = Optional.of(mode);
445+
return this;
446+
}
447+
448+
@java.lang.Override
449+
@JsonSetter(value = "mode", nulls = Nulls.SKIP)
450+
public _FinalStage mode(Optional<SyncMode> mode) {
451+
this.mode = mode;
452+
return this;
453+
}
454+
460455
/**
461456
* <p>DEPRECATED: Use automatically_add_new_objects/automatically_add_new_fields instead</p>
462457
* @return Reference to {@code this} so that method calls can be chained together.

‎src/main/java/com/polytomic/api/resources/modelsync/ModelSyncClient.java‎

Lines changed: 38 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@
2727
import com.polytomic.api.types.StartModelSyncResponseEnvelope;
2828
import com.polytomic.api.types.SyncStatusEnvelope;
2929
import com.polytomic.api.types.TargetResponseEnvelope;
30+
import com.polytomic.api.types.V4TargetObjectsResponseEnvelope;
3031
import java.io.IOException;
3132
import java.util.function.Supplier;
3233
import okhttp3.Headers;
@@ -212,6 +213,43 @@ public TargetResponseEnvelope getTargetFields(
212213
}
213214
}
214215

216+
public V4TargetObjectsResponseEnvelope getTargetObjects(String id) {
217+
return getTargetObjects(id, null);
218+
}
219+
220+
public V4TargetObjectsResponseEnvelope getTargetObjects(String id, RequestOptions requestOptions) {
221+
HttpUrl httpUrl = HttpUrl.parse(this.clientOptions.environment().getUrl())
222+
.newBuilder()
223+
.addPathSegments("api/connections")
224+
.addPathSegment(id)
225+
.addPathSegments("modelsync/targetobjects")
226+
.build();
227+
Request okhttpRequest = new Request.Builder()
228+
.url(httpUrl)
229+
.method("GET", null)
230+
.headers(Headers.of(clientOptions.headers(requestOptions)))
231+
.addHeader("Content-Type", "application/json")
232+
.build();
233+
try {
234+
OkHttpClient client = clientOptions.httpClient();
235+
if (requestOptions != null && requestOptions.getTimeout().isPresent()) {
236+
client = clientOptions.httpClientWithTimeout(requestOptions);
237+
}
238+
Response response = client.newCall(okhttpRequest).execute();
239+
ResponseBody responseBody = response.body();
240+
if (response.isSuccessful()) {
241+
return ObjectMappers.JSON_MAPPER.readValue(
242+
responseBody.string(), V4TargetObjectsResponseEnvelope.class);
243+
}
244+
throw new ApiError(
245+
response.code(),
246+
ObjectMappers.JSON_MAPPER.readValue(
247+
responseBody != null ? responseBody.string() : "{}", Object.class));
248+
} catch (IOException e) {
249+
throw new RuntimeException(e);
250+
}
251+
}
252+
215253
public ListModelSyncResponseEnvelope list() {
216254
return list(null);
217255
}

‎src/main/java/com/polytomic/api/resources/queryrunner/QueryRunnerClient.java‎

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -48,9 +48,6 @@ public V4RunQueryEnvelope runQuery(String connectionId, V4RunQueryRequest reques
4848
httpUrl.addQueryParameter("query", request.getQuery().get());
4949
}
5050
Map<String, Object> properties = new HashMap<>();
51-
if (request.getV4RunQueryRequestQuery().isPresent()) {
52-
properties.put("query", request.getV4RunQueryRequestQuery());
53-
}
5451
RequestBody body;
5552
try {
5653
body = RequestBody.create(

0 commit comments

Comments
 (0)