1use reqwest;
13use serde::{Deserialize, Serialize};
14use crate::{apis::ResponseContent, models};
15use super::{Error, configuration};
16
17
18#[derive(Debug, Clone, Serialize, Deserialize)]
20#[serde(untagged)]
21pub enum AddUserError {
22 UnknownValue(serde_json::Value),
23}
24
25#[derive(Debug, Clone, Serialize, Deserialize)]
27#[serde(untagged)]
28pub enum ArchiveWorkspaceError {
29 UnknownValue(serde_json::Value),
30}
31
32#[derive(Debug, Clone, Serialize, Deserialize)]
34#[serde(untagged)]
35pub enum ChangeWorkspaceColorError {
36 UnknownValue(serde_json::Value),
37}
38
39#[derive(Debug, Clone, Serialize, Deserialize)]
41#[serde(untagged)]
42pub enum ChangeWorkspaceIdError {
43 UnknownValue(serde_json::Value),
44}
45
46#[derive(Debug, Clone, Serialize, Deserialize)]
48#[serde(untagged)]
49pub enum ChangeWorkspaceNameError {
50 UnknownValue(serde_json::Value),
51}
52
53#[derive(Debug, Clone, Serialize, Deserialize)]
55#[serde(untagged)]
56pub enum ConnectTeamsError {
57 UnknownValue(serde_json::Value),
58}
59
60#[derive(Debug, Clone, Serialize, Deserialize)]
62#[serde(untagged)]
63pub enum CreateWorkspaceError {
64 UnknownValue(serde_json::Value),
65}
66
67#[derive(Debug, Clone, Serialize, Deserialize)]
69#[serde(untagged)]
70pub enum CreateWorkspaceForkError {
71 UnknownValue(serde_json::Value),
72}
73
74#[derive(Debug, Clone, Serialize, Deserialize)]
76#[serde(untagged)]
77pub enum DeleteGitSyncRepositoryError {
78 UnknownValue(serde_json::Value),
79}
80
81#[derive(Debug, Clone, Serialize, Deserialize)]
83#[serde(untagged)]
84pub enum DeleteInviteError {
85 UnknownValue(serde_json::Value),
86}
87
88#[derive(Debug, Clone, Serialize, Deserialize)]
90#[serde(untagged)]
91pub enum DeleteWorkspaceError {
92 UnknownValue(serde_json::Value),
93}
94
95#[derive(Debug, Clone, Serialize, Deserialize)]
97#[serde(untagged)]
98pub enum EditAutoInviteError {
99 UnknownValue(serde_json::Value),
100}
101
102#[derive(Debug, Clone, Serialize, Deserialize)]
104#[serde(untagged)]
105pub enum EditCopilotConfigError {
106 UnknownValue(serde_json::Value),
107}
108
109#[derive(Debug, Clone, Serialize, Deserialize)]
111#[serde(untagged)]
112pub enum EditDefaultScriptsError {
113 UnknownValue(serde_json::Value),
114}
115
116#[derive(Debug, Clone, Serialize, Deserialize)]
118#[serde(untagged)]
119pub enum EditDeployToError {
120 UnknownValue(serde_json::Value),
121}
122
123#[derive(Debug, Clone, Serialize, Deserialize)]
125#[serde(untagged)]
126pub enum EditDucklakeConfigError {
127 UnknownValue(serde_json::Value),
128}
129
130#[derive(Debug, Clone, Serialize, Deserialize)]
132#[serde(untagged)]
133pub enum EditErrorHandlerError {
134 UnknownValue(serde_json::Value),
135}
136
137#[derive(Debug, Clone, Serialize, Deserialize)]
139#[serde(untagged)]
140pub enum EditGitSyncRepositoryError {
141 UnknownValue(serde_json::Value),
142}
143
144#[derive(Debug, Clone, Serialize, Deserialize)]
146#[serde(untagged)]
147pub enum EditInstanceGroupsError {
148 UnknownValue(serde_json::Value),
149}
150
151#[derive(Debug, Clone, Serialize, Deserialize)]
153#[serde(untagged)]
154pub enum EditLargeFileStorageConfigError {
155 UnknownValue(serde_json::Value),
156}
157
158#[derive(Debug, Clone, Serialize, Deserialize)]
160#[serde(untagged)]
161pub enum EditSlackCommandError {
162 UnknownValue(serde_json::Value),
163}
164
165#[derive(Debug, Clone, Serialize, Deserialize)]
167#[serde(untagged)]
168pub enum EditTeamsCommandError {
169 UnknownValue(serde_json::Value),
170}
171
172#[derive(Debug, Clone, Serialize, Deserialize)]
174#[serde(untagged)]
175pub enum EditWebhookError {
176 UnknownValue(serde_json::Value),
177}
178
179#[derive(Debug, Clone, Serialize, Deserialize)]
181#[serde(untagged)]
182pub enum EditWorkspaceDefaultAppError {
183 UnknownValue(serde_json::Value),
184}
185
186#[derive(Debug, Clone, Serialize, Deserialize)]
188#[serde(untagged)]
189pub enum EditWorkspaceDeployUiSettingsError {
190 UnknownValue(serde_json::Value),
191}
192
193#[derive(Debug, Clone, Serialize, Deserialize)]
195#[serde(untagged)]
196pub enum EditWorkspaceGitSyncConfigError {
197 UnknownValue(serde_json::Value),
198}
199
200#[derive(Debug, Clone, Serialize, Deserialize)]
202#[serde(untagged)]
203pub enum ExistsUsernameError {
204 UnknownValue(serde_json::Value),
205}
206
207#[derive(Debug, Clone, Serialize, Deserialize)]
209#[serde(untagged)]
210pub enum ExistsWorkspaceError {
211 UnknownValue(serde_json::Value),
212}
213
214#[derive(Debug, Clone, Serialize, Deserialize)]
216#[serde(untagged)]
217pub enum GetCopilotInfoError {
218 UnknownValue(serde_json::Value),
219}
220
221#[derive(Debug, Clone, Serialize, Deserialize)]
223#[serde(untagged)]
224pub enum GetDefaultScriptsError {
225 UnknownValue(serde_json::Value),
226}
227
228#[derive(Debug, Clone, Serialize, Deserialize)]
230#[serde(untagged)]
231pub enum GetDeployToError {
232 UnknownValue(serde_json::Value),
233}
234
235#[derive(Debug, Clone, Serialize, Deserialize)]
237#[serde(untagged)]
238pub enum GetGithubAppTokenError {
239 UnknownValue(serde_json::Value),
240}
241
242#[derive(Debug, Clone, Serialize, Deserialize)]
244#[serde(untagged)]
245pub enum GetIsPremiumError {
246 UnknownValue(serde_json::Value),
247}
248
249#[derive(Debug, Clone, Serialize, Deserialize)]
251#[serde(untagged)]
252pub enum GetLargeFileStorageConfigError {
253 UnknownValue(serde_json::Value),
254}
255
256#[derive(Debug, Clone, Serialize, Deserialize)]
258#[serde(untagged)]
259pub enum GetPremiumInfoError {
260 UnknownValue(serde_json::Value),
261}
262
263#[derive(Debug, Clone, Serialize, Deserialize)]
265#[serde(untagged)]
266pub enum GetSettingsError {
267 UnknownValue(serde_json::Value),
268}
269
270#[derive(Debug, Clone, Serialize, Deserialize)]
272#[serde(untagged)]
273pub enum GetThresholdAlertError {
274 UnknownValue(serde_json::Value),
275}
276
277#[derive(Debug, Clone, Serialize, Deserialize)]
279#[serde(untagged)]
280pub enum GetUsedTriggersError {
281 UnknownValue(serde_json::Value),
282}
283
284#[derive(Debug, Clone, Serialize, Deserialize)]
286#[serde(untagged)]
287pub enum GetWorkspaceDefaultAppError {
288 UnknownValue(serde_json::Value),
289}
290
291#[derive(Debug, Clone, Serialize, Deserialize)]
293#[serde(untagged)]
294pub enum GetWorkspaceEncryptionKeyError {
295 UnknownValue(serde_json::Value),
296}
297
298#[derive(Debug, Clone, Serialize, Deserialize)]
300#[serde(untagged)]
301pub enum GetWorkspaceNameError {
302 UnknownValue(serde_json::Value),
303}
304
305#[derive(Debug, Clone, Serialize, Deserialize)]
307#[serde(untagged)]
308pub enum GetWorkspaceUsageError {
309 UnknownValue(serde_json::Value),
310}
311
312#[derive(Debug, Clone, Serialize, Deserialize)]
314#[serde(untagged)]
315pub enum InviteUserError {
316 UnknownValue(serde_json::Value),
317}
318
319#[derive(Debug, Clone, Serialize, Deserialize)]
321#[serde(untagged)]
322pub enum IsDomainAllowedError {
323 UnknownValue(serde_json::Value),
324}
325
326#[derive(Debug, Clone, Serialize, Deserialize)]
328#[serde(untagged)]
329pub enum LeaveWorkspaceError {
330 UnknownValue(serde_json::Value),
331}
332
333#[derive(Debug, Clone, Serialize, Deserialize)]
335#[serde(untagged)]
336pub enum ListAvailableTeamsChannelsError {
337 UnknownValue(serde_json::Value),
338}
339
340#[derive(Debug, Clone, Serialize, Deserialize)]
342#[serde(untagged)]
343pub enum ListAvailableTeamsIdsError {
344 UnknownValue(serde_json::Value),
345}
346
347#[derive(Debug, Clone, Serialize, Deserialize)]
349#[serde(untagged)]
350pub enum ListDucklakesError {
351 UnknownValue(serde_json::Value),
352}
353
354#[derive(Debug, Clone, Serialize, Deserialize)]
356#[serde(untagged)]
357pub enum ListPendingInvitesError {
358 UnknownValue(serde_json::Value),
359}
360
361#[derive(Debug, Clone, Serialize, Deserialize)]
363#[serde(untagged)]
364pub enum ListUserWorkspacesError {
365 UnknownValue(serde_json::Value),
366}
367
368#[derive(Debug, Clone, Serialize, Deserialize)]
370#[serde(untagged)]
371pub enum ListWorkspacesError {
372 UnknownValue(serde_json::Value),
373}
374
375#[derive(Debug, Clone, Serialize, Deserialize)]
377#[serde(untagged)]
378pub enum ListWorkspacesAsSuperAdminError {
379 UnknownValue(serde_json::Value),
380}
381
382#[derive(Debug, Clone, Serialize, Deserialize)]
384#[serde(untagged)]
385pub enum RunSlackMessageTestJobError {
386 UnknownValue(serde_json::Value),
387}
388
389#[derive(Debug, Clone, Serialize, Deserialize)]
391#[serde(untagged)]
392pub enum RunTeamsMessageTestJobError {
393 UnknownValue(serde_json::Value),
394}
395
396#[derive(Debug, Clone, Serialize, Deserialize)]
398#[serde(untagged)]
399pub enum SetEnvironmentVariableError {
400 UnknownValue(serde_json::Value),
401}
402
403#[derive(Debug, Clone, Serialize, Deserialize)]
405#[serde(untagged)]
406pub enum SetThresholdAlertError {
407 UnknownValue(serde_json::Value),
408}
409
410#[derive(Debug, Clone, Serialize, Deserialize)]
412#[serde(untagged)]
413pub enum SetWorkspaceEncryptionKeyError {
414 UnknownValue(serde_json::Value),
415}
416
417#[derive(Debug, Clone, Serialize, Deserialize)]
419#[serde(untagged)]
420pub enum UnarchiveWorkspaceError {
421 UnknownValue(serde_json::Value),
422}
423
424#[derive(Debug, Clone, Serialize, Deserialize)]
426#[serde(untagged)]
427pub enum UpdateOperatorSettingsError {
428 UnknownValue(serde_json::Value),
429}
430
431
432pub async fn add_user(configuration: &configuration::Configuration, workspace: &str, add_user_request: models::AddUserRequest) -> Result<String, Error<AddUserError>> {
433 let local_var_configuration = configuration;
434
435 let local_var_client = &local_var_configuration.client;
436
437 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/add_user", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
438 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
439
440 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
441 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
442 }
443 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
444 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
445 };
446 local_var_req_builder = local_var_req_builder.json(&add_user_request);
447
448 let local_var_req = local_var_req_builder.build()?;
449 let local_var_resp = local_var_client.execute(local_var_req).await?;
450
451 let local_var_status = local_var_resp.status();
452 let local_var_content = local_var_resp.text().await?;
453
454 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
455 crate::from_str_patched(&local_var_content).map_err(Error::from)
456 } else {
457 let local_var_entity: Option<AddUserError> = crate::from_str_patched(&local_var_content).ok();
458 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
459 Err(Error::ResponseError(local_var_error))
460 }
461}
462
463pub async fn archive_workspace(configuration: &configuration::Configuration, workspace: &str) -> Result<String, Error<ArchiveWorkspaceError>> {
464 let local_var_configuration = configuration;
465
466 let local_var_client = &local_var_configuration.client;
467
468 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/archive", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
469 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
470
471 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
472 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
473 }
474 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
475 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
476 };
477
478 let local_var_req = local_var_req_builder.build()?;
479 let local_var_resp = local_var_client.execute(local_var_req).await?;
480
481 let local_var_status = local_var_resp.status();
482 let local_var_content = local_var_resp.text().await?;
483
484 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
485 crate::from_str_patched(&local_var_content).map_err(Error::from)
486 } else {
487 let local_var_entity: Option<ArchiveWorkspaceError> = crate::from_str_patched(&local_var_content).ok();
488 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
489 Err(Error::ResponseError(local_var_error))
490 }
491}
492
493pub async fn change_workspace_color(configuration: &configuration::Configuration, workspace: &str, change_workspace_color_request: Option<models::ChangeWorkspaceColorRequest>) -> Result<String, Error<ChangeWorkspaceColorError>> {
494 let local_var_configuration = configuration;
495
496 let local_var_client = &local_var_configuration.client;
497
498 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/change_workspace_color", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
499 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
500
501 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
502 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
503 }
504 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
505 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
506 };
507 local_var_req_builder = local_var_req_builder.json(&change_workspace_color_request);
508
509 let local_var_req = local_var_req_builder.build()?;
510 let local_var_resp = local_var_client.execute(local_var_req).await?;
511
512 let local_var_status = local_var_resp.status();
513 let local_var_content = local_var_resp.text().await?;
514
515 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
516 crate::from_str_patched(&local_var_content).map_err(Error::from)
517 } else {
518 let local_var_entity: Option<ChangeWorkspaceColorError> = crate::from_str_patched(&local_var_content).ok();
519 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
520 Err(Error::ResponseError(local_var_error))
521 }
522}
523
524pub async fn change_workspace_id(configuration: &configuration::Configuration, workspace: &str, change_workspace_id_request: Option<models::ChangeWorkspaceIdRequest>) -> Result<String, Error<ChangeWorkspaceIdError>> {
525 let local_var_configuration = configuration;
526
527 let local_var_client = &local_var_configuration.client;
528
529 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/change_workspace_id", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
530 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
531
532 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
533 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
534 }
535 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
536 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
537 };
538 local_var_req_builder = local_var_req_builder.json(&change_workspace_id_request);
539
540 let local_var_req = local_var_req_builder.build()?;
541 let local_var_resp = local_var_client.execute(local_var_req).await?;
542
543 let local_var_status = local_var_resp.status();
544 let local_var_content = local_var_resp.text().await?;
545
546 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
547 crate::from_str_patched(&local_var_content).map_err(Error::from)
548 } else {
549 let local_var_entity: Option<ChangeWorkspaceIdError> = crate::from_str_patched(&local_var_content).ok();
550 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
551 Err(Error::ResponseError(local_var_error))
552 }
553}
554
555pub async fn change_workspace_name(configuration: &configuration::Configuration, workspace: &str, change_workspace_name_request: Option<models::ChangeWorkspaceNameRequest>) -> Result<String, Error<ChangeWorkspaceNameError>> {
556 let local_var_configuration = configuration;
557
558 let local_var_client = &local_var_configuration.client;
559
560 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/change_workspace_name", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
561 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
562
563 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
564 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
565 }
566 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
567 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
568 };
569 local_var_req_builder = local_var_req_builder.json(&change_workspace_name_request);
570
571 let local_var_req = local_var_req_builder.build()?;
572 let local_var_resp = local_var_client.execute(local_var_req).await?;
573
574 let local_var_status = local_var_resp.status();
575 let local_var_content = local_var_resp.text().await?;
576
577 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
578 crate::from_str_patched(&local_var_content).map_err(Error::from)
579 } else {
580 let local_var_entity: Option<ChangeWorkspaceNameError> = crate::from_str_patched(&local_var_content).ok();
581 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
582 Err(Error::ResponseError(local_var_error))
583 }
584}
585
586pub async fn connect_teams(configuration: &configuration::Configuration, workspace: &str, connect_teams_request: models::ConnectTeamsRequest) -> Result<String, Error<ConnectTeamsError>> {
587 let local_var_configuration = configuration;
588
589 let local_var_client = &local_var_configuration.client;
590
591 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/connect_teams", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
592 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
593
594 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
595 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
596 }
597 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
598 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
599 };
600 local_var_req_builder = local_var_req_builder.json(&connect_teams_request);
601
602 let local_var_req = local_var_req_builder.build()?;
603 let local_var_resp = local_var_client.execute(local_var_req).await?;
604
605 let local_var_status = local_var_resp.status();
606 let local_var_content = local_var_resp.text().await?;
607
608 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
609 crate::from_str_patched(&local_var_content).map_err(Error::from)
610 } else {
611 let local_var_entity: Option<ConnectTeamsError> = crate::from_str_patched(&local_var_content).ok();
612 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
613 Err(Error::ResponseError(local_var_error))
614 }
615}
616
617pub async fn create_workspace(configuration: &configuration::Configuration, create_workspace: models::CreateWorkspace) -> Result<String, Error<CreateWorkspaceError>> {
618 let local_var_configuration = configuration;
619
620 let local_var_client = &local_var_configuration.client;
621
622 let local_var_uri_str = format!("{}/workspaces/create", local_var_configuration.base_path);
623 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
624
625 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
626 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
627 }
628 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
629 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
630 };
631 local_var_req_builder = local_var_req_builder.json(&create_workspace);
632
633 let local_var_req = local_var_req_builder.build()?;
634 let local_var_resp = local_var_client.execute(local_var_req).await?;
635
636 let local_var_status = local_var_resp.status();
637 let local_var_content = local_var_resp.text().await?;
638
639 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
640 crate::from_str_patched(&local_var_content).map_err(Error::from)
641 } else {
642 let local_var_entity: Option<CreateWorkspaceError> = crate::from_str_patched(&local_var_content).ok();
643 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
644 Err(Error::ResponseError(local_var_error))
645 }
646}
647
648pub async fn create_workspace_fork(configuration: &configuration::Configuration, create_workspace_fork: models::CreateWorkspaceFork) -> Result<String, Error<CreateWorkspaceForkError>> {
649 let local_var_configuration = configuration;
650
651 let local_var_client = &local_var_configuration.client;
652
653 let local_var_uri_str = format!("{}/workspaces/create_fork", local_var_configuration.base_path);
654 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
655
656 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
657 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
658 }
659 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
660 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
661 };
662 local_var_req_builder = local_var_req_builder.json(&create_workspace_fork);
663
664 let local_var_req = local_var_req_builder.build()?;
665 let local_var_resp = local_var_client.execute(local_var_req).await?;
666
667 let local_var_status = local_var_resp.status();
668 let local_var_content = local_var_resp.text().await?;
669
670 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
671 crate::from_str_patched(&local_var_content).map_err(Error::from)
672 } else {
673 let local_var_entity: Option<CreateWorkspaceForkError> = crate::from_str_patched(&local_var_content).ok();
674 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
675 Err(Error::ResponseError(local_var_error))
676 }
677}
678
679pub async fn delete_git_sync_repository(configuration: &configuration::Configuration, workspace: &str, delete_git_sync_repository_request: models::DeleteGitSyncRepositoryRequest) -> Result<serde_json::Value, Error<DeleteGitSyncRepositoryError>> {
680 let local_var_configuration = configuration;
681
682 let local_var_client = &local_var_configuration.client;
683
684 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/delete_git_sync_repository", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
685 let mut local_var_req_builder = local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
686
687 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
688 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
689 }
690 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
691 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
692 };
693 local_var_req_builder = local_var_req_builder.json(&delete_git_sync_repository_request);
694
695 let local_var_req = local_var_req_builder.build()?;
696 let local_var_resp = local_var_client.execute(local_var_req).await?;
697
698 let local_var_status = local_var_resp.status();
699 let local_var_content = local_var_resp.text().await?;
700
701 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
702 crate::from_str_patched(&local_var_content).map_err(Error::from)
703 } else {
704 let local_var_entity: Option<DeleteGitSyncRepositoryError> = crate::from_str_patched(&local_var_content).ok();
705 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
706 Err(Error::ResponseError(local_var_error))
707 }
708}
709
710pub async fn delete_invite(configuration: &configuration::Configuration, workspace: &str, delete_invite_request: models::DeleteInviteRequest) -> Result<String, Error<DeleteInviteError>> {
711 let local_var_configuration = configuration;
712
713 let local_var_client = &local_var_configuration.client;
714
715 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/delete_invite", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
716 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
717
718 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
719 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
720 }
721 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
722 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
723 };
724 local_var_req_builder = local_var_req_builder.json(&delete_invite_request);
725
726 let local_var_req = local_var_req_builder.build()?;
727 let local_var_resp = local_var_client.execute(local_var_req).await?;
728
729 let local_var_status = local_var_resp.status();
730 let local_var_content = local_var_resp.text().await?;
731
732 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
733 crate::from_str_patched(&local_var_content).map_err(Error::from)
734 } else {
735 let local_var_entity: Option<DeleteInviteError> = crate::from_str_patched(&local_var_content).ok();
736 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
737 Err(Error::ResponseError(local_var_error))
738 }
739}
740
741pub async fn delete_workspace(configuration: &configuration::Configuration, workspace: &str) -> Result<String, Error<DeleteWorkspaceError>> {
742 let local_var_configuration = configuration;
743
744 let local_var_client = &local_var_configuration.client;
745
746 let local_var_uri_str = format!("{}/workspaces/delete/{workspace}", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
747 let mut local_var_req_builder = local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
748
749 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
750 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
751 }
752 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
753 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
754 };
755
756 let local_var_req = local_var_req_builder.build()?;
757 let local_var_resp = local_var_client.execute(local_var_req).await?;
758
759 let local_var_status = local_var_resp.status();
760 let local_var_content = local_var_resp.text().await?;
761
762 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
763 crate::from_str_patched(&local_var_content).map_err(Error::from)
764 } else {
765 let local_var_entity: Option<DeleteWorkspaceError> = crate::from_str_patched(&local_var_content).ok();
766 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
767 Err(Error::ResponseError(local_var_error))
768 }
769}
770
771pub async fn edit_auto_invite(configuration: &configuration::Configuration, workspace: &str, edit_auto_invite_request: models::EditAutoInviteRequest) -> Result<String, Error<EditAutoInviteError>> {
772 let local_var_configuration = configuration;
773
774 let local_var_client = &local_var_configuration.client;
775
776 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_auto_invite", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
777 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
778
779 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
780 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
781 }
782 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
783 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
784 };
785 local_var_req_builder = local_var_req_builder.json(&edit_auto_invite_request);
786
787 let local_var_req = local_var_req_builder.build()?;
788 let local_var_resp = local_var_client.execute(local_var_req).await?;
789
790 let local_var_status = local_var_resp.status();
791 let local_var_content = local_var_resp.text().await?;
792
793 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
794 crate::from_str_patched(&local_var_content).map_err(Error::from)
795 } else {
796 let local_var_entity: Option<EditAutoInviteError> = crate::from_str_patched(&local_var_content).ok();
797 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
798 Err(Error::ResponseError(local_var_error))
799 }
800}
801
802pub async fn edit_copilot_config(configuration: &configuration::Configuration, workspace: &str, ai_config: models::AiConfig) -> Result<String, Error<EditCopilotConfigError>> {
803 let local_var_configuration = configuration;
804
805 let local_var_client = &local_var_configuration.client;
806
807 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_copilot_config", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
808 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
809
810 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
811 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
812 }
813 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
814 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
815 };
816 local_var_req_builder = local_var_req_builder.json(&ai_config);
817
818 let local_var_req = local_var_req_builder.build()?;
819 let local_var_resp = local_var_client.execute(local_var_req).await?;
820
821 let local_var_status = local_var_resp.status();
822 let local_var_content = local_var_resp.text().await?;
823
824 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
825 crate::from_str_patched(&local_var_content).map_err(Error::from)
826 } else {
827 let local_var_entity: Option<EditCopilotConfigError> = crate::from_str_patched(&local_var_content).ok();
828 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
829 Err(Error::ResponseError(local_var_error))
830 }
831}
832
833pub async fn edit_default_scripts(configuration: &configuration::Configuration, workspace: &str, workspace_default_scripts: Option<models::WorkspaceDefaultScripts>) -> Result<String, Error<EditDefaultScriptsError>> {
834 let local_var_configuration = configuration;
835
836 let local_var_client = &local_var_configuration.client;
837
838 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/default_scripts", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
839 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
840
841 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
842 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
843 }
844 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
845 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
846 };
847 local_var_req_builder = local_var_req_builder.json(&workspace_default_scripts);
848
849 let local_var_req = local_var_req_builder.build()?;
850 let local_var_resp = local_var_client.execute(local_var_req).await?;
851
852 let local_var_status = local_var_resp.status();
853 let local_var_content = local_var_resp.text().await?;
854
855 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
856 crate::from_str_patched(&local_var_content).map_err(Error::from)
857 } else {
858 let local_var_entity: Option<EditDefaultScriptsError> = crate::from_str_patched(&local_var_content).ok();
859 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
860 Err(Error::ResponseError(local_var_error))
861 }
862}
863
864pub async fn edit_deploy_to(configuration: &configuration::Configuration, workspace: &str, get_deploy_to200_response: models::GetDeployTo200Response) -> Result<String, Error<EditDeployToError>> {
865 let local_var_configuration = configuration;
866
867 let local_var_client = &local_var_configuration.client;
868
869 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_deploy_to", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
870 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
871
872 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
873 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
874 }
875 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
876 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
877 };
878 local_var_req_builder = local_var_req_builder.json(&get_deploy_to200_response);
879
880 let local_var_req = local_var_req_builder.build()?;
881 let local_var_resp = local_var_client.execute(local_var_req).await?;
882
883 let local_var_status = local_var_resp.status();
884 let local_var_content = local_var_resp.text().await?;
885
886 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
887 crate::from_str_patched(&local_var_content).map_err(Error::from)
888 } else {
889 let local_var_entity: Option<EditDeployToError> = crate::from_str_patched(&local_var_content).ok();
890 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
891 Err(Error::ResponseError(local_var_error))
892 }
893}
894
895pub async fn edit_ducklake_config(configuration: &configuration::Configuration, workspace: &str, edit_ducklake_config_request: models::EditDucklakeConfigRequest) -> Result<serde_json::Value, Error<EditDucklakeConfigError>> {
896 let local_var_configuration = configuration;
897
898 let local_var_client = &local_var_configuration.client;
899
900 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_ducklake_config", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
901 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
902
903 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
904 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
905 }
906 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
907 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
908 };
909 local_var_req_builder = local_var_req_builder.json(&edit_ducklake_config_request);
910
911 let local_var_req = local_var_req_builder.build()?;
912 let local_var_resp = local_var_client.execute(local_var_req).await?;
913
914 let local_var_status = local_var_resp.status();
915 let local_var_content = local_var_resp.text().await?;
916
917 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
918 crate::from_str_patched(&local_var_content).map_err(Error::from)
919 } else {
920 let local_var_entity: Option<EditDucklakeConfigError> = crate::from_str_patched(&local_var_content).ok();
921 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
922 Err(Error::ResponseError(local_var_error))
923 }
924}
925
926pub async fn edit_error_handler(configuration: &configuration::Configuration, workspace: &str, edit_error_handler_request: models::EditErrorHandlerRequest) -> Result<String, Error<EditErrorHandlerError>> {
927 let local_var_configuration = configuration;
928
929 let local_var_client = &local_var_configuration.client;
930
931 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_error_handler", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
932 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
933
934 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
935 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
936 }
937 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
938 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
939 };
940 local_var_req_builder = local_var_req_builder.json(&edit_error_handler_request);
941
942 let local_var_req = local_var_req_builder.build()?;
943 let local_var_resp = local_var_client.execute(local_var_req).await?;
944
945 let local_var_status = local_var_resp.status();
946 let local_var_content = local_var_resp.text().await?;
947
948 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
949 crate::from_str_patched(&local_var_content).map_err(Error::from)
950 } else {
951 let local_var_entity: Option<EditErrorHandlerError> = crate::from_str_patched(&local_var_content).ok();
952 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
953 Err(Error::ResponseError(local_var_error))
954 }
955}
956
957pub async fn edit_git_sync_repository(configuration: &configuration::Configuration, workspace: &str, edit_git_sync_repository_request: models::EditGitSyncRepositoryRequest) -> Result<serde_json::Value, Error<EditGitSyncRepositoryError>> {
958 let local_var_configuration = configuration;
959
960 let local_var_client = &local_var_configuration.client;
961
962 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_git_sync_repository", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
963 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
964
965 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
966 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
967 }
968 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
969 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
970 };
971 local_var_req_builder = local_var_req_builder.json(&edit_git_sync_repository_request);
972
973 let local_var_req = local_var_req_builder.build()?;
974 let local_var_resp = local_var_client.execute(local_var_req).await?;
975
976 let local_var_status = local_var_resp.status();
977 let local_var_content = local_var_resp.text().await?;
978
979 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
980 crate::from_str_patched(&local_var_content).map_err(Error::from)
981 } else {
982 let local_var_entity: Option<EditGitSyncRepositoryError> = crate::from_str_patched(&local_var_content).ok();
983 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
984 Err(Error::ResponseError(local_var_error))
985 }
986}
987
988pub async fn edit_instance_groups(configuration: &configuration::Configuration, workspace: &str, edit_instance_groups_request: models::EditInstanceGroupsRequest) -> Result<String, Error<EditInstanceGroupsError>> {
989 let local_var_configuration = configuration;
990
991 let local_var_client = &local_var_configuration.client;
992
993 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_instance_groups", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
994 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
995
996 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
997 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
998 }
999 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1000 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1001 };
1002 local_var_req_builder = local_var_req_builder.json(&edit_instance_groups_request);
1003
1004 let local_var_req = local_var_req_builder.build()?;
1005 let local_var_resp = local_var_client.execute(local_var_req).await?;
1006
1007 let local_var_status = local_var_resp.status();
1008 let local_var_content = local_var_resp.text().await?;
1009
1010 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1011 crate::from_str_patched(&local_var_content).map_err(Error::from)
1012 } else {
1013 let local_var_entity: Option<EditInstanceGroupsError> = crate::from_str_patched(&local_var_content).ok();
1014 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1015 Err(Error::ResponseError(local_var_error))
1016 }
1017}
1018
1019pub async fn edit_large_file_storage_config(configuration: &configuration::Configuration, workspace: &str, edit_large_file_storage_config_request: models::EditLargeFileStorageConfigRequest) -> Result<serde_json::Value, Error<EditLargeFileStorageConfigError>> {
1020 let local_var_configuration = configuration;
1021
1022 let local_var_client = &local_var_configuration.client;
1023
1024 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_large_file_storage_config", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1025 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1026
1027 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1028 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1029 }
1030 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1031 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1032 };
1033 local_var_req_builder = local_var_req_builder.json(&edit_large_file_storage_config_request);
1034
1035 let local_var_req = local_var_req_builder.build()?;
1036 let local_var_resp = local_var_client.execute(local_var_req).await?;
1037
1038 let local_var_status = local_var_resp.status();
1039 let local_var_content = local_var_resp.text().await?;
1040
1041 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1042 crate::from_str_patched(&local_var_content).map_err(Error::from)
1043 } else {
1044 let local_var_entity: Option<EditLargeFileStorageConfigError> = crate::from_str_patched(&local_var_content).ok();
1045 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1046 Err(Error::ResponseError(local_var_error))
1047 }
1048}
1049
1050pub async fn edit_slack_command(configuration: &configuration::Configuration, workspace: &str, edit_slack_command_request: models::EditSlackCommandRequest) -> Result<String, Error<EditSlackCommandError>> {
1051 let local_var_configuration = configuration;
1052
1053 let local_var_client = &local_var_configuration.client;
1054
1055 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_slack_command", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1056 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1057
1058 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1059 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1060 }
1061 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1062 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1063 };
1064 local_var_req_builder = local_var_req_builder.json(&edit_slack_command_request);
1065
1066 let local_var_req = local_var_req_builder.build()?;
1067 let local_var_resp = local_var_client.execute(local_var_req).await?;
1068
1069 let local_var_status = local_var_resp.status();
1070 let local_var_content = local_var_resp.text().await?;
1071
1072 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1073 crate::from_str_patched(&local_var_content).map_err(Error::from)
1074 } else {
1075 let local_var_entity: Option<EditSlackCommandError> = crate::from_str_patched(&local_var_content).ok();
1076 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1077 Err(Error::ResponseError(local_var_error))
1078 }
1079}
1080
1081pub async fn edit_teams_command(configuration: &configuration::Configuration, workspace: &str, edit_slack_command_request: models::EditSlackCommandRequest) -> Result<String, Error<EditTeamsCommandError>> {
1082 let local_var_configuration = configuration;
1083
1084 let local_var_client = &local_var_configuration.client;
1085
1086 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_teams_command", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1087 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1088
1089 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1090 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1091 }
1092 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1093 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1094 };
1095 local_var_req_builder = local_var_req_builder.json(&edit_slack_command_request);
1096
1097 let local_var_req = local_var_req_builder.build()?;
1098 let local_var_resp = local_var_client.execute(local_var_req).await?;
1099
1100 let local_var_status = local_var_resp.status();
1101 let local_var_content = local_var_resp.text().await?;
1102
1103 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1104 crate::from_str_patched(&local_var_content).map_err(Error::from)
1105 } else {
1106 let local_var_entity: Option<EditTeamsCommandError> = crate::from_str_patched(&local_var_content).ok();
1107 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1108 Err(Error::ResponseError(local_var_error))
1109 }
1110}
1111
1112pub async fn edit_webhook(configuration: &configuration::Configuration, workspace: &str, edit_webhook_request: models::EditWebhookRequest) -> Result<String, Error<EditWebhookError>> {
1113 let local_var_configuration = configuration;
1114
1115 let local_var_client = &local_var_configuration.client;
1116
1117 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_webhook", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1118 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1119
1120 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1121 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1122 }
1123 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1124 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1125 };
1126 local_var_req_builder = local_var_req_builder.json(&edit_webhook_request);
1127
1128 let local_var_req = local_var_req_builder.build()?;
1129 let local_var_resp = local_var_client.execute(local_var_req).await?;
1130
1131 let local_var_status = local_var_resp.status();
1132 let local_var_content = local_var_resp.text().await?;
1133
1134 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1135 crate::from_str_patched(&local_var_content).map_err(Error::from)
1136 } else {
1137 let local_var_entity: Option<EditWebhookError> = crate::from_str_patched(&local_var_content).ok();
1138 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1139 Err(Error::ResponseError(local_var_error))
1140 }
1141}
1142
1143pub async fn edit_workspace_default_app(configuration: &configuration::Configuration, workspace: &str, edit_workspace_default_app_request: models::EditWorkspaceDefaultAppRequest) -> Result<String, Error<EditWorkspaceDefaultAppError>> {
1144 let local_var_configuration = configuration;
1145
1146 let local_var_client = &local_var_configuration.client;
1147
1148 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_default_app", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1149 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1150
1151 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1152 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1153 }
1154 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1155 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1156 };
1157 local_var_req_builder = local_var_req_builder.json(&edit_workspace_default_app_request);
1158
1159 let local_var_req = local_var_req_builder.build()?;
1160 let local_var_resp = local_var_client.execute(local_var_req).await?;
1161
1162 let local_var_status = local_var_resp.status();
1163 let local_var_content = local_var_resp.text().await?;
1164
1165 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1166 crate::from_str_patched(&local_var_content).map_err(Error::from)
1167 } else {
1168 let local_var_entity: Option<EditWorkspaceDefaultAppError> = crate::from_str_patched(&local_var_content).ok();
1169 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1170 Err(Error::ResponseError(local_var_error))
1171 }
1172}
1173
1174pub async fn edit_workspace_deploy_ui_settings(configuration: &configuration::Configuration, workspace: &str, edit_workspace_deploy_ui_settings_request: models::EditWorkspaceDeployUiSettingsRequest) -> Result<serde_json::Value, Error<EditWorkspaceDeployUiSettingsError>> {
1175 let local_var_configuration = configuration;
1176
1177 let local_var_client = &local_var_configuration.client;
1178
1179 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_deploy_ui_config", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1180 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1181
1182 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1183 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1184 }
1185 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1186 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1187 };
1188 local_var_req_builder = local_var_req_builder.json(&edit_workspace_deploy_ui_settings_request);
1189
1190 let local_var_req = local_var_req_builder.build()?;
1191 let local_var_resp = local_var_client.execute(local_var_req).await?;
1192
1193 let local_var_status = local_var_resp.status();
1194 let local_var_content = local_var_resp.text().await?;
1195
1196 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1197 crate::from_str_patched(&local_var_content).map_err(Error::from)
1198 } else {
1199 let local_var_entity: Option<EditWorkspaceDeployUiSettingsError> = crate::from_str_patched(&local_var_content).ok();
1200 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1201 Err(Error::ResponseError(local_var_error))
1202 }
1203}
1204
1205pub async fn edit_workspace_git_sync_config(configuration: &configuration::Configuration, workspace: &str, edit_workspace_git_sync_config_request: models::EditWorkspaceGitSyncConfigRequest) -> Result<serde_json::Value, Error<EditWorkspaceGitSyncConfigError>> {
1206 let local_var_configuration = configuration;
1207
1208 let local_var_client = &local_var_configuration.client;
1209
1210 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_git_sync_config", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1211 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1212
1213 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1214 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1215 }
1216 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1217 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1218 };
1219 local_var_req_builder = local_var_req_builder.json(&edit_workspace_git_sync_config_request);
1220
1221 let local_var_req = local_var_req_builder.build()?;
1222 let local_var_resp = local_var_client.execute(local_var_req).await?;
1223
1224 let local_var_status = local_var_resp.status();
1225 let local_var_content = local_var_resp.text().await?;
1226
1227 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1228 crate::from_str_patched(&local_var_content).map_err(Error::from)
1229 } else {
1230 let local_var_entity: Option<EditWorkspaceGitSyncConfigError> = crate::from_str_patched(&local_var_content).ok();
1231 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1232 Err(Error::ResponseError(local_var_error))
1233 }
1234}
1235
1236pub async fn exists_username(configuration: &configuration::Configuration, exists_username_request: models::ExistsUsernameRequest) -> Result<bool, Error<ExistsUsernameError>> {
1237 let local_var_configuration = configuration;
1238
1239 let local_var_client = &local_var_configuration.client;
1240
1241 let local_var_uri_str = format!("{}/workspaces/exists_username", local_var_configuration.base_path);
1242 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1243
1244 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1245 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1246 }
1247 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1248 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1249 };
1250 local_var_req_builder = local_var_req_builder.json(&exists_username_request);
1251
1252 let local_var_req = local_var_req_builder.build()?;
1253 let local_var_resp = local_var_client.execute(local_var_req).await?;
1254
1255 let local_var_status = local_var_resp.status();
1256 let local_var_content = local_var_resp.text().await?;
1257
1258 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1259 crate::from_str_patched(&local_var_content).map_err(Error::from)
1260 } else {
1261 let local_var_entity: Option<ExistsUsernameError> = crate::from_str_patched(&local_var_content).ok();
1262 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1263 Err(Error::ResponseError(local_var_error))
1264 }
1265}
1266
1267pub async fn exists_workspace(configuration: &configuration::Configuration, exists_workspace_request: models::ExistsWorkspaceRequest) -> Result<bool, Error<ExistsWorkspaceError>> {
1268 let local_var_configuration = configuration;
1269
1270 let local_var_client = &local_var_configuration.client;
1271
1272 let local_var_uri_str = format!("{}/workspaces/exists", local_var_configuration.base_path);
1273 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1274
1275 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1276 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1277 }
1278 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1279 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1280 };
1281 local_var_req_builder = local_var_req_builder.json(&exists_workspace_request);
1282
1283 let local_var_req = local_var_req_builder.build()?;
1284 let local_var_resp = local_var_client.execute(local_var_req).await?;
1285
1286 let local_var_status = local_var_resp.status();
1287 let local_var_content = local_var_resp.text().await?;
1288
1289 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1290 crate::from_str_patched(&local_var_content).map_err(Error::from)
1291 } else {
1292 let local_var_entity: Option<ExistsWorkspaceError> = crate::from_str_patched(&local_var_content).ok();
1293 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1294 Err(Error::ResponseError(local_var_error))
1295 }
1296}
1297
1298pub async fn get_copilot_info(configuration: &configuration::Configuration, workspace: &str) -> Result<models::AiConfig, Error<GetCopilotInfoError>> {
1299 let local_var_configuration = configuration;
1300
1301 let local_var_client = &local_var_configuration.client;
1302
1303 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/get_copilot_info", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1304 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1305
1306 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1307 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1308 }
1309 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1310 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1311 };
1312
1313 let local_var_req = local_var_req_builder.build()?;
1314 let local_var_resp = local_var_client.execute(local_var_req).await?;
1315
1316 let local_var_status = local_var_resp.status();
1317 let local_var_content = local_var_resp.text().await?;
1318
1319 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1320 crate::from_str_patched(&local_var_content).map_err(Error::from)
1321 } else {
1322 let local_var_entity: Option<GetCopilotInfoError> = crate::from_str_patched(&local_var_content).ok();
1323 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1324 Err(Error::ResponseError(local_var_error))
1325 }
1326}
1327
1328pub async fn get_default_scripts(configuration: &configuration::Configuration, workspace: &str) -> Result<models::WorkspaceDefaultScripts, Error<GetDefaultScriptsError>> {
1329 let local_var_configuration = configuration;
1330
1331 let local_var_client = &local_var_configuration.client;
1332
1333 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/default_scripts", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1334 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1335
1336 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1337 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1338 }
1339 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1340 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1341 };
1342
1343 let local_var_req = local_var_req_builder.build()?;
1344 let local_var_resp = local_var_client.execute(local_var_req).await?;
1345
1346 let local_var_status = local_var_resp.status();
1347 let local_var_content = local_var_resp.text().await?;
1348
1349 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1350 crate::from_str_patched(&local_var_content).map_err(Error::from)
1351 } else {
1352 let local_var_entity: Option<GetDefaultScriptsError> = crate::from_str_patched(&local_var_content).ok();
1353 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1354 Err(Error::ResponseError(local_var_error))
1355 }
1356}
1357
1358pub async fn get_deploy_to(configuration: &configuration::Configuration, workspace: &str) -> Result<models::GetDeployTo200Response, Error<GetDeployToError>> {
1359 let local_var_configuration = configuration;
1360
1361 let local_var_client = &local_var_configuration.client;
1362
1363 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/get_deploy_to", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1364 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1365
1366 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1367 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1368 }
1369 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1370 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1371 };
1372
1373 let local_var_req = local_var_req_builder.build()?;
1374 let local_var_resp = local_var_client.execute(local_var_req).await?;
1375
1376 let local_var_status = local_var_resp.status();
1377 let local_var_content = local_var_resp.text().await?;
1378
1379 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1380 crate::from_str_patched(&local_var_content).map_err(Error::from)
1381 } else {
1382 let local_var_entity: Option<GetDeployToError> = crate::from_str_patched(&local_var_content).ok();
1383 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1384 Err(Error::ResponseError(local_var_error))
1385 }
1386}
1387
1388pub async fn get_github_app_token(configuration: &configuration::Configuration, workspace: &str, get_github_app_token_request: models::GetGithubAppTokenRequest) -> Result<models::GetGithubAppToken200Response, Error<GetGithubAppTokenError>> {
1389 let local_var_configuration = configuration;
1390
1391 let local_var_client = &local_var_configuration.client;
1392
1393 let local_var_uri_str = format!("{}/w/{workspace}/github_app/token", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1394 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1395
1396 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1397 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1398 }
1399 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1400 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1401 };
1402 local_var_req_builder = local_var_req_builder.json(&get_github_app_token_request);
1403
1404 let local_var_req = local_var_req_builder.build()?;
1405 let local_var_resp = local_var_client.execute(local_var_req).await?;
1406
1407 let local_var_status = local_var_resp.status();
1408 let local_var_content = local_var_resp.text().await?;
1409
1410 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1411 crate::from_str_patched(&local_var_content).map_err(Error::from)
1412 } else {
1413 let local_var_entity: Option<GetGithubAppTokenError> = crate::from_str_patched(&local_var_content).ok();
1414 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1415 Err(Error::ResponseError(local_var_error))
1416 }
1417}
1418
1419pub async fn get_is_premium(configuration: &configuration::Configuration, workspace: &str) -> Result<bool, Error<GetIsPremiumError>> {
1420 let local_var_configuration = configuration;
1421
1422 let local_var_client = &local_var_configuration.client;
1423
1424 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/is_premium", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1425 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1426
1427 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1428 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1429 }
1430 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1431 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1432 };
1433
1434 let local_var_req = local_var_req_builder.build()?;
1435 let local_var_resp = local_var_client.execute(local_var_req).await?;
1436
1437 let local_var_status = local_var_resp.status();
1438 let local_var_content = local_var_resp.text().await?;
1439
1440 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1441 crate::from_str_patched(&local_var_content).map_err(Error::from)
1442 } else {
1443 let local_var_entity: Option<GetIsPremiumError> = crate::from_str_patched(&local_var_content).ok();
1444 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1445 Err(Error::ResponseError(local_var_error))
1446 }
1447}
1448
1449pub async fn get_large_file_storage_config(configuration: &configuration::Configuration, workspace: &str) -> Result<models::LargeFileStorage, Error<GetLargeFileStorageConfigError>> {
1450 let local_var_configuration = configuration;
1451
1452 let local_var_client = &local_var_configuration.client;
1453
1454 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/get_large_file_storage_config", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1455 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1456
1457 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1458 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1459 }
1460 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1461 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1462 };
1463
1464 let local_var_req = local_var_req_builder.build()?;
1465 let local_var_resp = local_var_client.execute(local_var_req).await?;
1466
1467 let local_var_status = local_var_resp.status();
1468 let local_var_content = local_var_resp.text().await?;
1469
1470 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1471 crate::from_str_patched(&local_var_content).map_err(Error::from)
1472 } else {
1473 let local_var_entity: Option<GetLargeFileStorageConfigError> = crate::from_str_patched(&local_var_content).ok();
1474 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1475 Err(Error::ResponseError(local_var_error))
1476 }
1477}
1478
1479pub async fn get_premium_info(configuration: &configuration::Configuration, workspace: &str, skip_subscription_fetch: Option<bool>) -> Result<models::GetPremiumInfo200Response, Error<GetPremiumInfoError>> {
1480 let local_var_configuration = configuration;
1481
1482 let local_var_client = &local_var_configuration.client;
1483
1484 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/premium_info", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1485 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1486
1487 if let Some(ref local_var_str) = skip_subscription_fetch {
1488 local_var_req_builder = local_var_req_builder.query(&[("skip_subscription_fetch", &local_var_str.to_string())]);
1489 }
1490 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1491 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1492 }
1493 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1494 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1495 };
1496
1497 let local_var_req = local_var_req_builder.build()?;
1498 let local_var_resp = local_var_client.execute(local_var_req).await?;
1499
1500 let local_var_status = local_var_resp.status();
1501 let local_var_content = local_var_resp.text().await?;
1502
1503 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1504 crate::from_str_patched(&local_var_content).map_err(Error::from)
1505 } else {
1506 let local_var_entity: Option<GetPremiumInfoError> = crate::from_str_patched(&local_var_content).ok();
1507 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1508 Err(Error::ResponseError(local_var_error))
1509 }
1510}
1511
1512pub async fn get_settings(configuration: &configuration::Configuration, workspace: &str) -> Result<models::GetSettings200Response, Error<GetSettingsError>> {
1513 let local_var_configuration = configuration;
1514
1515 let local_var_client = &local_var_configuration.client;
1516
1517 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/get_settings", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1518 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1519
1520 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1521 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1522 }
1523 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1524 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1525 };
1526
1527 let local_var_req = local_var_req_builder.build()?;
1528 let local_var_resp = local_var_client.execute(local_var_req).await?;
1529
1530 let local_var_status = local_var_resp.status();
1531 let local_var_content = local_var_resp.text().await?;
1532
1533 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1534 crate::from_str_patched(&local_var_content).map_err(Error::from)
1535 } else {
1536 let local_var_entity: Option<GetSettingsError> = crate::from_str_patched(&local_var_content).ok();
1537 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1538 Err(Error::ResponseError(local_var_error))
1539 }
1540}
1541
1542pub async fn get_threshold_alert(configuration: &configuration::Configuration, workspace: &str) -> Result<models::GetThresholdAlert200Response, Error<GetThresholdAlertError>> {
1543 let local_var_configuration = configuration;
1544
1545 let local_var_client = &local_var_configuration.client;
1546
1547 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/threshold_alert", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1548 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1549
1550 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1551 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1552 }
1553 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1554 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1555 };
1556
1557 let local_var_req = local_var_req_builder.build()?;
1558 let local_var_resp = local_var_client.execute(local_var_req).await?;
1559
1560 let local_var_status = local_var_resp.status();
1561 let local_var_content = local_var_resp.text().await?;
1562
1563 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1564 crate::from_str_patched(&local_var_content).map_err(Error::from)
1565 } else {
1566 let local_var_entity: Option<GetThresholdAlertError> = crate::from_str_patched(&local_var_content).ok();
1567 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1568 Err(Error::ResponseError(local_var_error))
1569 }
1570}
1571
1572pub async fn get_used_triggers(configuration: &configuration::Configuration, workspace: &str) -> Result<models::GetUsedTriggers200Response, Error<GetUsedTriggersError>> {
1573 let local_var_configuration = configuration;
1574
1575 let local_var_client = &local_var_configuration.client;
1576
1577 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/used_triggers", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1578 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1579
1580 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1581 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1582 }
1583 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1584 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1585 };
1586
1587 let local_var_req = local_var_req_builder.build()?;
1588 let local_var_resp = local_var_client.execute(local_var_req).await?;
1589
1590 let local_var_status = local_var_resp.status();
1591 let local_var_content = local_var_resp.text().await?;
1592
1593 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1594 crate::from_str_patched(&local_var_content).map_err(Error::from)
1595 } else {
1596 let local_var_entity: Option<GetUsedTriggersError> = crate::from_str_patched(&local_var_content).ok();
1597 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1598 Err(Error::ResponseError(local_var_error))
1599 }
1600}
1601
1602pub async fn get_workspace_default_app(configuration: &configuration::Configuration, workspace: &str) -> Result<models::EditWorkspaceDefaultAppRequest, Error<GetWorkspaceDefaultAppError>> {
1603 let local_var_configuration = configuration;
1604
1605 let local_var_client = &local_var_configuration.client;
1606
1607 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/default_app", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1608 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1609
1610 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1611 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1612 }
1613 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1614 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1615 };
1616
1617 let local_var_req = local_var_req_builder.build()?;
1618 let local_var_resp = local_var_client.execute(local_var_req).await?;
1619
1620 let local_var_status = local_var_resp.status();
1621 let local_var_content = local_var_resp.text().await?;
1622
1623 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1624 crate::from_str_patched(&local_var_content).map_err(Error::from)
1625 } else {
1626 let local_var_entity: Option<GetWorkspaceDefaultAppError> = crate::from_str_patched(&local_var_content).ok();
1627 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1628 Err(Error::ResponseError(local_var_error))
1629 }
1630}
1631
1632pub async fn get_workspace_encryption_key(configuration: &configuration::Configuration, workspace: &str) -> Result<models::GetWorkspaceEncryptionKey200Response, Error<GetWorkspaceEncryptionKeyError>> {
1633 let local_var_configuration = configuration;
1634
1635 let local_var_client = &local_var_configuration.client;
1636
1637 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/encryption_key", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1638 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1639
1640 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1641 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1642 }
1643 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1644 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1645 };
1646
1647 let local_var_req = local_var_req_builder.build()?;
1648 let local_var_resp = local_var_client.execute(local_var_req).await?;
1649
1650 let local_var_status = local_var_resp.status();
1651 let local_var_content = local_var_resp.text().await?;
1652
1653 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1654 crate::from_str_patched(&local_var_content).map_err(Error::from)
1655 } else {
1656 let local_var_entity: Option<GetWorkspaceEncryptionKeyError> = crate::from_str_patched(&local_var_content).ok();
1657 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1658 Err(Error::ResponseError(local_var_error))
1659 }
1660}
1661
1662pub async fn get_workspace_name(configuration: &configuration::Configuration, workspace: &str) -> Result<String, Error<GetWorkspaceNameError>> {
1663 let local_var_configuration = configuration;
1664
1665 let local_var_client = &local_var_configuration.client;
1666
1667 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/get_workspace_name", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1668 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1669
1670 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1671 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1672 }
1673 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1674 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1675 };
1676
1677 let local_var_req = local_var_req_builder.build()?;
1678 let local_var_resp = local_var_client.execute(local_var_req).await?;
1679
1680 let local_var_status = local_var_resp.status();
1681 let local_var_content = local_var_resp.text().await?;
1682
1683 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1684 crate::from_str_patched(&local_var_content).map_err(Error::from)
1685 } else {
1686 let local_var_entity: Option<GetWorkspaceNameError> = crate::from_str_patched(&local_var_content).ok();
1687 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1688 Err(Error::ResponseError(local_var_error))
1689 }
1690}
1691
1692pub async fn get_workspace_usage(configuration: &configuration::Configuration, workspace: &str) -> Result<f64, Error<GetWorkspaceUsageError>> {
1693 let local_var_configuration = configuration;
1694
1695 let local_var_client = &local_var_configuration.client;
1696
1697 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/usage", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1698 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1699
1700 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1701 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1702 }
1703 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1704 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1705 };
1706
1707 let local_var_req = local_var_req_builder.build()?;
1708 let local_var_resp = local_var_client.execute(local_var_req).await?;
1709
1710 let local_var_status = local_var_resp.status();
1711 let local_var_content = local_var_resp.text().await?;
1712
1713 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1714 crate::from_str_patched(&local_var_content).map_err(Error::from)
1715 } else {
1716 let local_var_entity: Option<GetWorkspaceUsageError> = crate::from_str_patched(&local_var_content).ok();
1717 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1718 Err(Error::ResponseError(local_var_error))
1719 }
1720}
1721
1722pub async fn invite_user(configuration: &configuration::Configuration, workspace: &str, invite_user_request: models::InviteUserRequest) -> Result<String, Error<InviteUserError>> {
1723 let local_var_configuration = configuration;
1724
1725 let local_var_client = &local_var_configuration.client;
1726
1727 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/invite_user", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1728 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1729
1730 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1731 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1732 }
1733 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1734 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1735 };
1736 local_var_req_builder = local_var_req_builder.json(&invite_user_request);
1737
1738 let local_var_req = local_var_req_builder.build()?;
1739 let local_var_resp = local_var_client.execute(local_var_req).await?;
1740
1741 let local_var_status = local_var_resp.status();
1742 let local_var_content = local_var_resp.text().await?;
1743
1744 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1745 crate::from_str_patched(&local_var_content).map_err(Error::from)
1746 } else {
1747 let local_var_entity: Option<InviteUserError> = crate::from_str_patched(&local_var_content).ok();
1748 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1749 Err(Error::ResponseError(local_var_error))
1750 }
1751}
1752
1753pub async fn is_domain_allowed(configuration: &configuration::Configuration, ) -> Result<bool, Error<IsDomainAllowedError>> {
1754 let local_var_configuration = configuration;
1755
1756 let local_var_client = &local_var_configuration.client;
1757
1758 let local_var_uri_str = format!("{}/workspaces/allowed_domain_auto_invite", local_var_configuration.base_path);
1759 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1760
1761 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1762 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1763 }
1764 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1765 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1766 };
1767
1768 let local_var_req = local_var_req_builder.build()?;
1769 let local_var_resp = local_var_client.execute(local_var_req).await?;
1770
1771 let local_var_status = local_var_resp.status();
1772 let local_var_content = local_var_resp.text().await?;
1773
1774 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1775 crate::from_str_patched(&local_var_content).map_err(Error::from)
1776 } else {
1777 let local_var_entity: Option<IsDomainAllowedError> = crate::from_str_patched(&local_var_content).ok();
1778 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1779 Err(Error::ResponseError(local_var_error))
1780 }
1781}
1782
1783pub async fn leave_workspace(configuration: &configuration::Configuration, workspace: &str) -> Result<String, Error<LeaveWorkspaceError>> {
1784 let local_var_configuration = configuration;
1785
1786 let local_var_client = &local_var_configuration.client;
1787
1788 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/leave", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1789 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1790
1791 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1792 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1793 }
1794 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1795 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1796 };
1797
1798 let local_var_req = local_var_req_builder.build()?;
1799 let local_var_resp = local_var_client.execute(local_var_req).await?;
1800
1801 let local_var_status = local_var_resp.status();
1802 let local_var_content = local_var_resp.text().await?;
1803
1804 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1805 crate::from_str_patched(&local_var_content).map_err(Error::from)
1806 } else {
1807 let local_var_entity: Option<LeaveWorkspaceError> = crate::from_str_patched(&local_var_content).ok();
1808 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1809 Err(Error::ResponseError(local_var_error))
1810 }
1811}
1812
1813pub async fn list_available_teams_channels(configuration: &configuration::Configuration, workspace: &str, team_id: &str, search: Option<&str>) -> Result<Vec<models::ListAvailableTeamsChannels200ResponseInner>, Error<ListAvailableTeamsChannelsError>> {
1814 let local_var_configuration = configuration;
1815
1816 let local_var_client = &local_var_configuration.client;
1817
1818 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/available_teams_channels", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1819 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1820
1821 local_var_req_builder = local_var_req_builder.query(&[("team_id", &team_id.to_string())]);
1822 if let Some(ref local_var_str) = search {
1823 local_var_req_builder = local_var_req_builder.query(&[("search", &local_var_str.to_string())]);
1824 }
1825 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1826 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1827 }
1828 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1829 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1830 };
1831
1832 let local_var_req = local_var_req_builder.build()?;
1833 let local_var_resp = local_var_client.execute(local_var_req).await?;
1834
1835 let local_var_status = local_var_resp.status();
1836 let local_var_content = local_var_resp.text().await?;
1837
1838 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1839 crate::from_str_patched(&local_var_content).map_err(Error::from)
1840 } else {
1841 let local_var_entity: Option<ListAvailableTeamsChannelsError> = crate::from_str_patched(&local_var_content).ok();
1842 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1843 Err(Error::ResponseError(local_var_error))
1844 }
1845}
1846
1847pub async fn list_available_teams_ids(configuration: &configuration::Configuration, workspace: &str, search: Option<&str>) -> Result<Vec<models::ListAvailableTeamsIds200ResponseInner>, Error<ListAvailableTeamsIdsError>> {
1848 let local_var_configuration = configuration;
1849
1850 let local_var_client = &local_var_configuration.client;
1851
1852 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/available_teams_ids", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1853 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1854
1855 if let Some(ref local_var_str) = search {
1856 local_var_req_builder = local_var_req_builder.query(&[("search", &local_var_str.to_string())]);
1857 }
1858 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1859 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1860 }
1861 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1862 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1863 };
1864
1865 let local_var_req = local_var_req_builder.build()?;
1866 let local_var_resp = local_var_client.execute(local_var_req).await?;
1867
1868 let local_var_status = local_var_resp.status();
1869 let local_var_content = local_var_resp.text().await?;
1870
1871 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1872 crate::from_str_patched(&local_var_content).map_err(Error::from)
1873 } else {
1874 let local_var_entity: Option<ListAvailableTeamsIdsError> = crate::from_str_patched(&local_var_content).ok();
1875 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1876 Err(Error::ResponseError(local_var_error))
1877 }
1878}
1879
1880pub async fn list_ducklakes(configuration: &configuration::Configuration, workspace: &str) -> Result<Vec<String>, Error<ListDucklakesError>> {
1881 let local_var_configuration = configuration;
1882
1883 let local_var_client = &local_var_configuration.client;
1884
1885 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/list_ducklakes", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1886 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1887
1888 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1889 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1890 }
1891 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1892 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1893 };
1894
1895 let local_var_req = local_var_req_builder.build()?;
1896 let local_var_resp = local_var_client.execute(local_var_req).await?;
1897
1898 let local_var_status = local_var_resp.status();
1899 let local_var_content = local_var_resp.text().await?;
1900
1901 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1902 crate::from_str_patched(&local_var_content).map_err(Error::from)
1903 } else {
1904 let local_var_entity: Option<ListDucklakesError> = crate::from_str_patched(&local_var_content).ok();
1905 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1906 Err(Error::ResponseError(local_var_error))
1907 }
1908}
1909
1910pub async fn list_pending_invites(configuration: &configuration::Configuration, workspace: &str) -> Result<Vec<models::WorkspaceInvite>, Error<ListPendingInvitesError>> {
1911 let local_var_configuration = configuration;
1912
1913 let local_var_client = &local_var_configuration.client;
1914
1915 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/list_pending_invites", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1916 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1917
1918 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1919 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1920 }
1921 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1922 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1923 };
1924
1925 let local_var_req = local_var_req_builder.build()?;
1926 let local_var_resp = local_var_client.execute(local_var_req).await?;
1927
1928 let local_var_status = local_var_resp.status();
1929 let local_var_content = local_var_resp.text().await?;
1930
1931 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1932 crate::from_str_patched(&local_var_content).map_err(Error::from)
1933 } else {
1934 let local_var_entity: Option<ListPendingInvitesError> = crate::from_str_patched(&local_var_content).ok();
1935 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1936 Err(Error::ResponseError(local_var_error))
1937 }
1938}
1939
1940pub async fn list_user_workspaces(configuration: &configuration::Configuration, ) -> Result<models::UserWorkspaceList, Error<ListUserWorkspacesError>> {
1941 let local_var_configuration = configuration;
1942
1943 let local_var_client = &local_var_configuration.client;
1944
1945 let local_var_uri_str = format!("{}/workspaces/users", local_var_configuration.base_path);
1946 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1947
1948 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1949 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1950 }
1951 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1952 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1953 };
1954
1955 let local_var_req = local_var_req_builder.build()?;
1956 let local_var_resp = local_var_client.execute(local_var_req).await?;
1957
1958 let local_var_status = local_var_resp.status();
1959 let local_var_content = local_var_resp.text().await?;
1960
1961 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1962 crate::from_str_patched(&local_var_content).map_err(Error::from)
1963 } else {
1964 let local_var_entity: Option<ListUserWorkspacesError> = crate::from_str_patched(&local_var_content).ok();
1965 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1966 Err(Error::ResponseError(local_var_error))
1967 }
1968}
1969
1970pub async fn list_workspaces(configuration: &configuration::Configuration, ) -> Result<Vec<models::Workspace>, Error<ListWorkspacesError>> {
1971 let local_var_configuration = configuration;
1972
1973 let local_var_client = &local_var_configuration.client;
1974
1975 let local_var_uri_str = format!("{}/workspaces/list", local_var_configuration.base_path);
1976 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1977
1978 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1979 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1980 }
1981 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1982 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1983 };
1984
1985 let local_var_req = local_var_req_builder.build()?;
1986 let local_var_resp = local_var_client.execute(local_var_req).await?;
1987
1988 let local_var_status = local_var_resp.status();
1989 let local_var_content = local_var_resp.text().await?;
1990
1991 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1992 crate::from_str_patched(&local_var_content).map_err(Error::from)
1993 } else {
1994 let local_var_entity: Option<ListWorkspacesError> = crate::from_str_patched(&local_var_content).ok();
1995 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1996 Err(Error::ResponseError(local_var_error))
1997 }
1998}
1999
2000pub async fn list_workspaces_as_super_admin(configuration: &configuration::Configuration, page: Option<i32>, per_page: Option<i32>) -> Result<Vec<models::Workspace>, Error<ListWorkspacesAsSuperAdminError>> {
2001 let local_var_configuration = configuration;
2002
2003 let local_var_client = &local_var_configuration.client;
2004
2005 let local_var_uri_str = format!("{}/workspaces/list_as_superadmin", local_var_configuration.base_path);
2006 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
2007
2008 if let Some(ref local_var_str) = page {
2009 local_var_req_builder = local_var_req_builder.query(&[("page", &local_var_str.to_string())]);
2010 }
2011 if let Some(ref local_var_str) = per_page {
2012 local_var_req_builder = local_var_req_builder.query(&[("per_page", &local_var_str.to_string())]);
2013 }
2014 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2015 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2016 }
2017 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2018 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2019 };
2020
2021 let local_var_req = local_var_req_builder.build()?;
2022 let local_var_resp = local_var_client.execute(local_var_req).await?;
2023
2024 let local_var_status = local_var_resp.status();
2025 let local_var_content = local_var_resp.text().await?;
2026
2027 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2028 crate::from_str_patched(&local_var_content).map_err(Error::from)
2029 } else {
2030 let local_var_entity: Option<ListWorkspacesAsSuperAdminError> = crate::from_str_patched(&local_var_content).ok();
2031 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2032 Err(Error::ResponseError(local_var_error))
2033 }
2034}
2035
2036pub async fn run_slack_message_test_job(configuration: &configuration::Configuration, workspace: &str, run_slack_message_test_job_request: models::RunSlackMessageTestJobRequest) -> Result<models::RunSlackMessageTestJob200Response, Error<RunSlackMessageTestJobError>> {
2037 let local_var_configuration = configuration;
2038
2039 let local_var_client = &local_var_configuration.client;
2040
2041 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/run_slack_message_test_job", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2042 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
2043
2044 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2045 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2046 }
2047 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2048 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2049 };
2050 local_var_req_builder = local_var_req_builder.json(&run_slack_message_test_job_request);
2051
2052 let local_var_req = local_var_req_builder.build()?;
2053 let local_var_resp = local_var_client.execute(local_var_req).await?;
2054
2055 let local_var_status = local_var_resp.status();
2056 let local_var_content = local_var_resp.text().await?;
2057
2058 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2059 crate::from_str_patched(&local_var_content).map_err(Error::from)
2060 } else {
2061 let local_var_entity: Option<RunSlackMessageTestJobError> = crate::from_str_patched(&local_var_content).ok();
2062 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2063 Err(Error::ResponseError(local_var_error))
2064 }
2065}
2066
2067pub async fn run_teams_message_test_job(configuration: &configuration::Configuration, workspace: &str, run_slack_message_test_job_request: models::RunSlackMessageTestJobRequest) -> Result<models::RunSlackMessageTestJob200Response, Error<RunTeamsMessageTestJobError>> {
2068 let local_var_configuration = configuration;
2069
2070 let local_var_client = &local_var_configuration.client;
2071
2072 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/run_teams_message_test_job", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2073 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
2074
2075 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2076 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2077 }
2078 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2079 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2080 };
2081 local_var_req_builder = local_var_req_builder.json(&run_slack_message_test_job_request);
2082
2083 let local_var_req = local_var_req_builder.build()?;
2084 let local_var_resp = local_var_client.execute(local_var_req).await?;
2085
2086 let local_var_status = local_var_resp.status();
2087 let local_var_content = local_var_resp.text().await?;
2088
2089 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2090 crate::from_str_patched(&local_var_content).map_err(Error::from)
2091 } else {
2092 let local_var_entity: Option<RunTeamsMessageTestJobError> = crate::from_str_patched(&local_var_content).ok();
2093 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2094 Err(Error::ResponseError(local_var_error))
2095 }
2096}
2097
2098pub async fn set_environment_variable(configuration: &configuration::Configuration, workspace: &str, set_environment_variable_request: models::SetEnvironmentVariableRequest) -> Result<String, Error<SetEnvironmentVariableError>> {
2099 let local_var_configuration = configuration;
2100
2101 let local_var_client = &local_var_configuration.client;
2102
2103 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/set_environment_variable", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2104 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
2105
2106 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2107 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2108 }
2109 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2110 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2111 };
2112 local_var_req_builder = local_var_req_builder.json(&set_environment_variable_request);
2113
2114 let local_var_req = local_var_req_builder.build()?;
2115 let local_var_resp = local_var_client.execute(local_var_req).await?;
2116
2117 let local_var_status = local_var_resp.status();
2118 let local_var_content = local_var_resp.text().await?;
2119
2120 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2121 crate::from_str_patched(&local_var_content).map_err(Error::from)
2122 } else {
2123 let local_var_entity: Option<SetEnvironmentVariableError> = crate::from_str_patched(&local_var_content).ok();
2124 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2125 Err(Error::ResponseError(local_var_error))
2126 }
2127}
2128
2129pub async fn set_threshold_alert(configuration: &configuration::Configuration, workspace: &str, set_threshold_alert_request: models::SetThresholdAlertRequest) -> Result<String, Error<SetThresholdAlertError>> {
2130 let local_var_configuration = configuration;
2131
2132 let local_var_client = &local_var_configuration.client;
2133
2134 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/threshold_alert", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2135 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
2136
2137 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2138 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2139 }
2140 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2141 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2142 };
2143 local_var_req_builder = local_var_req_builder.json(&set_threshold_alert_request);
2144
2145 let local_var_req = local_var_req_builder.build()?;
2146 let local_var_resp = local_var_client.execute(local_var_req).await?;
2147
2148 let local_var_status = local_var_resp.status();
2149 let local_var_content = local_var_resp.text().await?;
2150
2151 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2152 crate::from_str_patched(&local_var_content).map_err(Error::from)
2153 } else {
2154 let local_var_entity: Option<SetThresholdAlertError> = crate::from_str_patched(&local_var_content).ok();
2155 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2156 Err(Error::ResponseError(local_var_error))
2157 }
2158}
2159
2160pub async fn set_workspace_encryption_key(configuration: &configuration::Configuration, workspace: &str, set_workspace_encryption_key_request: models::SetWorkspaceEncryptionKeyRequest) -> Result<String, Error<SetWorkspaceEncryptionKeyError>> {
2161 let local_var_configuration = configuration;
2162
2163 let local_var_client = &local_var_configuration.client;
2164
2165 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/encryption_key", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2166 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
2167
2168 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2169 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2170 }
2171 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2172 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2173 };
2174 local_var_req_builder = local_var_req_builder.json(&set_workspace_encryption_key_request);
2175
2176 let local_var_req = local_var_req_builder.build()?;
2177 let local_var_resp = local_var_client.execute(local_var_req).await?;
2178
2179 let local_var_status = local_var_resp.status();
2180 let local_var_content = local_var_resp.text().await?;
2181
2182 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2183 crate::from_str_patched(&local_var_content).map_err(Error::from)
2184 } else {
2185 let local_var_entity: Option<SetWorkspaceEncryptionKeyError> = crate::from_str_patched(&local_var_content).ok();
2186 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2187 Err(Error::ResponseError(local_var_error))
2188 }
2189}
2190
2191pub async fn unarchive_workspace(configuration: &configuration::Configuration, workspace: &str) -> Result<String, Error<UnarchiveWorkspaceError>> {
2192 let local_var_configuration = configuration;
2193
2194 let local_var_client = &local_var_configuration.client;
2195
2196 let local_var_uri_str = format!("{}/workspaces/unarchive/{workspace}", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2197 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
2198
2199 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2200 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2201 }
2202 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2203 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2204 };
2205
2206 let local_var_req = local_var_req_builder.build()?;
2207 let local_var_resp = local_var_client.execute(local_var_req).await?;
2208
2209 let local_var_status = local_var_resp.status();
2210 let local_var_content = local_var_resp.text().await?;
2211
2212 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2213 crate::from_str_patched(&local_var_content).map_err(Error::from)
2214 } else {
2215 let local_var_entity: Option<UnarchiveWorkspaceError> = crate::from_str_patched(&local_var_content).ok();
2216 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2217 Err(Error::ResponseError(local_var_error))
2218 }
2219}
2220
2221pub async fn update_operator_settings(configuration: &configuration::Configuration, workspace: &str, operator_settings: Option<models::OperatorSettings>) -> Result<String, Error<UpdateOperatorSettingsError>> {
2223 let local_var_configuration = configuration;
2224
2225 let local_var_client = &local_var_configuration.client;
2226
2227 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/operator_settings", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2228 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
2229
2230 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2231 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2232 }
2233 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2234 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2235 };
2236 local_var_req_builder = local_var_req_builder.json(&operator_settings);
2237
2238 let local_var_req = local_var_req_builder.build()?;
2239 let local_var_resp = local_var_client.execute(local_var_req).await?;
2240
2241 let local_var_status = local_var_resp.status();
2242 let local_var_content = local_var_resp.text().await?;
2243
2244 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2245 crate::from_str_patched(&local_var_content).map_err(Error::from)
2246 } else {
2247 let local_var_entity: Option<UpdateOperatorSettingsError> = crate::from_str_patched(&local_var_content).ok();
2248 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2249 Err(Error::ResponseError(local_var_error))
2250 }
2251}
2252