Skip to content

Commit 029cb68

Browse files
saileshwar-skyflowsaileshwar-skyflow
committed
SK-2646: update fern generated code
1 parent ae1a35b commit 029cb68

56 files changed

Lines changed: 1563 additions & 1056 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎v3/src/main/java/com/skyflow/VaultClient.java‎

Lines changed: 27 additions & 27 deletions
Original file line numberDiff line numberDiff line change
@@ -8,11 +8,11 @@
88
import com.skyflow.errors.SkyflowException;
99
import com.skyflow.generated.rest.ApiClient;
1010
import com.skyflow.generated.rest.ApiClientBuilder;
11-
import com.skyflow.generated.rest.resources.recordservice.RecordserviceClient;
12-
import com.skyflow.generated.rest.resources.recordservice.requests.InsertRequest;
13-
import com.skyflow.generated.rest.types.EnumUpdateType;
14-
import com.skyflow.generated.rest.types.InsertRecordData;
15-
import com.skyflow.generated.rest.types.Upsert;
11+
import com.skyflow.generated.rest.resources.flowservice.FlowserviceClient;
12+
import com.skyflow.generated.rest.resources.flowservice.requests.V1InsertRequest;
13+
import com.skyflow.generated.rest.types.FlowEnumUpdateType;
14+
import com.skyflow.generated.rest.types.V1InsertRecordData;
15+
import com.skyflow.generated.rest.types.V1Upsert;
1616
import com.skyflow.logs.InfoLogs;
1717
import com.skyflow.serviceaccount.util.Token;
1818
import com.skyflow.utils.Constants;
@@ -48,8 +48,8 @@ protected VaultClient(VaultConfig vaultConfig, Credentials credentials) throws S
4848
updateVaultURL();
4949
}
5050

