ory_client/apis/
courier_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 GetCourierMessageError {
22 Status400(models::ErrorGeneric),
23 DefaultResponse(models::ErrorGeneric),
24 UnknownValue(serde_json::Value),
25}
26
27#[derive(Debug, Clone, Serialize, Deserialize)]
29#[serde(untagged)]
30pub enum ListCourierMessagesError {
31 Status400(models::ErrorGeneric),
32 DefaultResponse(models::ErrorGeneric),
33 UnknownValue(serde_json::Value),
34}
35
36
37pub async fn get_courier_message(configuration: &configuration::Configuration, id: &str) -> Result<models::Message, Error<GetCourierMessageError>> {
39 let local_var_configuration = configuration;
40
41 let local_var_client = &local_var_configuration.client;
42
43 let local_var_uri_str = format!("{}/admin/courier/messages/{id}", local_var_configuration.base_path, id=crate::apis::urlencode(id));
44 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
45
46 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
47 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
48 }
49 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
50 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
51 };
52
53 let local_var_req = local_var_req_builder.build()?;
54 let local_var_resp = local_var_client.execute(local_var_req).await?;
55
56 let local_var_status = local_var_resp.status();
57 let local_var_content = local_var_resp.text().await?;
58
59 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
60 serde_json::from_str(&local_var_content).map_err(Error::from)
61 } else {
62 let local_var_entity: Option<GetCourierMessageError> = serde_json::from_str(&local_var_content).ok();
63 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
64 Err(Error::ResponseError(local_var_error))
65 }
66}
67
68pub async fn list_courier_messages(configuration: &configuration::Configuration, page_size: Option<i64>, page_token: Option<&str>, status: Option<models::CourierMessageStatus>, recipient: Option<&str>) -> Result<Vec<models::Message>, Error<ListCourierMessagesError>> {
70 let local_var_configuration = configuration;
71
72 let local_var_client = &local_var_configuration.client;
73
74 let local_var_uri_str = format!("{}/admin/courier/messages", local_var_configuration.base_path);
75 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
76
77 if let Some(ref local_var_str) = page_size {
78 local_var_req_builder = local_var_req_builder.query(&[("page_size", &local_var_str.to_string())]);
79 }
80 if let Some(ref local_var_str) = page_token {
81 local_var_req_builder = local_var_req_builder.query(&[("page_token", &local_var_str.to_string())]);
82 }
83 if let Some(ref local_var_str) = status {
84 local_var_req_builder = local_var_req_builder.query(&[("status", &local_var_str.to_string())]);
85 }
86 if let Some(ref local_var_str) = recipient {
87 local_var_req_builder = local_var_req_builder.query(&[("recipient", &local_var_str.to_string())]);
88 }
89 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
90 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
91 }
92 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
93 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
94 };
95
96 let local_var_req = local_var_req_builder.build()?;
97 let local_var_resp = local_var_client.execute(local_var_req).await?;
98
99 let local_var_status = local_var_resp.status();
100 let local_var_content = local_var_resp.text().await?;
101
102 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
103 serde_json::from_str(&local_var_content).map_err(Error::from)
104 } else {
105 let local_var_entity: Option<ListCourierMessagesError> = serde_json::from_str(&local_var_content).ok();
106 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
107 Err(Error::ResponseError(local_var_error))
108 }
109}
110