diff --git a/src/service/event.rs b/src/service/event.rs new file mode 100644 index 0000000..8c0f255 --- /dev/null +++ b/src/service/event.rs @@ -0,0 +1,68 @@ +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, 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 token")), + }, + Err(err) => Err(std::io::Error::other(err.to_string())), + } + } +} + +async fn parse_response( + response: &str, +) -> Result, std::io::Error> { + match serde_json::from_str::(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 = 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())), + } +} diff --git a/src/service/mod.rs b/src/service/mod.rs index 788f4cc..0095e9d 100644 --- a/src/service/mod.rs +++ b/src/service/mod.rs @@ -1,4 +1,5 @@ pub mod core; +pub mod event; pub mod queue; pub mod auth {