71 lines
2.6 KiB
Rust
71 lines
2.6 KiB
Rust
pub struct Event {
|
|
pub app: crate::app::App,
|
|
pub token: textsender_models::token::LoginResult,
|
|
}
|
|
|
|
impl Event {
|
|
pub async fn get(
|
|
&self,
|
|
scheduled_message_id: &uuid::Uuid,
|
|
) -> Result<Vec<textsender_models::message::scheduling::ScheduledMessageEvent>, std::io::Error>
|
|
{
|
|
let client = reqwest::Client::new();
|
|
let endpoint =
|
|
format!("api/v1/schedule/message/event?scheduled_message_id={scheduled_message_id}");
|
|
let api_url = format!("{}/{endpoint}", self.app.api_url);
|
|
|
|
println!("Url: {api_url:?}");
|
|
|
|
let (key, header) = super::auth_header(&self.token.access_token);
|
|
|
|
match client.get(api_url).header(key, header).send().await {
|
|
Ok(response) => match response.status() {
|
|
reqwest::StatusCode::OK => match response.text().await {
|
|
Ok(val) => match parse_response(&val).await {
|
|
Ok(login_result) => Ok(login_result),
|
|
Err(err) => Err(err),
|
|
},
|
|
Err(err) => Err(std::io::Error::other(err)),
|
|
},
|
|
_ => Err(std::io::Error::other(
|
|
"Error getting Scheduled Message Event",
|
|
)),
|
|
},
|
|
Err(err) => Err(std::io::Error::other(err.to_string())),
|
|
}
|
|
}
|
|
}
|
|
|
|
async fn parse_response(
|
|
response: &str,
|
|
) -> Result<Vec<textsender_models::message::scheduling::ScheduledMessageEvent>, std::io::Error> {
|
|
match serde_json::from_str::<serde_json::Value>(response) {
|
|
Ok(j) => match j.get("data") {
|
|
Some(serde_json::Value::Array(lrs)) => {
|
|
if lrs.is_empty() {
|
|
Err(std::io::Error::other("Error response is empty"))
|
|
} else {
|
|
let mut events: Vec<
|
|
textsender_models::message::scheduling::ScheduledMessageEvent,
|
|
> = Vec::new();
|
|
|
|
for event in lrs.iter() {
|
|
let ll: textsender_models::message::scheduling::ScheduledMessageEvent =
|
|
match serde_json::from_value(event.clone()) {
|
|
Ok(lr) => lr,
|
|
Err(err) => {
|
|
return Err(std::io::Error::other(err.to_string()));
|
|
}
|
|
};
|
|
events.push(ll);
|
|
}
|
|
|
|
Ok(events)
|
|
}
|
|
}
|
|
_ => Err(std::io::Error::other("Error parsing response")),
|
|
},
|
|
Err(err) => Err(std::io::Error::other(err.to_string())),
|
|
}
|
|
}
|