TokenAssistant\TokenDispatcher

Complexity

Total Complexity

10

Size/Duplication

Total Lines	102
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	assign()	0	12	4
A	recycle()	0	10	2
A	reassign()	0	6	1
A	getUserIdByToken()	0	4	1
A	getTokenByUserId()	0	4	1

<?php
/**
 * @filename TokenDispatcher.php
 * @touch    09/11/2016 11:29
 * @author   wudege <hi@wudege.me>
 * @version  1.0.0
 */

namespace TokenAssistant;

use Predis\Client;

class TokenDispatcher implements TokenDispatcherInterface
{
    const TOKEN_HASH_NAMESPACE   = 'token:';
    const USER_ID_HASH_NAMESPACE = 'user-id:';

    /**
     * @var Client
     */
    private $redisClient;

    /**
     * TokenDispatcher constructor.
     *
     * @param Client $client
     */
    public function __construct(Client $client)
    {
        $this->redisClient = $client;
    }

    /**
     * Assign a new token or gain existed token.
     * @author wudege <hi@wudege.me>
     *
     * @param string $userId
     * @param bool   $forceRefresh
     *
     * @return string
     */
    public function assign($userId, $forceRefresh = true)
    {
        $token = $this->getTokenByUserId($userId);
        if ($token && $forceRefresh) {
            $this->redisClient->hdel(static::TOKEN_HASH_NAMESPACE, $token);
        }
        $token = $token ? $token : Util::genToken();
        $this->redisClient->hset(static::TOKEN_HASH_NAMESPACE, $token, $userId);
        $this->redisClient->hset(static::USER_ID_HASH_NAMESPACE, $userId, $token);

        return $token;
    }

    /**
     * Recycle token if exist.
     * @author wudege <hi@wudege.me>
     *
     * @param string $userId
     *
     * @return bool
     */
    public function recycle($userId)
    {
        $token = $this->getTokenByUserId($userId);
        if ($token) {
            $this->redisClient->hdel(static::TOKEN_HASH_NAMESPACE, $token);
        }
        $this->redisClient->hdel(static::USER_ID_HASH_NAMESPACE, $userId);

        return true;
    }

    /**
     * Recycle the old token if exist, then assign new token.
     * @author wudege <hi@wudege.me>
     *
     * @param $userId
     *
     * @return string
     */
    public function reassign($userId)
    {
        $this->recycle($userId);

        return $this->assign($userId);
    }

    /**
     * Get user id from token.
     * @author wudege <hi@wudege.me>
     *
     * @param string $token
     *
     * @return string
     */
    public function getUserIdByToken($token)
    {
        return $this->redisClient->hget(static::TOKEN_HASH_NAMESPACE, $token);
    }

    /**
     *
     * @author wudege <hi@wudege.me>
     *
     * @param string $userId
     *
     * @return string
     */
    public function getTokenByUserId($userId)
    {
        return $this->redisClient->hget(static::USER_ID_HASH_NAMESPACE, $userId);
    }
}