diff options
Diffstat (limited to 'src/email')
-rw-r--r-- | src/email/mod.rs | 2 | ||||
-rw-r--r-- | src/email/models.rs | 38 | ||||
-rw-r--r-- | src/email/routes.rs | 26 |
3 files changed, 66 insertions, 0 deletions
diff --git a/src/email/mod.rs b/src/email/mod.rs new file mode 100644 index 0000000..a0e1883 --- /dev/null +++ b/src/email/mod.rs @@ -0,0 +1,2 @@ +pub mod models; +pub mod routes; diff --git a/src/email/models.rs b/src/email/models.rs new file mode 100644 index 0000000..477092d --- /dev/null +++ b/src/email/models.rs @@ -0,0 +1,38 @@ +use crate::db::get_client; +use crate::errors::AppError; + +use deadpool_postgres::Pool; +use serde::{Deserialize, Serialize}; +use tokio_pg_mapper::FromTokioPostgresRow; +use tokio_pg_mapper_derive::PostgresMapper; + +#[derive(Serialize, Deserialize, PostgresMapper)] +#[pg_mapper(table = "email")] +/// Emails model +pub struct Email { + pub email: String, + pub hash_md5: String, +} + +// Struct used to creare a new email +#[derive(Serialize, Deserialize)] +pub struct EmailData { + pub email: String, +} + +impl Email { + /// Find all emails, returns email and its MD5 hash + pub async fn find_all(pool: Pool) -> Result<Vec<Email>, AppError> { + let client = get_client(pool.clone()).await.unwrap(); + let statement = client.prepare("SELECT * FROM email").await?; + + let emails = client + .query(&statement, &[]) + .await? + .iter() + .map(|row| Email::from_row_ref(row).unwrap()) + .collect::<Vec<Email>>(); + + Ok(emails) + } +} diff --git a/src/email/routes.rs b/src/email/routes.rs new file mode 100644 index 0000000..06b74fb --- /dev/null +++ b/src/email/routes.rs @@ -0,0 +1,26 @@ +use crate::config::AppState; +use crate::email::models::Email; +use crate::errors::AppErrorResponse; +use actix_web::{web, HttpResponse, Responder}; +use slog::info; + +/// Endpoint used for retrieve all emails +async fn index(state: web::Data<AppState>) -> impl Responder { + let result = Email::find_all(state.pool.clone()).await; + info!(state.log, "GET /email/"); + + match result { + Ok(emails) => HttpResponse::Ok().json(emails), + _ => HttpResponse::BadRequest().json(AppErrorResponse { + detail: "Error trying to read all emails from database" + .to_string(), + }), + } +} + +pub fn config(cfg: &mut web::ServiceConfig) { + cfg.service( + web::scope("/email") + .service(web::resource("{_:/?}").route(web::get().to(index))), + ); +} |