Redis::destroy() - Code Metrics - KIVagant/staticus-core - Measure and Improve Code Quality continuously with Scrutinizer

Redis::destroy() A
last analyzed 2017-08-22 07:53 UTC

↳ Parent: Redis

Complexity

Conditions	4
Paths	6

Size

Total Lines	15
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	20

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
dl	0
loc	15
ccs	0
cts	12
cp	0
rs	9.2
c	1
b	0
f	0
cc	4
eloc	8
nc	6
nop	2
crap	20

<?php

namespace Staticus\Auth\SaveHandlers;

use Zend\Session\SaveHandler\SaveHandlerInterface;

/**
 * Session save handler for redis.io
 */
class Redis implements SaveHandlerInterface
{

    /**
     * @var \Redis
     */
    protected $redis;

    /**
     * Session Save Path
     *
     * @var string
     */
    protected $sessionSavePath;

    /**
     * Session Name
     *
     * @var string
     */
    protected $sessionName;

    /**
     * Lifetime
     * @var int
     */
    protected $lifetime;

    /**
     * Constructor
     * @param string $host
     * @param string $port
     * @param string $password
     */
    public function __construct($host, $port, $password)
    {
        $this->redis = new \Redis();
        $this->redis->connect($host, $port);
        $this->redis->auth($password);
    }

    /**
     * Open Session - retrieve resources
     * @param string $savePath
     * @param string $name
     * @return bool
     */
    public function open($savePath, $name)
    {
        $this->sessionSavePath = $savePath;
        $this->sessionName = $name;
        $this->lifetime = (int)ini_get('session.gc_maxlifetime');
        return true;
    }

    /**
     * Close Session - free resources
     *
     */
    public function close()
    {
        $this->redis->close();
        return true;
    }

    /**
     * Read session data
     *
     * @param string $identifier
     * @return bool|string
     */
    public function read($identifier)
    {
        return (string)$this->redis->get($this->getSessionKey($identifier));
    }

    /**
     * Read sessions for user
     * @param $userId
     * @return array
     */
    public function readByUser($userId)
    {
        return $this->redis->sMembers($this->getUserKey($userId));
    }

    /**
     * Write Session - commit data to resource
     * @param string $identifier
     * @param mixed  $data
     * @return bool
     */
    public function write($identifier, $data)
    {
        return $this->redis->setex(
            $this->getSessionKey($identifier),
            $this->lifetime,
            $data
        );
    }

    /**
     * Write session ids for user
     * @param $sessionId
     * @param $userId
     */
    public function writeByUser($sessionId, $userId)
    {
        $this->redis->sAdd($this->getUserKey($userId), $sessionId);
    }

    /**
     * Destroy Session and remove data from user's container
     * @param string $sessionId
     * @param null $userId
     */
    public function destroy($sessionId, $userId = null)
    {
        $sessionKey = $this->getSessionKey($sessionId);
        if ($this->redis->exists($sessionKey)) {
            $this->redis->delete($sessionKey);
        }

        /* Remove session id from user's container */
        if (null !== $userId) {
            $userKey = $this->getUserKey($userId);
            if ($this->redis->sIsMember($userKey, $sessionId)) {
                $this->redis->sRemove($userKey, $sessionId);
            }
        }
    }

    /**
     * Destroy all sessions by user
     * @param $userId
     */
    public function destroyByUser($userId)
    {
        foreach ($this->readByUser($userId) as $sessionId) {
            $this->destroy($sessionId);
        }

        $userKey = $this->getUserKey($userId);
        if ($this->redis->exists($userKey)) {
            $this->redis->delete($userKey);
        }
    }

    /**
     * Add prefix for session's key
     * @param $sessionId
     * @return string
     */
    protected function getSessionKey($sessionId)
    {
        return 'session_' . $sessionId;
    }

    /**
     * Add prefix for user's key
     * @param $userId
     * @return string
     */
    protected function getUserKey($userId)
    {
        return 'user_' . $userId;
    }

    /**
     * Garbage Collection - remove old session data older
     * than $maxlifetime (in seconds)
     *
     * @param int $maxlifetime
     * @return bool|void
     */
    public function gc($maxlifetime)

    {
        // TODO: Implement gc() method.
    }
}


