LemmyNet/lemmy
2
0
Fork 0
mirror of https://github.com/LemmyNet/lemmy.git synced 2024-11-12 15:34:00 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Adding a ban expires update job. Fixes #2177

Browse source
This commit is contained in:
Dessalines 2022-03-30 09:56:23 -04:00
parent ad7e6d99ed
commit 3ad172e8ed
1 changed files with 12 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/scheduled_tasks.rs
View file

@ -13,12 +13,14 @@ pub fn setup(pool: DbPool) -> Result<(), LemmyError> {
let conn = pool.get()?; let conn = pool.get()?;
active_counts(&conn); active_counts(&conn);
update_banned_when_expired(&conn);
// On startup, reindex the tables non-concurrently // On startup, reindex the tables non-concurrently
// TODO remove this for now, since it slows down startup a lot on lemmy.ml // TODO remove this for now, since it slows down startup a lot on lemmy.ml
reindex_aggregates_tables(&conn, true); reindex_aggregates_tables(&conn, true);
scheduler.every(1.hour()).run(move || { scheduler.every(1.hour()).run(move || {
active_counts(&conn); active_counts(&conn);
update_banned_when_expired(&conn);
reindex_aggregates_tables(&conn, true); reindex_aggregates_tables(&conn, true);
}); });
@ -91,3 +93,13 @@ fn active_counts(conn: &PgConnection) {
info!("Done."); info!("Done.");
} }
/// Set banned to false after ban expires
fn update_banned_when_expired(conn: &PgConnection) {
info!("Updating banned column if it expires ...");
let update_ban_expires_stmt =
format!("update person set banned = false where banned = true and ban_expires < now()");
sql_query(update_ban_expires_stmt)
.execute(conn)
.expect("update banned when expires");
}