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 AttachDevWorkspaceError {
36 UnknownValue(serde_json::Value),
37}
38
39#[derive(Debug, Clone, Serialize, Deserialize)]
41#[serde(untagged)]
42pub enum CancelDeploymentRequestError {
43 UnknownValue(serde_json::Value),
44}
45
46#[derive(Debug, Clone, Serialize, Deserialize)]
48#[serde(untagged)]
49pub enum ChangeWorkspaceColorError {
50 UnknownValue(serde_json::Value),
51}
52
53#[derive(Debug, Clone, Serialize, Deserialize)]
55#[serde(untagged)]
56pub enum ChangeWorkspaceIdError {
57 UnknownValue(serde_json::Value),
58}
59
60#[derive(Debug, Clone, Serialize, Deserialize)]
62#[serde(untagged)]
63pub enum ChangeWorkspaceNameError {
64 UnknownValue(serde_json::Value),
65}
66
67#[derive(Debug, Clone, Serialize, Deserialize)]
69#[serde(untagged)]
70pub enum CloseDeploymentRequestMergedError {
71 UnknownValue(serde_json::Value),
72}
73
74#[derive(Debug, Clone, Serialize, Deserialize)]
76#[serde(untagged)]
77pub enum CompareWorkspacesError {
78 UnknownValue(serde_json::Value),
79}
80
81#[derive(Debug, Clone, Serialize, Deserialize)]
83#[serde(untagged)]
84pub enum ConnectSlackError {
85 UnknownValue(serde_json::Value),
86}
87
88#[derive(Debug, Clone, Serialize, Deserialize)]
90#[serde(untagged)]
91pub enum ConnectTeamsError {
92 UnknownValue(serde_json::Value),
93}
94
95#[derive(Debug, Clone, Serialize, Deserialize)]
97#[serde(untagged)]
98pub enum CreateDeploymentRequestError {
99 Status400(),
100 Status409(),
101 UnknownValue(serde_json::Value),
102}
103
104#[derive(Debug, Clone, Serialize, Deserialize)]
106#[serde(untagged)]
107pub enum CreateDeploymentRequestCommentError {
108 Status400(),
109 UnknownValue(serde_json::Value),
110}
111
112#[derive(Debug, Clone, Serialize, Deserialize)]
114#[serde(untagged)]
115pub enum CreatePgDatabaseError {
116 UnknownValue(serde_json::Value),
117}
118
119#[derive(Debug, Clone, Serialize, Deserialize)]
121#[serde(untagged)]
122pub enum CreateProtectionRuleError {
123 Status400(),
124 UnknownValue(serde_json::Value),
125}
126
127#[derive(Debug, Clone, Serialize, Deserialize)]
129#[serde(untagged)]
130pub enum CreateServiceAccountError {
131 UnknownValue(serde_json::Value),
132}
133
134#[derive(Debug, Clone, Serialize, Deserialize)]
136#[serde(untagged)]
137pub enum CreateWorkspaceError {
138 UnknownValue(serde_json::Value),
139}
140
141#[derive(Debug, Clone, Serialize, Deserialize)]
143#[serde(untagged)]
144pub enum CreateWorkspaceForkError {
145 UnknownValue(serde_json::Value),
146}
147
148#[derive(Debug, Clone, Serialize, Deserialize)]
150#[serde(untagged)]
151pub enum CreateWorkspaceForkGitBranchError {
152 UnknownValue(serde_json::Value),
153}
154
155#[derive(Debug, Clone, Serialize, Deserialize)]
157#[serde(untagged)]
158pub enum DeleteAiSkillError {
159 UnknownValue(serde_json::Value),
160}
161
162#[derive(Debug, Clone, Serialize, Deserialize)]
164#[serde(untagged)]
165pub enum DeleteGitSyncRepositoryError {
166 UnknownValue(serde_json::Value),
167}
168
169#[derive(Debug, Clone, Serialize, Deserialize)]
171#[serde(untagged)]
172pub enum DeleteInviteError {
173 UnknownValue(serde_json::Value),
174}
175
176#[derive(Debug, Clone, Serialize, Deserialize)]
178#[serde(untagged)]
179pub enum DeleteProtectionRuleError {
180 Status404(),
181 UnknownValue(serde_json::Value),
182}
183
184#[derive(Debug, Clone, Serialize, Deserialize)]
186#[serde(untagged)]
187pub enum DeleteWorkspaceError {
188 UnknownValue(serde_json::Value),
189}
190
191#[derive(Debug, Clone, Serialize, Deserialize)]
193#[serde(untagged)]
194pub enum DeleteWorkspaceSlackOauthConfigError {
195 UnknownValue(serde_json::Value),
196}
197
198#[derive(Debug, Clone, Serialize, Deserialize)]
200#[serde(untagged)]
201pub enum DetachDevWorkspaceError {
202 UnknownValue(serde_json::Value),
203}
204
205#[derive(Debug, Clone, Serialize, Deserialize)]
207#[serde(untagged)]
208pub enum DropForkedDatatableDatabasesError {
209 UnknownValue(serde_json::Value),
210}
211
212#[derive(Debug, Clone, Serialize, Deserialize)]
214#[serde(untagged)]
215pub enum DropForkedDucklakeNamespacesError {
216 UnknownValue(serde_json::Value),
217}
218
219#[derive(Debug, Clone, Serialize, Deserialize)]
221#[serde(untagged)]
222pub enum EditAutoInviteError {
223 UnknownValue(serde_json::Value),
224}
225
226#[derive(Debug, Clone, Serialize, Deserialize)]
228#[serde(untagged)]
229pub enum EditCopilotConfigError {
230 UnknownValue(serde_json::Value),
231}
232
233#[derive(Debug, Clone, Serialize, Deserialize)]
235#[serde(untagged)]
236pub enum EditDataTableConfigError {
237 UnknownValue(serde_json::Value),
238}
239
240#[derive(Debug, Clone, Serialize, Deserialize)]
242#[serde(untagged)]
243pub enum EditDefaultScriptsError {
244 UnknownValue(serde_json::Value),
245}
246
247#[derive(Debug, Clone, Serialize, Deserialize)]
249#[serde(untagged)]
250pub enum EditDeployToError {
251 UnknownValue(serde_json::Value),
252}
253
254#[derive(Debug, Clone, Serialize, Deserialize)]
256#[serde(untagged)]
257pub enum EditDucklakeConfigError {
258 UnknownValue(serde_json::Value),
259}
260
261#[derive(Debug, Clone, Serialize, Deserialize)]
263#[serde(untagged)]
264pub enum EditErrorHandlerError {
265 UnknownValue(serde_json::Value),
266}
267
268#[derive(Debug, Clone, Serialize, Deserialize)]
270#[serde(untagged)]
271pub enum EditGitSyncRepositoryError {
272 UnknownValue(serde_json::Value),
273}
274
275#[derive(Debug, Clone, Serialize, Deserialize)]
277#[serde(untagged)]
278pub enum EditInstanceGroupsError {
279 UnknownValue(serde_json::Value),
280}
281
282#[derive(Debug, Clone, Serialize, Deserialize)]
284#[serde(untagged)]
285pub enum EditLargeFileStorageConfigError {
286 UnknownValue(serde_json::Value),
287}
288
289#[derive(Debug, Clone, Serialize, Deserialize)]
291#[serde(untagged)]
292pub enum EditSlackCommandError {
293 UnknownValue(serde_json::Value),
294}
295
296#[derive(Debug, Clone, Serialize, Deserialize)]
298#[serde(untagged)]
299pub enum EditSuccessHandlerError {
300 UnknownValue(serde_json::Value),
301}
302
303#[derive(Debug, Clone, Serialize, Deserialize)]
305#[serde(untagged)]
306pub enum EditTeamsCommandError {
307 UnknownValue(serde_json::Value),
308}
309
310#[derive(Debug, Clone, Serialize, Deserialize)]
312#[serde(untagged)]
313pub enum EditWebhookError {
314 UnknownValue(serde_json::Value),
315}
316
317#[derive(Debug, Clone, Serialize, Deserialize)]
319#[serde(untagged)]
320pub enum EditWorkspaceDefaultAppError {
321 UnknownValue(serde_json::Value),
322}
323
324#[derive(Debug, Clone, Serialize, Deserialize)]
326#[serde(untagged)]
327pub enum EditWorkspaceDeployUiSettingsError {
328 UnknownValue(serde_json::Value),
329}
330
331#[derive(Debug, Clone, Serialize, Deserialize)]
333#[serde(untagged)]
334pub enum EditWorkspaceGitSyncConfigError {
335 UnknownValue(serde_json::Value),
336}
337
338#[derive(Debug, Clone, Serialize, Deserialize)]
340#[serde(untagged)]
341pub enum ExistsUsernameError {
342 UnknownValue(serde_json::Value),
343}
344
345#[derive(Debug, Clone, Serialize, Deserialize)]
347#[serde(untagged)]
348pub enum ExistsWorkspaceError {
349 UnknownValue(serde_json::Value),
350}
351
352#[derive(Debug, Clone, Serialize, Deserialize)]
354#[serde(untagged)]
355pub enum ExportPgSchemaError {
356 UnknownValue(serde_json::Value),
357}
358
359#[derive(Debug, Clone, Serialize, Deserialize)]
361#[serde(untagged)]
362pub enum GetAiSkillError {
363 UnknownValue(serde_json::Value),
364}
365
366#[derive(Debug, Clone, Serialize, Deserialize)]
368#[serde(untagged)]
369pub enum GetCloudQuotasError {
370 UnknownValue(serde_json::Value),
371}
372
373#[derive(Debug, Clone, Serialize, Deserialize)]
375#[serde(untagged)]
376pub enum GetCopilotInfoError {
377 UnknownValue(serde_json::Value),
378}
379
380#[derive(Debug, Clone, Serialize, Deserialize)]
382#[serde(untagged)]
383pub enum GetCopilotSettingsStateError {
384 UnknownValue(serde_json::Value),
385}
386
387#[derive(Debug, Clone, Serialize, Deserialize)]
389#[serde(untagged)]
390pub enum GetDataTableTableSchemaError {
391 UnknownValue(serde_json::Value),
392}
393
394#[derive(Debug, Clone, Serialize, Deserialize)]
396#[serde(untagged)]
397pub enum GetDatatableFullSchemaError {
398 UnknownValue(serde_json::Value),
399}
400
401#[derive(Debug, Clone, Serialize, Deserialize)]
403#[serde(untagged)]
404pub enum GetDefaultScriptsError {
405 UnknownValue(serde_json::Value),
406}
407
408#[derive(Debug, Clone, Serialize, Deserialize)]
410#[serde(untagged)]
411pub enum GetDependencyMapError {
412 UnknownValue(serde_json::Value),
413}
414
415#[derive(Debug, Clone, Serialize, Deserialize)]
417#[serde(untagged)]
418pub enum GetDependentsError {
419 UnknownValue(serde_json::Value),
420}
421
422#[derive(Debug, Clone, Serialize, Deserialize)]
424#[serde(untagged)]
425pub enum GetDependentsAmountsError {
426 UnknownValue(serde_json::Value),
427}
428
429#[derive(Debug, Clone, Serialize, Deserialize)]
431#[serde(untagged)]
432pub enum GetDeployToError {
433 UnknownValue(serde_json::Value),
434}
435
436#[derive(Debug, Clone, Serialize, Deserialize)]
438#[serde(untagged)]
439pub enum GetDevWorkspaceError {
440 UnknownValue(serde_json::Value),
441}
442
443#[derive(Debug, Clone, Serialize, Deserialize)]
445#[serde(untagged)]
446pub enum GetGitSyncEnabledError {
447 UnknownValue(serde_json::Value),
448}
449
450#[derive(Debug, Clone, Serialize, Deserialize)]
452#[serde(untagged)]
453pub enum GetGithubAppTokenError {
454 UnknownValue(serde_json::Value),
455}
456
457#[derive(Debug, Clone, Serialize, Deserialize)]
459#[serde(untagged)]
460pub enum GetImportsError {
461 UnknownValue(serde_json::Value),
462}
463
464#[derive(Debug, Clone, Serialize, Deserialize)]
466#[serde(untagged)]
467pub enum GetIsPremiumError {
468 UnknownValue(serde_json::Value),
469}
470
471#[derive(Debug, Clone, Serialize, Deserialize)]
473#[serde(untagged)]
474pub enum GetOpenDeploymentRequestError {
475 UnknownValue(serde_json::Value),
476}
477
478#[derive(Debug, Clone, Serialize, Deserialize)]
480#[serde(untagged)]
481pub enum GetPremiumInfoError {
482 UnknownValue(serde_json::Value),
483}
484
485#[derive(Debug, Clone, Serialize, Deserialize)]
487#[serde(untagged)]
488pub enum GetPublicSettingsError {
489 UnknownValue(serde_json::Value),
490}
491
492#[derive(Debug, Clone, Serialize, Deserialize)]
494#[serde(untagged)]
495pub enum GetSessionWorkspaceStatusError {
496 UnknownValue(serde_json::Value),
497}
498
499#[derive(Debug, Clone, Serialize, Deserialize)]
501#[serde(untagged)]
502pub enum GetSettingsError {
503 UnknownValue(serde_json::Value),
504}
505
506#[derive(Debug, Clone, Serialize, Deserialize)]
508#[serde(untagged)]
509pub enum GetSharedUiError {
510 UnknownValue(serde_json::Value),
511}
512
513#[derive(Debug, Clone, Serialize, Deserialize)]
515#[serde(untagged)]
516pub enum GetSharedUiVersionError {
517 UnknownValue(serde_json::Value),
518}
519
520#[derive(Debug, Clone, Serialize, Deserialize)]
522#[serde(untagged)]
523pub enum GetThresholdAlertError {
524 UnknownValue(serde_json::Value),
525}
526
527#[derive(Debug, Clone, Serialize, Deserialize)]
529#[serde(untagged)]
530pub enum GetUsedTriggersError {
531 UnknownValue(serde_json::Value),
532}
533
534#[derive(Debug, Clone, Serialize, Deserialize)]
536#[serde(untagged)]
537pub enum GetWorkspaceAsSuperAdminError {
538 UnknownValue(serde_json::Value),
539}
540
541#[derive(Debug, Clone, Serialize, Deserialize)]
543#[serde(untagged)]
544pub enum GetWorkspaceDefaultAppError {
545 UnknownValue(serde_json::Value),
546}
547
548#[derive(Debug, Clone, Serialize, Deserialize)]
550#[serde(untagged)]
551pub enum GetWorkspaceEncryptionKeyError {
552 UnknownValue(serde_json::Value),
553}
554
555#[derive(Debug, Clone, Serialize, Deserialize)]
557#[serde(untagged)]
558pub enum GetWorkspaceNameError {
559 UnknownValue(serde_json::Value),
560}
561
562#[derive(Debug, Clone, Serialize, Deserialize)]
564#[serde(untagged)]
565pub enum GetWorkspaceSlackOauthConfigError {
566 UnknownValue(serde_json::Value),
567}
568
569#[derive(Debug, Clone, Serialize, Deserialize)]
571#[serde(untagged)]
572pub enum GetWorkspaceUsageError {
573 UnknownValue(serde_json::Value),
574}
575
576#[derive(Debug, Clone, Serialize, Deserialize)]
578#[serde(untagged)]
579pub enum ImportPgDatabaseError {
580 UnknownValue(serde_json::Value),
581}
582
583#[derive(Debug, Clone, Serialize, Deserialize)]
585#[serde(untagged)]
586pub enum InviteUserError {
587 UnknownValue(serde_json::Value),
588}
589
590#[derive(Debug, Clone, Serialize, Deserialize)]
592#[serde(untagged)]
593pub enum IsDomainAllowedError {
594 UnknownValue(serde_json::Value),
595}
596
597#[derive(Debug, Clone, Serialize, Deserialize)]
599#[serde(untagged)]
600pub enum LeaveWorkspaceError {
601 UnknownValue(serde_json::Value),
602}
603
604#[derive(Debug, Clone, Serialize, Deserialize)]
606#[serde(untagged)]
607pub enum ListAiSkillsError {
608 UnknownValue(serde_json::Value),
609}
610
611#[derive(Debug, Clone, Serialize, Deserialize)]
613#[serde(untagged)]
614pub enum ListAvailableTeamsChannelsError {
615 UnknownValue(serde_json::Value),
616}
617
618#[derive(Debug, Clone, Serialize, Deserialize)]
620#[serde(untagged)]
621pub enum ListAvailableTeamsIdsError {
622 UnknownValue(serde_json::Value),
623}
624
625#[derive(Debug, Clone, Serialize, Deserialize)]
627#[serde(untagged)]
628pub enum ListDataTableSchemasError {
629 UnknownValue(serde_json::Value),
630}
631
632#[derive(Debug, Clone, Serialize, Deserialize)]
634#[serde(untagged)]
635pub enum ListDataTableTablesError {
636 UnknownValue(serde_json::Value),
637}
638
639#[derive(Debug, Clone, Serialize, Deserialize)]
641#[serde(untagged)]
642pub enum ListDataTablesError {
643 UnknownValue(serde_json::Value),
644}
645
646#[derive(Debug, Clone, Serialize, Deserialize)]
648#[serde(untagged)]
649pub enum ListDeploymentRequestEligibleDeployersError {
650 UnknownValue(serde_json::Value),
651}
652
653#[derive(Debug, Clone, Serialize, Deserialize)]
655#[serde(untagged)]
656pub enum ListDucklakesError {
657 UnknownValue(serde_json::Value),
658}
659
660#[derive(Debug, Clone, Serialize, Deserialize)]
662#[serde(untagged)]
663pub enum ListPendingInvitesError {
664 UnknownValue(serde_json::Value),
665}
666
667#[derive(Debug, Clone, Serialize, Deserialize)]
669#[serde(untagged)]
670pub enum ListProtectionRulesError {
671 UnknownValue(serde_json::Value),
672}
673
674#[derive(Debug, Clone, Serialize, Deserialize)]
676#[serde(untagged)]
677pub enum ListSharedUiError {
678 UnknownValue(serde_json::Value),
679}
680
681#[derive(Debug, Clone, Serialize, Deserialize)]
683#[serde(untagged)]
684pub enum ListUserWorkspacesError {
685 UnknownValue(serde_json::Value),
686}
687
688#[derive(Debug, Clone, Serialize, Deserialize)]
690#[serde(untagged)]
691pub enum ListWorkspacesError {
692 UnknownValue(serde_json::Value),
693}
694
695#[derive(Debug, Clone, Serialize, Deserialize)]
697#[serde(untagged)]
698pub enum ListWorkspacesAsSuperAdminError {
699 UnknownValue(serde_json::Value),
700}
701
702#[derive(Debug, Clone, Serialize, Deserialize)]
704#[serde(untagged)]
705pub enum ListWsSpecificError {
706 UnknownValue(serde_json::Value),
707}
708
709#[derive(Debug, Clone, Serialize, Deserialize)]
711#[serde(untagged)]
712pub enum ListWsSpecificVersionsError {
713 UnknownValue(serde_json::Value),
714}
715
716#[derive(Debug, Clone, Serialize, Deserialize)]
718#[serde(untagged)]
719pub enum LogAiChatError {
720 UnknownValue(serde_json::Value),
721}
722
723#[derive(Debug, Clone, Serialize, Deserialize)]
725#[serde(untagged)]
726pub enum PruneVersionsError {
727 UnknownValue(serde_json::Value),
728}
729
730#[derive(Debug, Clone, Serialize, Deserialize)]
732#[serde(untagged)]
733pub enum RebuildDependencyMapError {
734 UnknownValue(serde_json::Value),
735}
736
737#[derive(Debug, Clone, Serialize, Deserialize)]
739#[serde(untagged)]
740pub enum ResetDiffTallyError {
741 UnknownValue(serde_json::Value),
742}
743
744#[derive(Debug, Clone, Serialize, Deserialize)]
746#[serde(untagged)]
747pub enum RunSlackMessageTestJobError {
748 UnknownValue(serde_json::Value),
749}
750
751#[derive(Debug, Clone, Serialize, Deserialize)]
753#[serde(untagged)]
754pub enum RunTeamsMessageTestJobError {
755 UnknownValue(serde_json::Value),
756}
757
758#[derive(Debug, Clone, Serialize, Deserialize)]
760#[serde(untagged)]
761pub enum SetDevWorkspaceLabelError {
762 UnknownValue(serde_json::Value),
763}
764
765#[derive(Debug, Clone, Serialize, Deserialize)]
767#[serde(untagged)]
768pub enum SetEnvironmentVariableError {
769 UnknownValue(serde_json::Value),
770}
771
772#[derive(Debug, Clone, Serialize, Deserialize)]
774#[serde(untagged)]
775pub enum SetThresholdAlertError {
776 UnknownValue(serde_json::Value),
777}
778
779#[derive(Debug, Clone, Serialize, Deserialize)]
781#[serde(untagged)]
782pub enum SetWorkspaceEncryptionKeyError {
783 UnknownValue(serde_json::Value),
784}
785
786#[derive(Debug, Clone, Serialize, Deserialize)]
788#[serde(untagged)]
789pub enum SetWorkspaceSlackOauthConfigError {
790 UnknownValue(serde_json::Value),
791}
792
793#[derive(Debug, Clone, Serialize, Deserialize)]
795#[serde(untagged)]
796pub enum SetWsSpecificError {
797 UnknownValue(serde_json::Value),
798}
799
800#[derive(Debug, Clone, Serialize, Deserialize)]
802#[serde(untagged)]
803pub enum UnarchiveWorkspaceError {
804 UnknownValue(serde_json::Value),
805}
806
807#[derive(Debug, Clone, Serialize, Deserialize)]
809#[serde(untagged)]
810pub enum UpdateOperatorSettingsError {
811 UnknownValue(serde_json::Value),
812}
813
814#[derive(Debug, Clone, Serialize, Deserialize)]
816#[serde(untagged)]
817pub enum UpdateProtectionRuleError {
818 Status404(),
819 UnknownValue(serde_json::Value),
820}
821
822#[derive(Debug, Clone, Serialize, Deserialize)]
824#[serde(untagged)]
825pub enum UpdateSharedUiError {
826 UnknownValue(serde_json::Value),
827}
828
829#[derive(Debug, Clone, Serialize, Deserialize)]
831#[serde(untagged)]
832pub enum UploadAiSkillsError {
833 UnknownValue(serde_json::Value),
834}
835
836
837pub async fn add_user(configuration: &configuration::Configuration, workspace: &str, add_user_request: models::AddUserRequest) -> Result<String, Error<AddUserError>> {
838 let local_var_configuration = configuration;
839
840 let local_var_client = &local_var_configuration.client;
841
842 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/add_user", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
843 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
844
845 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
846 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
847 }
848 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
849 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
850 };
851 local_var_req_builder = local_var_req_builder.json(&add_user_request);
852
853 let local_var_req = local_var_req_builder.build()?;
854 let local_var_resp = local_var_client.execute(local_var_req).await?;
855
856 let local_var_status = local_var_resp.status();
857 let local_var_content = local_var_resp.text().await?;
858
859 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
860 crate::from_str_patched(&local_var_content).map_err(Error::from)
861 } else {
862 let local_var_entity: Option<AddUserError> = crate::from_str_patched(&local_var_content).ok();
863 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
864 Err(Error::ResponseError(local_var_error))
865 }
866}
867
868pub async fn archive_workspace(configuration: &configuration::Configuration, workspace: &str) -> Result<String, Error<ArchiveWorkspaceError>> {
869 let local_var_configuration = configuration;
870
871 let local_var_client = &local_var_configuration.client;
872
873 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/archive", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
874 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
875
876 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
877 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
878 }
879 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
880 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
881 };
882
883 let local_var_req = local_var_req_builder.build()?;
884 let local_var_resp = local_var_client.execute(local_var_req).await?;
885
886 let local_var_status = local_var_resp.status();
887 let local_var_content = local_var_resp.text().await?;
888
889 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
890 crate::from_str_patched(&local_var_content).map_err(Error::from)
891 } else {
892 let local_var_entity: Option<ArchiveWorkspaceError> = crate::from_str_patched(&local_var_content).ok();
893 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
894 Err(Error::ResponseError(local_var_error))
895 }
896}
897
898pub async fn attach_dev_workspace(configuration: &configuration::Configuration, workspace: &str, attach_dev_workspace_request: models::AttachDevWorkspaceRequest) -> Result<String, Error<AttachDevWorkspaceError>> {
899 let local_var_configuration = configuration;
900
901 let local_var_client = &local_var_configuration.client;
902
903 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/attach_dev_workspace", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
904 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
905
906 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
907 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
908 }
909 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
910 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
911 };
912 local_var_req_builder = local_var_req_builder.json(&attach_dev_workspace_request);
913
914 let local_var_req = local_var_req_builder.build()?;
915 let local_var_resp = local_var_client.execute(local_var_req).await?;
916
917 let local_var_status = local_var_resp.status();
918 let local_var_content = local_var_resp.text().await?;
919
920 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
921 crate::from_str_patched(&local_var_content).map_err(Error::from)
922 } else {
923 let local_var_entity: Option<AttachDevWorkspaceError> = crate::from_str_patched(&local_var_content).ok();
924 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
925 Err(Error::ResponseError(local_var_error))
926 }
927}
928
929pub async fn cancel_deployment_request(configuration: &configuration::Configuration, workspace: &str, id: i64) -> Result<String, Error<CancelDeploymentRequestError>> {
930 let local_var_configuration = configuration;
931
932 let local_var_client = &local_var_configuration.client;
933
934 let local_var_uri_str = format!("{}/w/{workspace}/deployment_request/{id}/cancel", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace), id=id);
935 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
936
937 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
938 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
939 }
940 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
941 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
942 };
943
944 let local_var_req = local_var_req_builder.build()?;
945 let local_var_resp = local_var_client.execute(local_var_req).await?;
946
947 let local_var_status = local_var_resp.status();
948 let local_var_content = local_var_resp.text().await?;
949
950 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
951 crate::from_str_patched(&local_var_content).map_err(Error::from)
952 } else {
953 let local_var_entity: Option<CancelDeploymentRequestError> = crate::from_str_patched(&local_var_content).ok();
954 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
955 Err(Error::ResponseError(local_var_error))
956 }
957}
958
959pub async fn change_workspace_color(configuration: &configuration::Configuration, workspace: &str, change_workspace_color_request: Option<models::ChangeWorkspaceColorRequest>) -> Result<String, Error<ChangeWorkspaceColorError>> {
960 let local_var_configuration = configuration;
961
962 let local_var_client = &local_var_configuration.client;
963
964 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/change_workspace_color", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
965 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
966
967 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
968 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
969 }
970 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
971 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
972 };
973 local_var_req_builder = local_var_req_builder.json(&change_workspace_color_request);
974
975 let local_var_req = local_var_req_builder.build()?;
976 let local_var_resp = local_var_client.execute(local_var_req).await?;
977
978 let local_var_status = local_var_resp.status();
979 let local_var_content = local_var_resp.text().await?;
980
981 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
982 crate::from_str_patched(&local_var_content).map_err(Error::from)
983 } else {
984 let local_var_entity: Option<ChangeWorkspaceColorError> = crate::from_str_patched(&local_var_content).ok();
985 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
986 Err(Error::ResponseError(local_var_error))
987 }
988}
989
990pub async fn change_workspace_id(configuration: &configuration::Configuration, workspace: &str, change_workspace_id_request: Option<models::ChangeWorkspaceIdRequest>) -> Result<String, Error<ChangeWorkspaceIdError>> {
991 let local_var_configuration = configuration;
992
993 let local_var_client = &local_var_configuration.client;
994
995 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/change_workspace_id", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
996 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
997
998 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
999 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1000 }
1001 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1002 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1003 };
1004 local_var_req_builder = local_var_req_builder.json(&change_workspace_id_request);
1005
1006 let local_var_req = local_var_req_builder.build()?;
1007 let local_var_resp = local_var_client.execute(local_var_req).await?;
1008
1009 let local_var_status = local_var_resp.status();
1010 let local_var_content = local_var_resp.text().await?;
1011
1012 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1013 crate::from_str_patched(&local_var_content).map_err(Error::from)
1014 } else {
1015 let local_var_entity: Option<ChangeWorkspaceIdError> = crate::from_str_patched(&local_var_content).ok();
1016 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1017 Err(Error::ResponseError(local_var_error))
1018 }
1019}
1020
1021pub async fn change_workspace_name(configuration: &configuration::Configuration, workspace: &str, change_workspace_name_request: Option<models::ChangeWorkspaceNameRequest>) -> Result<String, Error<ChangeWorkspaceNameError>> {
1022 let local_var_configuration = configuration;
1023
1024 let local_var_client = &local_var_configuration.client;
1025
1026 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/change_workspace_name", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1027 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1028
1029 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1030 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1031 }
1032 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1033 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1034 };
1035 local_var_req_builder = local_var_req_builder.json(&change_workspace_name_request);
1036
1037 let local_var_req = local_var_req_builder.build()?;
1038 let local_var_resp = local_var_client.execute(local_var_req).await?;
1039
1040 let local_var_status = local_var_resp.status();
1041 let local_var_content = local_var_resp.text().await?;
1042
1043 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1044 crate::from_str_patched(&local_var_content).map_err(Error::from)
1045 } else {
1046 let local_var_entity: Option<ChangeWorkspaceNameError> = crate::from_str_patched(&local_var_content).ok();
1047 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1048 Err(Error::ResponseError(local_var_error))
1049 }
1050}
1051
1052pub async fn close_deployment_request_merged(configuration: &configuration::Configuration, workspace: &str, id: i64) -> Result<String, Error<CloseDeploymentRequestMergedError>> {
1054 let local_var_configuration = configuration;
1055
1056 let local_var_client = &local_var_configuration.client;
1057
1058 let local_var_uri_str = format!("{}/w/{workspace}/deployment_request/{id}/close_merged", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace), id=id);
1059 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1060
1061 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1062 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1063 }
1064 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1065 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1066 };
1067
1068 let local_var_req = local_var_req_builder.build()?;
1069 let local_var_resp = local_var_client.execute(local_var_req).await?;
1070
1071 let local_var_status = local_var_resp.status();
1072 let local_var_content = local_var_resp.text().await?;
1073
1074 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1075 crate::from_str_patched(&local_var_content).map_err(Error::from)
1076 } else {
1077 let local_var_entity: Option<CloseDeploymentRequestMergedError> = crate::from_str_patched(&local_var_content).ok();
1078 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1079 Err(Error::ResponseError(local_var_error))
1080 }
1081}
1082
1083pub async fn compare_workspaces(configuration: &configuration::Configuration, workspace: &str, target_workspace_id: &str) -> Result<models::WorkspaceComparison, Error<CompareWorkspacesError>> {
1085 let local_var_configuration = configuration;
1086
1087 let local_var_client = &local_var_configuration.client;
1088
1089 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/compare/{target_workspace_id}", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace), target_workspace_id=crate::apis::urlencode(target_workspace_id));
1090 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1091
1092 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1093 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1094 }
1095 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1096 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1097 };
1098
1099 let local_var_req = local_var_req_builder.build()?;
1100 let local_var_resp = local_var_client.execute(local_var_req).await?;
1101
1102 let local_var_status = local_var_resp.status();
1103 let local_var_content = local_var_resp.text().await?;
1104
1105 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1106 crate::from_str_patched(&local_var_content).map_err(Error::from)
1107 } else {
1108 let local_var_entity: Option<CompareWorkspacesError> = crate::from_str_patched(&local_var_content).ok();
1109 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1110 Err(Error::ResponseError(local_var_error))
1111 }
1112}
1113
1114pub async fn connect_slack(configuration: &configuration::Configuration, workspace: &str, connect_slack_request: models::ConnectSlackRequest) -> Result<(), Error<ConnectSlackError>> {
1115 let local_var_configuration = configuration;
1116
1117 let local_var_client = &local_var_configuration.client;
1118
1119 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/connect_slack", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1120 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1121
1122 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1123 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1124 }
1125 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1126 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1127 };
1128 local_var_req_builder = local_var_req_builder.json(&connect_slack_request);
1129
1130 let local_var_req = local_var_req_builder.build()?;
1131 let local_var_resp = local_var_client.execute(local_var_req).await?;
1132
1133 let local_var_status = local_var_resp.status();
1134 let local_var_content = local_var_resp.text().await?;
1135
1136 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1137 Ok(())
1138 } else {
1139 let local_var_entity: Option<ConnectSlackError> = crate::from_str_patched(&local_var_content).ok();
1140 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1141 Err(Error::ResponseError(local_var_error))
1142 }
1143}
1144
1145pub async fn connect_teams(configuration: &configuration::Configuration, workspace: &str, connect_teams_request: models::ConnectTeamsRequest) -> Result<String, Error<ConnectTeamsError>> {
1146 let local_var_configuration = configuration;
1147
1148 let local_var_client = &local_var_configuration.client;
1149
1150 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/connect_teams", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1151 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1152
1153 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1154 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1155 }
1156 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1157 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1158 };
1159 local_var_req_builder = local_var_req_builder.json(&connect_teams_request);
1160
1161 let local_var_req = local_var_req_builder.build()?;
1162 let local_var_resp = local_var_client.execute(local_var_req).await?;
1163
1164 let local_var_status = local_var_resp.status();
1165 let local_var_content = local_var_resp.text().await?;
1166
1167 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1168 crate::from_str_patched(&local_var_content).map_err(Error::from)
1169 } else {
1170 let local_var_entity: Option<ConnectTeamsError> = crate::from_str_patched(&local_var_content).ok();
1171 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1172 Err(Error::ResponseError(local_var_error))
1173 }
1174}
1175
1176pub async fn create_deployment_request(configuration: &configuration::Configuration, workspace: &str, create_deployment_request_request: models::CreateDeploymentRequestRequest) -> Result<models::DeploymentRequest, Error<CreateDeploymentRequestError>> {
1177 let local_var_configuration = configuration;
1178
1179 let local_var_client = &local_var_configuration.client;
1180
1181 let local_var_uri_str = format!("{}/w/{workspace}/deployment_request", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1182 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1183
1184 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1185 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1186 }
1187 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1188 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1189 };
1190 local_var_req_builder = local_var_req_builder.json(&create_deployment_request_request);
1191
1192 let local_var_req = local_var_req_builder.build()?;
1193 let local_var_resp = local_var_client.execute(local_var_req).await?;
1194
1195 let local_var_status = local_var_resp.status();
1196 let local_var_content = local_var_resp.text().await?;
1197
1198 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1199 crate::from_str_patched(&local_var_content).map_err(Error::from)
1200 } else {
1201 let local_var_entity: Option<CreateDeploymentRequestError> = crate::from_str_patched(&local_var_content).ok();
1202 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1203 Err(Error::ResponseError(local_var_error))
1204 }
1205}
1206
1207pub async fn create_deployment_request_comment(configuration: &configuration::Configuration, workspace: &str, id: i64, create_deployment_request_comment_request: models::CreateDeploymentRequestCommentRequest) -> Result<models::DeploymentRequestComment, Error<CreateDeploymentRequestCommentError>> {
1208 let local_var_configuration = configuration;
1209
1210 let local_var_client = &local_var_configuration.client;
1211
1212 let local_var_uri_str = format!("{}/w/{workspace}/deployment_request/{id}/comment", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace), id=id);
1213 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1214
1215 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1216 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1217 }
1218 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1219 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1220 };
1221 local_var_req_builder = local_var_req_builder.json(&create_deployment_request_comment_request);
1222
1223 let local_var_req = local_var_req_builder.build()?;
1224 let local_var_resp = local_var_client.execute(local_var_req).await?;
1225
1226 let local_var_status = local_var_resp.status();
1227 let local_var_content = local_var_resp.text().await?;
1228
1229 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1230 crate::from_str_patched(&local_var_content).map_err(Error::from)
1231 } else {
1232 let local_var_entity: Option<CreateDeploymentRequestCommentError> = crate::from_str_patched(&local_var_content).ok();
1233 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1234 Err(Error::ResponseError(local_var_error))
1235 }
1236}
1237
1238pub async fn create_pg_database(configuration: &configuration::Configuration, workspace: &str, create_pg_database_request: models::CreatePgDatabaseRequest) -> Result<String, Error<CreatePgDatabaseError>> {
1239 let local_var_configuration = configuration;
1240
1241 let local_var_client = &local_var_configuration.client;
1242
1243 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/create_pg_database", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1244 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1245
1246 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1247 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1248 }
1249 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1250 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1251 };
1252 local_var_req_builder = local_var_req_builder.json(&create_pg_database_request);
1253
1254 let local_var_req = local_var_req_builder.build()?;
1255 let local_var_resp = local_var_client.execute(local_var_req).await?;
1256
1257 let local_var_status = local_var_resp.status();
1258 let local_var_content = local_var_resp.text().await?;
1259
1260 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1261 crate::from_str_patched(&local_var_content).map_err(Error::from)
1262 } else {
1263 let local_var_entity: Option<CreatePgDatabaseError> = crate::from_str_patched(&local_var_content).ok();
1264 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1265 Err(Error::ResponseError(local_var_error))
1266 }
1267}
1268
1269pub async fn create_protection_rule(configuration: &configuration::Configuration, workspace: &str, create_protection_rule_request: models::CreateProtectionRuleRequest) -> Result<String, Error<CreateProtectionRuleError>> {
1270 let local_var_configuration = configuration;
1271
1272 let local_var_client = &local_var_configuration.client;
1273
1274 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/protection_rules", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1275 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1276
1277 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1278 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1279 }
1280 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1281 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1282 };
1283 local_var_req_builder = local_var_req_builder.json(&create_protection_rule_request);
1284
1285 let local_var_req = local_var_req_builder.build()?;
1286 let local_var_resp = local_var_client.execute(local_var_req).await?;
1287
1288 let local_var_status = local_var_resp.status();
1289 let local_var_content = local_var_resp.text().await?;
1290
1291 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1292 crate::from_str_patched(&local_var_content).map_err(Error::from)
1293 } else {
1294 let local_var_entity: Option<CreateProtectionRuleError> = crate::from_str_patched(&local_var_content).ok();
1295 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1296 Err(Error::ResponseError(local_var_error))
1297 }
1298}
1299
1300pub async fn create_service_account(configuration: &configuration::Configuration, workspace: &str, create_service_account_request: models::CreateServiceAccountRequest) -> Result<String, Error<CreateServiceAccountError>> {
1301 let local_var_configuration = configuration;
1302
1303 let local_var_client = &local_var_configuration.client;
1304
1305 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/create_service_account", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1306 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1307
1308 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1309 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1310 }
1311 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1312 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1313 };
1314 local_var_req_builder = local_var_req_builder.json(&create_service_account_request);
1315
1316 let local_var_req = local_var_req_builder.build()?;
1317 let local_var_resp = local_var_client.execute(local_var_req).await?;
1318
1319 let local_var_status = local_var_resp.status();
1320 let local_var_content = local_var_resp.text().await?;
1321
1322 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1323 crate::from_str_patched(&local_var_content).map_err(Error::from)
1324 } else {
1325 let local_var_entity: Option<CreateServiceAccountError> = crate::from_str_patched(&local_var_content).ok();
1326 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1327 Err(Error::ResponseError(local_var_error))
1328 }
1329}
1330
1331pub async fn create_workspace(configuration: &configuration::Configuration, create_workspace: models::CreateWorkspace) -> Result<String, Error<CreateWorkspaceError>> {
1332 let local_var_configuration = configuration;
1333
1334 let local_var_client = &local_var_configuration.client;
1335
1336 let local_var_uri_str = format!("{}/workspaces/create", local_var_configuration.base_path);
1337 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1338
1339 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1340 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1341 }
1342 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1343 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1344 };
1345 local_var_req_builder = local_var_req_builder.json(&create_workspace);
1346
1347 let local_var_req = local_var_req_builder.build()?;
1348 let local_var_resp = local_var_client.execute(local_var_req).await?;
1349
1350 let local_var_status = local_var_resp.status();
1351 let local_var_content = local_var_resp.text().await?;
1352
1353 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1354 crate::from_str_patched(&local_var_content).map_err(Error::from)
1355 } else {
1356 let local_var_entity: Option<CreateWorkspaceError> = crate::from_str_patched(&local_var_content).ok();
1357 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1358 Err(Error::ResponseError(local_var_error))
1359 }
1360}
1361
1362pub async fn create_workspace_fork(configuration: &configuration::Configuration, workspace: &str, create_workspace_fork: models::CreateWorkspaceFork) -> Result<String, Error<CreateWorkspaceForkError>> {
1363 let local_var_configuration = configuration;
1364
1365 let local_var_client = &local_var_configuration.client;
1366
1367 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/create_fork", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1368 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1369
1370 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1371 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1372 }
1373 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1374 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1375 };
1376 local_var_req_builder = local_var_req_builder.json(&create_workspace_fork);
1377
1378 let local_var_req = local_var_req_builder.build()?;
1379 let local_var_resp = local_var_client.execute(local_var_req).await?;
1380
1381 let local_var_status = local_var_resp.status();
1382 let local_var_content = local_var_resp.text().await?;
1383
1384 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1385 crate::from_str_patched(&local_var_content).map_err(Error::from)
1386 } else {
1387 let local_var_entity: Option<CreateWorkspaceForkError> = crate::from_str_patched(&local_var_content).ok();
1388 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1389 Err(Error::ResponseError(local_var_error))
1390 }
1391}
1392
1393pub async fn create_workspace_fork_git_branch(configuration: &configuration::Configuration, workspace: &str, create_workspace_fork: models::CreateWorkspaceFork) -> Result<Vec<uuid::Uuid>, Error<CreateWorkspaceForkGitBranchError>> {
1394 let local_var_configuration = configuration;
1395
1396 let local_var_client = &local_var_configuration.client;
1397
1398 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/create_workspace_fork_branch", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1399 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1400
1401 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1402 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1403 }
1404 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1405 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1406 };
1407 local_var_req_builder = local_var_req_builder.json(&create_workspace_fork);
1408
1409 let local_var_req = local_var_req_builder.build()?;
1410 let local_var_resp = local_var_client.execute(local_var_req).await?;
1411
1412 let local_var_status = local_var_resp.status();
1413 let local_var_content = local_var_resp.text().await?;
1414
1415 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1416 crate::from_str_patched(&local_var_content).map_err(Error::from)
1417 } else {
1418 let local_var_entity: Option<CreateWorkspaceForkGitBranchError> = crate::from_str_patched(&local_var_content).ok();
1419 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1420 Err(Error::ResponseError(local_var_error))
1421 }
1422}
1423
1424pub async fn delete_ai_skill(configuration: &configuration::Configuration, workspace: &str, name: &str) -> Result<String, Error<DeleteAiSkillError>> {
1425 let local_var_configuration = configuration;
1426
1427 let local_var_client = &local_var_configuration.client;
1428
1429 let local_var_uri_str = format!("{}/w/{workspace}/ai_skills/delete/{name}", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace), name=crate::apis::urlencode(name));
1430 let mut local_var_req_builder = local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
1431
1432 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1433 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1434 }
1435 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1436 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1437 };
1438
1439 let local_var_req = local_var_req_builder.build()?;
1440 let local_var_resp = local_var_client.execute(local_var_req).await?;
1441
1442 let local_var_status = local_var_resp.status();
1443 let local_var_content = local_var_resp.text().await?;
1444
1445 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1446 crate::from_str_patched(&local_var_content).map_err(Error::from)
1447 } else {
1448 let local_var_entity: Option<DeleteAiSkillError> = crate::from_str_patched(&local_var_content).ok();
1449 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1450 Err(Error::ResponseError(local_var_error))
1451 }
1452}
1453
1454pub async fn delete_git_sync_repository(configuration: &configuration::Configuration, workspace: &str, delete_git_sync_repository_request: models::DeleteGitSyncRepositoryRequest) -> Result<serde_json::Value, Error<DeleteGitSyncRepositoryError>> {
1455 let local_var_configuration = configuration;
1456
1457 let local_var_client = &local_var_configuration.client;
1458
1459 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/delete_git_sync_repository", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1460 let mut local_var_req_builder = local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
1461
1462 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1463 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1464 }
1465 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1466 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1467 };
1468 local_var_req_builder = local_var_req_builder.json(&delete_git_sync_repository_request);
1469
1470 let local_var_req = local_var_req_builder.build()?;
1471 let local_var_resp = local_var_client.execute(local_var_req).await?;
1472
1473 let local_var_status = local_var_resp.status();
1474 let local_var_content = local_var_resp.text().await?;
1475
1476 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1477 crate::from_str_patched(&local_var_content).map_err(Error::from)
1478 } else {
1479 let local_var_entity: Option<DeleteGitSyncRepositoryError> = crate::from_str_patched(&local_var_content).ok();
1480 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1481 Err(Error::ResponseError(local_var_error))
1482 }
1483}
1484
1485pub async fn delete_invite(configuration: &configuration::Configuration, workspace: &str, delete_invite_request: models::DeleteInviteRequest) -> Result<String, Error<DeleteInviteError>> {
1486 let local_var_configuration = configuration;
1487
1488 let local_var_client = &local_var_configuration.client;
1489
1490 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/delete_invite", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1491 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1492
1493 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1494 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1495 }
1496 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1497 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1498 };
1499 local_var_req_builder = local_var_req_builder.json(&delete_invite_request);
1500
1501 let local_var_req = local_var_req_builder.build()?;
1502 let local_var_resp = local_var_client.execute(local_var_req).await?;
1503
1504 let local_var_status = local_var_resp.status();
1505 let local_var_content = local_var_resp.text().await?;
1506
1507 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1508 crate::from_str_patched(&local_var_content).map_err(Error::from)
1509 } else {
1510 let local_var_entity: Option<DeleteInviteError> = crate::from_str_patched(&local_var_content).ok();
1511 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1512 Err(Error::ResponseError(local_var_error))
1513 }
1514}
1515
1516pub async fn delete_protection_rule(configuration: &configuration::Configuration, workspace: &str, rule_name: &str) -> Result<String, Error<DeleteProtectionRuleError>> {
1517 let local_var_configuration = configuration;
1518
1519 let local_var_client = &local_var_configuration.client;
1520
1521 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/protection_rules/{rule_name}", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace), rule_name=crate::apis::urlencode(rule_name));
1522 let mut local_var_req_builder = local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
1523
1524 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1525 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1526 }
1527 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1528 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1529 };
1530
1531 let local_var_req = local_var_req_builder.build()?;
1532 let local_var_resp = local_var_client.execute(local_var_req).await?;
1533
1534 let local_var_status = local_var_resp.status();
1535 let local_var_content = local_var_resp.text().await?;
1536
1537 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1538 crate::from_str_patched(&local_var_content).map_err(Error::from)
1539 } else {
1540 let local_var_entity: Option<DeleteProtectionRuleError> = crate::from_str_patched(&local_var_content).ok();
1541 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1542 Err(Error::ResponseError(local_var_error))
1543 }
1544}
1545
1546pub async fn delete_workspace(configuration: &configuration::Configuration, workspace: &str, only_delete_forks: Option<bool>) -> Result<String, Error<DeleteWorkspaceError>> {
1547 let local_var_configuration = configuration;
1548
1549 let local_var_client = &local_var_configuration.client;
1550
1551 let local_var_uri_str = format!("{}/workspaces/delete/{workspace}", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1552 let mut local_var_req_builder = local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
1553
1554 if let Some(ref local_var_str) = only_delete_forks {
1555 local_var_req_builder = local_var_req_builder.query(&[("only_delete_forks", &local_var_str.to_string())]);
1556 }
1557 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1558 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1559 }
1560 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1561 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1562 };
1563
1564 let local_var_req = local_var_req_builder.build()?;
1565 let local_var_resp = local_var_client.execute(local_var_req).await?;
1566
1567 let local_var_status = local_var_resp.status();
1568 let local_var_content = local_var_resp.text().await?;
1569
1570 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1571 crate::from_str_patched(&local_var_content).map_err(Error::from)
1572 } else {
1573 let local_var_entity: Option<DeleteWorkspaceError> = crate::from_str_patched(&local_var_content).ok();
1574 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1575 Err(Error::ResponseError(local_var_error))
1576 }
1577}
1578
1579pub async fn delete_workspace_slack_oauth_config(configuration: &configuration::Configuration, workspace: &str) -> Result<String, Error<DeleteWorkspaceSlackOauthConfigError>> {
1580 let local_var_configuration = configuration;
1581
1582 let local_var_client = &local_var_configuration.client;
1583
1584 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/slack_oauth_config", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1585 let mut local_var_req_builder = local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
1586
1587 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1588 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1589 }
1590 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1591 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1592 };
1593
1594 let local_var_req = local_var_req_builder.build()?;
1595 let local_var_resp = local_var_client.execute(local_var_req).await?;
1596
1597 let local_var_status = local_var_resp.status();
1598 let local_var_content = local_var_resp.text().await?;
1599
1600 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1601 crate::from_str_patched(&local_var_content).map_err(Error::from)
1602 } else {
1603 let local_var_entity: Option<DeleteWorkspaceSlackOauthConfigError> = crate::from_str_patched(&local_var_content).ok();
1604 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1605 Err(Error::ResponseError(local_var_error))
1606 }
1607}
1608
1609pub async fn detach_dev_workspace(configuration: &configuration::Configuration, workspace: &str, detach_dev_workspace_request: models::DetachDevWorkspaceRequest) -> Result<String, Error<DetachDevWorkspaceError>> {
1610 let local_var_configuration = configuration;
1611
1612 let local_var_client = &local_var_configuration.client;
1613
1614 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/detach_dev_workspace", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1615 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1616
1617 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1618 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1619 }
1620 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1621 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1622 };
1623 local_var_req_builder = local_var_req_builder.json(&detach_dev_workspace_request);
1624
1625 let local_var_req = local_var_req_builder.build()?;
1626 let local_var_resp = local_var_client.execute(local_var_req).await?;
1627
1628 let local_var_status = local_var_resp.status();
1629 let local_var_content = local_var_resp.text().await?;
1630
1631 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1632 crate::from_str_patched(&local_var_content).map_err(Error::from)
1633 } else {
1634 let local_var_entity: Option<DetachDevWorkspaceError> = crate::from_str_patched(&local_var_content).ok();
1635 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1636 Err(Error::ResponseError(local_var_error))
1637 }
1638}
1639
1640pub async fn drop_forked_datatable_databases(configuration: &configuration::Configuration, workspace: &str, drop_forked_datatable_databases_request: models::DropForkedDatatableDatabasesRequest) -> Result<Vec<String>, Error<DropForkedDatatableDatabasesError>> {
1641 let local_var_configuration = configuration;
1642
1643 let local_var_client = &local_var_configuration.client;
1644
1645 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/drop_forked_datatable_databases", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1646 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1647
1648 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1649 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1650 }
1651 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1652 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1653 };
1654 local_var_req_builder = local_var_req_builder.json(&drop_forked_datatable_databases_request);
1655
1656 let local_var_req = local_var_req_builder.build()?;
1657 let local_var_resp = local_var_client.execute(local_var_req).await?;
1658
1659 let local_var_status = local_var_resp.status();
1660 let local_var_content = local_var_resp.text().await?;
1661
1662 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1663 crate::from_str_patched(&local_var_content).map_err(Error::from)
1664 } else {
1665 let local_var_entity: Option<DropForkedDatatableDatabasesError> = crate::from_str_patched(&local_var_content).ok();
1666 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1667 Err(Error::ResponseError(local_var_error))
1668 }
1669}
1670
1671pub async fn drop_forked_ducklake_namespaces(configuration: &configuration::Configuration, workspace: &str) -> Result<Vec<String>, Error<DropForkedDucklakeNamespacesError>> {
1672 let local_var_configuration = configuration;
1673
1674 let local_var_client = &local_var_configuration.client;
1675
1676 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/drop_forked_ducklake_namespaces", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1677 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1678
1679 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1680 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1681 }
1682 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1683 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1684 };
1685
1686 let local_var_req = local_var_req_builder.build()?;
1687 let local_var_resp = local_var_client.execute(local_var_req).await?;
1688
1689 let local_var_status = local_var_resp.status();
1690 let local_var_content = local_var_resp.text().await?;
1691
1692 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1693 crate::from_str_patched(&local_var_content).map_err(Error::from)
1694 } else {
1695 let local_var_entity: Option<DropForkedDucklakeNamespacesError> = crate::from_str_patched(&local_var_content).ok();
1696 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1697 Err(Error::ResponseError(local_var_error))
1698 }
1699}
1700
1701pub async fn edit_auto_invite(configuration: &configuration::Configuration, workspace: &str, edit_auto_invite_request: models::EditAutoInviteRequest) -> Result<String, Error<EditAutoInviteError>> {
1702 let local_var_configuration = configuration;
1703
1704 let local_var_client = &local_var_configuration.client;
1705
1706 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_auto_invite", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1707 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1708
1709 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1710 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1711 }
1712 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1713 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1714 };
1715 local_var_req_builder = local_var_req_builder.json(&edit_auto_invite_request);
1716
1717 let local_var_req = local_var_req_builder.build()?;
1718 let local_var_resp = local_var_client.execute(local_var_req).await?;
1719
1720 let local_var_status = local_var_resp.status();
1721 let local_var_content = local_var_resp.text().await?;
1722
1723 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1724 crate::from_str_patched(&local_var_content).map_err(Error::from)
1725 } else {
1726 let local_var_entity: Option<EditAutoInviteError> = crate::from_str_patched(&local_var_content).ok();
1727 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1728 Err(Error::ResponseError(local_var_error))
1729 }
1730}
1731
1732pub async fn edit_copilot_config(configuration: &configuration::Configuration, workspace: &str, ai_config: models::AiConfig) -> Result<models::EditCopilotConfig200Response, Error<EditCopilotConfigError>> {
1733 let local_var_configuration = configuration;
1734
1735 let local_var_client = &local_var_configuration.client;
1736
1737 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_copilot_config", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1738 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1739
1740 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1741 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1742 }
1743 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1744 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1745 };
1746 local_var_req_builder = local_var_req_builder.json(&ai_config);
1747
1748 let local_var_req = local_var_req_builder.build()?;
1749 let local_var_resp = local_var_client.execute(local_var_req).await?;
1750
1751 let local_var_status = local_var_resp.status();
1752 let local_var_content = local_var_resp.text().await?;
1753
1754 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1755 crate::from_str_patched(&local_var_content).map_err(Error::from)
1756 } else {
1757 let local_var_entity: Option<EditCopilotConfigError> = crate::from_str_patched(&local_var_content).ok();
1758 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1759 Err(Error::ResponseError(local_var_error))
1760 }
1761}
1762
1763pub async fn edit_data_table_config(configuration: &configuration::Configuration, workspace: &str, edit_data_table_config_request: models::EditDataTableConfigRequest) -> Result<serde_json::Value, Error<EditDataTableConfigError>> {
1764 let local_var_configuration = configuration;
1765
1766 let local_var_client = &local_var_configuration.client;
1767
1768 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_datatable_config", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1769 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1770
1771 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1772 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1773 }
1774 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1775 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1776 };
1777 local_var_req_builder = local_var_req_builder.json(&edit_data_table_config_request);
1778
1779 let local_var_req = local_var_req_builder.build()?;
1780 let local_var_resp = local_var_client.execute(local_var_req).await?;
1781
1782 let local_var_status = local_var_resp.status();
1783 let local_var_content = local_var_resp.text().await?;
1784
1785 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1786 crate::from_str_patched(&local_var_content).map_err(Error::from)
1787 } else {
1788 let local_var_entity: Option<EditDataTableConfigError> = crate::from_str_patched(&local_var_content).ok();
1789 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1790 Err(Error::ResponseError(local_var_error))
1791 }
1792}
1793
1794pub async fn edit_default_scripts(configuration: &configuration::Configuration, workspace: &str, workspace_default_scripts: Option<models::WorkspaceDefaultScripts>) -> Result<String, Error<EditDefaultScriptsError>> {
1795 let local_var_configuration = configuration;
1796
1797 let local_var_client = &local_var_configuration.client;
1798
1799 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/default_scripts", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1800 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1801
1802 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1803 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1804 }
1805 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1806 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1807 };
1808 local_var_req_builder = local_var_req_builder.json(&workspace_default_scripts);
1809
1810 let local_var_req = local_var_req_builder.build()?;
1811 let local_var_resp = local_var_client.execute(local_var_req).await?;
1812
1813 let local_var_status = local_var_resp.status();
1814 let local_var_content = local_var_resp.text().await?;
1815
1816 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1817 crate::from_str_patched(&local_var_content).map_err(Error::from)
1818 } else {
1819 let local_var_entity: Option<EditDefaultScriptsError> = crate::from_str_patched(&local_var_content).ok();
1820 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1821 Err(Error::ResponseError(local_var_error))
1822 }
1823}
1824
1825pub async fn edit_deploy_to(configuration: &configuration::Configuration, workspace: &str, get_deploy_to200_response: models::GetDeployTo200Response) -> Result<String, Error<EditDeployToError>> {
1826 let local_var_configuration = configuration;
1827
1828 let local_var_client = &local_var_configuration.client;
1829
1830 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_deploy_to", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1831 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1832
1833 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1834 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1835 }
1836 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1837 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1838 };
1839 local_var_req_builder = local_var_req_builder.json(&get_deploy_to200_response);
1840
1841 let local_var_req = local_var_req_builder.build()?;
1842 let local_var_resp = local_var_client.execute(local_var_req).await?;
1843
1844 let local_var_status = local_var_resp.status();
1845 let local_var_content = local_var_resp.text().await?;
1846
1847 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1848 crate::from_str_patched(&local_var_content).map_err(Error::from)
1849 } else {
1850 let local_var_entity: Option<EditDeployToError> = crate::from_str_patched(&local_var_content).ok();
1851 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1852 Err(Error::ResponseError(local_var_error))
1853 }
1854}
1855
1856pub async fn edit_ducklake_config(configuration: &configuration::Configuration, workspace: &str, edit_ducklake_config_request: models::EditDucklakeConfigRequest) -> Result<serde_json::Value, Error<EditDucklakeConfigError>> {
1857 let local_var_configuration = configuration;
1858
1859 let local_var_client = &local_var_configuration.client;
1860
1861 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_ducklake_config", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1862 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1863
1864 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1865 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1866 }
1867 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1868 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1869 };
1870 local_var_req_builder = local_var_req_builder.json(&edit_ducklake_config_request);
1871
1872 let local_var_req = local_var_req_builder.build()?;
1873 let local_var_resp = local_var_client.execute(local_var_req).await?;
1874
1875 let local_var_status = local_var_resp.status();
1876 let local_var_content = local_var_resp.text().await?;
1877
1878 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1879 crate::from_str_patched(&local_var_content).map_err(Error::from)
1880 } else {
1881 let local_var_entity: Option<EditDucklakeConfigError> = crate::from_str_patched(&local_var_content).ok();
1882 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1883 Err(Error::ResponseError(local_var_error))
1884 }
1885}
1886
1887pub async fn edit_error_handler(configuration: &configuration::Configuration, workspace: &str, edit_error_handler: models::EditErrorHandler) -> Result<String, Error<EditErrorHandlerError>> {
1888 let local_var_configuration = configuration;
1889
1890 let local_var_client = &local_var_configuration.client;
1891
1892 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_error_handler", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1893 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1894
1895 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1896 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1897 }
1898 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1899 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1900 };
1901 local_var_req_builder = local_var_req_builder.json(&edit_error_handler);
1902
1903 let local_var_req = local_var_req_builder.build()?;
1904 let local_var_resp = local_var_client.execute(local_var_req).await?;
1905
1906 let local_var_status = local_var_resp.status();
1907 let local_var_content = local_var_resp.text().await?;
1908
1909 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1910 crate::from_str_patched(&local_var_content).map_err(Error::from)
1911 } else {
1912 let local_var_entity: Option<EditErrorHandlerError> = crate::from_str_patched(&local_var_content).ok();
1913 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1914 Err(Error::ResponseError(local_var_error))
1915 }
1916}
1917
1918pub async fn edit_git_sync_repository(configuration: &configuration::Configuration, workspace: &str, edit_git_sync_repository_request: models::EditGitSyncRepositoryRequest) -> Result<serde_json::Value, Error<EditGitSyncRepositoryError>> {
1919 let local_var_configuration = configuration;
1920
1921 let local_var_client = &local_var_configuration.client;
1922
1923 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_git_sync_repository", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1924 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1925
1926 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1927 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1928 }
1929 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1930 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1931 };
1932 local_var_req_builder = local_var_req_builder.json(&edit_git_sync_repository_request);
1933
1934 let local_var_req = local_var_req_builder.build()?;
1935 let local_var_resp = local_var_client.execute(local_var_req).await?;
1936
1937 let local_var_status = local_var_resp.status();
1938 let local_var_content = local_var_resp.text().await?;
1939
1940 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1941 crate::from_str_patched(&local_var_content).map_err(Error::from)
1942 } else {
1943 let local_var_entity: Option<EditGitSyncRepositoryError> = crate::from_str_patched(&local_var_content).ok();
1944 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1945 Err(Error::ResponseError(local_var_error))
1946 }
1947}
1948
1949pub async fn edit_instance_groups(configuration: &configuration::Configuration, workspace: &str, edit_instance_groups_request: models::EditInstanceGroupsRequest) -> Result<String, Error<EditInstanceGroupsError>> {
1950 let local_var_configuration = configuration;
1951
1952 let local_var_client = &local_var_configuration.client;
1953
1954 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_instance_groups", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1955 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1956
1957 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1958 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1959 }
1960 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1961 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1962 };
1963 local_var_req_builder = local_var_req_builder.json(&edit_instance_groups_request);
1964
1965 let local_var_req = local_var_req_builder.build()?;
1966 let local_var_resp = local_var_client.execute(local_var_req).await?;
1967
1968 let local_var_status = local_var_resp.status();
1969 let local_var_content = local_var_resp.text().await?;
1970
1971 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1972 crate::from_str_patched(&local_var_content).map_err(Error::from)
1973 } else {
1974 let local_var_entity: Option<EditInstanceGroupsError> = crate::from_str_patched(&local_var_content).ok();
1975 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
1976 Err(Error::ResponseError(local_var_error))
1977 }
1978}
1979
1980pub 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>> {
1981 let local_var_configuration = configuration;
1982
1983 let local_var_client = &local_var_configuration.client;
1984
1985 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_large_file_storage_config", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
1986 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1987
1988 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
1989 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
1990 }
1991 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
1992 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
1993 };
1994 local_var_req_builder = local_var_req_builder.json(&edit_large_file_storage_config_request);
1995
1996 let local_var_req = local_var_req_builder.build()?;
1997 let local_var_resp = local_var_client.execute(local_var_req).await?;
1998
1999 let local_var_status = local_var_resp.status();
2000 let local_var_content = local_var_resp.text().await?;
2001
2002 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2003 crate::from_str_patched(&local_var_content).map_err(Error::from)
2004 } else {
2005 let local_var_entity: Option<EditLargeFileStorageConfigError> = crate::from_str_patched(&local_var_content).ok();
2006 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2007 Err(Error::ResponseError(local_var_error))
2008 }
2009}
2010
2011pub async fn edit_slack_command(configuration: &configuration::Configuration, workspace: &str, edit_slack_command_request: models::EditSlackCommandRequest) -> Result<String, Error<EditSlackCommandError>> {
2012 let local_var_configuration = configuration;
2013
2014 let local_var_client = &local_var_configuration.client;
2015
2016 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_slack_command", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2017 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
2018
2019 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2020 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2021 }
2022 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2023 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2024 };
2025 local_var_req_builder = local_var_req_builder.json(&edit_slack_command_request);
2026
2027 let local_var_req = local_var_req_builder.build()?;
2028 let local_var_resp = local_var_client.execute(local_var_req).await?;
2029
2030 let local_var_status = local_var_resp.status();
2031 let local_var_content = local_var_resp.text().await?;
2032
2033 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2034 crate::from_str_patched(&local_var_content).map_err(Error::from)
2035 } else {
2036 let local_var_entity: Option<EditSlackCommandError> = crate::from_str_patched(&local_var_content).ok();
2037 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2038 Err(Error::ResponseError(local_var_error))
2039 }
2040}
2041
2042pub async fn edit_success_handler(configuration: &configuration::Configuration, workspace: &str, edit_success_handler: models::EditSuccessHandler) -> Result<String, Error<EditSuccessHandlerError>> {
2043 let local_var_configuration = configuration;
2044
2045 let local_var_client = &local_var_configuration.client;
2046
2047 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_success_handler", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2048 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
2049
2050 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2051 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2052 }
2053 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2054 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2055 };
2056 local_var_req_builder = local_var_req_builder.json(&edit_success_handler);
2057
2058 let local_var_req = local_var_req_builder.build()?;
2059 let local_var_resp = local_var_client.execute(local_var_req).await?;
2060
2061 let local_var_status = local_var_resp.status();
2062 let local_var_content = local_var_resp.text().await?;
2063
2064 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2065 crate::from_str_patched(&local_var_content).map_err(Error::from)
2066 } else {
2067 let local_var_entity: Option<EditSuccessHandlerError> = crate::from_str_patched(&local_var_content).ok();
2068 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2069 Err(Error::ResponseError(local_var_error))
2070 }
2071}
2072
2073pub async fn edit_teams_command(configuration: &configuration::Configuration, workspace: &str, edit_slack_command_request: models::EditSlackCommandRequest) -> Result<String, Error<EditTeamsCommandError>> {
2074 let local_var_configuration = configuration;
2075
2076 let local_var_client = &local_var_configuration.client;
2077
2078 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_teams_command", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2079 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
2080
2081 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2082 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2083 }
2084 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2085 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2086 };
2087 local_var_req_builder = local_var_req_builder.json(&edit_slack_command_request);
2088
2089 let local_var_req = local_var_req_builder.build()?;
2090 let local_var_resp = local_var_client.execute(local_var_req).await?;
2091
2092 let local_var_status = local_var_resp.status();
2093 let local_var_content = local_var_resp.text().await?;
2094
2095 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2096 crate::from_str_patched(&local_var_content).map_err(Error::from)
2097 } else {
2098 let local_var_entity: Option<EditTeamsCommandError> = crate::from_str_patched(&local_var_content).ok();
2099 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2100 Err(Error::ResponseError(local_var_error))
2101 }
2102}
2103
2104pub async fn edit_webhook(configuration: &configuration::Configuration, workspace: &str, edit_webhook_request: models::EditWebhookRequest) -> Result<String, Error<EditWebhookError>> {
2105 let local_var_configuration = configuration;
2106
2107 let local_var_client = &local_var_configuration.client;
2108
2109 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_webhook", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2110 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
2111
2112 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2113 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2114 }
2115 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2116 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2117 };
2118 local_var_req_builder = local_var_req_builder.json(&edit_webhook_request);
2119
2120 let local_var_req = local_var_req_builder.build()?;
2121 let local_var_resp = local_var_client.execute(local_var_req).await?;
2122
2123 let local_var_status = local_var_resp.status();
2124 let local_var_content = local_var_resp.text().await?;
2125
2126 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2127 crate::from_str_patched(&local_var_content).map_err(Error::from)
2128 } else {
2129 let local_var_entity: Option<EditWebhookError> = crate::from_str_patched(&local_var_content).ok();
2130 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2131 Err(Error::ResponseError(local_var_error))
2132 }
2133}
2134
2135pub async fn edit_workspace_default_app(configuration: &configuration::Configuration, workspace: &str, edit_workspace_default_app_request: models::EditWorkspaceDefaultAppRequest) -> Result<String, Error<EditWorkspaceDefaultAppError>> {
2136 let local_var_configuration = configuration;
2137
2138 let local_var_client = &local_var_configuration.client;
2139
2140 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_default_app", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2141 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
2142
2143 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2144 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2145 }
2146 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2147 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2148 };
2149 local_var_req_builder = local_var_req_builder.json(&edit_workspace_default_app_request);
2150
2151 let local_var_req = local_var_req_builder.build()?;
2152 let local_var_resp = local_var_client.execute(local_var_req).await?;
2153
2154 let local_var_status = local_var_resp.status();
2155 let local_var_content = local_var_resp.text().await?;
2156
2157 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2158 crate::from_str_patched(&local_var_content).map_err(Error::from)
2159 } else {
2160 let local_var_entity: Option<EditWorkspaceDefaultAppError> = crate::from_str_patched(&local_var_content).ok();
2161 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2162 Err(Error::ResponseError(local_var_error))
2163 }
2164}
2165
2166pub 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>> {
2167 let local_var_configuration = configuration;
2168
2169 let local_var_client = &local_var_configuration.client;
2170
2171 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_deploy_ui_config", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2172 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
2173
2174 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2175 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2176 }
2177 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2178 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2179 };
2180 local_var_req_builder = local_var_req_builder.json(&edit_workspace_deploy_ui_settings_request);
2181
2182 let local_var_req = local_var_req_builder.build()?;
2183 let local_var_resp = local_var_client.execute(local_var_req).await?;
2184
2185 let local_var_status = local_var_resp.status();
2186 let local_var_content = local_var_resp.text().await?;
2187
2188 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2189 crate::from_str_patched(&local_var_content).map_err(Error::from)
2190 } else {
2191 let local_var_entity: Option<EditWorkspaceDeployUiSettingsError> = crate::from_str_patched(&local_var_content).ok();
2192 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2193 Err(Error::ResponseError(local_var_error))
2194 }
2195}
2196
2197pub 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>> {
2198 let local_var_configuration = configuration;
2199
2200 let local_var_client = &local_var_configuration.client;
2201
2202 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/edit_git_sync_config", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2203 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
2204
2205 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2206 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2207 }
2208 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2209 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2210 };
2211 local_var_req_builder = local_var_req_builder.json(&edit_workspace_git_sync_config_request);
2212
2213 let local_var_req = local_var_req_builder.build()?;
2214 let local_var_resp = local_var_client.execute(local_var_req).await?;
2215
2216 let local_var_status = local_var_resp.status();
2217 let local_var_content = local_var_resp.text().await?;
2218
2219 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2220 crate::from_str_patched(&local_var_content).map_err(Error::from)
2221 } else {
2222 let local_var_entity: Option<EditWorkspaceGitSyncConfigError> = crate::from_str_patched(&local_var_content).ok();
2223 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2224 Err(Error::ResponseError(local_var_error))
2225 }
2226}
2227
2228pub async fn exists_username(configuration: &configuration::Configuration, exists_username_request: models::ExistsUsernameRequest) -> Result<bool, Error<ExistsUsernameError>> {
2229 let local_var_configuration = configuration;
2230
2231 let local_var_client = &local_var_configuration.client;
2232
2233 let local_var_uri_str = format!("{}/workspaces/exists_username", local_var_configuration.base_path);
2234 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
2235
2236 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2237 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2238 }
2239 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2240 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2241 };
2242 local_var_req_builder = local_var_req_builder.json(&exists_username_request);
2243
2244 let local_var_req = local_var_req_builder.build()?;
2245 let local_var_resp = local_var_client.execute(local_var_req).await?;
2246
2247 let local_var_status = local_var_resp.status();
2248 let local_var_content = local_var_resp.text().await?;
2249
2250 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2251 crate::from_str_patched(&local_var_content).map_err(Error::from)
2252 } else {
2253 let local_var_entity: Option<ExistsUsernameError> = crate::from_str_patched(&local_var_content).ok();
2254 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2255 Err(Error::ResponseError(local_var_error))
2256 }
2257}
2258
2259pub async fn exists_workspace(configuration: &configuration::Configuration, exists_workspace_request: models::ExistsWorkspaceRequest) -> Result<bool, Error<ExistsWorkspaceError>> {
2260 let local_var_configuration = configuration;
2261
2262 let local_var_client = &local_var_configuration.client;
2263
2264 let local_var_uri_str = format!("{}/workspaces/exists", local_var_configuration.base_path);
2265 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
2266
2267 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2268 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2269 }
2270 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2271 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2272 };
2273 local_var_req_builder = local_var_req_builder.json(&exists_workspace_request);
2274
2275 let local_var_req = local_var_req_builder.build()?;
2276 let local_var_resp = local_var_client.execute(local_var_req).await?;
2277
2278 let local_var_status = local_var_resp.status();
2279 let local_var_content = local_var_resp.text().await?;
2280
2281 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2282 crate::from_str_patched(&local_var_content).map_err(Error::from)
2283 } else {
2284 let local_var_entity: Option<ExistsWorkspaceError> = crate::from_str_patched(&local_var_content).ok();
2285 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2286 Err(Error::ResponseError(local_var_error))
2287 }
2288}
2289
2290pub async fn export_pg_schema(configuration: &configuration::Configuration, workspace: &str, export_pg_schema_request: models::ExportPgSchemaRequest) -> Result<String, Error<ExportPgSchemaError>> {
2291 let local_var_configuration = configuration;
2292
2293 let local_var_client = &local_var_configuration.client;
2294
2295 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/export_pg_schema", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2296 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
2297
2298 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2299 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2300 }
2301 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2302 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2303 };
2304 local_var_req_builder = local_var_req_builder.json(&export_pg_schema_request);
2305
2306 let local_var_req = local_var_req_builder.build()?;
2307 let local_var_resp = local_var_client.execute(local_var_req).await?;
2308
2309 let local_var_status = local_var_resp.status();
2310 let local_var_content = local_var_resp.text().await?;
2311
2312 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2313 crate::from_str_patched(&local_var_content).map_err(Error::from)
2314 } else {
2315 let local_var_entity: Option<ExportPgSchemaError> = crate::from_str_patched(&local_var_content).ok();
2316 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2317 Err(Error::ResponseError(local_var_error))
2318 }
2319}
2320
2321pub async fn get_ai_skill(configuration: &configuration::Configuration, workspace: &str, name: &str) -> Result<models::GetAiSkill200Response, Error<GetAiSkillError>> {
2322 let local_var_configuration = configuration;
2323
2324 let local_var_client = &local_var_configuration.client;
2325
2326 let local_var_uri_str = format!("{}/w/{workspace}/ai_skills/get/{name}", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace), name=crate::apis::urlencode(name));
2327 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
2328
2329 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2330 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2331 }
2332 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2333 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2334 };
2335
2336 let local_var_req = local_var_req_builder.build()?;
2337 let local_var_resp = local_var_client.execute(local_var_req).await?;
2338
2339 let local_var_status = local_var_resp.status();
2340 let local_var_content = local_var_resp.text().await?;
2341
2342 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2343 crate::from_str_patched(&local_var_content).map_err(Error::from)
2344 } else {
2345 let local_var_entity: Option<GetAiSkillError> = crate::from_str_patched(&local_var_content).ok();
2346 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2347 Err(Error::ResponseError(local_var_error))
2348 }
2349}
2350
2351pub async fn get_cloud_quotas(configuration: &configuration::Configuration, workspace: &str) -> Result<models::GetCloudQuotas200Response, Error<GetCloudQuotasError>> {
2352 let local_var_configuration = configuration;
2353
2354 let local_var_client = &local_var_configuration.client;
2355
2356 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/cloud_quotas", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2357 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
2358
2359 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2360 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2361 }
2362 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2363 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2364 };
2365
2366 let local_var_req = local_var_req_builder.build()?;
2367 let local_var_resp = local_var_client.execute(local_var_req).await?;
2368
2369 let local_var_status = local_var_resp.status();
2370 let local_var_content = local_var_resp.text().await?;
2371
2372 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2373 crate::from_str_patched(&local_var_content).map_err(Error::from)
2374 } else {
2375 let local_var_entity: Option<GetCloudQuotasError> = crate::from_str_patched(&local_var_content).ok();
2376 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2377 Err(Error::ResponseError(local_var_error))
2378 }
2379}
2380
2381pub async fn get_copilot_info(configuration: &configuration::Configuration, workspace: &str) -> Result<models::AiConfig, Error<GetCopilotInfoError>> {
2382 let local_var_configuration = configuration;
2383
2384 let local_var_client = &local_var_configuration.client;
2385
2386 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/get_copilot_info", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2387 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
2388
2389 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2390 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2391 }
2392 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2393 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2394 };
2395
2396 let local_var_req = local_var_req_builder.build()?;
2397 let local_var_resp = local_var_client.execute(local_var_req).await?;
2398
2399 let local_var_status = local_var_resp.status();
2400 let local_var_content = local_var_resp.text().await?;
2401
2402 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2403 crate::from_str_patched(&local_var_content).map_err(Error::from)
2404 } else {
2405 let local_var_entity: Option<GetCopilotInfoError> = crate::from_str_patched(&local_var_content).ok();
2406 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2407 Err(Error::ResponseError(local_var_error))
2408 }
2409}
2410
2411pub async fn get_copilot_settings_state(configuration: &configuration::Configuration, workspace: &str) -> Result<models::GetCopilotSettingsState200Response, Error<GetCopilotSettingsStateError>> {
2412 let local_var_configuration = configuration;
2413
2414 let local_var_client = &local_var_configuration.client;
2415
2416 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/get_copilot_settings_state", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2417 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
2418
2419 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2420 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2421 }
2422 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2423 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2424 };
2425
2426 let local_var_req = local_var_req_builder.build()?;
2427 let local_var_resp = local_var_client.execute(local_var_req).await?;
2428
2429 let local_var_status = local_var_resp.status();
2430 let local_var_content = local_var_resp.text().await?;
2431
2432 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2433 crate::from_str_patched(&local_var_content).map_err(Error::from)
2434 } else {
2435 let local_var_entity: Option<GetCopilotSettingsStateError> = crate::from_str_patched(&local_var_content).ok();
2436 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2437 Err(Error::ResponseError(local_var_error))
2438 }
2439}
2440
2441pub async fn get_data_table_table_schema(configuration: &configuration::Configuration, workspace: &str, datatable_name: &str, schema_name: &str, table_name: &str) -> Result<models::DataTableTableSchema, Error<GetDataTableTableSchemaError>> {
2442 let local_var_configuration = configuration;
2443
2444 let local_var_client = &local_var_configuration.client;
2445
2446 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/get_datatable_table_schema", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2447 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
2448
2449 local_var_req_builder = local_var_req_builder.query(&[("datatable_name", &datatable_name.to_string())]);
2450 local_var_req_builder = local_var_req_builder.query(&[("schema_name", &schema_name.to_string())]);
2451 local_var_req_builder = local_var_req_builder.query(&[("table_name", &table_name.to_string())]);
2452 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2453 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2454 }
2455 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2456 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2457 };
2458
2459 let local_var_req = local_var_req_builder.build()?;
2460 let local_var_resp = local_var_client.execute(local_var_req).await?;
2461
2462 let local_var_status = local_var_resp.status();
2463 let local_var_content = local_var_resp.text().await?;
2464
2465 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2466 crate::from_str_patched(&local_var_content).map_err(Error::from)
2467 } else {
2468 let local_var_entity: Option<GetDataTableTableSchemaError> = crate::from_str_patched(&local_var_content).ok();
2469 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2470 Err(Error::ResponseError(local_var_error))
2471 }
2472}
2473
2474pub async fn get_datatable_full_schema(configuration: &configuration::Configuration, workspace: &str, get_datatable_full_schema_request: models::GetDatatableFullSchemaRequest) -> Result<std::collections::HashMap<String, std::collections::HashMap<String, models::GetDatatableFullSchema200ResponseValueValue>>, Error<GetDatatableFullSchemaError>> {
2475 let local_var_configuration = configuration;
2476
2477 let local_var_client = &local_var_configuration.client;
2478
2479 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/get_datatable_full_schema", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2480 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
2481
2482 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2483 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2484 }
2485 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2486 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2487 };
2488 local_var_req_builder = local_var_req_builder.json(&get_datatable_full_schema_request);
2489
2490 let local_var_req = local_var_req_builder.build()?;
2491 let local_var_resp = local_var_client.execute(local_var_req).await?;
2492
2493 let local_var_status = local_var_resp.status();
2494 let local_var_content = local_var_resp.text().await?;
2495
2496 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2497 crate::from_str_patched(&local_var_content).map_err(Error::from)
2498 } else {
2499 let local_var_entity: Option<GetDatatableFullSchemaError> = crate::from_str_patched(&local_var_content).ok();
2500 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2501 Err(Error::ResponseError(local_var_error))
2502 }
2503}
2504
2505pub async fn get_default_scripts(configuration: &configuration::Configuration, workspace: &str) -> Result<models::WorkspaceDefaultScripts, Error<GetDefaultScriptsError>> {
2506 let local_var_configuration = configuration;
2507
2508 let local_var_client = &local_var_configuration.client;
2509
2510 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/default_scripts", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2511 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
2512
2513 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2514 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2515 }
2516 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2517 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2518 };
2519
2520 let local_var_req = local_var_req_builder.build()?;
2521 let local_var_resp = local_var_client.execute(local_var_req).await?;
2522
2523 let local_var_status = local_var_resp.status();
2524 let local_var_content = local_var_resp.text().await?;
2525
2526 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2527 crate::from_str_patched(&local_var_content).map_err(Error::from)
2528 } else {
2529 let local_var_entity: Option<GetDefaultScriptsError> = crate::from_str_patched(&local_var_content).ok();
2530 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2531 Err(Error::ResponseError(local_var_error))
2532 }
2533}
2534
2535pub async fn get_dependency_map(configuration: &configuration::Configuration, workspace: &str) -> Result<Vec<models::DependencyMap>, Error<GetDependencyMapError>> {
2536 let local_var_configuration = configuration;
2537
2538 let local_var_client = &local_var_configuration.client;
2539
2540 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/get_dependency_map", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2541 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
2542
2543 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2544 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2545 }
2546 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2547 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2548 };
2549
2550 let local_var_req = local_var_req_builder.build()?;
2551 let local_var_resp = local_var_client.execute(local_var_req).await?;
2552
2553 let local_var_status = local_var_resp.status();
2554 let local_var_content = local_var_resp.text().await?;
2555
2556 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2557 crate::from_str_patched(&local_var_content).map_err(Error::from)
2558 } else {
2559 let local_var_entity: Option<GetDependencyMapError> = crate::from_str_patched(&local_var_content).ok();
2560 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2561 Err(Error::ResponseError(local_var_error))
2562 }
2563}
2564
2565pub async fn get_dependents(configuration: &configuration::Configuration, workspace: &str, imported_path: &str) -> Result<Vec<models::DependencyDependent>, Error<GetDependentsError>> {
2566 let local_var_configuration = configuration;
2567
2568 let local_var_client = &local_var_configuration.client;
2569
2570 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/get_dependents/{imported_path}", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace), imported_path=crate::apis::urlencode(imported_path));
2571 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
2572
2573 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2574 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2575 }
2576 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2577 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2578 };
2579
2580 let local_var_req = local_var_req_builder.build()?;
2581 let local_var_resp = local_var_client.execute(local_var_req).await?;
2582
2583 let local_var_status = local_var_resp.status();
2584 let local_var_content = local_var_resp.text().await?;
2585
2586 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2587 crate::from_str_patched(&local_var_content).map_err(Error::from)
2588 } else {
2589 let local_var_entity: Option<GetDependentsError> = crate::from_str_patched(&local_var_content).ok();
2590 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2591 Err(Error::ResponseError(local_var_error))
2592 }
2593}
2594
2595pub async fn get_dependents_amounts(configuration: &configuration::Configuration, workspace: &str, request_body: Vec<String>) -> Result<Vec<models::DependentsAmount>, Error<GetDependentsAmountsError>> {
2596 let local_var_configuration = configuration;
2597
2598 let local_var_client = &local_var_configuration.client;
2599
2600 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/get_dependents_amounts", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2601 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
2602
2603 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2604 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2605 }
2606 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2607 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2608 };
2609 local_var_req_builder = local_var_req_builder.json(&request_body);
2610
2611 let local_var_req = local_var_req_builder.build()?;
2612 let local_var_resp = local_var_client.execute(local_var_req).await?;
2613
2614 let local_var_status = local_var_resp.status();
2615 let local_var_content = local_var_resp.text().await?;
2616
2617 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2618 crate::from_str_patched(&local_var_content).map_err(Error::from)
2619 } else {
2620 let local_var_entity: Option<GetDependentsAmountsError> = crate::from_str_patched(&local_var_content).ok();
2621 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2622 Err(Error::ResponseError(local_var_error))
2623 }
2624}
2625
2626pub async fn get_deploy_to(configuration: &configuration::Configuration, workspace: &str) -> Result<models::GetDeployTo200Response, Error<GetDeployToError>> {
2627 let local_var_configuration = configuration;
2628
2629 let local_var_client = &local_var_configuration.client;
2630
2631 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/get_deploy_to", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2632 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
2633
2634 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2635 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2636 }
2637 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2638 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2639 };
2640
2641 let local_var_req = local_var_req_builder.build()?;
2642 let local_var_resp = local_var_client.execute(local_var_req).await?;
2643
2644 let local_var_status = local_var_resp.status();
2645 let local_var_content = local_var_resp.text().await?;
2646
2647 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2648 crate::from_str_patched(&local_var_content).map_err(Error::from)
2649 } else {
2650 let local_var_entity: Option<GetDeployToError> = crate::from_str_patched(&local_var_content).ok();
2651 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2652 Err(Error::ResponseError(local_var_error))
2653 }
2654}
2655
2656pub async fn get_dev_workspace(configuration: &configuration::Configuration, workspace: &str) -> Result<models::GetDevWorkspace200Response, Error<GetDevWorkspaceError>> {
2657 let local_var_configuration = configuration;
2658
2659 let local_var_client = &local_var_configuration.client;
2660
2661 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/get_dev_workspace", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2662 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
2663
2664 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2665 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2666 }
2667 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2668 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2669 };
2670
2671 let local_var_req = local_var_req_builder.build()?;
2672 let local_var_resp = local_var_client.execute(local_var_req).await?;
2673
2674 let local_var_status = local_var_resp.status();
2675 let local_var_content = local_var_resp.text().await?;
2676
2677 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2678 crate::from_str_patched(&local_var_content).map_err(Error::from)
2679 } else {
2680 let local_var_entity: Option<GetDevWorkspaceError> = crate::from_str_patched(&local_var_content).ok();
2681 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2682 Err(Error::ResponseError(local_var_error))
2683 }
2684}
2685
2686pub async fn get_git_sync_enabled(configuration: &configuration::Configuration, workspace: &str) -> Result<models::GetGitSyncEnabled200Response, Error<GetGitSyncEnabledError>> {
2687 let local_var_configuration = configuration;
2688
2689 let local_var_client = &local_var_configuration.client;
2690
2691 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/git_sync_enabled", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2692 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
2693
2694 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2695 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2696 }
2697 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2698 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2699 };
2700
2701 let local_var_req = local_var_req_builder.build()?;
2702 let local_var_resp = local_var_client.execute(local_var_req).await?;
2703
2704 let local_var_status = local_var_resp.status();
2705 let local_var_content = local_var_resp.text().await?;
2706
2707 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2708 crate::from_str_patched(&local_var_content).map_err(Error::from)
2709 } else {
2710 let local_var_entity: Option<GetGitSyncEnabledError> = crate::from_str_patched(&local_var_content).ok();
2711 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2712 Err(Error::ResponseError(local_var_error))
2713 }
2714}
2715
2716pub async fn get_github_app_token(configuration: &configuration::Configuration, workspace: &str, get_github_app_token_request: models::GetGithubAppTokenRequest) -> Result<models::GetGithubAppToken200Response, Error<GetGithubAppTokenError>> {
2717 let local_var_configuration = configuration;
2718
2719 let local_var_client = &local_var_configuration.client;
2720
2721 let local_var_uri_str = format!("{}/w/{workspace}/github_app/token", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2722 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
2723
2724 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2725 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2726 }
2727 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2728 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2729 };
2730 local_var_req_builder = local_var_req_builder.json(&get_github_app_token_request);
2731
2732 let local_var_req = local_var_req_builder.build()?;
2733 let local_var_resp = local_var_client.execute(local_var_req).await?;
2734
2735 let local_var_status = local_var_resp.status();
2736 let local_var_content = local_var_resp.text().await?;
2737
2738 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2739 crate::from_str_patched(&local_var_content).map_err(Error::from)
2740 } else {
2741 let local_var_entity: Option<GetGithubAppTokenError> = crate::from_str_patched(&local_var_content).ok();
2742 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2743 Err(Error::ResponseError(local_var_error))
2744 }
2745}
2746
2747pub async fn get_imports(configuration: &configuration::Configuration, workspace: &str, importer_path: &str) -> Result<Vec<String>, Error<GetImportsError>> {
2748 let local_var_configuration = configuration;
2749
2750 let local_var_client = &local_var_configuration.client;
2751
2752 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/get_imports/{importer_path}", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace), importer_path=crate::apis::urlencode(importer_path));
2753 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
2754
2755 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2756 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2757 }
2758 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2759 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2760 };
2761
2762 let local_var_req = local_var_req_builder.build()?;
2763 let local_var_resp = local_var_client.execute(local_var_req).await?;
2764
2765 let local_var_status = local_var_resp.status();
2766 let local_var_content = local_var_resp.text().await?;
2767
2768 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2769 crate::from_str_patched(&local_var_content).map_err(Error::from)
2770 } else {
2771 let local_var_entity: Option<GetImportsError> = crate::from_str_patched(&local_var_content).ok();
2772 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2773 Err(Error::ResponseError(local_var_error))
2774 }
2775}
2776
2777pub async fn get_is_premium(configuration: &configuration::Configuration, workspace: &str) -> Result<bool, Error<GetIsPremiumError>> {
2778 let local_var_configuration = configuration;
2779
2780 let local_var_client = &local_var_configuration.client;
2781
2782 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/is_premium", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2783 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
2784
2785 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2786 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2787 }
2788 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2789 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2790 };
2791
2792 let local_var_req = local_var_req_builder.build()?;
2793 let local_var_resp = local_var_client.execute(local_var_req).await?;
2794
2795 let local_var_status = local_var_resp.status();
2796 let local_var_content = local_var_resp.text().await?;
2797
2798 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2799 crate::from_str_patched(&local_var_content).map_err(Error::from)
2800 } else {
2801 let local_var_entity: Option<GetIsPremiumError> = crate::from_str_patched(&local_var_content).ok();
2802 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2803 Err(Error::ResponseError(local_var_error))
2804 }
2805}
2806
2807pub async fn get_open_deployment_request(configuration: &configuration::Configuration, workspace: &str) -> Result<models::DeploymentRequest, Error<GetOpenDeploymentRequestError>> {
2808 let local_var_configuration = configuration;
2809
2810 let local_var_client = &local_var_configuration.client;
2811
2812 let local_var_uri_str = format!("{}/w/{workspace}/deployment_request/open", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2813 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
2814
2815 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2816 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2817 }
2818 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2819 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2820 };
2821
2822 let local_var_req = local_var_req_builder.build()?;
2823 let local_var_resp = local_var_client.execute(local_var_req).await?;
2824
2825 let local_var_status = local_var_resp.status();
2826 let local_var_content = local_var_resp.text().await?;
2827
2828 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2829 crate::from_str_patched(&local_var_content).map_err(Error::from)
2830 } else {
2831 let local_var_entity: Option<GetOpenDeploymentRequestError> = crate::from_str_patched(&local_var_content).ok();
2832 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2833 Err(Error::ResponseError(local_var_error))
2834 }
2835}
2836
2837pub async fn get_premium_info(configuration: &configuration::Configuration, workspace: &str, skip_subscription_fetch: Option<bool>) -> Result<models::GetPremiumInfo200Response, Error<GetPremiumInfoError>> {
2838 let local_var_configuration = configuration;
2839
2840 let local_var_client = &local_var_configuration.client;
2841
2842 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/premium_info", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2843 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
2844
2845 if let Some(ref local_var_str) = skip_subscription_fetch {
2846 local_var_req_builder = local_var_req_builder.query(&[("skip_subscription_fetch", &local_var_str.to_string())]);
2847 }
2848 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2849 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2850 }
2851 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2852 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2853 };
2854
2855 let local_var_req = local_var_req_builder.build()?;
2856 let local_var_resp = local_var_client.execute(local_var_req).await?;
2857
2858 let local_var_status = local_var_resp.status();
2859 let local_var_content = local_var_resp.text().await?;
2860
2861 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2862 crate::from_str_patched(&local_var_content).map_err(Error::from)
2863 } else {
2864 let local_var_entity: Option<GetPremiumInfoError> = crate::from_str_patched(&local_var_content).ok();
2865 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2866 Err(Error::ResponseError(local_var_error))
2867 }
2868}
2869
2870pub async fn get_public_settings(configuration: &configuration::Configuration, workspace: &str) -> Result<models::GetPublicSettings200Response, Error<GetPublicSettingsError>> {
2872 let local_var_configuration = configuration;
2873
2874 let local_var_client = &local_var_configuration.client;
2875
2876 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/get_public_settings", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2877 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
2878
2879 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2880 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2881 }
2882 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2883 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2884 };
2885
2886 let local_var_req = local_var_req_builder.build()?;
2887 let local_var_resp = local_var_client.execute(local_var_req).await?;
2888
2889 let local_var_status = local_var_resp.status();
2890 let local_var_content = local_var_resp.text().await?;
2891
2892 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2893 crate::from_str_patched(&local_var_content).map_err(Error::from)
2894 } else {
2895 let local_var_entity: Option<GetPublicSettingsError> = crate::from_str_patched(&local_var_content).ok();
2896 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2897 Err(Error::ResponseError(local_var_error))
2898 }
2899}
2900
2901pub async fn get_session_workspace_status(configuration: &configuration::Configuration, get_session_workspace_status_request: models::GetSessionWorkspaceStatusRequest) -> Result<std::collections::HashMap<String, String>, Error<GetSessionWorkspaceStatusError>> {
2902 let local_var_configuration = configuration;
2903
2904 let local_var_client = &local_var_configuration.client;
2905
2906 let local_var_uri_str = format!("{}/workspaces/session_workspace_status", local_var_configuration.base_path);
2907 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
2908
2909 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2910 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2911 }
2912 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2913 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2914 };
2915 local_var_req_builder = local_var_req_builder.json(&get_session_workspace_status_request);
2916
2917 let local_var_req = local_var_req_builder.build()?;
2918 let local_var_resp = local_var_client.execute(local_var_req).await?;
2919
2920 let local_var_status = local_var_resp.status();
2921 let local_var_content = local_var_resp.text().await?;
2922
2923 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2924 crate::from_str_patched(&local_var_content).map_err(Error::from)
2925 } else {
2926 let local_var_entity: Option<GetSessionWorkspaceStatusError> = crate::from_str_patched(&local_var_content).ok();
2927 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2928 Err(Error::ResponseError(local_var_error))
2929 }
2930}
2931
2932pub async fn get_settings(configuration: &configuration::Configuration, workspace: &str) -> Result<models::GetSettings200Response, Error<GetSettingsError>> {
2934 let local_var_configuration = configuration;
2935
2936 let local_var_client = &local_var_configuration.client;
2937
2938 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/get_settings", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2939 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
2940
2941 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2942 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2943 }
2944 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2945 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2946 };
2947
2948 let local_var_req = local_var_req_builder.build()?;
2949 let local_var_resp = local_var_client.execute(local_var_req).await?;
2950
2951 let local_var_status = local_var_resp.status();
2952 let local_var_content = local_var_resp.text().await?;
2953
2954 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2955 crate::from_str_patched(&local_var_content).map_err(Error::from)
2956 } else {
2957 let local_var_entity: Option<GetSettingsError> = crate::from_str_patched(&local_var_content).ok();
2958 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2959 Err(Error::ResponseError(local_var_error))
2960 }
2961}
2962
2963pub async fn get_shared_ui(configuration: &configuration::Configuration, workspace: &str) -> Result<models::GetSharedUi200Response, Error<GetSharedUiError>> {
2964 let local_var_configuration = configuration;
2965
2966 let local_var_client = &local_var_configuration.client;
2967
2968 let local_var_uri_str = format!("{}/w/{workspace}/shared_ui/get", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2969 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
2970
2971 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
2972 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
2973 }
2974 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
2975 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
2976 };
2977
2978 let local_var_req = local_var_req_builder.build()?;
2979 let local_var_resp = local_var_client.execute(local_var_req).await?;
2980
2981 let local_var_status = local_var_resp.status();
2982 let local_var_content = local_var_resp.text().await?;
2983
2984 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
2985 crate::from_str_patched(&local_var_content).map_err(Error::from)
2986 } else {
2987 let local_var_entity: Option<GetSharedUiError> = crate::from_str_patched(&local_var_content).ok();
2988 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
2989 Err(Error::ResponseError(local_var_error))
2990 }
2991}
2992
2993pub async fn get_shared_ui_version(configuration: &configuration::Configuration, workspace: &str) -> Result<models::GetSharedUiVersion200Response, Error<GetSharedUiVersionError>> {
2994 let local_var_configuration = configuration;
2995
2996 let local_var_client = &local_var_configuration.client;
2997
2998 let local_var_uri_str = format!("{}/w/{workspace}/shared_ui/version", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
2999 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3000
3001 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3002 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3003 }
3004 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3005 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3006 };
3007
3008 let local_var_req = local_var_req_builder.build()?;
3009 let local_var_resp = local_var_client.execute(local_var_req).await?;
3010
3011 let local_var_status = local_var_resp.status();
3012 let local_var_content = local_var_resp.text().await?;
3013
3014 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3015 crate::from_str_patched(&local_var_content).map_err(Error::from)
3016 } else {
3017 let local_var_entity: Option<GetSharedUiVersionError> = crate::from_str_patched(&local_var_content).ok();
3018 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3019 Err(Error::ResponseError(local_var_error))
3020 }
3021}
3022
3023pub async fn get_threshold_alert(configuration: &configuration::Configuration, workspace: &str) -> Result<models::GetThresholdAlert200Response, Error<GetThresholdAlertError>> {
3024 let local_var_configuration = configuration;
3025
3026 let local_var_client = &local_var_configuration.client;
3027
3028 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/threshold_alert", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3029 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3030
3031 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3032 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3033 }
3034 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3035 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3036 };
3037
3038 let local_var_req = local_var_req_builder.build()?;
3039 let local_var_resp = local_var_client.execute(local_var_req).await?;
3040
3041 let local_var_status = local_var_resp.status();
3042 let local_var_content = local_var_resp.text().await?;
3043
3044 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3045 crate::from_str_patched(&local_var_content).map_err(Error::from)
3046 } else {
3047 let local_var_entity: Option<GetThresholdAlertError> = crate::from_str_patched(&local_var_content).ok();
3048 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3049 Err(Error::ResponseError(local_var_error))
3050 }
3051}
3052
3053pub async fn get_used_triggers(configuration: &configuration::Configuration, workspace: &str) -> Result<models::GetUsedTriggers200Response, Error<GetUsedTriggersError>> {
3054 let local_var_configuration = configuration;
3055
3056 let local_var_client = &local_var_configuration.client;
3057
3058 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/used_triggers", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3059 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3060
3061 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3062 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3063 }
3064 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3065 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3066 };
3067
3068 let local_var_req = local_var_req_builder.build()?;
3069 let local_var_resp = local_var_client.execute(local_var_req).await?;
3070
3071 let local_var_status = local_var_resp.status();
3072 let local_var_content = local_var_resp.text().await?;
3073
3074 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3075 crate::from_str_patched(&local_var_content).map_err(Error::from)
3076 } else {
3077 let local_var_entity: Option<GetUsedTriggersError> = crate::from_str_patched(&local_var_content).ok();
3078 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3079 Err(Error::ResponseError(local_var_error))
3080 }
3081}
3082
3083pub async fn get_workspace_as_super_admin(configuration: &configuration::Configuration, workspace: &str) -> Result<models::Workspace, Error<GetWorkspaceAsSuperAdminError>> {
3084 let local_var_configuration = configuration;
3085
3086 let local_var_client = &local_var_configuration.client;
3087
3088 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/get_as_superadmin", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3089 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3090
3091 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3092 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3093 }
3094 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3095 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3096 };
3097
3098 let local_var_req = local_var_req_builder.build()?;
3099 let local_var_resp = local_var_client.execute(local_var_req).await?;
3100
3101 let local_var_status = local_var_resp.status();
3102 let local_var_content = local_var_resp.text().await?;
3103
3104 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3105 crate::from_str_patched(&local_var_content).map_err(Error::from)
3106 } else {
3107 let local_var_entity: Option<GetWorkspaceAsSuperAdminError> = crate::from_str_patched(&local_var_content).ok();
3108 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3109 Err(Error::ResponseError(local_var_error))
3110 }
3111}
3112
3113pub async fn get_workspace_default_app(configuration: &configuration::Configuration, workspace: &str) -> Result<models::GetWorkspaceDefaultApp200Response, Error<GetWorkspaceDefaultAppError>> {
3114 let local_var_configuration = configuration;
3115
3116 let local_var_client = &local_var_configuration.client;
3117
3118 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/default_app", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3119 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3120
3121 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3122 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3123 }
3124 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3125 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3126 };
3127
3128 let local_var_req = local_var_req_builder.build()?;
3129 let local_var_resp = local_var_client.execute(local_var_req).await?;
3130
3131 let local_var_status = local_var_resp.status();
3132 let local_var_content = local_var_resp.text().await?;
3133
3134 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3135 crate::from_str_patched(&local_var_content).map_err(Error::from)
3136 } else {
3137 let local_var_entity: Option<GetWorkspaceDefaultAppError> = crate::from_str_patched(&local_var_content).ok();
3138 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3139 Err(Error::ResponseError(local_var_error))
3140 }
3141}
3142
3143pub async fn get_workspace_encryption_key(configuration: &configuration::Configuration, workspace: &str) -> Result<models::GetWorkspaceEncryptionKey200Response, Error<GetWorkspaceEncryptionKeyError>> {
3144 let local_var_configuration = configuration;
3145
3146 let local_var_client = &local_var_configuration.client;
3147
3148 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/encryption_key", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3149 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3150
3151 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3152 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3153 }
3154 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3155 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3156 };
3157
3158 let local_var_req = local_var_req_builder.build()?;
3159 let local_var_resp = local_var_client.execute(local_var_req).await?;
3160
3161 let local_var_status = local_var_resp.status();
3162 let local_var_content = local_var_resp.text().await?;
3163
3164 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3165 crate::from_str_patched(&local_var_content).map_err(Error::from)
3166 } else {
3167 let local_var_entity: Option<GetWorkspaceEncryptionKeyError> = crate::from_str_patched(&local_var_content).ok();
3168 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3169 Err(Error::ResponseError(local_var_error))
3170 }
3171}
3172
3173pub async fn get_workspace_name(configuration: &configuration::Configuration, workspace: &str) -> Result<String, Error<GetWorkspaceNameError>> {
3174 let local_var_configuration = configuration;
3175
3176 let local_var_client = &local_var_configuration.client;
3177
3178 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/get_workspace_name", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3179 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3180
3181 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3182 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3183 }
3184 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3185 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3186 };
3187
3188 let local_var_req = local_var_req_builder.build()?;
3189 let local_var_resp = local_var_client.execute(local_var_req).await?;
3190
3191 let local_var_status = local_var_resp.status();
3192 let local_var_content = local_var_resp.text().await?;
3193
3194 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3195 crate::from_str_patched(&local_var_content).map_err(Error::from)
3196 } else {
3197 let local_var_entity: Option<GetWorkspaceNameError> = crate::from_str_patched(&local_var_content).ok();
3198 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3199 Err(Error::ResponseError(local_var_error))
3200 }
3201}
3202
3203pub async fn get_workspace_slack_oauth_config(configuration: &configuration::Configuration, workspace: &str) -> Result<models::GetWorkspaceSlackOauthConfig200Response, Error<GetWorkspaceSlackOauthConfigError>> {
3204 let local_var_configuration = configuration;
3205
3206 let local_var_client = &local_var_configuration.client;
3207
3208 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/slack_oauth_config", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3209 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3210
3211 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3212 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3213 }
3214 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3215 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3216 };
3217
3218 let local_var_req = local_var_req_builder.build()?;
3219 let local_var_resp = local_var_client.execute(local_var_req).await?;
3220
3221 let local_var_status = local_var_resp.status();
3222 let local_var_content = local_var_resp.text().await?;
3223
3224 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3225 crate::from_str_patched(&local_var_content).map_err(Error::from)
3226 } else {
3227 let local_var_entity: Option<GetWorkspaceSlackOauthConfigError> = crate::from_str_patched(&local_var_content).ok();
3228 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3229 Err(Error::ResponseError(local_var_error))
3230 }
3231}
3232
3233pub async fn get_workspace_usage(configuration: &configuration::Configuration, workspace: &str) -> Result<f64, Error<GetWorkspaceUsageError>> {
3234 let local_var_configuration = configuration;
3235
3236 let local_var_client = &local_var_configuration.client;
3237
3238 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/usage", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3239 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3240
3241 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3242 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3243 }
3244 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3245 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3246 };
3247
3248 let local_var_req = local_var_req_builder.build()?;
3249 let local_var_resp = local_var_client.execute(local_var_req).await?;
3250
3251 let local_var_status = local_var_resp.status();
3252 let local_var_content = local_var_resp.text().await?;
3253
3254 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3255 crate::from_str_patched(&local_var_content).map_err(Error::from)
3256 } else {
3257 let local_var_entity: Option<GetWorkspaceUsageError> = crate::from_str_patched(&local_var_content).ok();
3258 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3259 Err(Error::ResponseError(local_var_error))
3260 }
3261}
3262
3263pub async fn import_pg_database(configuration: &configuration::Configuration, workspace: &str, import_pg_database_request: models::ImportPgDatabaseRequest) -> Result<String, Error<ImportPgDatabaseError>> {
3264 let local_var_configuration = configuration;
3265
3266 let local_var_client = &local_var_configuration.client;
3267
3268 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/import_pg_database", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3269 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
3270
3271 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3272 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3273 }
3274 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3275 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3276 };
3277 local_var_req_builder = local_var_req_builder.json(&import_pg_database_request);
3278
3279 let local_var_req = local_var_req_builder.build()?;
3280 let local_var_resp = local_var_client.execute(local_var_req).await?;
3281
3282 let local_var_status = local_var_resp.status();
3283 let local_var_content = local_var_resp.text().await?;
3284
3285 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3286 crate::from_str_patched(&local_var_content).map_err(Error::from)
3287 } else {
3288 let local_var_entity: Option<ImportPgDatabaseError> = crate::from_str_patched(&local_var_content).ok();
3289 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3290 Err(Error::ResponseError(local_var_error))
3291 }
3292}
3293
3294pub async fn invite_user(configuration: &configuration::Configuration, workspace: &str, invite_user_request: models::InviteUserRequest) -> Result<String, Error<InviteUserError>> {
3295 let local_var_configuration = configuration;
3296
3297 let local_var_client = &local_var_configuration.client;
3298
3299 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/invite_user", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3300 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
3301
3302 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3303 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3304 }
3305 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3306 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3307 };
3308 local_var_req_builder = local_var_req_builder.json(&invite_user_request);
3309
3310 let local_var_req = local_var_req_builder.build()?;
3311 let local_var_resp = local_var_client.execute(local_var_req).await?;
3312
3313 let local_var_status = local_var_resp.status();
3314 let local_var_content = local_var_resp.text().await?;
3315
3316 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3317 crate::from_str_patched(&local_var_content).map_err(Error::from)
3318 } else {
3319 let local_var_entity: Option<InviteUserError> = crate::from_str_patched(&local_var_content).ok();
3320 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3321 Err(Error::ResponseError(local_var_error))
3322 }
3323}
3324
3325pub async fn is_domain_allowed(configuration: &configuration::Configuration, ) -> Result<bool, Error<IsDomainAllowedError>> {
3326 let local_var_configuration = configuration;
3327
3328 let local_var_client = &local_var_configuration.client;
3329
3330 let local_var_uri_str = format!("{}/workspaces/allowed_domain_auto_invite", local_var_configuration.base_path);
3331 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3332
3333 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3334 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3335 }
3336 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3337 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3338 };
3339
3340 let local_var_req = local_var_req_builder.build()?;
3341 let local_var_resp = local_var_client.execute(local_var_req).await?;
3342
3343 let local_var_status = local_var_resp.status();
3344 let local_var_content = local_var_resp.text().await?;
3345
3346 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3347 crate::from_str_patched(&local_var_content).map_err(Error::from)
3348 } else {
3349 let local_var_entity: Option<IsDomainAllowedError> = crate::from_str_patched(&local_var_content).ok();
3350 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3351 Err(Error::ResponseError(local_var_error))
3352 }
3353}
3354
3355pub async fn leave_workspace(configuration: &configuration::Configuration, workspace: &str) -> Result<String, Error<LeaveWorkspaceError>> {
3356 let local_var_configuration = configuration;
3357
3358 let local_var_client = &local_var_configuration.client;
3359
3360 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/leave", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3361 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
3362
3363 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3364 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3365 }
3366 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3367 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3368 };
3369
3370 let local_var_req = local_var_req_builder.build()?;
3371 let local_var_resp = local_var_client.execute(local_var_req).await?;
3372
3373 let local_var_status = local_var_resp.status();
3374 let local_var_content = local_var_resp.text().await?;
3375
3376 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3377 crate::from_str_patched(&local_var_content).map_err(Error::from)
3378 } else {
3379 let local_var_entity: Option<LeaveWorkspaceError> = crate::from_str_patched(&local_var_content).ok();
3380 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3381 Err(Error::ResponseError(local_var_error))
3382 }
3383}
3384
3385pub async fn list_ai_skills(configuration: &configuration::Configuration, workspace: &str) -> Result<Vec<models::ListAiSkills200ResponseInner>, Error<ListAiSkillsError>> {
3386 let local_var_configuration = configuration;
3387
3388 let local_var_client = &local_var_configuration.client;
3389
3390 let local_var_uri_str = format!("{}/w/{workspace}/ai_skills/list", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3391 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3392
3393 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3394 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3395 }
3396 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3397 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3398 };
3399
3400 let local_var_req = local_var_req_builder.build()?;
3401 let local_var_resp = local_var_client.execute(local_var_req).await?;
3402
3403 let local_var_status = local_var_resp.status();
3404 let local_var_content = local_var_resp.text().await?;
3405
3406 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3407 crate::from_str_patched(&local_var_content).map_err(Error::from)
3408 } else {
3409 let local_var_entity: Option<ListAiSkillsError> = crate::from_str_patched(&local_var_content).ok();
3410 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3411 Err(Error::ResponseError(local_var_error))
3412 }
3413}
3414
3415pub async fn list_available_teams_channels(configuration: &configuration::Configuration, workspace: &str, team_id: &str) -> Result<models::ListAvailableTeamsChannels200Response, Error<ListAvailableTeamsChannelsError>> {
3416 let local_var_configuration = configuration;
3417
3418 let local_var_client = &local_var_configuration.client;
3419
3420 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/available_teams_channels", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3421 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3422
3423 local_var_req_builder = local_var_req_builder.query(&[("team_id", &team_id.to_string())]);
3424 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3425 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3426 }
3427 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3428 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3429 };
3430
3431 let local_var_req = local_var_req_builder.build()?;
3432 let local_var_resp = local_var_client.execute(local_var_req).await?;
3433
3434 let local_var_status = local_var_resp.status();
3435 let local_var_content = local_var_resp.text().await?;
3436
3437 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3438 crate::from_str_patched(&local_var_content).map_err(Error::from)
3439 } else {
3440 let local_var_entity: Option<ListAvailableTeamsChannelsError> = crate::from_str_patched(&local_var_content).ok();
3441 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3442 Err(Error::ResponseError(local_var_error))
3443 }
3444}
3445
3446pub async fn list_available_teams_ids(configuration: &configuration::Configuration, workspace: &str, search: Option<&str>, next_link: Option<&str>) -> Result<models::ListAvailableTeamsIds200Response, Error<ListAvailableTeamsIdsError>> {
3447 let local_var_configuration = configuration;
3448
3449 let local_var_client = &local_var_configuration.client;
3450
3451 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/available_teams_ids", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3452 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3453
3454 if let Some(ref local_var_str) = search {
3455 local_var_req_builder = local_var_req_builder.query(&[("search", &local_var_str.to_string())]);
3456 }
3457 if let Some(ref local_var_str) = next_link {
3458 local_var_req_builder = local_var_req_builder.query(&[("next_link", &local_var_str.to_string())]);
3459 }
3460 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3461 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3462 }
3463 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3464 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3465 };
3466
3467 let local_var_req = local_var_req_builder.build()?;
3468 let local_var_resp = local_var_client.execute(local_var_req).await?;
3469
3470 let local_var_status = local_var_resp.status();
3471 let local_var_content = local_var_resp.text().await?;
3472
3473 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3474 crate::from_str_patched(&local_var_content).map_err(Error::from)
3475 } else {
3476 let local_var_entity: Option<ListAvailableTeamsIdsError> = crate::from_str_patched(&local_var_content).ok();
3477 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3478 Err(Error::ResponseError(local_var_error))
3479 }
3480}
3481
3482pub async fn list_data_table_schemas(configuration: &configuration::Configuration, workspace: &str) -> Result<Vec<models::DataTableSchema>, Error<ListDataTableSchemasError>> {
3483 let local_var_configuration = configuration;
3484
3485 let local_var_client = &local_var_configuration.client;
3486
3487 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/list_datatable_schemas", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3488 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3489
3490 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3491 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3492 }
3493 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3494 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3495 };
3496
3497 let local_var_req = local_var_req_builder.build()?;
3498 let local_var_resp = local_var_client.execute(local_var_req).await?;
3499
3500 let local_var_status = local_var_resp.status();
3501 let local_var_content = local_var_resp.text().await?;
3502
3503 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3504 crate::from_str_patched(&local_var_content).map_err(Error::from)
3505 } else {
3506 let local_var_entity: Option<ListDataTableSchemasError> = crate::from_str_patched(&local_var_content).ok();
3507 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3508 Err(Error::ResponseError(local_var_error))
3509 }
3510}
3511
3512pub async fn list_data_table_tables(configuration: &configuration::Configuration, workspace: &str) -> Result<Vec<models::DataTableTables>, Error<ListDataTableTablesError>> {
3513 let local_var_configuration = configuration;
3514
3515 let local_var_client = &local_var_configuration.client;
3516
3517 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/list_datatable_tables", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3518 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3519
3520 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3521 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3522 }
3523 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3524 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3525 };
3526
3527 let local_var_req = local_var_req_builder.build()?;
3528 let local_var_resp = local_var_client.execute(local_var_req).await?;
3529
3530 let local_var_status = local_var_resp.status();
3531 let local_var_content = local_var_resp.text().await?;
3532
3533 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3534 crate::from_str_patched(&local_var_content).map_err(Error::from)
3535 } else {
3536 let local_var_entity: Option<ListDataTableTablesError> = crate::from_str_patched(&local_var_content).ok();
3537 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3538 Err(Error::ResponseError(local_var_error))
3539 }
3540}
3541
3542pub async fn list_data_tables(configuration: &configuration::Configuration, workspace: &str) -> Result<Vec<models::ListDataTables200ResponseInner>, Error<ListDataTablesError>> {
3543 let local_var_configuration = configuration;
3544
3545 let local_var_client = &local_var_configuration.client;
3546
3547 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/list_datatables", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3548 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3549
3550 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3551 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3552 }
3553 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3554 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3555 };
3556
3557 let local_var_req = local_var_req_builder.build()?;
3558 let local_var_resp = local_var_client.execute(local_var_req).await?;
3559
3560 let local_var_status = local_var_resp.status();
3561 let local_var_content = local_var_resp.text().await?;
3562
3563 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3564 crate::from_str_patched(&local_var_content).map_err(Error::from)
3565 } else {
3566 let local_var_entity: Option<ListDataTablesError> = crate::from_str_patched(&local_var_content).ok();
3567 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3568 Err(Error::ResponseError(local_var_error))
3569 }
3570}
3571
3572pub async fn list_deployment_request_eligible_deployers(configuration: &configuration::Configuration, workspace: &str) -> Result<Vec<models::DeploymentRequestEligibleDeployer>, Error<ListDeploymentRequestEligibleDeployersError>> {
3574 let local_var_configuration = configuration;
3575
3576 let local_var_client = &local_var_configuration.client;
3577
3578 let local_var_uri_str = format!("{}/w/{workspace}/deployment_request/eligible_deployers", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3579 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3580
3581 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3582 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3583 }
3584 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3585 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3586 };
3587
3588 let local_var_req = local_var_req_builder.build()?;
3589 let local_var_resp = local_var_client.execute(local_var_req).await?;
3590
3591 let local_var_status = local_var_resp.status();
3592 let local_var_content = local_var_resp.text().await?;
3593
3594 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3595 crate::from_str_patched(&local_var_content).map_err(Error::from)
3596 } else {
3597 let local_var_entity: Option<ListDeploymentRequestEligibleDeployersError> = crate::from_str_patched(&local_var_content).ok();
3598 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3599 Err(Error::ResponseError(local_var_error))
3600 }
3601}
3602
3603pub async fn list_ducklakes(configuration: &configuration::Configuration, workspace: &str) -> Result<Vec<String>, Error<ListDucklakesError>> {
3604 let local_var_configuration = configuration;
3605
3606 let local_var_client = &local_var_configuration.client;
3607
3608 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/list_ducklakes", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3609 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3610
3611 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3612 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3613 }
3614 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3615 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3616 };
3617
3618 let local_var_req = local_var_req_builder.build()?;
3619 let local_var_resp = local_var_client.execute(local_var_req).await?;
3620
3621 let local_var_status = local_var_resp.status();
3622 let local_var_content = local_var_resp.text().await?;
3623
3624 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3625 crate::from_str_patched(&local_var_content).map_err(Error::from)
3626 } else {
3627 let local_var_entity: Option<ListDucklakesError> = crate::from_str_patched(&local_var_content).ok();
3628 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3629 Err(Error::ResponseError(local_var_error))
3630 }
3631}
3632
3633pub async fn list_pending_invites(configuration: &configuration::Configuration, workspace: &str) -> Result<Vec<models::WorkspaceInvite>, Error<ListPendingInvitesError>> {
3634 let local_var_configuration = configuration;
3635
3636 let local_var_client = &local_var_configuration.client;
3637
3638 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/list_pending_invites", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3639 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3640
3641 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3642 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3643 }
3644 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3645 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3646 };
3647
3648 let local_var_req = local_var_req_builder.build()?;
3649 let local_var_resp = local_var_client.execute(local_var_req).await?;
3650
3651 let local_var_status = local_var_resp.status();
3652 let local_var_content = local_var_resp.text().await?;
3653
3654 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3655 crate::from_str_patched(&local_var_content).map_err(Error::from)
3656 } else {
3657 let local_var_entity: Option<ListPendingInvitesError> = crate::from_str_patched(&local_var_content).ok();
3658 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3659 Err(Error::ResponseError(local_var_error))
3660 }
3661}
3662
3663pub async fn list_protection_rules(configuration: &configuration::Configuration, workspace: &str) -> Result<Vec<models::ProtectionRuleset>, Error<ListProtectionRulesError>> {
3664 let local_var_configuration = configuration;
3665
3666 let local_var_client = &local_var_configuration.client;
3667
3668 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/protection_rules", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3669 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3670
3671 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3672 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3673 }
3674 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3675 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3676 };
3677
3678 let local_var_req = local_var_req_builder.build()?;
3679 let local_var_resp = local_var_client.execute(local_var_req).await?;
3680
3681 let local_var_status = local_var_resp.status();
3682 let local_var_content = local_var_resp.text().await?;
3683
3684 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3685 crate::from_str_patched(&local_var_content).map_err(Error::from)
3686 } else {
3687 let local_var_entity: Option<ListProtectionRulesError> = crate::from_str_patched(&local_var_content).ok();
3688 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3689 Err(Error::ResponseError(local_var_error))
3690 }
3691}
3692
3693pub async fn list_shared_ui(configuration: &configuration::Configuration, workspace: &str) -> Result<models::ListSharedUi200Response, Error<ListSharedUiError>> {
3694 let local_var_configuration = configuration;
3695
3696 let local_var_client = &local_var_configuration.client;
3697
3698 let local_var_uri_str = format!("{}/w/{workspace}/shared_ui/list", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3699 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3700
3701 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3702 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3703 }
3704 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3705 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3706 };
3707
3708 let local_var_req = local_var_req_builder.build()?;
3709 let local_var_resp = local_var_client.execute(local_var_req).await?;
3710
3711 let local_var_status = local_var_resp.status();
3712 let local_var_content = local_var_resp.text().await?;
3713
3714 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3715 crate::from_str_patched(&local_var_content).map_err(Error::from)
3716 } else {
3717 let local_var_entity: Option<ListSharedUiError> = crate::from_str_patched(&local_var_content).ok();
3718 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3719 Err(Error::ResponseError(local_var_error))
3720 }
3721}
3722
3723pub async fn list_user_workspaces(configuration: &configuration::Configuration, ) -> Result<models::UserWorkspaceList, Error<ListUserWorkspacesError>> {
3724 let local_var_configuration = configuration;
3725
3726 let local_var_client = &local_var_configuration.client;
3727
3728 let local_var_uri_str = format!("{}/workspaces/users", local_var_configuration.base_path);
3729 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3730
3731 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3732 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3733 }
3734 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3735 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3736 };
3737
3738 let local_var_req = local_var_req_builder.build()?;
3739 let local_var_resp = local_var_client.execute(local_var_req).await?;
3740
3741 let local_var_status = local_var_resp.status();
3742 let local_var_content = local_var_resp.text().await?;
3743
3744 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3745 crate::from_str_patched(&local_var_content).map_err(Error::from)
3746 } else {
3747 let local_var_entity: Option<ListUserWorkspacesError> = crate::from_str_patched(&local_var_content).ok();
3748 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3749 Err(Error::ResponseError(local_var_error))
3750 }
3751}
3752
3753pub async fn list_workspaces(configuration: &configuration::Configuration, ) -> Result<Vec<models::Workspace>, Error<ListWorkspacesError>> {
3754 let local_var_configuration = configuration;
3755
3756 let local_var_client = &local_var_configuration.client;
3757
3758 let local_var_uri_str = format!("{}/workspaces/list", local_var_configuration.base_path);
3759 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3760
3761 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3762 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3763 }
3764 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3765 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3766 };
3767
3768 let local_var_req = local_var_req_builder.build()?;
3769 let local_var_resp = local_var_client.execute(local_var_req).await?;
3770
3771 let local_var_status = local_var_resp.status();
3772 let local_var_content = local_var_resp.text().await?;
3773
3774 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3775 crate::from_str_patched(&local_var_content).map_err(Error::from)
3776 } else {
3777 let local_var_entity: Option<ListWorkspacesError> = crate::from_str_patched(&local_var_content).ok();
3778 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3779 Err(Error::ResponseError(local_var_error))
3780 }
3781}
3782
3783pub async fn list_workspaces_as_super_admin(configuration: &configuration::Configuration, page: Option<i32>, per_page: Option<i32>) -> Result<Vec<models::Workspace>, Error<ListWorkspacesAsSuperAdminError>> {
3784 let local_var_configuration = configuration;
3785
3786 let local_var_client = &local_var_configuration.client;
3787
3788 let local_var_uri_str = format!("{}/workspaces/list_as_superadmin", local_var_configuration.base_path);
3789 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3790
3791 if let Some(ref local_var_str) = page {
3792 local_var_req_builder = local_var_req_builder.query(&[("page", &local_var_str.to_string())]);
3793 }
3794 if let Some(ref local_var_str) = per_page {
3795 local_var_req_builder = local_var_req_builder.query(&[("per_page", &local_var_str.to_string())]);
3796 }
3797 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3798 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3799 }
3800 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3801 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3802 };
3803
3804 let local_var_req = local_var_req_builder.build()?;
3805 let local_var_resp = local_var_client.execute(local_var_req).await?;
3806
3807 let local_var_status = local_var_resp.status();
3808 let local_var_content = local_var_resp.text().await?;
3809
3810 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3811 crate::from_str_patched(&local_var_content).map_err(Error::from)
3812 } else {
3813 let local_var_entity: Option<ListWorkspacesAsSuperAdminError> = crate::from_str_patched(&local_var_content).ok();
3814 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3815 Err(Error::ResponseError(local_var_error))
3816 }
3817}
3818
3819pub async fn list_ws_specific(configuration: &configuration::Configuration, workspace: &str) -> Result<Vec<models::ListWsSpecific200ResponseInner>, Error<ListWsSpecificError>> {
3820 let local_var_configuration = configuration;
3821
3822 let local_var_client = &local_var_configuration.client;
3823
3824 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/list_ws_specific", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3825 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3826
3827 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3828 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3829 }
3830 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3831 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3832 };
3833
3834 let local_var_req = local_var_req_builder.build()?;
3835 let local_var_resp = local_var_client.execute(local_var_req).await?;
3836
3837 let local_var_status = local_var_resp.status();
3838 let local_var_content = local_var_resp.text().await?;
3839
3840 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3841 crate::from_str_patched(&local_var_content).map_err(Error::from)
3842 } else {
3843 let local_var_entity: Option<ListWsSpecificError> = crate::from_str_patched(&local_var_content).ok();
3844 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3845 Err(Error::ResponseError(local_var_error))
3846 }
3847}
3848
3849pub async fn list_ws_specific_versions(configuration: &configuration::Configuration, workspace: &str, kind: &str, path: &str) -> Result<Vec<String>, Error<ListWsSpecificVersionsError>> {
3850 let local_var_configuration = configuration;
3851
3852 let local_var_client = &local_var_configuration.client;
3853
3854 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/list_ws_specific_versions", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3855 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
3856
3857 local_var_req_builder = local_var_req_builder.query(&[("kind", &kind.to_string())]);
3858 local_var_req_builder = local_var_req_builder.query(&[("path", &path.to_string())]);
3859 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3860 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3861 }
3862 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3863 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3864 };
3865
3866 let local_var_req = local_var_req_builder.build()?;
3867 let local_var_resp = local_var_client.execute(local_var_req).await?;
3868
3869 let local_var_status = local_var_resp.status();
3870 let local_var_content = local_var_resp.text().await?;
3871
3872 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3873 crate::from_str_patched(&local_var_content).map_err(Error::from)
3874 } else {
3875 let local_var_entity: Option<ListWsSpecificVersionsError> = crate::from_str_patched(&local_var_content).ok();
3876 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3877 Err(Error::ResponseError(local_var_error))
3878 }
3879}
3880
3881pub async fn log_ai_chat(configuration: &configuration::Configuration, workspace: &str, log_ai_chat_request: models::LogAiChatRequest) -> Result<(), Error<LogAiChatError>> {
3882 let local_var_configuration = configuration;
3883
3884 let local_var_client = &local_var_configuration.client;
3885
3886 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/log_chat", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3887 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
3888
3889 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3890 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3891 }
3892 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3893 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3894 };
3895 local_var_req_builder = local_var_req_builder.json(&log_ai_chat_request);
3896
3897 let local_var_req = local_var_req_builder.build()?;
3898 let local_var_resp = local_var_client.execute(local_var_req).await?;
3899
3900 let local_var_status = local_var_resp.status();
3901 let local_var_content = local_var_resp.text().await?;
3902
3903 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3904 Ok(())
3905 } else {
3906 let local_var_entity: Option<LogAiChatError> = crate::from_str_patched(&local_var_content).ok();
3907 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3908 Err(Error::ResponseError(local_var_error))
3909 }
3910}
3911
3912pub async fn prune_versions(configuration: &configuration::Configuration, workspace: &str, prune_versions_request: models::PruneVersionsRequest) -> Result<models::PruneVersions200Response, Error<PruneVersionsError>> {
3913 let local_var_configuration = configuration;
3914
3915 let local_var_client = &local_var_configuration.client;
3916
3917 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/prune_versions", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3918 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
3919
3920 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3921 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3922 }
3923 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3924 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3925 };
3926 local_var_req_builder = local_var_req_builder.json(&prune_versions_request);
3927
3928 let local_var_req = local_var_req_builder.build()?;
3929 let local_var_resp = local_var_client.execute(local_var_req).await?;
3930
3931 let local_var_status = local_var_resp.status();
3932 let local_var_content = local_var_resp.text().await?;
3933
3934 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3935 crate::from_str_patched(&local_var_content).map_err(Error::from)
3936 } else {
3937 let local_var_entity: Option<PruneVersionsError> = crate::from_str_patched(&local_var_content).ok();
3938 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3939 Err(Error::ResponseError(local_var_error))
3940 }
3941}
3942
3943pub async fn rebuild_dependency_map(configuration: &configuration::Configuration, workspace: &str) -> Result<String, Error<RebuildDependencyMapError>> {
3944 let local_var_configuration = configuration;
3945
3946 let local_var_client = &local_var_configuration.client;
3947
3948 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/rebuild_dependency_map", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
3949 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
3950
3951 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3952 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3953 }
3954 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3955 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3956 };
3957
3958 let local_var_req = local_var_req_builder.build()?;
3959 let local_var_resp = local_var_client.execute(local_var_req).await?;
3960
3961 let local_var_status = local_var_resp.status();
3962 let local_var_content = local_var_resp.text().await?;
3963
3964 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3965 crate::from_str_patched(&local_var_content).map_err(Error::from)
3966 } else {
3967 let local_var_entity: Option<RebuildDependencyMapError> = crate::from_str_patched(&local_var_content).ok();
3968 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
3969 Err(Error::ResponseError(local_var_error))
3970 }
3971}
3972
3973pub async fn reset_diff_tally(configuration: &configuration::Configuration, workspace: &str, fork_workspace_id: &str) -> Result<serde_json::Value, Error<ResetDiffTallyError>> {
3975 let local_var_configuration = configuration;
3976
3977 let local_var_client = &local_var_configuration.client;
3978
3979 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/reset_diff_tally/{fork_workspace_id}", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace), fork_workspace_id=crate::apis::urlencode(fork_workspace_id));
3980 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
3981
3982 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
3983 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
3984 }
3985 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
3986 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
3987 };
3988
3989 let local_var_req = local_var_req_builder.build()?;
3990 let local_var_resp = local_var_client.execute(local_var_req).await?;
3991
3992 let local_var_status = local_var_resp.status();
3993 let local_var_content = local_var_resp.text().await?;
3994
3995 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
3996 crate::from_str_patched(&local_var_content).map_err(Error::from)
3997 } else {
3998 let local_var_entity: Option<ResetDiffTallyError> = crate::from_str_patched(&local_var_content).ok();
3999 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
4000 Err(Error::ResponseError(local_var_error))
4001 }
4002}
4003
4004pub 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>> {
4005 let local_var_configuration = configuration;
4006
4007 let local_var_client = &local_var_configuration.client;
4008
4009 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/run_slack_message_test_job", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
4010 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
4011
4012 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
4013 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
4014 }
4015 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
4016 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
4017 };
4018 local_var_req_builder = local_var_req_builder.json(&run_slack_message_test_job_request);
4019
4020 let local_var_req = local_var_req_builder.build()?;
4021 let local_var_resp = local_var_client.execute(local_var_req).await?;
4022
4023 let local_var_status = local_var_resp.status();
4024 let local_var_content = local_var_resp.text().await?;
4025
4026 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
4027 crate::from_str_patched(&local_var_content).map_err(Error::from)
4028 } else {
4029 let local_var_entity: Option<RunSlackMessageTestJobError> = crate::from_str_patched(&local_var_content).ok();
4030 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
4031 Err(Error::ResponseError(local_var_error))
4032 }
4033}
4034
4035pub 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>> {
4036 let local_var_configuration = configuration;
4037
4038 let local_var_client = &local_var_configuration.client;
4039
4040 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/run_teams_message_test_job", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
4041 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
4042
4043 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
4044 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
4045 }
4046 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
4047 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
4048 };
4049 local_var_req_builder = local_var_req_builder.json(&run_slack_message_test_job_request);
4050
4051 let local_var_req = local_var_req_builder.build()?;
4052 let local_var_resp = local_var_client.execute(local_var_req).await?;
4053
4054 let local_var_status = local_var_resp.status();
4055 let local_var_content = local_var_resp.text().await?;
4056
4057 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
4058 crate::from_str_patched(&local_var_content).map_err(Error::from)
4059 } else {
4060 let local_var_entity: Option<RunTeamsMessageTestJobError> = crate::from_str_patched(&local_var_content).ok();
4061 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
4062 Err(Error::ResponseError(local_var_error))
4063 }
4064}
4065
4066pub async fn set_dev_workspace_label(configuration: &configuration::Configuration, workspace: &str, set_dev_workspace_label_request: models::SetDevWorkspaceLabelRequest) -> Result<String, Error<SetDevWorkspaceLabelError>> {
4067 let local_var_configuration = configuration;
4068
4069 let local_var_client = &local_var_configuration.client;
4070
4071 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/set_dev_workspace_label", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
4072 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
4073
4074 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
4075 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
4076 }
4077 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
4078 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
4079 };
4080 local_var_req_builder = local_var_req_builder.json(&set_dev_workspace_label_request);
4081
4082 let local_var_req = local_var_req_builder.build()?;
4083 let local_var_resp = local_var_client.execute(local_var_req).await?;
4084
4085 let local_var_status = local_var_resp.status();
4086 let local_var_content = local_var_resp.text().await?;
4087
4088 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
4089 crate::from_str_patched(&local_var_content).map_err(Error::from)
4090 } else {
4091 let local_var_entity: Option<SetDevWorkspaceLabelError> = crate::from_str_patched(&local_var_content).ok();
4092 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
4093 Err(Error::ResponseError(local_var_error))
4094 }
4095}
4096
4097pub async fn set_environment_variable(configuration: &configuration::Configuration, workspace: &str, set_environment_variable_request: models::SetEnvironmentVariableRequest) -> Result<String, Error<SetEnvironmentVariableError>> {
4098 let local_var_configuration = configuration;
4099
4100 let local_var_client = &local_var_configuration.client;
4101
4102 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/set_environment_variable", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
4103 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
4104
4105 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
4106 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
4107 }
4108 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
4109 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
4110 };
4111 local_var_req_builder = local_var_req_builder.json(&set_environment_variable_request);
4112
4113 let local_var_req = local_var_req_builder.build()?;
4114 let local_var_resp = local_var_client.execute(local_var_req).await?;
4115
4116 let local_var_status = local_var_resp.status();
4117 let local_var_content = local_var_resp.text().await?;
4118
4119 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
4120 crate::from_str_patched(&local_var_content).map_err(Error::from)
4121 } else {
4122 let local_var_entity: Option<SetEnvironmentVariableError> = crate::from_str_patched(&local_var_content).ok();
4123 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
4124 Err(Error::ResponseError(local_var_error))
4125 }
4126}
4127
4128pub async fn set_threshold_alert(configuration: &configuration::Configuration, workspace: &str, set_threshold_alert_request: models::SetThresholdAlertRequest) -> Result<String, Error<SetThresholdAlertError>> {
4129 let local_var_configuration = configuration;
4130
4131 let local_var_client = &local_var_configuration.client;
4132
4133 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/threshold_alert", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
4134 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
4135
4136 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
4137 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
4138 }
4139 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
4140 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
4141 };
4142 local_var_req_builder = local_var_req_builder.json(&set_threshold_alert_request);
4143
4144 let local_var_req = local_var_req_builder.build()?;
4145 let local_var_resp = local_var_client.execute(local_var_req).await?;
4146
4147 let local_var_status = local_var_resp.status();
4148 let local_var_content = local_var_resp.text().await?;
4149
4150 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
4151 crate::from_str_patched(&local_var_content).map_err(Error::from)
4152 } else {
4153 let local_var_entity: Option<SetThresholdAlertError> = crate::from_str_patched(&local_var_content).ok();
4154 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
4155 Err(Error::ResponseError(local_var_error))
4156 }
4157}
4158
4159pub async fn set_workspace_encryption_key(configuration: &configuration::Configuration, workspace: &str, set_workspace_encryption_key_request: models::SetWorkspaceEncryptionKeyRequest) -> Result<String, Error<SetWorkspaceEncryptionKeyError>> {
4160 let local_var_configuration = configuration;
4161
4162 let local_var_client = &local_var_configuration.client;
4163
4164 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/encryption_key", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
4165 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
4166
4167 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
4168 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
4169 }
4170 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
4171 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
4172 };
4173 local_var_req_builder = local_var_req_builder.json(&set_workspace_encryption_key_request);
4174
4175 let local_var_req = local_var_req_builder.build()?;
4176 let local_var_resp = local_var_client.execute(local_var_req).await?;
4177
4178 let local_var_status = local_var_resp.status();
4179 let local_var_content = local_var_resp.text().await?;
4180
4181 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
4182 crate::from_str_patched(&local_var_content).map_err(Error::from)
4183 } else {
4184 let local_var_entity: Option<SetWorkspaceEncryptionKeyError> = crate::from_str_patched(&local_var_content).ok();
4185 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
4186 Err(Error::ResponseError(local_var_error))
4187 }
4188}
4189
4190pub async fn set_workspace_slack_oauth_config(configuration: &configuration::Configuration, workspace: &str, set_workspace_slack_oauth_config_request: models::SetWorkspaceSlackOauthConfigRequest) -> Result<String, Error<SetWorkspaceSlackOauthConfigError>> {
4191 let local_var_configuration = configuration;
4192
4193 let local_var_client = &local_var_configuration.client;
4194
4195 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/slack_oauth_config", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
4196 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
4197
4198 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
4199 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
4200 }
4201 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
4202 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
4203 };
4204 local_var_req_builder = local_var_req_builder.json(&set_workspace_slack_oauth_config_request);
4205
4206 let local_var_req = local_var_req_builder.build()?;
4207 let local_var_resp = local_var_client.execute(local_var_req).await?;
4208
4209 let local_var_status = local_var_resp.status();
4210 let local_var_content = local_var_resp.text().await?;
4211
4212 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
4213 crate::from_str_patched(&local_var_content).map_err(Error::from)
4214 } else {
4215 let local_var_entity: Option<SetWorkspaceSlackOauthConfigError> = crate::from_str_patched(&local_var_content).ok();
4216 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
4217 Err(Error::ResponseError(local_var_error))
4218 }
4219}
4220
4221pub async fn set_ws_specific(configuration: &configuration::Configuration, workspace: &str, set_ws_specific_request: models::SetWsSpecificRequest) -> Result<String, Error<SetWsSpecificError>> {
4222 let local_var_configuration = configuration;
4223
4224 let local_var_client = &local_var_configuration.client;
4225
4226 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/set_ws_specific", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
4227 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
4228
4229 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
4230 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
4231 }
4232 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
4233 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
4234 };
4235 local_var_req_builder = local_var_req_builder.json(&set_ws_specific_request);
4236
4237 let local_var_req = local_var_req_builder.build()?;
4238 let local_var_resp = local_var_client.execute(local_var_req).await?;
4239
4240 let local_var_status = local_var_resp.status();
4241 let local_var_content = local_var_resp.text().await?;
4242
4243 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
4244 crate::from_str_patched(&local_var_content).map_err(Error::from)
4245 } else {
4246 let local_var_entity: Option<SetWsSpecificError> = crate::from_str_patched(&local_var_content).ok();
4247 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
4248 Err(Error::ResponseError(local_var_error))
4249 }
4250}
4251
4252pub async fn unarchive_workspace(configuration: &configuration::Configuration, workspace: &str) -> Result<String, Error<UnarchiveWorkspaceError>> {
4253 let local_var_configuration = configuration;
4254
4255 let local_var_client = &local_var_configuration.client;
4256
4257 let local_var_uri_str = format!("{}/workspaces/unarchive/{workspace}", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
4258 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
4259
4260 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
4261 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
4262 }
4263 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
4264 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
4265 };
4266
4267 let local_var_req = local_var_req_builder.build()?;
4268 let local_var_resp = local_var_client.execute(local_var_req).await?;
4269
4270 let local_var_status = local_var_resp.status();
4271 let local_var_content = local_var_resp.text().await?;
4272
4273 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
4274 crate::from_str_patched(&local_var_content).map_err(Error::from)
4275 } else {
4276 let local_var_entity: Option<UnarchiveWorkspaceError> = crate::from_str_patched(&local_var_content).ok();
4277 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
4278 Err(Error::ResponseError(local_var_error))
4279 }
4280}
4281
4282pub async fn update_operator_settings(configuration: &configuration::Configuration, workspace: &str, operator_settings: Option<models::OperatorSettings>) -> Result<String, Error<UpdateOperatorSettingsError>> {
4284 let local_var_configuration = configuration;
4285
4286 let local_var_client = &local_var_configuration.client;
4287
4288 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/operator_settings", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
4289 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
4290
4291 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
4292 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
4293 }
4294 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
4295 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
4296 };
4297 local_var_req_builder = local_var_req_builder.json(&operator_settings);
4298
4299 let local_var_req = local_var_req_builder.build()?;
4300 let local_var_resp = local_var_client.execute(local_var_req).await?;
4301
4302 let local_var_status = local_var_resp.status();
4303 let local_var_content = local_var_resp.text().await?;
4304
4305 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
4306 crate::from_str_patched(&local_var_content).map_err(Error::from)
4307 } else {
4308 let local_var_entity: Option<UpdateOperatorSettingsError> = crate::from_str_patched(&local_var_content).ok();
4309 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
4310 Err(Error::ResponseError(local_var_error))
4311 }
4312}
4313
4314pub async fn update_protection_rule(configuration: &configuration::Configuration, workspace: &str, rule_name: &str, update_protection_rule_request: models::UpdateProtectionRuleRequest) -> Result<String, Error<UpdateProtectionRuleError>> {
4315 let local_var_configuration = configuration;
4316
4317 let local_var_client = &local_var_configuration.client;
4318
4319 let local_var_uri_str = format!("{}/w/{workspace}/workspaces/protection_rules/{rule_name}", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace), rule_name=crate::apis::urlencode(rule_name));
4320 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
4321
4322 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
4323 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
4324 }
4325 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
4326 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
4327 };
4328 local_var_req_builder = local_var_req_builder.json(&update_protection_rule_request);
4329
4330 let local_var_req = local_var_req_builder.build()?;
4331 let local_var_resp = local_var_client.execute(local_var_req).await?;
4332
4333 let local_var_status = local_var_resp.status();
4334 let local_var_content = local_var_resp.text().await?;
4335
4336 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
4337 crate::from_str_patched(&local_var_content).map_err(Error::from)
4338 } else {
4339 let local_var_entity: Option<UpdateProtectionRuleError> = crate::from_str_patched(&local_var_content).ok();
4340 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
4341 Err(Error::ResponseError(local_var_error))
4342 }
4343}
4344
4345pub async fn update_shared_ui(configuration: &configuration::Configuration, workspace: &str, update_shared_ui_request: models::UpdateSharedUiRequest) -> Result<String, Error<UpdateSharedUiError>> {
4346 let local_var_configuration = configuration;
4347
4348 let local_var_client = &local_var_configuration.client;
4349
4350 let local_var_uri_str = format!("{}/w/{workspace}/shared_ui", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
4351 let mut local_var_req_builder = local_var_client.request(reqwest::Method::PUT, local_var_uri_str.as_str());
4352
4353 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
4354 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
4355 }
4356 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
4357 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
4358 };
4359 local_var_req_builder = local_var_req_builder.json(&update_shared_ui_request);
4360
4361 let local_var_req = local_var_req_builder.build()?;
4362 let local_var_resp = local_var_client.execute(local_var_req).await?;
4363
4364 let local_var_status = local_var_resp.status();
4365 let local_var_content = local_var_resp.text().await?;
4366
4367 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
4368 crate::from_str_patched(&local_var_content).map_err(Error::from)
4369 } else {
4370 let local_var_entity: Option<UpdateSharedUiError> = crate::from_str_patched(&local_var_content).ok();
4371 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
4372 Err(Error::ResponseError(local_var_error))
4373 }
4374}
4375
4376pub async fn upload_ai_skills(configuration: &configuration::Configuration, workspace: &str, upload_ai_skills_request: models::UploadAiSkillsRequest) -> Result<String, Error<UploadAiSkillsError>> {
4377 let local_var_configuration = configuration;
4378
4379 let local_var_client = &local_var_configuration.client;
4380
4381 let local_var_uri_str = format!("{}/w/{workspace}/ai_skills/upload", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
4382 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
4383
4384 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
4385 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
4386 }
4387 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
4388 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
4389 };
4390 local_var_req_builder = local_var_req_builder.json(&upload_ai_skills_request);
4391
4392 let local_var_req = local_var_req_builder.build()?;
4393 let local_var_resp = local_var_client.execute(local_var_req).await?;
4394
4395 let local_var_status = local_var_resp.status();
4396 let local_var_content = local_var_resp.text().await?;
4397
4398 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
4399 crate::from_str_patched(&local_var_content).map_err(Error::from)
4400 } else {
4401 let local_var_entity: Option<UploadAiSkillsError> = crate::from_str_patched(&local_var_content).ok();
4402 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
4403 Err(Error::ResponseError(local_var_error))
4404 }
4405}
4406