Waca\ConsoleTasks\RefreshOAuthDataTask

Complexity

Total Complexity

6

Size/Duplication

Total Lines	50
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
B	execute()	0	48	6

<?php
/******************************************************************************
 * Wikipedia Account Creation Assistance tool                                 *
 *                                                                            *
 * All code in this file is released into the public domain by the ACC        *
 * Development Team. Please see team.json for a list of contributors.         *
 ******************************************************************************/

namespace Waca\ConsoleTasks;

use Exception;
use PDO;
use Waca\DataObjects\User;
use Waca\Exceptions\OAuthException;
use Waca\Helpers\OAuthUserHelper;
use Waca\Helpers\SearchHelpers\UserSearchHelper;
use Waca\Tasks\ConsoleTaskBase;

class RefreshOAuthDataTask extends ConsoleTaskBase
{
    public function execute()
    {
        $database = $this->getDatabase();

        $idList = $database
            ->query('SELECT user FROM oauthtoken WHERE type = \'access\' AND expiry IS NULL')
            ->fetchAll(PDO::FETCH_COLUMN);

        if (count($idList) > 0) {
            /** @var User[] $users */
            $users = UserSearchHelper::get($database)->inIds($idList)->fetch();

            $expiredStatement = $database
                ->prepare('UPDATE oauthtoken SET expiry = CURRENT_TIMESTAMP() WHERE user = :u AND type = \'access\'');

            foreach ($users as $u) {
                try {
                    $database->beginTransaction();

                    $oauth = new OAuthUserHelper($u, $database, $this->getOAuthProtocolHelper(),
                        $this->getSiteConfiguration());

                    try {
                        $oauth->refreshIdentity();
                    }
                    catch (OAuthException $ex) {
                        $expiredStatement->execute(array(':u' => $u->getId()));
                    }

                    $database->commit();
                }
                catch (Exception $ex) {
                    $database->rollBack();

                    printf("Failed updating OAuth data for %s\n", $u->getUsername());
                    printf($ex->getMessage());
                }
                finally {
                    if ($database->hasActiveTransaction()) {
                        $database->rollBack();
                    }
                }
            }
        }

        $database->beginTransaction();
        $database->exec('DELETE FROM oauthtoken WHERE expiry IS NOT NULL AND expiry < NOW() AND type = \'request\'');
        $database->commit();
    }
}