use serde_json::json; use crate::model::*; use crate::FluentRequest; use serde::{Serialize, Deserialize}; use httpclient::InMemoryResponseExt; use crate::AsanaClient; /**You should use this struct via [`AsanaClient::create_status_for_object`]. On request success, this will return a [`CreateStatusForObjectResponse`].*/ #[derive(Debug, Clone, Serialize, Deserialize)] pub struct CreateStatusForObjectRequest { pub data: StatusUpdateRequest, pub limit: Option, pub offset: Option, pub opt_fields: Option>, pub opt_pretty: Option, } impl CreateStatusForObjectRequest {} impl FluentRequest<'_, CreateStatusForObjectRequest> { pub fn limit(mut self, limit: i64) -> Self { self.params.limit = Some(limit); self } pub fn offset(mut self, offset: &str) -> Self { self.params.offset = Some(offset.to_owned()); self } pub fn opt_fields( mut self, opt_fields: impl IntoIterator>, ) -> Self { self .params .opt_fields = Some( opt_fields.into_iter().map(|s| s.as_ref().to_owned()).collect(), ); self } pub fn opt_pretty(mut self, opt_pretty: bool) -> Self { self.params.opt_pretty = Some(opt_pretty); self } } impl<'a> ::std::future::IntoFuture for FluentRequest<'a, CreateStatusForObjectRequest> { type Output = httpclient::InMemoryResult; type IntoFuture = ::futures::future::BoxFuture<'a, Self::Output>; fn into_future(self) -> Self::IntoFuture { Box::pin(async move { let url = "/status_updates"; let mut r = self.client.client.post(url); r = r.json(json!({ "data" : self.params.data })); if let Some(ref unwrapped) = self.params.limit { r = r.query("limit", &unwrapped.to_string()); } if let Some(ref unwrapped) = self.params.offset { r = r.query("offset", &unwrapped.to_string()); } if let Some(ref unwrapped) = self.params.opt_fields { for item in unwrapped { r = r.query("opt_fields[]", &item.to_string()); } } if let Some(ref unwrapped) = self.params.opt_pretty { r = r.query("opt_pretty", &unwrapped.to_string()); } r = self.client.authenticate(r); let res = r.await?; res.json().map_err(Into::into) }) } }