diff --git a/README.md b/README.md index d992cc306..85009cdf1 100755 --- a/README.md +++ b/README.md @@ -21,7 +21,7 @@ The Developer Portal UI can also be used to help build your integration by showi ### Gradle ```groovy -implementation 'com.airbyte.api:public-api:0.5.3' +implementation 'com.airbyte.api:public-api:0.7.1' ``` diff --git a/RELEASES.md b/RELEASES.md index 6b04f8a72..949c7cd37 100644 --- a/RELEASES.md +++ b/RELEASES.md @@ -207,4 +207,28 @@ Based on: - OpenAPI Doc 1.0.0 https://prod.speakeasyapi.dev/v1/apis/public-api/version/v0.1.0/schema/download - Speakeasy CLI 1.26.5 (2.23.6) https://github.com/speakeasy-api/speakeasy ### Releases -- [Maven Central v0.5.3] https://central.sonatype.com/artifact/com.airbyte/api/0.5.3 - . \ No newline at end of file +- [Maven Central v0.5.3] https://central.sonatype.com/artifact/com.airbyte/api/0.5.3 - . + +## 2023-05-03 00:11:17 +### Changes +Based on: +- OpenAPI Doc 1.0.0 https://prod.speakeasyapi.dev/v1/apis/public-api/version/v0.1.0/schema/download +- Speakeasy CLI 1.27.0 (2.24.0) https://github.com/speakeasy-api/speakeasy +### Releases +- [Maven Central v0.6.0] https://central.sonatype.com/artifact/com.airbyte/api/0.6.0 - . + +## 2023-05-05 00:11:13 +### Changes +Based on: +- OpenAPI Doc 1.0.0 https://prod.speakeasyapi.dev/v1/apis/public-api/version/v0.1.0/schema/download +- Speakeasy CLI 1.29.0 (2.26.0) https://github.com/speakeasy-api/speakeasy +### Releases +- [Maven Central v0.7.0] https://central.sonatype.com/artifact/com.airbyte/api/0.7.0 - . + +## 2023-05-06 00:11:54 +### Changes +Based on: +- OpenAPI Doc 1.0.0 https://prod.speakeasyapi.dev/v1/apis/public-api/version/v0.1.0/schema/download +- Speakeasy CLI 1.29.1 (2.26.1) https://github.com/speakeasy-api/speakeasy +### Releases +- [Maven Central v0.7.1] https://central.sonatype.com/artifact/com.airbyte/api/0.7.1 - . \ No newline at end of file diff --git a/docs/sources/README.md b/docs/sources/README.md index 3cade97f3..44aedb303 100755 --- a/docs/sources/README.md +++ b/docs/sources/README.md @@ -148,9 +148,6 @@ import com.airbyte.api.models.shared.SourceFacebookMarketing; import com.airbyte.api.models.shared.SourceFacebookMarketingFacebookMarketingEnum; import com.airbyte.api.models.shared.SourceFacebookMarketingInsightConfig; import com.airbyte.api.models.shared.SourceFacebookMarketingInsightConfigLevelEnum; -import com.airbyte.api.models.shared.SourceFacebookMarketingInsightConfigValidActionBreakdownsEnum; -import com.airbyte.api.models.shared.SourceFacebookMarketingInsightConfigValidBreakdownsEnum; -import com.airbyte.api.models.shared.SourceFacebookMarketingInsightConfigValidEnumsEnum; import com.airbyte.api.models.shared.SourceFacebookPages; import com.airbyte.api.models.shared.SourceFacebookPagesFacebookPagesEnum; import com.airbyte.api.models.shared.SourceFaker; @@ -519,7 +516,6 @@ import com.airbyte.api.models.shared.SourceS3FormatCSV; import com.airbyte.api.models.shared.SourceS3FormatCSVFiletypeEnum; import com.airbyte.api.models.shared.SourceS3FormatJsonl; import com.airbyte.api.models.shared.SourceS3FormatJsonlFiletypeEnum; -import com.airbyte.api.models.shared.SourceS3FormatJsonlUnexpectedFieldBehaviorEnum; import com.airbyte.api.models.shared.SourceS3FormatParquet; import com.airbyte.api.models.shared.SourceS3FormatParquetFiletypeEnum; import com.airbyte.api.models.shared.SourceS3S3AmazonWebServices; diff --git a/docs/workspaces/README.md b/docs/workspaces/README.md index 8f2cc7afd..10eff6a26 100755 --- a/docs/workspaces/README.md +++ b/docs/workspaces/README.md @@ -22,7 +22,6 @@ import com.airbyte.api.models.operations.CreateOrUpdateWorkspaceOAuthCredentials import com.airbyte.api.models.operations.CreateOrUpdateWorkspaceOAuthCredentialsResponse; import com.airbyte.api.models.shared.Security; import com.airbyte.api.models.shared.WorkspaceOAuthCredentialsRequest; -import com.airbyte.api.models.shared.WorkspaceOAuthCredentialsRequestActorTypeEnum; public class Application { public static void main(String[] args) { @@ -33,7 +32,7 @@ public class Application { }}) .build(); - CreateOrUpdateWorkspaceOAuthCredentialsRequest req = new CreateOrUpdateWorkspaceOAuthCredentialsRequest( new WorkspaceOAuthCredentialsRequest(WorkspaceOAuthCredentialsRequestActorTypeEnum.SOURCE, new java.util.HashMap() {{ + CreateOrUpdateWorkspaceOAuthCredentialsRequest req = new CreateOrUpdateWorkspaceOAuthCredentialsRequest( new WorkspaceOAuthCredentialsRequest("inventore", new java.util.HashMap() {{ put("totam", "accusamus"); put("aliquam", "odio"); }}, "occaecati");, "commodi"); diff --git a/files.gen b/files.gen index 9b13a7f92..aa11f4eca 100755 --- a/files.gen +++ b/files.gen @@ -538,9 +538,6 @@ lib/src/main/java/com/airbyte/api/models/shared/SourceEmailoctopusEmailoctopusEn lib/src/main/java/com/airbyte/api/models/shared/SourceEmailoctopus.java lib/src/main/java/com/airbyte/api/models/shared/SourceExchangeRatesExchangeRatesEnum.java lib/src/main/java/com/airbyte/api/models/shared/SourceExchangeRates.java -lib/src/main/java/com/airbyte/api/models/shared/SourceFacebookMarketingInsightConfigValidActionBreakdownsEnum.java -lib/src/main/java/com/airbyte/api/models/shared/SourceFacebookMarketingInsightConfigValidBreakdownsEnum.java -lib/src/main/java/com/airbyte/api/models/shared/SourceFacebookMarketingInsightConfigValidEnumsEnum.java lib/src/main/java/com/airbyte/api/models/shared/SourceFacebookMarketingInsightConfigLevelEnum.java lib/src/main/java/com/airbyte/api/models/shared/SourceFacebookMarketingInsightConfig.java lib/src/main/java/com/airbyte/api/models/shared/SourceFacebookMarketingFacebookMarketingEnum.java @@ -905,7 +902,6 @@ lib/src/main/java/com/airbyte/api/models/shared/SourceRkiCovid.java lib/src/main/java/com/airbyte/api/models/shared/SourceRssRssEnum.java lib/src/main/java/com/airbyte/api/models/shared/SourceRss.java lib/src/main/java/com/airbyte/api/models/shared/SourceS3FormatJsonlFiletypeEnum.java -lib/src/main/java/com/airbyte/api/models/shared/SourceS3FormatJsonlUnexpectedFieldBehaviorEnum.java lib/src/main/java/com/airbyte/api/models/shared/SourceS3FormatJsonl.java lib/src/main/java/com/airbyte/api/models/shared/SourceS3FormatAvroFiletypeEnum.java lib/src/main/java/com/airbyte/api/models/shared/SourceS3FormatAvro.java @@ -1092,7 +1088,6 @@ lib/src/main/java/com/airbyte/api/models/shared/SourceZuora.java lib/src/main/java/com/airbyte/api/models/shared/InitiateOauthRequest.java lib/src/main/java/com/airbyte/api/models/shared/SourcesResponse.java lib/src/main/java/com/airbyte/api/models/shared/StreamProperties.java -lib/src/main/java/com/airbyte/api/models/shared/WorkspaceOAuthCredentialsRequestActorTypeEnum.java lib/src/main/java/com/airbyte/api/models/shared/WorkspaceOAuthCredentialsRequest.java lib/src/main/java/com/airbyte/api/models/shared/WorkspaceResponse.java lib/src/main/java/com/airbyte/api/models/shared/WorkspaceCreateRequest.java diff --git a/gen.yaml b/gen.yaml index 3514f245a..00fca9c3a 100644 --- a/gen.yaml +++ b/gen.yaml @@ -2,19 +2,20 @@ configVersion: 1.0.0 management: docChecksum: b33273ead3e10c4bc4f9bfeed6ad97a4 docVersion: 1.0.0 - speakeasyVersion: 1.26.5 - generationVersion: 2.23.6 + speakeasyVersion: 1.29.1 + generationVersion: 2.26.1 generation: telemetryEnabled: true sdkClassName: airbyte singleTagPerOp: false java: - version: 0.5.3 + version: 0.7.1 artifactID: api companyEmail: info@airbyte.com companyName: Airbyte companyURL: www.airbyte.com githubURL: github.com/airbytehq/airbyte-api-java-sdk groupID: com.airbyte + maxMethodParams: 0 ossrhURL: https://s01.oss.sonatype.org/service/local/staging/deploy/maven2/ projectName: public-api diff --git a/lib/build.gradle b/lib/build.gradle index 07803b85a..71404ab1d 100755 --- a/lib/build.gradle +++ b/lib/build.gradle @@ -41,7 +41,7 @@ publishing { maven(MavenPublication) { groupId = 'com.airbyte' artifactId = 'api' - version = '0.5.3' + version = '0.7.1' from components.java diff --git a/lib/src/main/java/com/airbyte/api/Airbyte.java b/lib/src/main/java/com/airbyte/api/Airbyte.java index 732461fe7..16c540481 100755 --- a/lib/src/main/java/com/airbyte/api/Airbyte.java +++ b/lib/src/main/java/com/airbyte/api/Airbyte.java @@ -30,8 +30,8 @@ public class Airbyte { private com.airbyte.api.models.shared.Security _security; private String _serverUrl; private String _language = "java"; - private String _sdkVersion = "0.5.3"; - private String _genVersion = "2.23.6"; + private String _sdkVersion = "0.7.1"; + private String _genVersion = "2.26.1"; /** * The Builder class allows the configuration of a new instance of the SDK. */ diff --git a/lib/src/main/java/com/airbyte/api/Connections.java b/lib/src/main/java/com/airbyte/api/Connections.java index 70bf141f5..935e9d07a 100755 --- a/lib/src/main/java/com/airbyte/api/Connections.java +++ b/lib/src/main/java/com/airbyte/api/Connections.java @@ -31,12 +31,6 @@ public Connections(HTTPClient defaultClient, HTTPClient securityClient, String s this._genVersion = genVersion; } - /** - * Create a connection - * @param request the request object containing all of the parameters for the API call - * @return the response from the API call - * @throws Exception if the API call fails - */ public com.airbyte.api.models.operations.CreateConnectionResponse createConnection(com.airbyte.api.models.shared.ConnectionCreateRequest request) throws Exception { String baseUrl = this._serverUrl; String url = com.airbyte.api.utils.Utils.generateURL(baseUrl, "/connections"); @@ -76,12 +70,6 @@ else if (httpRes.statusCode() == 400 || httpRes.statusCode() == 403) { return res; } - /** - * Delete a Connection - * @param request the request object containing all of the parameters for the API call - * @return the response from the API call - * @throws Exception if the API call fails - */ public com.airbyte.api.models.operations.DeleteConnectionResponse deleteConnection(com.airbyte.api.models.operations.DeleteConnectionRequest request) throws Exception { String baseUrl = this._serverUrl; String url = com.airbyte.api.utils.Utils.generateURL(com.airbyte.api.models.operations.DeleteConnectionRequest.class, baseUrl, "/connections/{connectionId}", request, null); @@ -108,12 +96,6 @@ public com.airbyte.api.models.operations.DeleteConnectionResponse deleteConnecti return res; } - /** - * Get Connection details - * @param request the request object containing all of the parameters for the API call - * @return the response from the API call - * @throws Exception if the API call fails - */ public com.airbyte.api.models.operations.GetConnectionResponse getConnection(com.airbyte.api.models.operations.GetConnectionRequest request) throws Exception { String baseUrl = this._serverUrl; String url = com.airbyte.api.utils.Utils.generateURL(com.airbyte.api.models.operations.GetConnectionRequest.class, baseUrl, "/connections/{connectionId}", request, null); @@ -148,12 +130,6 @@ else if (httpRes.statusCode() == 403 || httpRes.statusCode() == 404) { return res; } - /** - * List connections - * @param request the request object containing all of the parameters for the API call - * @return the response from the API call - * @throws Exception if the API call fails - */ public com.airbyte.api.models.operations.ListConnectionsResponse listConnections(com.airbyte.api.models.operations.ListConnectionsRequest request) throws Exception { String baseUrl = this._serverUrl; String url = com.airbyte.api.utils.Utils.generateURL(baseUrl, "/connections"); diff --git a/lib/src/main/java/com/airbyte/api/Destinations.java b/lib/src/main/java/com/airbyte/api/Destinations.java index 7bc7d9708..4b4477ebf 100755 --- a/lib/src/main/java/com/airbyte/api/Destinations.java +++ b/lib/src/main/java/com/airbyte/api/Destinations.java @@ -31,13 +31,6 @@ public Destinations(HTTPClient defaultClient, HTTPClient securityClient, String this._genVersion = genVersion; } - /** - * Create a destination - * Creates a destination given a name, workspace id, and a json blob containing the configuration for the source. - * @param request the request object containing all of the parameters for the API call - * @return the response from the API call - * @throws Exception if the API call fails - */ public com.airbyte.api.models.operations.CreateDestinationResponse createDestination(com.airbyte.api.models.shared.DestinationCreateRequest request) throws Exception { String baseUrl = this._serverUrl; String url = com.airbyte.api.utils.Utils.generateURL(baseUrl, "/destinations"); @@ -74,12 +67,6 @@ else if (httpRes.statusCode() == 400 || httpRes.statusCode() == 403 || httpRes.s return res; } - /** - * Delete a Destination - * @param request the request object containing all of the parameters for the API call - * @return the response from the API call - * @throws Exception if the API call fails - */ public com.airbyte.api.models.operations.DeleteDestinationResponse deleteDestination(com.airbyte.api.models.operations.DeleteDestinationRequest request) throws Exception { String baseUrl = this._serverUrl; String url = com.airbyte.api.utils.Utils.generateURL(com.airbyte.api.models.operations.DeleteDestinationRequest.class, baseUrl, "/destinations/{destinationId}", request, null); @@ -106,12 +93,6 @@ public com.airbyte.api.models.operations.DeleteDestinationResponse deleteDestina return res; } - /** - * Get Destination details - * @param request the request object containing all of the parameters for the API call - * @return the response from the API call - * @throws Exception if the API call fails - */ public com.airbyte.api.models.operations.GetDestinationResponse getDestination(com.airbyte.api.models.operations.GetDestinationRequest request) throws Exception { String baseUrl = this._serverUrl; String url = com.airbyte.api.utils.Utils.generateURL(com.airbyte.api.models.operations.GetDestinationRequest.class, baseUrl, "/destinations/{destinationId}", request, null); @@ -146,12 +127,6 @@ else if (httpRes.statusCode() == 403 || httpRes.statusCode() == 404) { return res; } - /** - * List destinations - * @param request the request object containing all of the parameters for the API call - * @return the response from the API call - * @throws Exception if the API call fails - */ public com.airbyte.api.models.operations.ListDestinationsResponse listDestinations(com.airbyte.api.models.operations.ListDestinationsRequest request) throws Exception { String baseUrl = this._serverUrl; String url = com.airbyte.api.utils.Utils.generateURL(baseUrl, "/destinations"); diff --git a/lib/src/main/java/com/airbyte/api/Jobs.java b/lib/src/main/java/com/airbyte/api/Jobs.java index 9acb21728..623ab865a 100755 --- a/lib/src/main/java/com/airbyte/api/Jobs.java +++ b/lib/src/main/java/com/airbyte/api/Jobs.java @@ -31,12 +31,6 @@ public Jobs(HTTPClient defaultClient, HTTPClient securityClient, String serverUr this._genVersion = genVersion; } - /** - * Cancel a running Job - * @param request the request object containing all of the parameters for the API call - * @return the response from the API call - * @throws Exception if the API call fails - */ public com.airbyte.api.models.operations.CancelJobResponse cancelJob(com.airbyte.api.models.operations.CancelJobRequest request) throws Exception { String baseUrl = this._serverUrl; String url = com.airbyte.api.utils.Utils.generateURL(com.airbyte.api.models.operations.CancelJobRequest.class, baseUrl, "/jobs/{jobId}", request, null); @@ -71,12 +65,6 @@ else if (httpRes.statusCode() == 403 || httpRes.statusCode() == 404) { return res; } - /** - * Trigger a sync or reset job of a connection - * @param request the request object containing all of the parameters for the API call - * @return the response from the API call - * @throws Exception if the API call fails - */ public com.airbyte.api.models.operations.CreateJobResponse createJob(com.airbyte.api.models.shared.JobCreateRequest request) throws Exception { String baseUrl = this._serverUrl; String url = com.airbyte.api.utils.Utils.generateURL(baseUrl, "/jobs"); @@ -116,12 +104,6 @@ else if (httpRes.statusCode() == 400 || httpRes.statusCode() == 403) { return res; } - /** - * Get Job status and details - * @param request the request object containing all of the parameters for the API call - * @return the response from the API call - * @throws Exception if the API call fails - */ public com.airbyte.api.models.operations.GetJobResponse getJob(com.airbyte.api.models.operations.GetJobRequest request) throws Exception { String baseUrl = this._serverUrl; String url = com.airbyte.api.utils.Utils.generateURL(com.airbyte.api.models.operations.GetJobRequest.class, baseUrl, "/jobs/{jobId}", request, null); @@ -156,12 +138,6 @@ else if (httpRes.statusCode() == 403 || httpRes.statusCode() == 404) { return res; } - /** - * List Jobs by sync type - * @param request the request object containing all of the parameters for the API call - * @return the response from the API call - * @throws Exception if the API call fails - */ public com.airbyte.api.models.operations.ListJobsResponse listJobs(com.airbyte.api.models.operations.ListJobsRequest request) throws Exception { String baseUrl = this._serverUrl; String url = com.airbyte.api.utils.Utils.generateURL(baseUrl, "/jobs"); diff --git a/lib/src/main/java/com/airbyte/api/Sources.java b/lib/src/main/java/com/airbyte/api/Sources.java index 1d39c0ea5..67aba62fc 100755 --- a/lib/src/main/java/com/airbyte/api/Sources.java +++ b/lib/src/main/java/com/airbyte/api/Sources.java @@ -31,13 +31,6 @@ public Sources(HTTPClient defaultClient, HTTPClient securityClient, String serve this._genVersion = genVersion; } - /** - * Create a source - * Creates a source given a name, workspace id, and a json blob containing the configuration for the source. - * @param request the request object containing all of the parameters for the API call - * @return the response from the API call - * @throws Exception if the API call fails - */ public com.airbyte.api.models.operations.CreateSourceResponse createSource(com.airbyte.api.models.shared.SourceCreateRequest request) throws Exception { String baseUrl = this._serverUrl; String url = com.airbyte.api.utils.Utils.generateURL(baseUrl, "/sources"); @@ -74,12 +67,6 @@ else if (httpRes.statusCode() == 400 || httpRes.statusCode() == 403) { return res; } - /** - * Delete a Source - * @param request the request object containing all of the parameters for the API call - * @return the response from the API call - * @throws Exception if the API call fails - */ public com.airbyte.api.models.operations.DeleteSourceResponse deleteSource(com.airbyte.api.models.operations.DeleteSourceRequest request) throws Exception { String baseUrl = this._serverUrl; String url = com.airbyte.api.utils.Utils.generateURL(com.airbyte.api.models.operations.DeleteSourceRequest.class, baseUrl, "/sources/{sourceId}", request, null); @@ -106,12 +93,6 @@ public com.airbyte.api.models.operations.DeleteSourceResponse deleteSource(com.a return res; } - /** - * Get Source details - * @param request the request object containing all of the parameters for the API call - * @return the response from the API call - * @throws Exception if the API call fails - */ public com.airbyte.api.models.operations.GetSourceResponse getSource(com.airbyte.api.models.operations.GetSourceRequest request) throws Exception { String baseUrl = this._serverUrl; String url = com.airbyte.api.utils.Utils.generateURL(com.airbyte.api.models.operations.GetSourceRequest.class, baseUrl, "/sources/{sourceId}", request, null); @@ -146,17 +127,6 @@ else if (httpRes.statusCode() == 403 || httpRes.statusCode() == 404) { return res; } - /** - * Initiate OAuth for a source - * Given a source ID, workspace ID, and redirect URL, initiates OAuth for the source. - * - * This returns a fully formed URL for performing user authentication against the relevant source identity provider (IdP). Once authentication has been completed, the IdP will redirect to an Airbyte endpoint which will save the access and refresh tokens off as a secret and return the secret ID to the redirect URL specified in the `secret_id` query string parameter. - * - * That secret ID can be used to create a source with credentials in place of actual tokens. - * @param request the request object containing all of the parameters for the API call - * @return the response from the API call - * @throws Exception if the API call fails - */ public com.airbyte.api.models.operations.InitiateOAuthResponse initiateOAuth(com.airbyte.api.models.shared.InitiateOauthRequest request) throws Exception { String baseUrl = this._serverUrl; String url = com.airbyte.api.utils.Utils.generateURL(baseUrl, "/sources/initiateOAuth"); @@ -188,12 +158,6 @@ public com.airbyte.api.models.operations.InitiateOAuthResponse initiateOAuth(com return res; } - /** - * List sources - * @param request the request object containing all of the parameters for the API call - * @return the response from the API call - * @throws Exception if the API call fails - */ public com.airbyte.api.models.operations.ListSourcesResponse listSources(com.airbyte.api.models.operations.ListSourcesRequest request) throws Exception { String baseUrl = this._serverUrl; String url = com.airbyte.api.utils.Utils.generateURL(baseUrl, "/sources"); diff --git a/lib/src/main/java/com/airbyte/api/Streams.java b/lib/src/main/java/com/airbyte/api/Streams.java index 968110a7e..49fb85151 100755 --- a/lib/src/main/java/com/airbyte/api/Streams.java +++ b/lib/src/main/java/com/airbyte/api/Streams.java @@ -30,12 +30,6 @@ public Streams(HTTPClient defaultClient, HTTPClient securityClient, String serve this._genVersion = genVersion; } - /** - * Get stream properties - * @param request the request object containing all of the parameters for the API call - * @return the response from the API call - * @throws Exception if the API call fails - */ public com.airbyte.api.models.operations.GetStreamPropertiesResponse getStreamProperties(com.airbyte.api.models.operations.GetStreamPropertiesRequest request) throws Exception { String baseUrl = this._serverUrl; String url = com.airbyte.api.utils.Utils.generateURL(baseUrl, "/streams"); diff --git a/lib/src/main/java/com/airbyte/api/Workspaces.java b/lib/src/main/java/com/airbyte/api/Workspaces.java index 0bc169d04..22046ca2c 100755 --- a/lib/src/main/java/com/airbyte/api/Workspaces.java +++ b/lib/src/main/java/com/airbyte/api/Workspaces.java @@ -31,14 +31,6 @@ public Workspaces(HTTPClient defaultClient, HTTPClient securityClient, String se this._genVersion = genVersion; } - /** - * Create OAuth override credentials for a workspace and source type. - * Create/update a set of OAuth credentials to override the Airbyte-provided OAuth credentials used for source/destination OAuth. - * In order to determine what the credential configuration needs to be, please see the connector specification of the relevant source/destination. - * @param request the request object containing all of the parameters for the API call - * @return the response from the API call - * @throws Exception if the API call fails - */ public com.airbyte.api.models.operations.CreateOrUpdateWorkspaceOAuthCredentialsResponse createOrUpdateWorkspaceOAuthCredentials(com.airbyte.api.models.operations.CreateOrUpdateWorkspaceOAuthCredentialsRequest request) throws Exception { String baseUrl = this._serverUrl; String url = com.airbyte.api.utils.Utils.generateURL(com.airbyte.api.models.operations.CreateOrUpdateWorkspaceOAuthCredentialsRequest.class, baseUrl, "/workspaces/{workspaceId}/oauthCredentials", request, null); @@ -70,12 +62,6 @@ public com.airbyte.api.models.operations.CreateOrUpdateWorkspaceOAuthCredentials return res; } - /** - * Create a workspace - * @param request the request object containing all of the parameters for the API call - * @return the response from the API call - * @throws Exception if the API call fails - */ public com.airbyte.api.models.operations.CreateWorkspaceResponse createWorkspace(com.airbyte.api.models.shared.WorkspaceCreateRequest request) throws Exception { String baseUrl = this._serverUrl; String url = com.airbyte.api.utils.Utils.generateURL(baseUrl, "/workspaces"); @@ -115,12 +101,6 @@ else if (httpRes.statusCode() == 400 || httpRes.statusCode() == 403) { return res; } - /** - * Get Workspace details - * @param request the request object containing all of the parameters for the API call - * @return the response from the API call - * @throws Exception if the API call fails - */ public com.airbyte.api.models.operations.GetWorkspaceResponse getWorkspace(com.airbyte.api.models.operations.GetWorkspaceRequest request) throws Exception { String baseUrl = this._serverUrl; String url = com.airbyte.api.utils.Utils.generateURL(com.airbyte.api.models.operations.GetWorkspaceRequest.class, baseUrl, "/workspaces/{workspaceId}", request, null); @@ -155,12 +135,6 @@ else if (httpRes.statusCode() == 403 || httpRes.statusCode() == 404) { return res; } - /** - * List workspaces - * @param request the request object containing all of the parameters for the API call - * @return the response from the API call - * @throws Exception if the API call fails - */ public com.airbyte.api.models.operations.ListWorkspacesResponse listWorkspaces(com.airbyte.api.models.operations.ListWorkspacesRequest request) throws Exception { String baseUrl = this._serverUrl; String url = com.airbyte.api.utils.Utils.generateURL(baseUrl, "/workspaces"); diff --git a/lib/src/main/java/com/airbyte/api/models/shared/SourceFacebookMarketingInsightConfig.java b/lib/src/main/java/com/airbyte/api/models/shared/SourceFacebookMarketingInsightConfig.java index e6a5332a0..186d64bba 100755 --- a/lib/src/main/java/com/airbyte/api/models/shared/SourceFacebookMarketingInsightConfig.java +++ b/lib/src/main/java/com/airbyte/api/models/shared/SourceFacebookMarketingInsightConfig.java @@ -22,8 +22,8 @@ public class SourceFacebookMarketingInsightConfig { */ @JsonInclude(Include.NON_ABSENT) @JsonProperty("action_breakdowns") - public SourceFacebookMarketingInsightConfigValidActionBreakdownsEnum[] actionBreakdowns; - public SourceFacebookMarketingInsightConfig withActionBreakdowns(SourceFacebookMarketingInsightConfigValidActionBreakdownsEnum[] actionBreakdowns) { + public Object[] actionBreakdowns; + public SourceFacebookMarketingInsightConfig withActionBreakdowns(Object[] actionBreakdowns) { this.actionBreakdowns = actionBreakdowns; return this; } @@ -33,8 +33,8 @@ public SourceFacebookMarketingInsightConfig withActionBreakdowns(SourceFacebookM */ @JsonInclude(Include.NON_ABSENT) @JsonProperty("breakdowns") - public SourceFacebookMarketingInsightConfigValidBreakdownsEnum[] breakdowns; - public SourceFacebookMarketingInsightConfig withBreakdowns(SourceFacebookMarketingInsightConfigValidBreakdownsEnum[] breakdowns) { + public Object[] breakdowns; + public SourceFacebookMarketingInsightConfig withBreakdowns(Object[] breakdowns) { this.breakdowns = breakdowns; return this; } @@ -57,8 +57,8 @@ public SourceFacebookMarketingInsightConfig withEndDate(OffsetDateTime endDate) */ @JsonInclude(Include.NON_ABSENT) @JsonProperty("fields") - public SourceFacebookMarketingInsightConfigValidEnumsEnum[] fields; - public SourceFacebookMarketingInsightConfig withFields(SourceFacebookMarketingInsightConfigValidEnumsEnum[] fields) { + public Object[] fields; + public SourceFacebookMarketingInsightConfig withFields(Object[] fields) { this.fields = fields; return this; } diff --git a/lib/src/main/java/com/airbyte/api/models/shared/SourceFacebookMarketingInsightConfigValidActionBreakdownsEnum.java b/lib/src/main/java/com/airbyte/api/models/shared/SourceFacebookMarketingInsightConfigValidActionBreakdownsEnum.java deleted file mode 100755 index 9f108f3ac..000000000 --- a/lib/src/main/java/com/airbyte/api/models/shared/SourceFacebookMarketingInsightConfigValidActionBreakdownsEnum.java +++ /dev/null @@ -1,32 +0,0 @@ -/* - * Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT. - */ - -package com.airbyte.api.models.shared; - -import com.fasterxml.jackson.annotation.JsonValue; - -/** - * SourceFacebookMarketingInsightConfigValidActionBreakdownsEnum - Generic enumeration. - * - * Derive from this class to define new enumerations. - */ -public enum SourceFacebookMarketingInsightConfigValidActionBreakdownsEnum { - ACTION_CANVAS_COMPONENT_NAME("action_canvas_component_name"), - ACTION_CAROUSEL_CARD_ID("action_carousel_card_id"), - ACTION_CAROUSEL_CARD_NAME("action_carousel_card_name"), - ACTION_DESTINATION("action_destination"), - ACTION_DEVICE("action_device"), - ACTION_REACTION("action_reaction"), - ACTION_TARGET_ID("action_target_id"), - ACTION_TYPE("action_type"), - ACTION_VIDEO_SOUND("action_video_sound"), - ACTION_VIDEO_TYPE("action_video_type"); - - @JsonValue - public final String value; - - private SourceFacebookMarketingInsightConfigValidActionBreakdownsEnum(String value) { - this.value = value; - } -} diff --git a/lib/src/main/java/com/airbyte/api/models/shared/SourceFacebookMarketingInsightConfigValidBreakdownsEnum.java b/lib/src/main/java/com/airbyte/api/models/shared/SourceFacebookMarketingInsightConfigValidBreakdownsEnum.java deleted file mode 100755 index 74e3b5a99..000000000 --- a/lib/src/main/java/com/airbyte/api/models/shared/SourceFacebookMarketingInsightConfigValidBreakdownsEnum.java +++ /dev/null @@ -1,49 +0,0 @@ -/* - * Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT. - */ - -package com.airbyte.api.models.shared; - -import com.fasterxml.jackson.annotation.JsonValue; - -/** - * SourceFacebookMarketingInsightConfigValidBreakdownsEnum - Generic enumeration. - * - * Derive from this class to define new enumerations. - */ -public enum SourceFacebookMarketingInsightConfigValidBreakdownsEnum { - AD_FORMAT_ASSET("ad_format_asset"), - AGE("age"), - APP_ID("app_id"), - BODY_ASSET("body_asset"), - CALL_TO_ACTION_ASSET("call_to_action_asset"), - COUNTRY("country"), - DESCRIPTION_ASSET("description_asset"), - DEVICE_PLATFORM("device_platform"), - DMA("dma"), - FREQUENCY_VALUE("frequency_value"), - GENDER("gender"), - HOURLY_STATS_AGGREGATED_BY_ADVERTISER_TIME_ZONE("hourly_stats_aggregated_by_advertiser_time_zone"), - HOURLY_STATS_AGGREGATED_BY_AUDIENCE_TIME_ZONE("hourly_stats_aggregated_by_audience_time_zone"), - IMAGE_ASSET("image_asset"), - IMPRESSION_DEVICE("impression_device"), - IS_CONVERSION_ID_MODELED("is_conversion_id_modeled"), - LINK_URL_ASSET("link_url_asset"), - MMM("mmm"), - PLACE_PAGE_ID("place_page_id"), - PLATFORM_POSITION("platform_position"), - PRODUCT_ID("product_id"), - PUBLISHER_PLATFORM("publisher_platform"), - REGION("region"), - SKAN_CAMPAIGN_ID("skan_campaign_id"), - SKAN_CONVERSION_ID("skan_conversion_id"), - TITLE_ASSET("title_asset"), - VIDEO_ASSET("video_asset"); - - @JsonValue - public final String value; - - private SourceFacebookMarketingInsightConfigValidBreakdownsEnum(String value) { - this.value = value; - } -} diff --git a/lib/src/main/java/com/airbyte/api/models/shared/SourceFacebookMarketingInsightConfigValidEnumsEnum.java b/lib/src/main/java/com/airbyte/api/models/shared/SourceFacebookMarketingInsightConfigValidEnumsEnum.java deleted file mode 100755 index c8a68f529..000000000 --- a/lib/src/main/java/com/airbyte/api/models/shared/SourceFacebookMarketingInsightConfigValidEnumsEnum.java +++ /dev/null @@ -1,153 +0,0 @@ -/* - * Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT. - */ - -package com.airbyte.api.models.shared; - -import com.fasterxml.jackson.annotation.JsonValue; - -/** - * SourceFacebookMarketingInsightConfigValidEnumsEnum - Generic enumeration. - * - * Derive from this class to define new enumerations. - */ -public enum SourceFacebookMarketingInsightConfigValidEnumsEnum { - ACCOUNT_CURRENCY("account_currency"), - ACCOUNT_ID("account_id"), - ACCOUNT_NAME("account_name"), - ACTION_VALUES("action_values"), - ACTIONS("actions"), - AD_BID_VALUE("ad_bid_value"), - AD_CLICK_ACTIONS("ad_click_actions"), - AD_ID("ad_id"), - AD_IMPRESSION_ACTIONS("ad_impression_actions"), - AD_NAME("ad_name"), - ADSET_BID_VALUE("adset_bid_value"), - ADSET_END("adset_end"), - ADSET_ID("adset_id"), - ADSET_NAME("adset_name"), - ADSET_START("adset_start"), - AGE_TARGETING("age_targeting"), - ATTRIBUTION_SETTING("attribution_setting"), - AUCTION_BID("auction_bid"), - AUCTION_COMPETITIVENESS("auction_competitiveness"), - AUCTION_MAX_COMPETITOR_BID("auction_max_competitor_bid"), - BUYING_TYPE("buying_type"), - CAMPAIGN_ID("campaign_id"), - CAMPAIGN_NAME("campaign_name"), - CANVAS_AVG_VIEW_PERCENT("canvas_avg_view_percent"), - CANVAS_AVG_VIEW_TIME("canvas_avg_view_time"), - CATALOG_SEGMENT_ACTIONS("catalog_segment_actions"), - CATALOG_SEGMENT_VALUE("catalog_segment_value"), - CATALOG_SEGMENT_VALUE_MOBILE_PURCHASE_ROAS("catalog_segment_value_mobile_purchase_roas"), - CATALOG_SEGMENT_VALUE_OMNI_PURCHASE_ROAS("catalog_segment_value_omni_purchase_roas"), - CATALOG_SEGMENT_VALUE_WEBSITE_PURCHASE_ROAS("catalog_segment_value_website_purchase_roas"), - CLICKS("clicks"), - CONVERSION_RATE_RANKING("conversion_rate_ranking"), - CONVERSION_VALUES("conversion_values"), - CONVERSIONS("conversions"), - CONVERTED_PRODUCT_QUANTITY("converted_product_quantity"), - CONVERTED_PRODUCT_VALUE("converted_product_value"), - COST_PER15_SEC_VIDEO_VIEW("cost_per_15_sec_video_view"), - COST_PER2_SEC_CONTINUOUS_VIDEO_VIEW("cost_per_2_sec_continuous_video_view"), - COST_PER_ACTION_TYPE("cost_per_action_type"), - COST_PER_AD_CLICK("cost_per_ad_click"), - COST_PER_CONVERSION("cost_per_conversion"), - COST_PER_DDA_COUNTBY_CONVS("cost_per_dda_countby_convs"), - COST_PER_ESTIMATED_AD_RECALLERS("cost_per_estimated_ad_recallers"), - COST_PER_INLINE_LINK_CLICK("cost_per_inline_link_click"), - COST_PER_INLINE_POST_ENGAGEMENT("cost_per_inline_post_engagement"), - COST_PER_ONE_THOUSAND_AD_IMPRESSION("cost_per_one_thousand_ad_impression"), - COST_PER_OUTBOUND_CLICK("cost_per_outbound_click"), - COST_PER_THRUPLAY("cost_per_thruplay"), - COST_PER_UNIQUE_ACTION_TYPE("cost_per_unique_action_type"), - COST_PER_UNIQUE_CLICK("cost_per_unique_click"), - COST_PER_UNIQUE_CONVERSION("cost_per_unique_conversion"), - COST_PER_UNIQUE_INLINE_LINK_CLICK("cost_per_unique_inline_link_click"), - COST_PER_UNIQUE_OUTBOUND_CLICK("cost_per_unique_outbound_click"), - CPC("cpc"), - CPM("cpm"), - CPP("cpp"), - CREATED_TIME("created_time"), - CTR("ctr"), - DATE_START("date_start"), - DATE_STOP("date_stop"), - DDA_COUNTBY_CONVS("dda_countby_convs"), - DDA_RESULTS("dda_results"), - ENGAGEMENT_RATE_RANKING("engagement_rate_ranking"), - ESTIMATED_AD_RECALL_RATE("estimated_ad_recall_rate"), - ESTIMATED_AD_RECALL_RATE_LOWER_BOUND("estimated_ad_recall_rate_lower_bound"), - ESTIMATED_AD_RECALL_RATE_UPPER_BOUND("estimated_ad_recall_rate_upper_bound"), - ESTIMATED_AD_RECALLERS("estimated_ad_recallers"), - ESTIMATED_AD_RECALLERS_LOWER_BOUND("estimated_ad_recallers_lower_bound"), - ESTIMATED_AD_RECALLERS_UPPER_BOUND("estimated_ad_recallers_upper_bound"), - FREQUENCY("frequency"), - FULL_VIEW_IMPRESSIONS("full_view_impressions"), - FULL_VIEW_REACH("full_view_reach"), - GENDER_TARGETING("gender_targeting"), - IMPRESSIONS("impressions"), - INLINE_LINK_CLICK_CTR("inline_link_click_ctr"), - INLINE_LINK_CLICKS("inline_link_clicks"), - INLINE_POST_ENGAGEMENT("inline_post_engagement"), - INSTANT_EXPERIENCE_CLICKS_TO_OPEN("instant_experience_clicks_to_open"), - INSTANT_EXPERIENCE_CLICKS_TO_START("instant_experience_clicks_to_start"), - INSTANT_EXPERIENCE_OUTBOUND_CLICKS("instant_experience_outbound_clicks"), - INTERACTIVE_COMPONENT_TAP("interactive_component_tap"), - LABELS("labels"), - LOCATION("location"), - MOBILE_APP_PURCHASE_ROAS("mobile_app_purchase_roas"), - OBJECTIVE("objective"), - OPTIMIZATION_GOAL("optimization_goal"), - OUTBOUND_CLICKS("outbound_clicks"), - OUTBOUND_CLICKS_CTR("outbound_clicks_ctr"), - PLACE_PAGE_NAME("place_page_name"), - PURCHASE_ROAS("purchase_roas"), - QUALIFYING_QUESTION_QUALIFY_ANSWER_RATE("qualifying_question_qualify_answer_rate"), - QUALITY_RANKING("quality_ranking"), - QUALITY_SCORE_ECTR("quality_score_ectr"), - QUALITY_SCORE_ECVR("quality_score_ecvr"), - QUALITY_SCORE_ORGANIC("quality_score_organic"), - REACH("reach"), - SOCIAL_SPEND("social_spend"), - SPEND("spend"), - TOTAL_POSTBACKS("total_postbacks"), - TOTAL_POSTBACKS_DETAILED("total_postbacks_detailed"), - UNIQUE_ACTIONS("unique_actions"), - UNIQUE_CLICKS("unique_clicks"), - UNIQUE_CONVERSIONS("unique_conversions"), - UNIQUE_CTR("unique_ctr"), - UNIQUE_INLINE_LINK_CLICK_CTR("unique_inline_link_click_ctr"), - UNIQUE_INLINE_LINK_CLICKS("unique_inline_link_clicks"), - UNIQUE_LINK_CLICKS_CTR("unique_link_clicks_ctr"), - UNIQUE_OUTBOUND_CLICKS("unique_outbound_clicks"), - UNIQUE_OUTBOUND_CLICKS_CTR("unique_outbound_clicks_ctr"), - UNIQUE_VIDEO_CONTINUOUS2_SEC_WATCHED_ACTIONS("unique_video_continuous_2_sec_watched_actions"), - UNIQUE_VIDEO_VIEW15_SEC("unique_video_view_15_sec"), - UPDATED_TIME("updated_time"), - VIDEO15_SEC_WATCHED_ACTIONS("video_15_sec_watched_actions"), - VIDEO30_SEC_WATCHED_ACTIONS("video_30_sec_watched_actions"), - VIDEO_AVG_TIME_WATCHED_ACTIONS("video_avg_time_watched_actions"), - VIDEO_CONTINUOUS2_SEC_WATCHED_ACTIONS("video_continuous_2_sec_watched_actions"), - VIDEO_P100_WATCHED_ACTIONS("video_p100_watched_actions"), - VIDEO_P25_WATCHED_ACTIONS("video_p25_watched_actions"), - VIDEO_P50_WATCHED_ACTIONS("video_p50_watched_actions"), - VIDEO_P75_WATCHED_ACTIONS("video_p75_watched_actions"), - VIDEO_P95_WATCHED_ACTIONS("video_p95_watched_actions"), - VIDEO_PLAY_ACTIONS("video_play_actions"), - VIDEO_PLAY_CURVE_ACTIONS("video_play_curve_actions"), - VIDEO_PLAY_RETENTION0_TO15S_ACTIONS("video_play_retention_0_to_15s_actions"), - VIDEO_PLAY_RETENTION20_TO60S_ACTIONS("video_play_retention_20_to_60s_actions"), - VIDEO_PLAY_RETENTION_GRAPH_ACTIONS("video_play_retention_graph_actions"), - VIDEO_THRUPLAY_WATCHED_ACTIONS("video_thruplay_watched_actions"), - VIDEO_TIME_WATCHED_ACTIONS("video_time_watched_actions"), - WEBSITE_CTR("website_ctr"), - WEBSITE_PURCHASE_ROAS("website_purchase_roas"), - WISH_BID("wish_bid"); - - @JsonValue - public final String value; - - private SourceFacebookMarketingInsightConfigValidEnumsEnum(String value) { - this.value = value; - } -} diff --git a/lib/src/main/java/com/airbyte/api/models/shared/SourceNytimesPeriodUsedForMostPopularStreamsEnum.java b/lib/src/main/java/com/airbyte/api/models/shared/SourceNytimesPeriodUsedForMostPopularStreamsEnum.java index 75f14f843..a08325c03 100755 --- a/lib/src/main/java/com/airbyte/api/models/shared/SourceNytimesPeriodUsedForMostPopularStreamsEnum.java +++ b/lib/src/main/java/com/airbyte/api/models/shared/SourceNytimesPeriodUsedForMostPopularStreamsEnum.java @@ -10,14 +10,14 @@ * SourceNytimesPeriodUsedForMostPopularStreamsEnum - Period of time (in days) */ public enum SourceNytimesPeriodUsedForMostPopularStreamsEnum { - ONE("1"), - SEVEN("7"), - THIRTY("30"); + ONE(1L), + SEVEN(7L), + THIRTY(30L); @JsonValue - public final String value; + public final Long value; - private SourceNytimesPeriodUsedForMostPopularStreamsEnum(String value) { + private SourceNytimesPeriodUsedForMostPopularStreamsEnum(Long value) { this.value = value; } } diff --git a/lib/src/main/java/com/airbyte/api/models/shared/SourceS3FormatJsonl.java b/lib/src/main/java/com/airbyte/api/models/shared/SourceS3FormatJsonl.java index 796b5cc1a..7667b0a43 100755 --- a/lib/src/main/java/com/airbyte/api/models/shared/SourceS3FormatJsonl.java +++ b/lib/src/main/java/com/airbyte/api/models/shared/SourceS3FormatJsonl.java @@ -47,8 +47,8 @@ public SourceS3FormatJsonl withNewlinesInValues(Boolean newlinesInValues) { */ @JsonInclude(Include.NON_ABSENT) @JsonProperty("unexpected_field_behavior") - public SourceS3FormatJsonlUnexpectedFieldBehaviorEnum unexpectedFieldBehavior; - public SourceS3FormatJsonl withUnexpectedFieldBehavior(SourceS3FormatJsonlUnexpectedFieldBehaviorEnum unexpectedFieldBehavior) { + public Object unexpectedFieldBehavior; + public SourceS3FormatJsonl withUnexpectedFieldBehavior(Object unexpectedFieldBehavior) { this.unexpectedFieldBehavior = unexpectedFieldBehavior; return this; } diff --git a/lib/src/main/java/com/airbyte/api/models/shared/SourceS3FormatJsonlUnexpectedFieldBehaviorEnum.java b/lib/src/main/java/com/airbyte/api/models/shared/SourceS3FormatJsonlUnexpectedFieldBehaviorEnum.java deleted file mode 100755 index 5d64f9315..000000000 --- a/lib/src/main/java/com/airbyte/api/models/shared/SourceS3FormatJsonlUnexpectedFieldBehaviorEnum.java +++ /dev/null @@ -1,23 +0,0 @@ -/* - * Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT. - */ - -package com.airbyte.api.models.shared; - -import com.fasterxml.jackson.annotation.JsonValue; - -/** - * SourceS3FormatJsonlUnexpectedFieldBehaviorEnum - How JSON fields outside of explicit_schema (if given) are treated. Check <a href="https://arrow.apache.org/docs/python/generated/pyarrow.json.ParseOptions.html" target="_blank">PyArrow documentation</a> for details - */ -public enum SourceS3FormatJsonlUnexpectedFieldBehaviorEnum { - IGNORE("ignore"), - INFER("infer"), - ERROR("error"); - - @JsonValue - public final String value; - - private SourceS3FormatJsonlUnexpectedFieldBehaviorEnum(String value) { - this.value = value; - } -} diff --git a/lib/src/main/java/com/airbyte/api/models/shared/WorkspaceOAuthCredentialsRequest.java b/lib/src/main/java/com/airbyte/api/models/shared/WorkspaceOAuthCredentialsRequest.java index 46dddabba..8b194f87d 100755 --- a/lib/src/main/java/com/airbyte/api/models/shared/WorkspaceOAuthCredentialsRequest.java +++ b/lib/src/main/java/com/airbyte/api/models/shared/WorkspaceOAuthCredentialsRequest.java @@ -14,8 +14,8 @@ public class WorkspaceOAuthCredentialsRequest { * Whether you're setting this override for a source or destination */ @JsonProperty("actorType") - public WorkspaceOAuthCredentialsRequestActorTypeEnum actorType; - public WorkspaceOAuthCredentialsRequest withActorType(WorkspaceOAuthCredentialsRequestActorTypeEnum actorType) { + public Object actorType; + public WorkspaceOAuthCredentialsRequest withActorType(Object actorType) { this.actorType = actorType; return this; } @@ -37,7 +37,7 @@ public WorkspaceOAuthCredentialsRequest withName(String name) { return this; } - public WorkspaceOAuthCredentialsRequest(@JsonProperty("actorType") WorkspaceOAuthCredentialsRequestActorTypeEnum actorType, @JsonProperty("configuration") java.util.Map configuration, @JsonProperty("name") String name) { + public WorkspaceOAuthCredentialsRequest(@JsonProperty("actorType") Object actorType, @JsonProperty("configuration") java.util.Map configuration, @JsonProperty("name") String name) { this.actorType = actorType; this.configuration = configuration; this.name = name; diff --git a/lib/src/main/java/com/airbyte/api/models/shared/WorkspaceOAuthCredentialsRequestActorTypeEnum.java b/lib/src/main/java/com/airbyte/api/models/shared/WorkspaceOAuthCredentialsRequestActorTypeEnum.java deleted file mode 100755 index 6418e3627..000000000 --- a/lib/src/main/java/com/airbyte/api/models/shared/WorkspaceOAuthCredentialsRequestActorTypeEnum.java +++ /dev/null @@ -1,22 +0,0 @@ -/* - * Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT. - */ - -package com.airbyte.api.models.shared; - -import com.fasterxml.jackson.annotation.JsonValue; - -/** - * WorkspaceOAuthCredentialsRequestActorTypeEnum - Whether you're setting this override for a source or destination - */ -public enum WorkspaceOAuthCredentialsRequestActorTypeEnum { - SOURCE("source"), - DESTINATION("destination"); - - @JsonValue - public final String value; - - private WorkspaceOAuthCredentialsRequestActorTypeEnum(String value) { - this.value = value; - } -} diff --git a/lib/src/main/java/com/airbyte/api/utils/QueryParameters.java b/lib/src/main/java/com/airbyte/api/utils/QueryParameters.java index 90fb4a638..6153af7f7 100755 --- a/lib/src/main/java/com/airbyte/api/utils/QueryParameters.java +++ b/lib/src/main/java/com/airbyte/api/utils/QueryParameters.java @@ -41,13 +41,17 @@ public static List parseQueryParams(Class t } else { switch (queryParamsMetadata.style) { case "form": - List params = parseFormParams(queryParamsMetadata, value); - allParams.addAll(params); + List formParams = parseDelimitedParams(queryParamsMetadata, value, ","); + allParams.addAll(formParams); break; case "deepObject": List deepObjectParams = parseDeepObjectParams(queryParamsMetadata, value); allParams.addAll(deepObjectParams); break; + case "pipeDelimited": + List pipeDelimitedParams = parseDelimitedParams(queryParamsMetadata, value, "|"); + allParams.addAll(pipeDelimitedParams); + break; } } } @@ -71,7 +75,7 @@ private static List parseSerializedParams(QueryParamsMetadata que return params; } - private static List parseFormParams(QueryParamsMetadata queryParamsMetadata, Object value) + private static List parseDelimitedParams(QueryParamsMetadata queryParamsMetadata, Object value, String delimiter) throws IllegalArgumentException, IllegalAccessException { List params = new ArrayList<>(); @@ -91,7 +95,7 @@ private static List parseFormParams(QueryParamsMetadata queryPara } if (items.size() > 0) { - values.add(String.join(",", items)); + values.add(String.join(delimiter, items)); } params.addAll(values.stream().map(v -> new BasicNameValuePair(queryParamsMetadata.name, v))