ChangeMailTokenDBRepository.php

Go to the documentation of this file.

<?php

declare(strict_types=1);

namespace ILIAS\User\Profile;

class ChangeMailTokenDBRepository implements ChangeMailTokenRepository
{
    public const TABLE_NAME = 'usr_change_email_token';

    public function __construct(
        private readonly \ilDBInterface $db,
        private readonly \ilSetting $settings
    ) {
    }

    public function getNewTokenForUser(
        \ilObjUser $user,
        string $new_email,
        int $now
    ): ChangeMailToken {
        $token = new ChangeMailToken(
            $user->getId(),
            $user->getEmail(),
            $new_email,
            $now
        );

        $this->storeChangeMailToken($token);
        return $token;
    }

    public function hasUserValidEmailConfirmationToken(\ilObjUser $user): bool
    {
        $query = $this->db->queryF(
            'SELECT count(*) as cnt FROM `' . self::TABLE_NAME . '`' . PHP_EOL
                . 'WHERE `usr_id` = %s' . PHP_EOL
                . 'AND `status` = %s' . PHP_EOL
                . 'AND `created_ts` >= %s',
            [
                \ilDBConstants::T_INTEGER,
                \ilDBConstants::T_INTEGER,
                \ilDBConstants::T_INTEGER
            ],
            [
                $user->getId(),
                ChangeMailStatus::EmailConfirmation->value,
                time() - ChangeMailStatus::EmailConfirmation->getValidity($this->settings)
            ]
        );

        $result = $this->db->fetchObject($query);

        if ($result->cnt > 0) {
            return true;
        }

        return false;
    }

    public function getTokenForTokenString(string $token_string, \ilObjUser $user): ?ChangeMailToken
    {
        $query = $this->db->queryF(
            'SELECT * FROM `' . self::TABLE_NAME . '` WHERE `token` = %s',
            [\ilDBConstants::T_TEXT],
            [$token_string]
        );

        $result = $this->db->fetchObject($query);

        if ($result === null) {
            return null;
        }

        $token = new ChangeMailToken(
            $user->getId(),
            $user->getEmail(),
            $result->new_email,
            $result->created_ts,
            ChangeMailStatus::from($result->status),
            $result->token
        );

        if (!$token->isTokenValidForCurrentStatus($this->settings)) {
            return null;
        }

        return $token;
    }

    public function moveToNextStep(ChangeMailToken $token, int $now): ChangeMailToken
    {
        $new_token = new ChangeMailToken(
            $token->getUserId(),
            $token->getCurrentEmail(),
            $token->getNewEmail(),
            $now,
            $token->getStatus()->next()
        );
        $this->deleteEntryByToken($token->getToken());
        $this->storeChangeMailToken($new_token);
        return $new_token;
    }

    public function deleteEntryByToken(string $token): void
    {
        $query = 'DELETE FROM `' . self::TABLE_NAME . '` WHERE `token` = %s';
        $this->db->manipulateF($query, [\ilDBConstants::T_TEXT], [$token]);
    }

    public function deleteExpiredEntries(): void
    {
        $validity = max(
            ChangeMailStatus::Login->getValidity($this->settings),
            ChangeMailStatus::EmailConfirmation->getValidity($this->settings)
        );
        $query = 'DELETE FROM `' . self::TABLE_NAME . '` WHERE `created_ts` < %s';
        $this->db->manipulateF($query, [\ilDBConstants::T_INTEGER], [time() - $validity]);
    }

    private function storeChangeMailToken(ChangeMailToken $token): void
    {
        $this->db->replace(
            self::TABLE_NAME,
            [
                'token' => ['text', $token->getToken()]
            ],
            [
                'usr_id' => [\ilDBConstants::T_TEXT, $token->getUserId()],
                'new_email' => [\ilDBConstants::T_TEXT, $token->getNewEmail()],
                'status' => [\ilDBConstants::T_INTEGER, $token->getStatus()->value],
                'created_ts' => [\ilDBConstants::T_INTEGER, $token->getCreatedTimestamp()]
            ]
        );
    }
}