1			<?php
2
3			namespace Staticus\Auth\SaveHandlers;
4
5			use Zend\Session\SaveHandler\SaveHandlerInterface;
6
7			/**
8			* Session save handler for redis.io
9			*/
10			class Redis implements SaveHandlerInterface
11			{
12
13			/**
14			* @var \Redis
15			*/
16			protected $redis;
17
18			/**
19			* Session Save Path
20			*
21			* @var string
22			*/
23			protected $sessionSavePath;
24
25			/**
26			* Session Name
27			*
28			* @var string
29			*/
30			protected $sessionName;
31
32			/**
33			* Lifetime
34			* @var int
35			*/
36			protected $lifetime;
37
38			/**
39			* Constructor
40			* @param string $host
41			* @param string $port
42			* @param string $password
43			*/
44			public function __construct($host, $port, $password)
45			{
46			$this->redis = new \Redis();
47			$this->redis->connect($host, $port);
48			$this->redis->auth($password);
49			}
50
51			/**
52			* Open Session - retrieve resources
53			* @param string $savePath
54			* @param string $name
55			* @return bool
56			*/
57			public function open($savePath, $name)
58			{
59			$this->sessionSavePath = $savePath;
60			$this->sessionName = $name;
61			$this->lifetime = (int)ini_get('session.gc_maxlifetime');
62			return true;
63			}
64
65			/**
66			* Close Session - free resources
67			*
68			*/
69			public function close()
70			{
71			$this->redis->close();
72			return true;
73			}
74
75			/**
76			* Read session data
77			*
78			* @param string $identifier
79			* @return bool\|string
80			*/
81			public function read($identifier)
82			{
83			return (string)$this->redis->get($this->getSessionKey($identifier));
84			}
85
86			/**
87			* Read sessions for user
88			* @param $userId
89			* @return array
90			*/
91			public function readByUser($userId)
92			{
93			return $this->redis->sMembers($this->getUserKey($userId));
94			}
95
96			/**
97			* Write Session - commit data to resource
98			* @param string $identifier
99			* @param mixed $data
100			* @return bool
101			*/
102			public function write($identifier, $data)
103			{
104			return $this->redis->setex(
105			$this->getSessionKey($identifier),
106			$this->lifetime,
107			$data
108			);
109			}
110
111			/**
112			* Write session ids for user
113			* @param $sessionId
114			* @param $userId
115			*/
116			public function writeByUser($sessionId, $userId)
117			{
118			$this->redis->sAdd($this->getUserKey($userId), $sessionId);
119			}
120
121			/**
122			* Destroy Session and remove data from user's container
123			* @param string $sessionId
124			* @param null $userId
125			*/
126			public function destroy($sessionId, $userId = null)
127			{
128			$sessionKey = $this->getSessionKey($sessionId);
129			if ($this->redis->exists($sessionKey)) {
130			$this->redis->delete($sessionKey);
131			}
132
133			/* Remove session id from user's container */
134			if (null !== $userId) {
135			$userKey = $this->getUserKey($userId);
136			if ($this->redis->sIsMember($userKey, $sessionId)) {
137			$this->redis->sRemove($userKey, $sessionId);
138			}
139			}
140			}
141
142			/**
143			* Destroy all sessions by user
144			* @param $userId
145			*/
146			public function destroyByUser($userId)
147			{
148			foreach ($this->readByUser($userId) as $sessionId) {
149			$this->destroy($sessionId);
150			}
151
152			$userKey = $this->getUserKey($userId);
153			if ($this->redis->exists($userKey)) {
154			$this->redis->delete($userKey);
155			}
156			}
157
158			/**
159			* Add prefix for session's key
160			* @param $sessionId
161			* @return string
162			*/
163			protected function getSessionKey($sessionId)
164			{
165			return 'session_' . $sessionId;
166			}
167
168			/**
169			* Add prefix for user's key
170			* @param $userId
171			* @return string
172			*/
173			protected function getUserKey($userId)
174			{
175			return 'user_' . $userId;
176			}
177
178			/**
179			* Garbage Collection - remove old session data older
180			* than $maxlifetime (in seconds)
181			*
182			* @param int $maxlifetime
183			* @return bool\|void
184			*/
185			public function gc($maxlifetime)
			0 ignored issues – show Coding Style introduced 2017-08-09 08:15 UTC by Report Bug Copy Issue Report This method's name is shorter than the configured minimum length of `3` characters. Even though PHP does not care about the name of your methods, it is generally a good practice to choose method names which can be easily understood by other human readers. Loading history...
186			{
187			// TODO: Implement gc() method.
188			}
189			}
190

KIVagant / staticus-core

Redis::destroy() A last analyzed 2017-08-22 07:53 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

Redis::destroy() A
last analyzed 2017-08-22 07:53 UTC