jira_api_v2/apis/
issue_watchers_api.rs1use reqwest;
13use serde::{Deserialize, Serialize};
14use crate::{apis::ResponseContent, models};
15use super::{Error, configuration};
16
17
18#[derive(Debug, Clone, Serialize, Deserialize)]
20#[serde(untagged)]
21pub enum AddWatcherError {
22 Status400(),
23 Status401(),
24 Status403(),
25 Status404(),
26 UnknownValue(serde_json::Value),
27}
28
29#[derive(Debug, Clone, Serialize, Deserialize)]
31#[serde(untagged)]
32pub enum GetIssueWatchersError {
33 Status401(),
34 Status404(),
35 UnknownValue(serde_json::Value),
36}
37
38#[derive(Debug, Clone, Serialize, Deserialize)]
40#[serde(untagged)]
41pub enum RemoveWatcherError {
42 Status400(),
43 Status401(),
44 Status403(),
45 Status404(),
46 UnknownValue(serde_json::Value),
47}
48
49
50pub async fn add_watcher(configuration: &configuration::Configuration, issue_id_or_key: &str, body: &str) -> Result<serde_json::Value, Error<AddWatcherError>> {
52 let p_issue_id_or_key = issue_id_or_key;
54 let p_body = body;
55
56 let uri_str = format!("{}/rest/api/2/issue/{issueIdOrKey}/watchers", configuration.base_path, issueIdOrKey=crate::apis::urlencode(p_issue_id_or_key));
57 let mut req_builder = configuration.client.request(reqwest::Method::POST, &uri_str);
58
59 if let Some(ref user_agent) = configuration.user_agent {
60 req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
61 }
62 if let Some(ref token) = configuration.oauth_access_token {
63 req_builder = req_builder.bearer_auth(token.to_owned());
64 };
65 if let Some(ref auth_conf) = configuration.basic_auth {
66 req_builder = req_builder.basic_auth(auth_conf.0.to_owned(), auth_conf.1.to_owned());
67 };
68 req_builder = req_builder.json(&p_body);
69
70 let req = req_builder.build()?;
71 let resp = configuration.client.execute(req).await?;
72
73 let status = resp.status();
74
75 if !status.is_client_error() && !status.is_server_error() {
76 let content = resp.text().await?;
77 serde_json::from_str(&content).map_err(Error::from)
78 } else {
79 let content = resp.text().await?;
80 let entity: Option<AddWatcherError> = serde_json::from_str(&content).ok();
81 Err(Error::ResponseError(ResponseContent { status, content, entity }))
82 }
83}
84
85pub async fn get_issue_watchers(configuration: &configuration::Configuration, issue_id_or_key: &str) -> Result<models::Watchers, Error<GetIssueWatchersError>> {
87 let p_issue_id_or_key = issue_id_or_key;
89
90 let uri_str = format!("{}/rest/api/2/issue/{issueIdOrKey}/watchers", configuration.base_path, issueIdOrKey=crate::apis::urlencode(p_issue_id_or_key));
91 let mut req_builder = configuration.client.request(reqwest::Method::GET, &uri_str);
92
93 if let Some(ref user_agent) = configuration.user_agent {
94 req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
95 }
96 if let Some(ref token) = configuration.oauth_access_token {
97 req_builder = req_builder.bearer_auth(token.to_owned());
98 };
99 if let Some(ref auth_conf) = configuration.basic_auth {
100 req_builder = req_builder.basic_auth(auth_conf.0.to_owned(), auth_conf.1.to_owned());
101 };
102
103 let req = req_builder.build()?;
104 let resp = configuration.client.execute(req).await?;
105
106 let status = resp.status();
107
108 if !status.is_client_error() && !status.is_server_error() {
109 let content = resp.text().await?;
110 serde_json::from_str(&content).map_err(Error::from)
111 } else {
112 let content = resp.text().await?;
113 let entity: Option<GetIssueWatchersError> = serde_json::from_str(&content).ok();
114 Err(Error::ResponseError(ResponseContent { status, content, entity }))
115 }
116}
117
118pub async fn remove_watcher(configuration: &configuration::Configuration, issue_id_or_key: &str, username: Option<&str>, account_id: Option<&str>) -> Result<(), Error<RemoveWatcherError>> {
120 let p_issue_id_or_key = issue_id_or_key;
122 let p_username = username;
123 let p_account_id = account_id;
124
125 let uri_str = format!("{}/rest/api/2/issue/{issueIdOrKey}/watchers", configuration.base_path, issueIdOrKey=crate::apis::urlencode(p_issue_id_or_key));
126 let mut req_builder = configuration.client.request(reqwest::Method::DELETE, &uri_str);
127
128 if let Some(ref param_value) = p_username {
129 req_builder = req_builder.query(&[("username", ¶m_value.to_string())]);
130 }
131 if let Some(ref param_value) = p_account_id {
132 req_builder = req_builder.query(&[("accountId", ¶m_value.to_string())]);
133 }
134 if let Some(ref user_agent) = configuration.user_agent {
135 req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
136 }
137 if let Some(ref token) = configuration.oauth_access_token {
138 req_builder = req_builder.bearer_auth(token.to_owned());
139 };
140 if let Some(ref auth_conf) = configuration.basic_auth {
141 req_builder = req_builder.basic_auth(auth_conf.0.to_owned(), auth_conf.1.to_owned());
142 };
143
144 let req = req_builder.build()?;
145 let resp = configuration.client.execute(req).await?;
146
147 let status = resp.status();
148
149 if !status.is_client_error() && !status.is_server_error() {
150 Ok(())
151 } else {
152 let content = resp.text().await?;
153 let entity: Option<RemoveWatcherError> = serde_json::from_str(&content).ok();
154 Err(Error::ResponseError(ResponseContent { status, content, entity }))
155 }
156}
157