sweelix\oauth2\server\services\redis\RefreshTokenService::insert()

Complexity

Conditions	9
Paths	57

Size

Total Lines	55
Code Lines	37

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	36
CRAP Score	9.0117

Importance

Changes

0

<?php
    protected function insert(RefreshTokenModelInterface $refreshToken, $attributes)
    {
        $result = false;
        if (!$refreshToken->beforeSave(true)) {
            return $result;
        }
        $refreshTokenId = $refreshToken->getKey();
        $refreshTokenKey = $this->getRefreshTokenKey($refreshTokenId);
        if (empty($refreshToken->userId) === false) {

Accessing userId on the interface sweelix\oauth2\server\interfaces\RefreshTokenModelInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

            $userRefreshTokensKey = $this->getUserRefreshTokensKey($refreshToken->userId);

Accessing userId on the interface sweelix\oauth2\server\interfaces\RefreshTokenModelInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

        } else {
            $userRefreshTokensKey = null;
        }
        $clientRefreshTokensKey = $this->getClientRefreshTokensKey($refreshToken->clientId);

Accessing clientId on the interface sweelix\oauth2\server\interfaces\RefreshTokenModelInterface suggest that you code against a concrete implementation. How about adding an instanceof check?

        //check if record exists
        $entityStatus = (int)$this->db->executeCommand('EXISTS', [$refreshTokenKey]);
        if ($entityStatus === 1) {
            throw new DuplicateKeyException('Duplicate key "'.$refreshTokenKey.'"');
        }

        $values = $refreshToken->getDirtyAttributes($attributes);

It seems like $attributes defined by parameter $attributes on line 103 can also be of type array; however, sweelix\oauth2\server\interfaces\BaseModelInterface::getDirtyAttributes() does only seem to accept array<integer,string>|null, maybe add an additional type check?

        $redisParameters = [$refreshTokenKey];
        $this->setAttributesDefinitions($refreshToken->attributesDefinition());
        foreach ($values as $key => $value)
        {
            if ($value !== null) {
                $redisParameters[] = $key;
                $redisParameters[] = $this->convertToDatabase($key, $value);
            }
        }
        //TODO: use EXEC/MULTI to avoid errors
        $transaction = $this->db->executeCommand('MULTI');
        if ($transaction === true) {
            try {
                $this->db->executeCommand('HMSET', $redisParameters);
                if ($userRefreshTokensKey !== null) {
                    $this->db->executeCommand('SADD', [$userRefreshTokensKey, $refreshTokenId]);
                }
                $this->db->executeCommand('SADD', [$clientRefreshTokensKey, $refreshTokenId]);
                $this->db->executeCommand('EXEC');
            } catch (DatabaseException $e) {
                // @codeCoverageIgnoreStart
                // we have a REDIS exception, we should not discard
                Yii::trace('Error while inserting entity', __METHOD__);
                throw $e;
                // @codeCoverageIgnoreEnd
            }
        }
        $changedAttributes = array_fill_keys(array_keys($values), null);
        $refreshToken->setOldAttributes($values);
        $refreshToken->afterSave(true, $changedAttributes);
        $result = true;
        return $result;
    }