edc_connector_client/api/
contract_definitions.rs

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

edc_connector_client/api/
contract_definitions.rs
