Waca\ConsoleTasks\ClearOldDataTask

Complexity

Total Complexity

3

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
A	execute()	0	45	3

<?php
/******************************************************************************
 * Wikipedia Account Creation Assistance tool                                 *
 * ACC Development Team. Please see team.json for a list of contributors.     *
 *                                                                            *
 * This is free and unencumbered software released into the public domain.    *
 * Please see LICENSE.md for the full licencing statement.                    *
 ******************************************************************************/

namespace Waca\ConsoleTasks;

use Exception;
use Waca\Tasks\ConsoleTaskBase;

class ClearOldDataTask extends ConsoleTaskBase
{
    public function execute()
    {
        $dataClearInterval = $this->getSiteConfiguration()->getDataClearInterval();
        $database = $this->getDatabase();

        $query = $database->prepare(<<<SQL
UPDATE request
SET ip = :ip, forwardedip = null, email = :mail, useragent = ''
WHERE date < DATE_SUB(curdate(), INTERVAL {$dataClearInterval})
AND status = 'Closed';
SQL
        );

        $success = $query->execute(array(
            ":ip"   => $this->getSiteConfiguration()->getDataClearIp(),
            ":mail" => $this->getSiteConfiguration()->getDataClearEmail(),
        ));

        if (!$success) {
            throw new Exception("Error in transaction 1: Could not clear data.");
        }

        $dataQuery = $database->prepare(<<<SQL
DELETE rd
FROM requestdata rd
INNER JOIN request r ON r.id = rd.request
WHERE r.date < DATE_SUB(curdate(), INTERVAL {$dataClearInterval})
  AND r.status = 'Closed';
SQL
        );

        $success = $dataQuery->execute();

        if (!$success) {
            throw new Exception("Error in transaction 2: Could not clear data.");
        }

        // FIXME: domains!
        $flaggedCommentsQuery = $database->query(<<<SQL
SELECT COUNT(1) FROM comment c INNER JOIN request r ON c.request = r.id WHERE c.flagged = 1 AND r.status = 'Closed'
SQL
        );

        $flaggedCommentsCount = $flaggedCommentsQuery->fetchColumn();
        $this->getNotificationHelper()->alertFlaggedComments($flaggedCommentsCount);
    }
}