use crate::{ newtypes::LocalUserId, schema::email_verification::dsl::*, source::email_verification::*, utils::{get_conn, DbPool}, }; use diesel::{dsl::*, insert_into, result::Error, ExpressionMethods, QueryDsl}; use diesel_async::RunQueryDsl; impl EmailVerification { pub async fn create(pool: &DbPool, form: &EmailVerificationForm) -> Result { let conn = &mut get_conn(pool).await?; insert_into(email_verification) .values(form) .get_result::(conn) .await } pub async fn read_for_token(pool: &DbPool, token: &str) -> Result { let conn = &mut get_conn(pool).await?; email_verification .filter(verification_token.eq(token)) .filter(published.gt(now - 7.days())) .first::(conn) .await } pub async fn delete_old_tokens_for_local_user( pool: &DbPool, local_user_id_: LocalUserId, ) -> Result { let conn = &mut get_conn(pool).await?; diesel::delete(email_verification.filter(local_user_id.eq(local_user_id_))) .execute(conn) .await } }