@@ -31,6 +31,13 @@ public Sources(HTTPClient defaultClient, HTTPClient securityClient, String serve
31
31
this ._genVersion = genVersion ;
32
32
}
33
33
34
+ /**
35
+ * Create a source
36
+ * Creates a source given a name, workspace id, and a json blob containing the configuration for the source.
37
+ * @param request the request object containing all of the parameters for the API call
38
+ * @return the response from the API call
39
+ * @throws Exception if the API call fails
40
+ */
34
41
public com .airbyte .api .models .operations .CreateSourceResponse createSource (com .airbyte .api .models .shared .SourceCreateRequest request ) throws Exception {
35
42
String baseUrl = this ._serverUrl ;
36
43
String url = com .airbyte .api .utils .Utils .generateURL (baseUrl , "/sources" );
@@ -67,6 +74,12 @@ else if (httpRes.statusCode() == 400 || httpRes.statusCode() == 403) {
67
74
return res ;
68
75
}
69
76
77
+ /**
78
+ * Delete a Source
79
+ * @param request the request object containing all of the parameters for the API call
80
+ * @return the response from the API call
81
+ * @throws Exception if the API call fails
82
+ */
70
83
public com .airbyte .api .models .operations .DeleteSourceResponse deleteSource (com .airbyte .api .models .operations .DeleteSourceRequest request ) throws Exception {
71
84
String baseUrl = this ._serverUrl ;
72
85
String url = com .airbyte .api .utils .Utils .generateURL (com .airbyte .api .models .operations .DeleteSourceRequest .class , baseUrl , "/sources/{sourceId}" , request , null );
@@ -93,6 +106,12 @@ public com.airbyte.api.models.operations.DeleteSourceResponse deleteSource(com.a
93
106
return res ;
94
107
}
95
108
109
+ /**
110
+ * Get Source details
111
+ * @param request the request object containing all of the parameters for the API call
112
+ * @return the response from the API call
113
+ * @throws Exception if the API call fails
114
+ */
96
115
public com .airbyte .api .models .operations .GetSourceResponse getSource (com .airbyte .api .models .operations .GetSourceRequest request ) throws Exception {
97
116
String baseUrl = this ._serverUrl ;
98
117
String url = com .airbyte .api .utils .Utils .generateURL (com .airbyte .api .models .operations .GetSourceRequest .class , baseUrl , "/sources/{sourceId}" , request , null );
@@ -127,6 +146,17 @@ else if (httpRes.statusCode() == 403 || httpRes.statusCode() == 404) {
127
146
return res ;
128
147
}
129
148
149
+ /**
150
+ * Initiate OAuth for a source
151
+ * Given a source ID, workspace ID, and redirect URL, initiates OAuth for the source.
152
+ *
153
+ * 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.
154
+ *
155
+ * That secret ID can be used to create a source with credentials in place of actual tokens.
156
+ * @param request the request object containing all of the parameters for the API call
157
+ * @return the response from the API call
158
+ * @throws Exception if the API call fails
159
+ */
130
160
public com .airbyte .api .models .operations .InitiateOAuthResponse initiateOAuth (com .airbyte .api .models .shared .InitiateOauthRequest request ) throws Exception {
131
161
String baseUrl = this ._serverUrl ;
132
162
String url = com .airbyte .api .utils .Utils .generateURL (baseUrl , "/sources/initiateOAuth" );
@@ -158,6 +188,12 @@ public com.airbyte.api.models.operations.InitiateOAuthResponse initiateOAuth(com
158
188
return res ;
159
189
}
160
190
191
+ /**
192
+ * List sources
193
+ * @param request the request object containing all of the parameters for the API call
194
+ * @return the response from the API call
195
+ * @throws Exception if the API call fails
196
+ */
161
197
public com .airbyte .api .models .operations .ListSourcesResponse listSources (com .airbyte .api .models .operations .ListSourcesRequest request ) throws Exception {
162
198
String baseUrl = this ._serverUrl ;
163
199
String url = com .airbyte .api .utils .Utils .generateURL (baseUrl , "/sources" );
0 commit comments