pipedrive_rs/apis/
stages_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 [`add_stage`]
19#[derive(Debug, Clone, Serialize, Deserialize)]
20#[serde(untagged)]
21pub enum AddStageError {
22    UnknownValue(serde_json::Value),
23}
24
25/// struct for typed errors of method [`delete_stage`]
26#[derive(Debug, Clone, Serialize, Deserialize)]
27#[serde(untagged)]
28pub enum DeleteStageError {
29    UnknownValue(serde_json::Value),
30}
31
32/// struct for typed errors of method [`delete_stages`]
33#[derive(Debug, Clone, Serialize, Deserialize)]
34#[serde(untagged)]
35pub enum DeleteStagesError {
36    UnknownValue(serde_json::Value),
37}
38
39/// struct for typed errors of method [`get_stage`]
40#[derive(Debug, Clone, Serialize, Deserialize)]
41#[serde(untagged)]
42pub enum GetStageError {
43    UnknownValue(serde_json::Value),
44}
45
46/// struct for typed errors of method [`get_stage_deals`]
47#[derive(Debug, Clone, Serialize, Deserialize)]
48#[serde(untagged)]
49pub enum GetStageDealsError {
50    UnknownValue(serde_json::Value),
51}
52
53/// struct for typed errors of method [`get_stages`]
54#[derive(Debug, Clone, Serialize, Deserialize)]
55#[serde(untagged)]
56pub enum GetStagesError {
57    UnknownValue(serde_json::Value),
58}
59
60/// struct for typed errors of method [`update_stage`]
61#[derive(Debug, Clone, Serialize, Deserialize)]
62#[serde(untagged)]
63pub enum UpdateStageError {
64    UnknownValue(serde_json::Value),
65}
66
67
68/// Adds a new stage, returns the ID upon success.
69pub async fn add_stage(configuration: &configuration::Configuration, add_stage_request: Option<crate::models::AddStageRequest>) -> Result<crate::models::StageResponse200, Error<AddStageError>> {
70    let local_var_configuration = configuration;
71
72    let local_var_client = &local_var_configuration.client;
73
74    let local_var_uri_str = format!("{}/stages", local_var_configuration.base_path);
75    let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
76
77    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
78        let local_var_key = local_var_apikey.key.clone();
79        let local_var_value = match local_var_apikey.prefix {
80            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
81            None => local_var_key,
82        };
83        local_var_req_builder = local_var_req_builder.query(&[("api_token", local_var_value)]);
84    }
85    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
86        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
87    }
88    if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
89        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
90    };
91    local_var_req_builder = local_var_req_builder.json(&add_stage_request);
92
93    let local_var_req = local_var_req_builder.build()?;
94    let local_var_resp = local_var_client.execute(local_var_req).await?;
95
96    let local_var_status = local_var_resp.status();
97    let local_var_content = local_var_resp.text().await?;
98
99    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
100        serde_json::from_str(&local_var_content).map_err(Error::from)
101    } else {
102        let local_var_entity: Option<AddStageError> = serde_json::from_str(&local_var_content).ok();
103        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
104        Err(Error::ResponseError(local_var_error))
105    }
106}
107
108/// Marks a stage as deleted.
109pub async fn delete_stage(configuration: &configuration::Configuration, id: i32) -> Result<crate::models::DeleteStageResponse200, Error<DeleteStageError>> {
110    let local_var_configuration = configuration;
111
112    let local_var_client = &local_var_configuration.client;
113
114    let local_var_uri_str = format!("{}/stages/{id}", local_var_configuration.base_path, id=id);
115    let mut local_var_req_builder = local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
116
117    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
118        let local_var_key = local_var_apikey.key.clone();
119        let local_var_value = match local_var_apikey.prefix {
120            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
121            None => local_var_key,
122        };
123        local_var_req_builder = local_var_req_builder.query(&[("api_token", local_var_value)]);
124    }
125    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
126        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
127    }
128    if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
129        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
130    };
131
132    let local_var_req = local_var_req_builder.build()?;
133    let local_var_resp = local_var_client.execute(local_var_req).await?;
134
135    let local_var_status = local_var_resp.status();
136    let local_var_content = local_var_resp.text().await?;
137
138    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
139        serde_json::from_str(&local_var_content).map_err(Error::from)
140    } else {
141        let local_var_entity: Option<DeleteStageError> = serde_json::from_str(&local_var_content).ok();
142        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
143        Err(Error::ResponseError(local_var_error))
144    }
145}
146
147/// Marks multiple stages as deleted.
148pub async fn delete_stages(configuration: &configuration::Configuration, ids: &str) -> Result<crate::models::DeleteStagesResponse200, Error<DeleteStagesError>> {
149    let local_var_configuration = configuration;
150
151    let local_var_client = &local_var_configuration.client;
152
153    let local_var_uri_str = format!("{}/stages", local_var_configuration.base_path);
154    let mut local_var_req_builder = local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
155
156    local_var_req_builder = local_var_req_builder.query(&[("ids", &ids.to_string())]);
157    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
158        let local_var_key = local_var_apikey.key.clone();
159        let local_var_value = match local_var_apikey.prefix {
160            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
161            None => local_var_key,
162        };
163        local_var_req_builder = local_var_req_builder.query(&[("api_token", local_var_value)]);
164    }
165    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
166        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
167    }
168    if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
169        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
170    };
171
172    let local_var_req = local_var_req_builder.build()?;
173    let local_var_resp = local_var_client.execute(local_var_req).await?;
174
175    let local_var_status = local_var_resp.status();
176    let local_var_content = local_var_resp.text().await?;
177
178    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
179        serde_json::from_str(&local_var_content).map_err(Error::from)
180    } else {
181        let local_var_entity: Option<DeleteStagesError> = serde_json::from_str(&local_var_content).ok();
182        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
183        Err(Error::ResponseError(local_var_error))
184    }
185}
186
187/// Returns data about a specific stage.
188pub async fn get_stage(configuration: &configuration::Configuration, id: i32, everyone: Option<f32>) -> Result<crate::models::GetStageResponse200, Error<GetStageError>> {
189    let local_var_configuration = configuration;
190
191    let local_var_client = &local_var_configuration.client;
192
193    let local_var_uri_str = format!("{}/stages/{id}", local_var_configuration.base_path, id=id);
194    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
195
196    if let Some(ref local_var_str) = everyone {
197        local_var_req_builder = local_var_req_builder.query(&[("everyone", &local_var_str.to_string())]);
198    }
199    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
200        let local_var_key = local_var_apikey.key.clone();
201        let local_var_value = match local_var_apikey.prefix {
202            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
203            None => local_var_key,
204        };
205        local_var_req_builder = local_var_req_builder.query(&[("api_token", local_var_value)]);
206    }
207    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
208        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
209    }
210    if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
211        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
212    };
213
214    let local_var_req = local_var_req_builder.build()?;
215    let local_var_resp = local_var_client.execute(local_var_req).await?;
216
217    let local_var_status = local_var_resp.status();
218    let local_var_content = local_var_resp.text().await?;
219
220    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
221        serde_json::from_str(&local_var_content).map_err(Error::from)
222    } else {
223        let local_var_entity: Option<GetStageError> = serde_json::from_str(&local_var_content).ok();
224        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
225        Err(Error::ResponseError(local_var_error))
226    }
227}
228
229/// Lists deals in a specific stage.
230pub async fn get_stage_deals(configuration: &configuration::Configuration, id: i32, filter_id: Option<i32>, user_id: Option<i32>, everyone: Option<f32>, start: Option<i32>, limit: Option<i32>) -> Result<crate::models::GetStageDealsResponse200, Error<GetStageDealsError>> {
231    let local_var_configuration = configuration;
232
233    let local_var_client = &local_var_configuration.client;
234
235    let local_var_uri_str = format!("{}/stages/{id}/deals", local_var_configuration.base_path, id=id);
236    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
237
238    if let Some(ref local_var_str) = filter_id {
239        local_var_req_builder = local_var_req_builder.query(&[("filter_id", &local_var_str.to_string())]);
240    }
241    if let Some(ref local_var_str) = user_id {
242        local_var_req_builder = local_var_req_builder.query(&[("user_id", &local_var_str.to_string())]);
243    }
244    if let Some(ref local_var_str) = everyone {
245        local_var_req_builder = local_var_req_builder.query(&[("everyone", &local_var_str.to_string())]);
246    }
247    if let Some(ref local_var_str) = start {
248        local_var_req_builder = local_var_req_builder.query(&[("start", &local_var_str.to_string())]);
249    }
250    if let Some(ref local_var_str) = limit {
251        local_var_req_builder = local_var_req_builder.query(&[("limit", &local_var_str.to_string())]);
252    }
253    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
254        let local_var_key = local_var_apikey.key.clone();
255        let local_var_value = match local_var_apikey.prefix {
256            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
257            None => local_var_key,
258        };
259        local_var_req_builder = local_var_req_builder.query(&[("api_token", local_var_value)]);
260    }
261    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
262        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
263    }
264    if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
265        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
266    };
267
268    let local_var_req = local_var_req_builder.build()?;
269    let local_var_resp = local_var_client.execute(local_var_req).await?;
270
271    let local_var_status = local_var_resp.status();
272    let local_var_content = local_var_resp.text().await?;
273
274    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
275        serde_json::from_str(&local_var_content).map_err(Error::from)
276    } else {
277        let local_var_entity: Option<GetStageDealsError> = serde_json::from_str(&local_var_content).ok();
278        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
279        Err(Error::ResponseError(local_var_error))
280    }
281}
282
283/// Returns data about all stages.
284pub async fn get_stages(configuration: &configuration::Configuration, pipeline_id: Option<i32>, start: Option<i32>, limit: Option<i32>) -> Result<crate::models::GetStagesResponse200, Error<GetStagesError>> {
285    let local_var_configuration = configuration;
286
287    let local_var_client = &local_var_configuration.client;
288
289    let local_var_uri_str = format!("{}/stages", local_var_configuration.base_path);
290    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
291
292    if let Some(ref local_var_str) = pipeline_id {
293        local_var_req_builder = local_var_req_builder.query(&[("pipeline_id", &local_var_str.to_string())]);
294    }
295    if let Some(ref local_var_str) = start {
296        local_var_req_builder = local_var_req_builder.query(&[("start", &local_var_str.to_string())]);
297    }
298    if let Some(ref local_var_str) = limit {
299        local_var_req_builder = local_var_req_builder.query(&[("limit", &local_var_str.to_string())]);
300    }
301    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
302        let local_var_key = local_var_apikey.key.clone();
303        let local_var_value = match local_var_apikey.prefix {
304            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
305            None => local_var_key,
306        };
307        local_var_req_builder = local_var_req_builder.query(&[("api_token", local_var_value)]);
308    }
309    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
310        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
311    }
312    if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
313        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
314    };
315
316    let local_var_req = local_var_req_builder.build()?;
317    let local_var_resp = local_var_client.execute(local_var_req).await?;
318
319    let local_var_status = local_var_resp.status();
320    let local_var_content = local_var_resp.text().await?;
321
322    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
323        serde_json::from_str(&local_var_content).map_err(Error::from)
324    } else {
325        let local_var_entity: Option<GetStagesError> = serde_json::from_str(&local_var_content).ok();
326        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
327        Err(Error::ResponseError(local_var_error))
328    }
329}
330
331/// Updates the properties of a stage.
332pub async fn update_stage(configuration: &configuration::Configuration, id: i32, update_stage_request: Option<crate::models::UpdateStageRequest>) -> Result<crate::models::StageResponse200, Error<UpdateStageError>> {
333    let local_var_configuration = configuration;
334
335    let local_var_client = &local_var_configuration.client;
336
337    let local_var_uri_str = format!("{}/stages/{id}", local_var_configuration.base_path, id=id);
338    let mut local_var_req_builder = local_var_client.request(reqwest::Method::PUT, local_var_uri_str.as_str());
339
340    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
341        let local_var_key = local_var_apikey.key.clone();
342        let local_var_value = match local_var_apikey.prefix {
343            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
344            None => local_var_key,
345        };
346        local_var_req_builder = local_var_req_builder.query(&[("api_token", local_var_value)]);
347    }
348    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
349        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
350    }
351    if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
352        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
353    };
354    local_var_req_builder = local_var_req_builder.json(&update_stage_request);
355
356    let local_var_req = local_var_req_builder.build()?;
357    let local_var_resp = local_var_client.execute(local_var_req).await?;
358
359    let local_var_status = local_var_resp.status();
360    let local_var_content = local_var_resp.text().await?;
361
362    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
363        serde_json::from_str(&local_var_content).map_err(Error::from)
364    } else {
365        let local_var_entity: Option<UpdateStageError> = serde_json::from_str(&local_var_content).ok();
366        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
367        Err(Error::ResponseError(local_var_error))
368    }
369}
370
pipedrive_rs/apis/stages_api.rs

pipedrive_rs/apis/
stages_api.rs