51-
protected RecordserviceClient getRecordsApi() {
52-
return this.apiClient.recordservice();
51+
protected FlowserviceClient getRecordsApi() {
52+
return this.apiClient.flowservice();
5353
}
5454

5555
protected VaultConfig getVaultConfig() {
@@ -141,34 +141,34 @@ protected void updateExecutorInHTTP() {
141141
apiClientBuilder.httpClient(httpClient);
142142
}
143143

144-
protected InsertRequest getBulkInsertRequestBody(com.skyflow.vault.data.InsertRequest request, VaultConfig config) {
144+
protected V1InsertRequest getBulkInsertRequestBody(com.skyflow.vault.data.InsertRequest request, VaultConfig config) {
145145
ArrayList<InsertRecord> records = request.getRecords();
146-
List<InsertRecordData> insertRecordDataList = new ArrayList<>();
146+
List<V1InsertRecordData> insertRecordDataList = new ArrayList<>();
147147
for (InsertRecord record : records) {
148-
InsertRecordData.Builder data = InsertRecordData.builder();
148+
V1InsertRecordData.Builder data = V1InsertRecordData.builder();
149149
data.data(record.getData());
150150
if (record.getTable() != null && !record.getTable().isEmpty()) {
151151
data.tableName(record.getTable());
152152
}
153153
if (record.getUpsert() != null && !record.getUpsert().isEmpty()) {
154154
if (record.getUpsertType() != null) {
155-
EnumUpdateType updateType = null;
155+
FlowEnumUpdateType updateType = null;
156156
if (record.getUpsertType() == UpsertType.REPLACE) {
157-
updateType = EnumUpdateType.REPLACE;
157+
updateType = FlowEnumUpdateType.REPLACE;
158158
} else if (record.getUpsertType() == UpsertType.UPDATE) {
159-
updateType = EnumUpdateType.UPDATE;
159+
updateType = FlowEnumUpdateType.UPDATE;
160160
}
161-
Upsert upsert = Upsert.builder().uniqueColumns(record.getUpsert()).updateType(updateType).build();
161+
V1Upsert upsert = V1Upsert.builder().uniqueColumns(record.getUpsert()).updateType(updateType).build();
162162
data.upsert(upsert);
163163
} else {
164-
Upsert upsert = Upsert.builder().uniqueColumns(record.getUpsert()).build();
164+
V1Upsert upsert = V1Upsert.builder().uniqueColumns(record.getUpsert()).build();
165165
data.upsert(upsert);
166166
}
167167
}
168168
insertRecordDataList.add(data.build());
169169
}
170170

171-
InsertRequest.Builder builder = InsertRequest.builder()
171+
V1InsertRequest.Builder builder = V1InsertRequest.builder()
172172
.vaultId(config.getVaultId())
173173
.records(insertRecordDataList);
174174

@@ -178,34 +178,34 @@ protected InsertRequest getBulkInsertRequestBody(com.skyflow.vault.data.InsertRe
178178

179179
if (request.getUpsert() != null && !request.getUpsert().isEmpty()) {
180180
if (request.getUpsertType() != null) {
181-
EnumUpdateType updateType = null;
181+
FlowEnumUpdateType updateType = null;
182182
if (request.getUpsertType() == UpsertType.REPLACE) {
183-
updateType = EnumUpdateType.REPLACE;
183+
updateType = FlowEnumUpdateType.REPLACE;
184184
} else if (request.getUpsertType() == UpsertType.UPDATE) {
185-
updateType = EnumUpdateType.UPDATE;
185+
updateType = FlowEnumUpdateType.UPDATE;
186186
}
187-
Upsert upsert = Upsert.builder().uniqueColumns(request.getUpsert()).updateType(updateType).build();
187+
V1Upsert upsert = V1Upsert.builder().uniqueColumns(request.getUpsert()).updateType(updateType).build();
188188
builder.upsert(upsert);
189189
} else {
190-
Upsert upsert = Upsert.builder().uniqueColumns(request.getUpsert()).build();
190+
V1Upsert upsert = V1Upsert.builder().uniqueColumns(request.getUpsert()).build();
191191
builder.upsert(upsert);
192192
}
193193
}
194194
return builder.build();
195195

196196
}
197197

198-
protected com.skyflow.generated.rest.resources.recordservice.requests.DetokenizeRequest getDetokenizeRequestBody(DetokenizeRequest request) {
198+
protected com.skyflow.generated.rest.resources.flowservice.requests.V1FlowDetokenizeRequest getDetokenizeRequestBody(DetokenizeRequest request) {
199199
List<String> tokens = request.getTokens();
200-
com.skyflow.generated.rest.resources.recordservice.requests.DetokenizeRequest.Builder builder =
201-
com.skyflow.generated.rest.resources.recordservice.requests.DetokenizeRequest.builder()
200+
com.skyflow.generated.rest.resources.flowservice.requests.V1FlowDetokenizeRequest.Builder builder =
201+
com.skyflow.generated.rest.resources.flowservice.requests.V1FlowDetokenizeRequest.builder()
202202
.vaultId(this.vaultConfig.getVaultId())
203203
.tokens(tokens);
204204
if (request.getTokenGroupRedactions() != null) {
205-
List<com.skyflow.generated.rest.types.TokenGroupRedactions> tokenGroupRedactionsList = new ArrayList<>();
205+
List<com.skyflow.generated.rest.types.V1TokenGroupRedactions> tokenGroupRedactionsList = new ArrayList<>();
206206
for (com.skyflow.vault.data.TokenGroupRedactions tokenGroupRedactions : request.getTokenGroupRedactions()) {
207-
com.skyflow.generated.rest.types.TokenGroupRedactions redactions =
208-
com.skyflow.generated.rest.types.TokenGroupRedactions.builder()
207+
com.skyflow.generated.rest.types.V1TokenGroupRedactions redactions =
208+
com.skyflow.generated.rest.types.V1TokenGroupRedactions.builder()
209209
.tokenGroupName(tokenGroupRedactions.getTokenGroupName())
210210
.redaction(tokenGroupRedactions.getRedaction())
211211
.build();

‎v3/src/main/java/com/skyflow/generated/rest/ApiClient.java‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -5,29 +5,29 @@
55

66
import com.skyflow.generated.rest.core.ClientOptions;
77
import com.skyflow.generated.rest.core.Suppliers;
8+
import com.skyflow.generated.rest.resources.flowservice.FlowserviceClient;
89
import com.skyflow.generated.rest.resources.records.RecordsClient;
9-
import com.skyflow.generated.rest.resources.recordservice.RecordserviceClient;
1010
import java.util.function.Supplier;
1111

1212
public class ApiClient {
1313
protected final ClientOptions clientOptions;
1414

1515
protected final Supplier<RecordsClient> recordsClient;
1616

17-
protected final Supplier<RecordserviceClient> recordserviceClient;
17+
protected final Supplier<FlowserviceClient> flowserviceClient;
1818

1919
public ApiClient(ClientOptions clientOptions) {
2020
this.clientOptions = clientOptions;
2121
this.recordsClient = Suppliers.memoize(() -> new RecordsClient(clientOptions));
22-
this.recordserviceClient = Suppliers.memoize(() -> new RecordserviceClient(clientOptions));
22+
this.flowserviceClient = Suppliers.memoize(() -> new FlowserviceClient(clientOptions));
2323
}
2424

2525
public RecordsClient records() {
2626
return this.recordsClient.get();
2727
}
2828

29-
public RecordserviceClient recordservice() {
30-
return this.recordserviceClient.get();
29+
public FlowserviceClient flowservice() {
30+
return this.flowserviceClient.get();
3131
}
3232

3333
public static ApiClientBuilder builder() {

‎v3/src/main/java/com/skyflow/generated/rest/AsyncApiClient.java‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -5,29 +5,29 @@
55

66
import com.skyflow.generated.rest.core.ClientOptions;
77
import com.skyflow.generated.rest.core.Suppliers;
8+
import com.skyflow.generated.rest.resources.flowservice.AsyncFlowserviceClient;
89
import com.skyflow.generated.rest.resources.records.AsyncRecordsClient;
9-
import com.skyflow.generated.rest.resources.recordservice.AsyncRecordserviceClient;
1010
import java.util.function.Supplier;
1111

1212
public class AsyncApiClient {
1313
protected final ClientOptions clientOptions;
1414

1515
protected final Supplier<AsyncRecordsClient> recordsClient;
1616

17-
protected final Supplier<AsyncRecordserviceClient> recordserviceClient;
17+
protected final Supplier<AsyncFlowserviceClient> flowserviceClient;
1818

1919
public AsyncApiClient(ClientOptions clientOptions) {
2020
this.clientOptions = clientOptions;
2121
this.recordsClient = Suppliers.memoize(() -> new AsyncRecordsClient(clientOptions));
22-
this.recordserviceClient = Suppliers.memoize(() -> new AsyncRecordserviceClient(clientOptions));
22+
this.flowserviceClient = Suppliers.memoize(() -> new AsyncFlowserviceClient(clientOptions));
2323
}
2424

2525
public AsyncRecordsClient records() {
2626
return this.recordsClient.get();
2727
}
2828

29-
public AsyncRecordserviceClient recordservice() {
30-
return this.recordserviceClient.get();
29+
public AsyncFlowserviceClient flowservice() {
30+
return this.flowserviceClient.get();
3131
}
3232

3333
public static AsyncApiClientBuilder builder() {

‎v3/src/main/java/com/skyflow/generated/rest/core/ClientOptions.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ private ClientOptions(
3434
{
3535
put("X-Fern-Language", "JAVA");
3636
put("X-Fern-SDK-Name", "com.skyflow.fern:api-sdk");
37-
put("X-Fern-SDK-Version", "0.0.352");
37+
put("X-Fern-SDK-Version", "0.0.98");
3838
}
3939
});
4040
this.headerSuppliers = headerSuppliers;

‎v3/src/main/java/com/skyflow/generated/rest/resources/flowservice/AsyncFlowserviceClient.java‎

Lines changed: 142 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,142 @@
1+
/**
2+
* This file was auto-generated by Fern from our API Definition.
3+
*/
4+
package com.skyflow.generated.rest.resources.flowservice;
5+
6+
import com.skyflow.generated.rest.core.ClientOptions;
7+
import com.skyflow.generated.rest.core.RequestOptions;
8+
import com.skyflow.generated.rest.resources.flowservice.requests.V1DeleteRequest;
9+
import com.skyflow.generated.rest.resources.flowservice.requests.V1FlowDeleteTokenRequest;
10+
import com.skyflow.generated.rest.resources.flowservice.requests.V1FlowDetokenizeRequest;
11+
import com.skyflow.generated.rest.resources.flowservice.requests.V1FlowTokenizeRequest;
12+
import com.skyflow.generated.rest.resources.flowservice.requests.V1FlowVaultMetricsRequest;
13+
import com.skyflow.generated.rest.resources.flowservice.requests.V1GetRequest;
14+
import com.skyflow.generated.rest.resources.flowservice.requests.V1InsertRequest;
15+
import com.skyflow.generated.rest.resources.flowservice.requests.V1UpdateRequest;
16+
import com.skyflow.generated.rest.types.V1DeleteResponse;
17+
import com.skyflow.generated.rest.types.V1FlowDeleteTokenResponse;
18+
import com.skyflow.generated.rest.types.V1FlowDetokenizeResponse;
19+
import com.skyflow.generated.rest.types.V1FlowTokenizeResponse;
20+
import com.skyflow.generated.rest.types.V1FlowVaultMetricsResponse;
21+
import com.skyflow.generated.rest.types.V1GetResponse;
22+
import com.skyflow.generated.rest.types.V1InsertResponse;
23+
import com.skyflow.generated.rest.types.V1UpdateResponse;
24+
import java.util.concurrent.CompletableFuture;
25+
26+
public class AsyncFlowserviceClient {
27+
protected final ClientOptions clientOptions;
28+
29+
private final AsyncRawFlowserviceClient rawClient;
30+
31+
public AsyncFlowserviceClient(ClientOptions clientOptions) {
32+
this.clientOptions = clientOptions;
33+
this.rawClient = new AsyncRawFlowserviceClient(clientOptions);
34+
}
35+
36+
/**
37+
* Get responses with HTTP metadata like headers
38+
*/
39+
public AsyncRawFlowserviceClient withRawResponse() {
40+
return this.rawClient;
41+
}
42+
43+
public CompletableFuture<V1DeleteResponse> delete() {
44+
return this.rawClient.delete().thenApply(response -> response.body());
45+
}
46+
47+
public CompletableFuture<V1DeleteResponse> delete(V1DeleteRequest request) {
48+
return this.rawClient.delete(request).thenApply(response -> response.body());
49+
}
50+
51+
public CompletableFuture<V1DeleteResponse> delete(V1DeleteRequest request, RequestOptions requestOptions) {
52+
return this.rawClient.delete(request, requestOptions).thenApply(response -> response.body());
53+
}
54+
55+
public CompletableFuture<V1GetResponse> get() {
56+
return this.rawClient.get().thenApply(response -> response.body());
57+
}
58+
59+
public CompletableFuture<V1GetResponse> get(V1GetRequest request) {
60+
return this.rawClient.get(request).thenApply(response -> response.body());
61+
}
62+
63+
public CompletableFuture<V1GetResponse> get(V1GetRequest request, RequestOptions requestOptions) {
64+
return this.rawClient.get(request, requestOptions).thenApply(response -> response.body());
65+
}
66+
67+
public CompletableFuture<V1InsertResponse> insert() {
68+
return this.rawClient.insert().thenApply(response -> response.body());
69+
}
70+
71+
public CompletableFuture<V1InsertResponse> insert(V1InsertRequest request) {
72+
return this.rawClient.insert(request).thenApply(response -> response.body());
73+
}
74+
75+
public CompletableFuture<V1InsertResponse> insert(V1InsertRequest request, RequestOptions requestOptions) {
76+
return this.rawClient.insert(request, requestOptions).thenApply(response -> response.body());
77+
}
78+
79+
public CompletableFuture<V1UpdateResponse> update() {
80+
return this.rawClient.update().thenApply(response -> response.body());
81+
}
82+
83+
public CompletableFuture<V1UpdateResponse> update(V1UpdateRequest request) {
84+
return this.rawClient.update(request).thenApply(response -> response.body());
85+
}
86+
87+
public CompletableFuture<V1UpdateResponse> update(V1UpdateRequest request, RequestOptions requestOptions) {
88+
return this.rawClient.update(request, requestOptions).thenApply(response -> response.body());
89+
}
90+
91+
public CompletableFuture<V1FlowDeleteTokenResponse> deletetoken() {
92+
return this.rawClient.deletetoken().thenApply(response -> response.body());
93+
}
94+
95+
public CompletableFuture<V1FlowDeleteTokenResponse> deletetoken(V1FlowDeleteTokenRequest request) {
96+
return this.rawClient.deletetoken(request).thenApply(response -> response.body());
97+
}
98+
99+
public CompletableFuture<V1FlowDeleteTokenResponse> deletetoken(
100+
V1FlowDeleteTokenRequest request, RequestOptions requestOptions) {
101+
return this.rawClient.deletetoken(request, requestOptions).thenApply(response -> response.body());
102+
}
103+
104+
public CompletableFuture<V1FlowDetokenizeResponse> detokenize() {
105+
return this.rawClient.detokenize().thenApply(response -> response.body());
106+
}
107+
108+
public CompletableFuture<V1FlowDetokenizeResponse> detokenize(V1FlowDetokenizeRequest request) {
109+
return this.rawClient.detokenize(request).thenApply(response -> response.body());
110+
}
111+
112+
public CompletableFuture<V1FlowDetokenizeResponse> detokenize(
113+
V1FlowDetokenizeRequest request, RequestOptions requestOptions) {
114+
return this.rawClient.detokenize(request, requestOptions).thenApply(response -> response.body());
115+
}
116+
117+
public CompletableFuture<V1FlowTokenizeResponse> tokenize() {
118+
return this.rawClient.tokenize().thenApply(response -> response.body());
119+
}
120+
121+
public CompletableFuture<V1FlowTokenizeResponse> tokenize(V1FlowTokenizeRequest request) {
122+
return this.rawClient.tokenize(request).thenApply(response -> response.body());
123+
}
124+
125+
public CompletableFuture<V1FlowTokenizeResponse> tokenize(
126+
V1FlowTokenizeRequest request, RequestOptions requestOptions) {
127+
return this.rawClient.tokenize(request, requestOptions).thenApply(response -> response.body());
128+
}
129+
130+
public CompletableFuture<V1FlowVaultMetricsResponse> flowvaultmetrics() {
131+
return this.rawClient.flowvaultmetrics().thenApply(response -> response.body());
132+
}
133+
134+
public CompletableFuture<V1FlowVaultMetricsResponse> flowvaultmetrics(V1FlowVaultMetricsRequest request) {
135+
return this.rawClient.flowvaultmetrics(request).thenApply(response -> response.body());
136+
}
137+
138+
public CompletableFuture<V1FlowVaultMetricsResponse> flowvaultmetrics(
139+
V1FlowVaultMetricsRequest request, RequestOptions requestOptions) {
140+
return this.rawClient.flowvaultmetrics(request, requestOptions).thenApply(response -> response.body());
141+
}
142+
}

0 commit comments

Comments
 (0)