mirror/lldap
1
0
Fork 0
mirror of https://github.com/nitnelave/lldap.git synced 2023-04-12 14:25:13 +00:00
Code Issues Projects Releases Wiki Activity

Add the OPAQUE tables to the cleanup cron

Browse Source
This commit is contained in:
Valentin Tolmer 2021-06-16 19:28:42 +02:00 committed by nitnelave
parent 4bc48a064d
commit f6372c7e02
1 changed files with 31 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
src/infra/db_cleaner.rs
View File

@ -1,5 +1,5 @@
use crate::{ use crate::{
domain::sql_tables::{DbQueryBuilder, Pool}, domain::sql_tables::{DbQueryBuilder, LoginAttempts, Pool, RegistrationAttempts},
infra::jwt_sql_tables::{JwtRefreshStorage, JwtStorage}, infra::jwt_sql_tables::{JwtRefreshStorage, JwtStorage},
}; };
use actix::prelude::*; use actix::prelude::*;
@ -57,7 +57,7 @@ impl Scheduler {
.execute(&sql_pool) .execute(&sql_pool)
.await .await
{ {
log::error!("DB cleanup error: {}", e); log::error!("DB error while cleaning up JWT refresh tokens: {}", e);
}; };
if let Err(e) = sqlx::query( if let Err(e) = sqlx::query(
&Query::delete() &Query::delete()
@ -68,7 +68,35 @@ impl Scheduler {
.execute(&sql_pool) .execute(&sql_pool)
.await .await
{ {
log::error!("DB cleanup error: {}", e); log::error!("DB error while cleaning up JWT storage: {}", e);
};
if let Err(e) = sqlx::query(
&Query::delete()
.from_table(LoginAttempts::Table)
.and_where(
Expr::col(LoginAttempts::Timestamp)
.lt(Local::now().naive_utc() - chrono::Duration::minutes(5)),
)
.to_string(DbQueryBuilder {}),
)
.execute(&sql_pool)
.await
{
log::error!("DB error while cleaning up login attempts: {}", e);
};
if let Err(e) = sqlx::query(
&Query::delete()
.from_table(RegistrationAttempts::Table)
.and_where(
Expr::col(RegistrationAttempts::Timestamp)
.lt(Local::now().naive_utc() - chrono::Duration::minutes(5)),
)
.to_string(DbQueryBuilder {}),
)
.execute(&sql_pool)
.await
{
log::error!("DB error while cleaning up registration attempts: {}", e);
}; };
log::info!("DB cleaned!"); log::info!("DB cleaned!");
} }