rework client a little to make more low level methods available
This commit is contained in:
Vincent Stuyck
parent
96402420c1
commit
c39315b2b7
204
src/client.rs
204
src/client.rs
@ -206,12 +206,15 @@ impl Client {
|
||||
}
|
||||
|
||||
impl InnerClient {
|
||||
#[inline]
|
||||
pub(crate) fn object_url(&self, domain_type: DomainType, id: impl Display) -> String {
|
||||
format!("{}/objects/{}/{}", self.url, domain_type, id)
|
||||
}
|
||||
#[inline]
|
||||
pub(crate) fn collection_url(&self, domain_type: DomainType) -> String {
|
||||
format!("{}/domain-types/{}/collections/all", self.url, domain_type)
|
||||
}
|
||||
#[inline]
|
||||
pub(crate) fn bulk_action_url(&self, domain_type: DomainType, action: BulkAction) -> String {
|
||||
format!(
|
||||
"{}/domain-types/{}/actions/bulk-{}/invoke",
|
||||
@ -282,114 +285,231 @@ impl InnerClient {
|
||||
}
|
||||
}
|
||||
|
||||
pub(crate) async fn create_domain_object<E: DomainExtension>(
|
||||
pub(crate) async fn create<O, Q>(
|
||||
&self,
|
||||
body: &E::CreationRequest,
|
||||
query: &E::CreationQuery,
|
||||
) -> Result<()> {
|
||||
domain_type: DomainType,
|
||||
object: &O,
|
||||
query: &Q
|
||||
) -> Result<()>
|
||||
where
|
||||
O: Serialize,
|
||||
Q: Serialize
|
||||
{
|
||||
let url = self.collection_url(domain_type);
|
||||
let request = self
|
||||
.http
|
||||
.post(self.collection_url(E::DOMAIN_TYPE))
|
||||
.json(body)
|
||||
.post(url)
|
||||
.json(object)
|
||||
.query(query)
|
||||
.build()
|
||||
.unwrap();
|
||||
|
||||
self.invoke_api(request).await
|
||||
}
|
||||
pub(crate) async fn read_domain_object<E: DomainExtension>(
|
||||
pub(crate) async fn create_domain_object<E: DomainExtension>(
|
||||
&self,
|
||||
object: &E::CreationRequest,
|
||||
query: &E::CreationQuery,
|
||||
) -> Result<()> {
|
||||
self.create(E::DOMAIN_TYPE, object, query).await
|
||||
}
|
||||
|
||||
pub(crate) async fn read<O, Q>(
|
||||
&self,
|
||||
domain_type: DomainType,
|
||||
id: impl Display,
|
||||
query: &E::ReadQuery,
|
||||
) -> Result<DomainObject<E>> {
|
||||
query: &Q,
|
||||
) -> Result<O>
|
||||
where
|
||||
O: DeserializeOwned,
|
||||
Q: Serialize
|
||||
{
|
||||
let url = self.object_url(domain_type, id);
|
||||
let request = self
|
||||
.http
|
||||
.get(self.object_url(E::DOMAIN_TYPE, id))
|
||||
.get(url)
|
||||
.query(query)
|
||||
.build()
|
||||
.unwrap();
|
||||
|
||||
self.query_api(request).await
|
||||
}
|
||||
pub(crate) async fn update_domain_object<E: DomainExtension>(
|
||||
pub(crate) async fn read_domain_object<E: DomainExtension>(
|
||||
&self,
|
||||
id: impl Display,
|
||||
request: &E::UpdateRequest,
|
||||
) -> Result<()> {
|
||||
let url = self.object_url(E::DOMAIN_TYPE, id);
|
||||
query: &E::ReadQuery,
|
||||
) -> Result<DomainObject<E>> {
|
||||
self.read(E::DOMAIN_TYPE, id, query).await
|
||||
}
|
||||
|
||||
pub(crate) async fn update<O>(
|
||||
&self,
|
||||
domain_type: DomainType,
|
||||
id: impl Display,
|
||||
object: &O,
|
||||
) -> Result<()>
|
||||
where
|
||||
O: Serialize,
|
||||
{
|
||||
let url = self.object_url(domain_type, id);
|
||||
let etag = self.get_etag(&url).await?;
|
||||
|
||||
let request = self
|
||||
.http
|
||||
.put(url)
|
||||
.json(&request)
|
||||
.json(object)
|
||||
.header(reqwest::header::IF_MATCH, etag)
|
||||
.build()
|
||||
.unwrap();
|
||||
|
||||
self.invoke_api(request).await
|
||||
}
|
||||
pub(crate) async fn update_domain_object<E: DomainExtension>(
|
||||
&self,
|
||||
id: impl Display,
|
||||
object: &E::UpdateRequest,
|
||||
) -> Result<()> {
|
||||
self.update(E::DOMAIN_TYPE, id, object).await
|
||||
}
|
||||
|
||||
pub(crate) async fn delete<Q>(
|
||||
&self,
|
||||
domain_type: DomainType,
|
||||
id: impl Display,
|
||||
query: &Q,
|
||||
) -> Result<()>
|
||||
where
|
||||
Q: Serialize,
|
||||
{
|
||||
let url = self.object_url(domain_type, id);
|
||||
let request = self
|
||||
.http
|
||||
.delete(url)
|
||||
.query(&query)
|
||||
.build()
|
||||
.unwrap();
|
||||
|
||||
self.invoke_api(request).await
|
||||
}
|
||||
pub(crate) async fn delete_domain_object<E: DomainExtension>(
|
||||
&self,
|
||||
id: impl Display,
|
||||
query: &E::DeleteQuery,
|
||||
) -> Result<()> {
|
||||
self.delete(E::DOMAIN_TYPE, id, query).await
|
||||
}
|
||||
|
||||
pub(crate) async fn bulk_create<O, Q>(
|
||||
&self,
|
||||
domain_type: DomainType,
|
||||
entries: &[O],
|
||||
query: &Q,
|
||||
) -> Result<()>
|
||||
where
|
||||
O: Serialize,
|
||||
Q: Serialize,
|
||||
{
|
||||
#[derive(Serialize)]
|
||||
struct Request<'a, E: Serialize> {
|
||||
entries: &'a [E],
|
||||
}
|
||||
let url = self.bulk_action_url(domain_type, BulkAction::Create);
|
||||
let body = Request::<O> { entries };
|
||||
|
||||
let request = self
|
||||
.http
|
||||
.delete(self.object_url(E::DOMAIN_TYPE, id))
|
||||
.query(&query)
|
||||
.post(url)
|
||||
.json(&body)
|
||||
.query(query)
|
||||
.build()
|
||||
.unwrap();
|
||||
|
||||
self.invoke_api(request).await
|
||||
}
|
||||
|
||||
pub(crate) async fn bulk_create_domain_objects<E: BulkCreateDomainExtension>(
|
||||
&self,
|
||||
entries: &[E::CreationRequest],
|
||||
query: &E::CreationQuery,
|
||||
) -> Result<()> {
|
||||
#[derive(Serialize)]
|
||||
struct Request<'a, D: BulkCreateDomainExtension> {
|
||||
entries: &'a [D::CreationRequest],
|
||||
self.bulk_create(E::DOMAIN_TYPE, entries, query).await
|
||||
}
|
||||
|
||||
let request = self
|
||||
.http
|
||||
.post(self.bulk_action_url(E::DOMAIN_TYPE, BulkAction::Create))
|
||||
.json(&Request::<E> { entries })
|
||||
pub(crate) async fn bulk_read<O, Q>(
|
||||
&self,
|
||||
domain_type: DomainType,
|
||||
query: &Q
|
||||
) -> Result<Vec<DomainObject<O>>>
|
||||
where
|
||||
O: DeserializeOwned,
|
||||
Q: Serialize
|
||||
{
|
||||
let url = self.collection_url(domain_type);
|
||||
let request = self.http
|
||||
.get(url)
|
||||
.query(query)
|
||||
.build()
|
||||
.unwrap();
|
||||
|
||||
self.invoke_api(request).await
|
||||
let response: DomainCollection<O> = self.query_api(request).await?;
|
||||
Ok(response.value)
|
||||
|
||||
}
|
||||
pub(crate) async fn bulk_read_domain_objects<E: BulkReadDomainExtension>(
|
||||
&self,
|
||||
query: &E::BulkReadQuery,
|
||||
) -> Result<Vec<DomainObject<E>>> {
|
||||
self.bulk_read(E::DOMAIN_TYPE, query).await
|
||||
}
|
||||
|
||||
pub(crate) async fn bulk_update<O>(
|
||||
&self,
|
||||
domain_type: DomainType,
|
||||
entries: &[O],
|
||||
) -> Result<()>
|
||||
where
|
||||
O: Serialize,
|
||||
{
|
||||
#[derive(Serialize)]
|
||||
struct Request<'a, E: Serialize> {
|
||||
entries: &'a [E],
|
||||
}
|
||||
|
||||
let url = self.bulk_action_url(domain_type, BulkAction::Update);
|
||||
let body = Request::<O> { entries };
|
||||
|
||||
let request = self
|
||||
.http
|
||||
.get(self.collection_url(E::DOMAIN_TYPE))
|
||||
.query(query)
|
||||
.put(url)
|
||||
.json(&body)
|
||||
.build()
|
||||
.unwrap();
|
||||
|
||||
let response: DomainCollection<E> = self.query_api(request).await?;
|
||||
Ok(response.value)
|
||||
self.invoke_api(request).await
|
||||
}
|
||||
pub(crate) async fn bulk_update_domain_objects<E: BulkUpdateDomainExtension>(
|
||||
&self,
|
||||
entries: &[E::BulkUpdateRequest],
|
||||
) -> Result<()> {
|
||||
#[derive(Serialize)]
|
||||
struct Request<'a, D: BulkUpdateDomainExtension> {
|
||||
entries: &'a [D::BulkUpdateRequest],
|
||||
self.bulk_update(E::DOMAIN_TYPE, entries).await
|
||||
}
|
||||
|
||||
pub(crate) async fn bulk_delete(
|
||||
&self,
|
||||
domain_type: DomainType,
|
||||
entries: &[String]
|
||||
) -> Result<()> {
|
||||
#[derive(Serialize)]
|
||||
struct Request<'a> {
|
||||
entries: &'a [String],
|
||||
}
|
||||
|
||||
let url = self.bulk_action_url(domain_type, BulkAction::Delete);
|
||||
let body = Request { entries };
|
||||
|
||||
let request = self
|
||||
.http
|
||||
.put(self.bulk_action_url(E::DOMAIN_TYPE, BulkAction::Update))
|
||||
.json(&Request::<E> { entries })
|
||||
.post(url)
|
||||
.json(&body)
|
||||
.build()
|
||||
.unwrap();
|
||||
|
||||
@ -399,19 +519,7 @@ impl InnerClient {
|
||||
&self,
|
||||
entries: &[String],
|
||||
) -> Result<()> {
|
||||
#[derive(Serialize)]
|
||||
struct Request<'a> {
|
||||
entries: &'a [String],
|
||||
}
|
||||
|
||||
let request = self
|
||||
.http
|
||||
.post(self.bulk_action_url(E::DOMAIN_TYPE, BulkAction::Delete))
|
||||
.json(&Request { entries })
|
||||
.build()
|
||||
.unwrap();
|
||||
|
||||
self.invoke_api(request).await
|
||||
self.bulk_delete(E::DOMAIN_TYPE, entries).await
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user