diff options
| -rw-r--r-- | lib/Travelynx/Command/maintenance.pm | 36 |
1 files changed, 36 insertions, 0 deletions
diff --git a/lib/Travelynx/Command/maintenance.pm b/lib/Travelynx/Command/maintenance.pm index b9f5947..329855b 100644 --- a/lib/Travelynx/Command/maintenance.pm +++ b/lib/Travelynx/Command/maintenance.pm @@ -14,6 +14,7 @@ sub run { my $now = DateTime->now( time_zone => 'Europe/Berlin' ); my $verification_deadline = $now->subtract( hours => 48 )->epoch; + my $deletion_deadline = $now->subtract( hours => 72 )->epoch; my $get_unverified_query = $dbh->prepare( @@ -21,6 +22,8 @@ qq{select email, extract(epoch from registered_at) from users where status = 0 a ); my $get_pending_query = $dbh->prepare(qq{select num_tries from pending_mails where email = ?;}); + my $get_deleted_query = $dbh->prepare( + qq{select id from users where deletion_requested < to_timestamp(?);}); my $set_pending_query = $dbh->prepare( qq{update pending_mails set num_tries = ?, last_try = to_timestamp(?) where email = ?;} @@ -33,6 +36,13 @@ qq{insert into pending_mails (email, num_tries, last_try) values (?, ?, to_times = $dbh->prepare( qq{delete from users where status = 0 and registered_at < to_timestamp(?);} ); + my $drop_tokens_query + = $dbh->prepare(qq{delete from tokens where user_id = ?;}); + my $drop_stats_query + = $dbh->prepare(qq{delete from monthly_stats where user_id = ?;}); + my $drop_actions_query + = $dbh->prepare(qq{delete from user_actions where user_id = ?;}); + my $drop_user_query = $dbh->prepare(qq{delete from users where id = ?;}); $dbh->begin_work; $get_unverified_query->execute($verification_deadline); @@ -57,6 +67,32 @@ qq{delete from users where status = 0 and registered_at < to_timestamp(?);} $drop_unverified_query->rows ); $dbh->commit; + $dbh->begin_work; + $get_deleted_query->execute($deletion_deadline); + my @uids_to_delete + = map { $_->[0] } @{ $get_deleted_query->fetchall_arrayref }; + + if ( @uids_to_delete < 10 ) { + for my $uid (@uids_to_delete) { + say "Deleting uid ${uid}..."; + $drop_tokens_query->execute($uid); + $drop_stats_query->execute($uid); + $drop_actions_query->execute($uid); + $drop_user_query->execute($uid); + printf( " %d tokens, %d monthly stats, %d actions\n", + $drop_tokens_query->rows, $drop_stats_query->rows, + $drop_actions_query->rows ); + } + } + else { + printf( + "Unusually high number of deletion requests (%d accounts)" + . " -- skipping automatic deletion, please investigate\n", + scalar @uids_to_delete + ); + } + $dbh->commit; + $dbh->disconnect; } |