edc_connector_client/api/
secrets.rs

1use crate::{
2    client::EdcConnectorClientInternal,
3    types::{
4        context::{WithContext, WithContextRef},
5        response::IdResponse,
6        secret::{NewSecret, Secret},
7    },
8    EdcResult,
9};
10
11pub struct SecretsApi<'a>(&'a EdcConnectorClientInternal);
12
13impl<'a> SecretsApi<'a> {
14    pub(crate) fn new(client: &'a EdcConnectorClientInternal) -> SecretsApi<'a> {
15        SecretsApi(client)
16    }
17
18    pub async fn create(&self, asset: &NewSecret) -> EdcResult<IdResponse<String>> {
19        let url = self.get_endpoint(&[]);
20        self.0
21            .post::<_, WithContext<IdResponse<String>>>(
22                url,
23                &WithContextRef::default_context(asset),
24            )
25            .await
26            .map(|ctx| ctx.inner)
27    }
28
29    pub async fn get(&self, id: &str) -> EdcResult<Secret> {
30        let url = self.get_endpoint(&[id]);
31        self.0
32            .get::<WithContext<Secret>>(url)
33            .await
34            .map(|ctx| ctx.inner)
35    }
36
37    pub async fn update(&self, asset: &Secret) -> EdcResult<()> {
38        let url = self.get_endpoint(&[]);
39        self.0
40            .put(url, &WithContextRef::default_context(asset))
41            .await
42    }
43
44    pub async fn delete(&self, id: &str) -> EdcResult<()> {
45        let url = self.get_endpoint(&[id]);
46        self.0.del(url).await
47    }
48
49    fn get_endpoint(&self, paths: &[&str]) -> String {
50        [self.0.management_url.as_str(), "v3", "secrets"]
51            .into_iter()
52            .chain(paths.iter().copied())
53            .collect::<Vec<_>>()
54            .join("/")
55    }
56}
edc_connector_client/api/secrets.rs

edc_connector_client/api/
secrets.rs
