summaryrefslogtreecommitdiff
path: root/lib/Travelynx/Command/maintenance.pm
diff options
context:
space:
mode:
Diffstat (limited to 'lib/Travelynx/Command/maintenance.pm')
-rw-r--r--lib/Travelynx/Command/maintenance.pm36
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;
}