Waca\ConsoleTasks\RefreshOAuthDataTask::execute()

Complexity

Conditions	6
Paths	2

Size

Total Lines	48
Code Lines	28

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	42

Importance

Changes	1
Bugs	0	Features	0

<?php
    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();
    }
}