pipedrive_rs/apis/
mailbox_api.rs

1/*
2 * Pipedrive API v1
3 *
4 * No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator)
5 *
6 * The version of the OpenAPI document: 1.0.0
7 * 
8 * Generated by: https://openapi-generator.tech
9 */
10
11
12use reqwest;
13
14use crate::apis::ResponseContent;
15use super::{Error, configuration};
16
17
18/// struct for typed errors of method [`delete_mail_thread`]
19#[derive(Debug, Clone, Serialize, Deserialize)]
20#[serde(untagged)]
21pub enum DeleteMailThreadError {
22    UnknownValue(serde_json::Value),
23}
24
25/// struct for typed errors of method [`get_mail_message`]
26#[derive(Debug, Clone, Serialize, Deserialize)]
27#[serde(untagged)]
28pub enum GetMailMessageError {
29    UnknownValue(serde_json::Value),
30}
31
32/// struct for typed errors of method [`get_mail_thread`]
33#[derive(Debug, Clone, Serialize, Deserialize)]
34#[serde(untagged)]
35pub enum GetMailThreadError {
36    UnknownValue(serde_json::Value),
37}
38
39/// struct for typed errors of method [`get_mail_thread_messages`]
40#[derive(Debug, Clone, Serialize, Deserialize)]
41#[serde(untagged)]
42pub enum GetMailThreadMessagesError {
43    UnknownValue(serde_json::Value),
44}
45
46/// struct for typed errors of method [`get_mail_threads`]
47#[derive(Debug, Clone, Serialize, Deserialize)]
48#[serde(untagged)]
49pub enum GetMailThreadsError {
50    UnknownValue(serde_json::Value),
51}
52
53/// struct for typed errors of method [`update_mail_thread_details`]
54#[derive(Debug, Clone, Serialize, Deserialize)]
55#[serde(untagged)]
56pub enum UpdateMailThreadDetailsError {
57    UnknownValue(serde_json::Value),
58}
59
60
61/// Marks a mail thread as deleted.
62pub async fn delete_mail_thread(configuration: &configuration::Configuration, id: i32) -> Result<crate::models::DeleteMailThreadResponse200, Error<DeleteMailThreadError>> {
63    let local_var_configuration = configuration;
64
65    let local_var_client = &local_var_configuration.client;
66
67    let local_var_uri_str = format!("{}/mailbox/mailThreads/{id}", local_var_configuration.base_path, id=id);
68    let mut local_var_req_builder = local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
69
70    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
71        let local_var_key = local_var_apikey.key.clone();
72        let local_var_value = match local_var_apikey.prefix {
73            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
74            None => local_var_key,
75        };
76        local_var_req_builder = local_var_req_builder.query(&[("api_token", local_var_value)]);
77    }
78    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
79        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
80    }
81    if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
82        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
83    };
84
85    let local_var_req = local_var_req_builder.build()?;
86    let local_var_resp = local_var_client.execute(local_var_req).await?;
87
88    let local_var_status = local_var_resp.status();
89    let local_var_content = local_var_resp.text().await?;
90
91    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
92        serde_json::from_str(&local_var_content).map_err(Error::from)
93    } else {
94        let local_var_entity: Option<DeleteMailThreadError> = serde_json::from_str(&local_var_content).ok();
95        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
96        Err(Error::ResponseError(local_var_error))
97    }
98}
99
100/// Returns data about a specific mail message.
101pub async fn get_mail_message(configuration: &configuration::Configuration, id: i32, include_body: Option<f32>) -> Result<crate::models::MailMessageResponse200, Error<GetMailMessageError>> {
102    let local_var_configuration = configuration;
103
104    let local_var_client = &local_var_configuration.client;
105
106    let local_var_uri_str = format!("{}/mailbox/mailMessages/{id}", local_var_configuration.base_path, id=id);
107    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
108
109    if let Some(ref local_var_str) = include_body {
110        local_var_req_builder = local_var_req_builder.query(&[("include_body", &local_var_str.to_string())]);
111    }
112    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
113        let local_var_key = local_var_apikey.key.clone();
114        let local_var_value = match local_var_apikey.prefix {
115            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
116            None => local_var_key,
117        };
118        local_var_req_builder = local_var_req_builder.query(&[("api_token", local_var_value)]);
119    }
120    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
121        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
122    }
123    if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
124        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
125    };
126
127    let local_var_req = local_var_req_builder.build()?;
128    let local_var_resp = local_var_client.execute(local_var_req).await?;
129
130    let local_var_status = local_var_resp.status();
131    let local_var_content = local_var_resp.text().await?;
132
133    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
134        serde_json::from_str(&local_var_content).map_err(Error::from)
135    } else {
136        let local_var_entity: Option<GetMailMessageError> = serde_json::from_str(&local_var_content).ok();
137        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
138        Err(Error::ResponseError(local_var_error))
139    }
140}
141
142/// Returns a specific mail thread.
143pub async fn get_mail_thread(configuration: &configuration::Configuration, id: i32) -> Result<crate::models::GetOneMailThreadResponse200, Error<GetMailThreadError>> {
144    let local_var_configuration = configuration;
145
146    let local_var_client = &local_var_configuration.client;
147
148    let local_var_uri_str = format!("{}/mailbox/mailThreads/{id}", local_var_configuration.base_path, id=id);
149    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
150
151    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
152        let local_var_key = local_var_apikey.key.clone();
153        let local_var_value = match local_var_apikey.prefix {
154            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
155            None => local_var_key,
156        };
157        local_var_req_builder = local_var_req_builder.query(&[("api_token", local_var_value)]);
158    }
159    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
160        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
161    }
162    if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
163        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
164    };
165
166    let local_var_req = local_var_req_builder.build()?;
167    let local_var_resp = local_var_client.execute(local_var_req).await?;
168
169    let local_var_status = local_var_resp.status();
170    let local_var_content = local_var_resp.text().await?;
171
172    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
173        serde_json::from_str(&local_var_content).map_err(Error::from)
174    } else {
175        let local_var_entity: Option<GetMailThreadError> = serde_json::from_str(&local_var_content).ok();
176        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
177        Err(Error::ResponseError(local_var_error))
178    }
179}
180
181/// Returns all the mail messages inside a specified mail thread.
182pub async fn get_mail_thread_messages(configuration: &configuration::Configuration, id: i32) -> Result<crate::models::GetAllMailMessagesOfMailThreadResponse200, Error<GetMailThreadMessagesError>> {
183    let local_var_configuration = configuration;
184
185    let local_var_client = &local_var_configuration.client;
186
187    let local_var_uri_str = format!("{}/mailbox/mailThreads/{id}/mailMessages", local_var_configuration.base_path, id=id);
188    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
189
190    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
191        let local_var_key = local_var_apikey.key.clone();
192        let local_var_value = match local_var_apikey.prefix {
193            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
194            None => local_var_key,
195        };
196        local_var_req_builder = local_var_req_builder.query(&[("api_token", local_var_value)]);
197    }
198    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
199        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
200    }
201    if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
202        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
203    };
204
205    let local_var_req = local_var_req_builder.build()?;
206    let local_var_resp = local_var_client.execute(local_var_req).await?;
207
208    let local_var_status = local_var_resp.status();
209    let local_var_content = local_var_resp.text().await?;
210
211    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
212        serde_json::from_str(&local_var_content).map_err(Error::from)
213    } else {
214        let local_var_entity: Option<GetMailThreadMessagesError> = serde_json::from_str(&local_var_content).ok();
215        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
216        Err(Error::ResponseError(local_var_error))
217    }
218}
219
220/// Returns mail threads in a specified folder ordered by the most recent message within.
221pub async fn get_mail_threads(configuration: &configuration::Configuration, folder: &str, start: Option<i32>, limit: Option<i32>) -> Result<crate::models::GetMailThreadsResponse200, Error<GetMailThreadsError>> {
222    let local_var_configuration = configuration;
223
224    let local_var_client = &local_var_configuration.client;
225
226    let local_var_uri_str = format!("{}/mailbox/mailThreads", local_var_configuration.base_path);
227    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
228
229    local_var_req_builder = local_var_req_builder.query(&[("folder", &folder.to_string())]);
230    if let Some(ref local_var_str) = start {
231        local_var_req_builder = local_var_req_builder.query(&[("start", &local_var_str.to_string())]);
232    }
233    if let Some(ref local_var_str) = limit {
234        local_var_req_builder = local_var_req_builder.query(&[("limit", &local_var_str.to_string())]);
235    }
236    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
237        let local_var_key = local_var_apikey.key.clone();
238        let local_var_value = match local_var_apikey.prefix {
239            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
240            None => local_var_key,
241        };
242        local_var_req_builder = local_var_req_builder.query(&[("api_token", local_var_value)]);
243    }
244    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
245        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
246    }
247    if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
248        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
249    };
250
251    let local_var_req = local_var_req_builder.build()?;
252    let local_var_resp = local_var_client.execute(local_var_req).await?;
253
254    let local_var_status = local_var_resp.status();
255    let local_var_content = local_var_resp.text().await?;
256
257    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
258        serde_json::from_str(&local_var_content).map_err(Error::from)
259    } else {
260        let local_var_entity: Option<GetMailThreadsError> = serde_json::from_str(&local_var_content).ok();
261        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
262        Err(Error::ResponseError(local_var_error))
263    }
264}
265
266/// Updates the properties of a mail thread.
267pub async fn update_mail_thread_details(configuration: &configuration::Configuration, id: i32, deal_id: Option<i32>, lead_id: Option<&str>, shared_flag: Option<f32>, read_flag: Option<f32>, archived_flag: Option<f32>) -> Result<crate::models::UpdateMailThreadDetailsResponse200, Error<UpdateMailThreadDetailsError>> {
268    let local_var_configuration = configuration;
269
270    let local_var_client = &local_var_configuration.client;
271
272    let local_var_uri_str = format!("{}/mailbox/mailThreads/{id}", local_var_configuration.base_path, id=id);
273    let mut local_var_req_builder = local_var_client.request(reqwest::Method::PUT, local_var_uri_str.as_str());
274
275    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
276        let local_var_key = local_var_apikey.key.clone();
277        let local_var_value = match local_var_apikey.prefix {
278            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
279            None => local_var_key,
280        };
281        local_var_req_builder = local_var_req_builder.query(&[("api_token", local_var_value)]);
282    }
283    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
284        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
285    }
286    if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
287        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
288    };
289    let mut local_var_form_params = std::collections::HashMap::new();
290    if let Some(local_var_param_value) = deal_id {
291        local_var_form_params.insert("deal_id", local_var_param_value.to_string());
292    }
293    if let Some(local_var_param_value) = lead_id {
294        local_var_form_params.insert("lead_id", local_var_param_value.to_string());
295    }
296    if let Some(local_var_param_value) = shared_flag {
297        local_var_form_params.insert("shared_flag", local_var_param_value.to_string());
298    }
299    if let Some(local_var_param_value) = read_flag {
300        local_var_form_params.insert("read_flag", local_var_param_value.to_string());
301    }
302    if let Some(local_var_param_value) = archived_flag {
303        local_var_form_params.insert("archived_flag", local_var_param_value.to_string());
304    }
305    local_var_req_builder = local_var_req_builder.form(&local_var_form_params);
306
307    let local_var_req = local_var_req_builder.build()?;
308    let local_var_resp = local_var_client.execute(local_var_req).await?;
309
310    let local_var_status = local_var_resp.status();
311    let local_var_content = local_var_resp.text().await?;
312
313    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
314        serde_json::from_str(&local_var_content).map_err(Error::from)
315    } else {
316        let local_var_entity: Option<UpdateMailThreadDetailsError> = serde_json::from_str(&local_var_content).ok();
317        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
318        Err(Error::ResponseError(local_var_error))
319    }
320}
321
pipedrive_rs/apis/mailbox_api.rs

pipedrive_rs/apis/
mailbox_api.rs
