MigrateRedisController - Code Metrics - pgaultier/yii2-oauth2 - Measure and Improve Code Quality continuously with Scrutinizer

MigrateRedisController A
last analyzed 2018-11-06 00:45 UTC

↳ Parent: Project

Complexity

Total Complexity

Size/Duplication

Total Lines	198
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	13

Importance

Changes

Metric	Value
wmc	38
lcom	1
cbo	13
dl	0
loc	198
rs	9.36
c	0
b	0
f	0

1 Method

Rating	Name	Duplication	Size	Complexity
F	actionMigrate()	0	195	38

<?php

namespace sweelix\oauth2\server\commands;

use sweelix\oauth2\server\interfaces\AccessTokenModelInterface;
use sweelix\oauth2\server\interfaces\JtiModelInterface;
use sweelix\oauth2\server\interfaces\RefreshTokenModelInterface;
use sweelix\oauth2\server\services\redis\AccessTokenService;
use sweelix\oauth2\server\services\redis\ClientService;
use sweelix\oauth2\server\services\redis\JtiService;
use sweelix\oauth2\server\services\redis\RefreshTokenService;
use Yii;
use yii\console\Controller;
use yii\console\ExitCode;
use sweelix\oauth2\server\Module;
use yii\di\Instance;
use yii\redis\Connection;

class MigrateRedisController extends Controller
{
    public function actionMigrate()
    {
        try {
            $module = Module::getInstance();
            /** @var Connection $db */
            $db = Instance::ensure($module->db, Connection::class);

            ///////////////
            ///
            /// AccessToken
            ///
            ///////////////
            $this->stdout('Start migrating AccessTokens ...' . "\n");
            /** @var AccessTokenService $accessTokenService */
            $accessTokenService = Yii::createObject('sweelix\oauth2\server\interfaces\AccessTokenServiceInterface');
            $accessTokenList = $accessTokenService->getAccessTokenListKey();
            if ($db->executeCommand('EXISTS', [$accessTokenList]) == 1) {
                $prompt = $this->prompt('The key "'.$accessTokenList.'" already exists. Do you want to continue ? (yes, no)', [
                    'required' => true,
                ]);
                switch ($prompt) {
                    case 'no':
                    case 'n':
                        exit();
                }
            }
            $userListKey = $accessTokenService->getUserListKey();
            if ($db->executeCommand('EXISTS', [$userListKey]) == 1) {
                $prompt = $this->prompt('The key "'.$userListKey.'" already exists. Do you want to continue ? (yes, no)', [
                    'required' => true,
                ]);
                switch ($prompt) {
                    case 'no':
                    case 'n':
                        exit();
                }
            }
            $accessToken = Yii::createObject('sweelix\oauth2\server\interfaces\AccessTokenModelInterface');
            $accessTokenClass = get_class($accessToken);
            $accessTokens = $db->executeCommand('KEYS', [$accessTokenService->getUserAccessTokensKey('*')]);
            if (!empty($accessTokens)) {
                $db->executeCommand('DEL', $accessTokens);
            }
            $accessTokens = $db->executeCommand('KEYS', [$accessTokenService->getClientAccessTokensKey('*')]);
            if (!empty($accessTokens)) {
                $db->executeCommand('DEL', $accessTokens);
            }
            $accessTokens = $db->executeCommand('KEYS', [$accessTokenService->getAccessTokenKey('*')]);
            foreach ($accessTokens as $accessTokenHash) {
$collection = json_decode($data, true);
if ( ! is_array($collection)) {
    throw new \RuntimeException('$collection must be an array.');
}

foreach ($collection as $item) { /** ... */ }
                if ($db->executeCommand('TYPE', [$accessTokenHash]) !== 'hash') {
                    continue;
                }
                $accessTokenData = $db->executeCommand('HGETALL', [$accessTokenHash]);
                if (!empty($accessTokenData)) {
                    /** @var AccessTokenModelInterface $accessToken */
                    $accessToken = $accessTokenClass::findOne($accessTokenData[1]); // id
                    if (!empty($accessToken)) {
                        $accessToken->delete();
                        $accessToken->save();
                    }
                }
            }
            $this->stdout('Done migrating AccessTokens !' . "\n");

            ///////////////
            ///
            /// Clients
            ///
            ///////////////
            $this->stdout('Start migrating Clients ...' . "\n");
            /** @var ClientService $clientService */
            $clientService = Yii::createObject('sweelix\oauth2\server\interfaces\ClientServiceInterface');
            $clientList = $clientService->getClientListKey();
            if ($db->executeCommand('EXISTS', [$clientList]) == 1) {
                $prompt = $this->prompt('The key "'.$clientList.'" already exists. Do you want to continue ? (yes, no)', [
                    'required' => true,
                ]);
                switch ($prompt) {
                    case 'no':
                    case 'n':
                        exit();
                }
            }
            $clients = $db->executeCommand('KEYS', [$clientService->getClientKey('*')]);
            foreach ($clients as $clientHash) {
$collection = json_decode($data, true);
if ( ! is_array($collection)) {
    throw new \RuntimeException('$collection must be an array.');
}

foreach ($collection as $item) { /** ... */ }
                if ($db->executeCommand('TYPE', [$clientHash]) !== 'hash') {
                    continue;
                }
                $clientData = $db->executeCommand('HGETALL', [$clientHash]);
                if (!empty($clientData)) {
                    $db->executeCommand('SADD', [$clientService->getClientListKey(), $clientData[1]]);
                }
            }
            $this->stdout('Done migrating Clients !' . "\n");

            ///////////////
            ///
            /// Jti
            ///
            ///////////////
            $this->stdout('Start migrating Jtis ...' . "\n");
            /** @var JtiService $jtiService */
            $jtiService = Yii::createObject('sweelix\oauth2\server\interfaces\JtiServiceInterface');
            $jtiList = $jtiService->getJtiListKey();
            if ($db->executeCommand('EXISTS', [$jtiList]) == 1) {
                $prompt = $this->prompt('The key "'.$jtiList.'" already exists. Do you want to continue ? (yes, no)', [
                    'required' => true,
                ]);
                switch ($prompt) {
                    case 'no':
                    case 'n':
                        exit();
                }
            }
            $jti = Yii::createObject('sweelix\oauth2\server\interfaces\JtiModelInterface');
            $jtiClass = get_class($jti);
            $jtis = $db->executeCommand('KEYS', [$jtiService->getSubjectJtisKey('*')]);
            if (!empty($jtis)) {
                $db->executeCommand('DEL', $jtis);
            }
            $jtis = $db->executeCommand('KEYS', [$jtiService->getSubjectJtisKey('*')]);
            if (!empty($jtis)) {
                $db->executeCommand('DEL', $jtis);
            }
            $jtis = $db->executeCommand('KEYS', [$jtiService->getJtiKey('*')]);
            foreach ($jtis as $jtiHash) {
$collection = json_decode($data, true);
if ( ! is_array($collection)) {
    throw new \RuntimeException('$collection must be an array.');
}

foreach ($collection as $item) { /** ... */ }
                if ($db->executeCommand('TYPE', [$jtiHash]) !== 'hash') {
                    continue;
                }
                $jtiData = $db->executeCommand('HGETALL', [$jtiHash]);
                if (!empty($jtiData)) {
                    /** @var JtiModelInterface $jti */
                    $jti = $jtiClass::findOne($jtiData[1]); // id
                    if (!empty($jti)) {
                        $jti->delete();
                        $jti->save();
                    }
                }
            }
            $this->stdout('Done migrating Jtis !' . "\n");

            ///////////////
            ///
            /// RefreshToken
            ///
            ///////////////
            $this->stdout('Start migrating RefreshTokens ...' . "\n");
            /** @var RefreshTokenService $refreshTokenService */
            $refreshTokenService = Yii::createObject('sweelix\oauth2\server\interfaces\RefreshTokenServiceInterface');
            $refreshTokenList = $refreshTokenService->getRefreshTokenListKey();
            if ($db->executeCommand('EXISTS', [$refreshTokenList]) == 1) {
                $prompt = $this->prompt('The key "'.$refreshTokenList.'" already exists. Do you want to continue ? (yes, no)', [
                    'required' => true,
                ]);
                switch ($prompt) {
                    case 'no':
                    case 'n':
                        exit();
                }
            }
            $refreshToken = Yii::createObject('sweelix\oauth2\server\interfaces\RefreshTokenModelInterface');
            $refreshTokenClass = get_class($refreshToken);
            $refreshTokens = $db->executeCommand('KEYS', [$refreshTokenService->getUserRefreshTokensKey('*')]);
            if (!empty($refreshTokens)) {
                $db->executeCommand('DEL', $refreshTokens);
            }
            $refreshTokens = $db->executeCommand('KEYS', [$refreshTokenService->getClientRefreshTokensKey('*')]);
            if (!empty($refreshTokens)) {
                $db->executeCommand('DEL', $refreshTokens);
            }
            $refreshTokens = $db->executeCommand('KEYS', [$refreshTokenService->getRefreshTokenKey('*')]);
            foreach ($refreshTokens as $refreshTokenHash) {
$collection = json_decode($data, true);
if ( ! is_array($collection)) {
    throw new \RuntimeException('$collection must be an array.');
}

foreach ($collection as $item) { /** ... */ }
                if ($db->executeCommand('TYPE', [$refreshTokenHash]) !== 'hash') {
                    continue;
                }
                $refreshTokenData = $db->executeCommand('HGETALL', [$refreshTokenHash]);
                if (!empty($refreshTokenData)) {
                    /** @var RefreshTokenModelInterface $refreshToken */
                    $refreshToken = $refreshTokenClass::findOne($refreshTokenData[1]); // id
                    if (!empty($refreshToken)) {
                        $refreshToken->delete();
                        $refreshToken->save();
                    }
                }
            }
            $this->stdout('Done migrating RefreshTokens !' . "\n");

            $this->stdout('Migration done !' . "\n");
            $exitCode = ExitCode::OK;
        } catch (\Exception $e) {
            $this->stderr($e->getMessage() . "\n");
            $exitCode = ExitCode::getReason($e->getCode());
        }
        return $exitCode;
    }
}


1			<?php
2
3			namespace sweelix\oauth2\server\commands;
4
5			use sweelix\oauth2\server\interfaces\AccessTokenModelInterface;
6			use sweelix\oauth2\server\interfaces\JtiModelInterface;
7			use sweelix\oauth2\server\interfaces\RefreshTokenModelInterface;
8			use sweelix\oauth2\server\services\redis\AccessTokenService;
9			use sweelix\oauth2\server\services\redis\ClientService;
10			use sweelix\oauth2\server\services\redis\JtiService;
11			use sweelix\oauth2\server\services\redis\RefreshTokenService;
12			use Yii;
13			use yii\console\Controller;
14			use yii\console\ExitCode;
15			use sweelix\oauth2\server\Module;
16			use yii\di\Instance;
17			use yii\redis\Connection;
18
19			class MigrateRedisController extends Controller
20			{
21			public function actionMigrate()
22			{
23			try {
24			$module = Module::getInstance();
25			/** @var Connection $db */
26			$db = Instance::ensure($module->db, Connection::class);
27
28			///////////////
29			///
30			/// AccessToken
31			///
32			///////////////
33			$this->stdout('Start migrating AccessTokens ...' . "\n");
34			/** @var AccessTokenService $accessTokenService */
35			$accessTokenService = Yii::createObject('sweelix\oauth2\server\interfaces\AccessTokenServiceInterface');
36			$accessTokenList = $accessTokenService->getAccessTokenListKey();
37			if ($db->executeCommand('EXISTS', [$accessTokenList]) == 1) {
38			$prompt = $this->prompt('The key "'.$accessTokenList.'" already exists. Do you want to continue ? (yes, no)', [
39			'required' => true,
40			]);
41			switch ($prompt) {
42			case 'no':
43			case 'n':
44			exit();
45			}
46			}
47			$userListKey = $accessTokenService->getUserListKey();
48			if ($db->executeCommand('EXISTS', [$userListKey]) == 1) {
49			$prompt = $this->prompt('The key "'.$userListKey.'" already exists. Do you want to continue ? (yes, no)', [
50			'required' => true,
51			]);
52			switch ($prompt) {
53			case 'no':
54			case 'n':
55			exit();
56			}
57			}
58			$accessToken = Yii::createObject('sweelix\oauth2\server\interfaces\AccessTokenModelInterface');
59			$accessTokenClass = get_class($accessToken);
60			$accessTokens = $db->executeCommand('KEYS', [$accessTokenService->getUserAccessTokensKey('*')]);
61			if (!empty($accessTokens)) {
62			$db->executeCommand('DEL', $accessTokens);
63			}
64			$accessTokens = $db->executeCommand('KEYS', [$accessTokenService->getClientAccessTokensKey('*')]);
65			if (!empty($accessTokens)) {
66			$db->executeCommand('DEL', $accessTokens);
67			}
68			$accessTokens = $db->executeCommand('KEYS', [$accessTokenService->getAccessTokenKey('*')]);
69			foreach ($accessTokens as $accessTokenHash) {
			0 ignored issues – show Bug introduced 2018-09-10 16:37 UTC by Report Bug Copy Issue Report The expression `$accessTokens` of type `boolean\|string\|null\|array` is not guaranteed to be traversable. How about adding an additional type check? There are different options of fixing this problem. If you want to be on the safe side, you can add an additional type-check: $collection = json_decode($data, true); if ( ! is_array($collection)) { throw new \RuntimeException('$collection must be an array.'); } foreach ($collection as $item) { /** ... / } If you are sure that the expression is traversable, you might want to add a doc comment cast* to improve IDE auto-completion and static analysis: /** @var array $collection / $collection = json_decode($data, true); foreach ($collection as $item) { /* .. / } Mark the issue as a false-positive*: Just hover the remove button, in the top-right corner of this issue for more options. Loading history...
70			if ($db->executeCommand('TYPE', [$accessTokenHash]) !== 'hash') {
71			continue;
72			}
73			$accessTokenData = $db->executeCommand('HGETALL', [$accessTokenHash]);
74			if (!empty($accessTokenData)) {
75			/** @var AccessTokenModelInterface $accessToken */
76			$accessToken = $accessTokenClass::findOne($accessTokenData[1]); // id
77			if (!empty($accessToken)) {
78			$accessToken->delete();
79			$accessToken->save();
80			}
81			}
82			}
83			$this->stdout('Done migrating AccessTokens !' . "\n");
84
85			///////////////
86			///
87			/// Clients
88			///
89			///////////////
90			$this->stdout('Start migrating Clients ...' . "\n");
91			/** @var ClientService $clientService */
92			$clientService = Yii::createObject('sweelix\oauth2\server\interfaces\ClientServiceInterface');
93			$clientList = $clientService->getClientListKey();
94			if ($db->executeCommand('EXISTS', [$clientList]) == 1) {
95			$prompt = $this->prompt('The key "'.$clientList.'" already exists. Do you want to continue ? (yes, no)', [
96			'required' => true,
97			]);
98			switch ($prompt) {
99			case 'no':
100			case 'n':
101			exit();
102			}
103			}
104			$clients = $db->executeCommand('KEYS', [$clientService->getClientKey('*')]);
105			foreach ($clients as $clientHash) {
			0 ignored issues – show Bug introduced 2018-09-10 16:37 UTC by Report Bug Copy Issue Report The expression `$clients` of type `boolean\|string\|null\|array` is not guaranteed to be traversable. How about adding an additional type check? There are different options of fixing this problem. If you want to be on the safe side, you can add an additional type-check: $collection = json_decode($data, true); if ( ! is_array($collection)) { throw new \RuntimeException('$collection must be an array.'); } foreach ($collection as $item) { /** ... / } If you are sure that the expression is traversable, you might want to add a doc comment cast* to improve IDE auto-completion and static analysis: /** @var array $collection / $collection = json_decode($data, true); foreach ($collection as $item) { /* .. / } Mark the issue as a false-positive*: Just hover the remove button, in the top-right corner of this issue for more options. Loading history...
106			if ($db->executeCommand('TYPE', [$clientHash]) !== 'hash') {
107			continue;
108			}
109			$clientData = $db->executeCommand('HGETALL', [$clientHash]);
110			if (!empty($clientData)) {
111			$db->executeCommand('SADD', [$clientService->getClientListKey(), $clientData[1]]);
112			}
113			}
114			$this->stdout('Done migrating Clients !' . "\n");
115
116			///////////////
117			///
118			/// Jti
119			///
120			///////////////
121			$this->stdout('Start migrating Jtis ...' . "\n");
122			/** @var JtiService $jtiService */
123			$jtiService = Yii::createObject('sweelix\oauth2\server\interfaces\JtiServiceInterface');
124			$jtiList = $jtiService->getJtiListKey();
125			if ($db->executeCommand('EXISTS', [$jtiList]) == 1) {
126			$prompt = $this->prompt('The key "'.$jtiList.'" already exists. Do you want to continue ? (yes, no)', [
127			'required' => true,
128			]);
129			switch ($prompt) {
130			case 'no':
131			case 'n':
132			exit();
133			}
134			}
135			$jti = Yii::createObject('sweelix\oauth2\server\interfaces\JtiModelInterface');
136			$jtiClass = get_class($jti);
137			$jtis = $db->executeCommand('KEYS', [$jtiService->getSubjectJtisKey('*')]);
138			if (!empty($jtis)) {
139			$db->executeCommand('DEL', $jtis);
140			}
141			$jtis = $db->executeCommand('KEYS', [$jtiService->getSubjectJtisKey('*')]);
142			if (!empty($jtis)) {
143			$db->executeCommand('DEL', $jtis);
144			}
145			$jtis = $db->executeCommand('KEYS', [$jtiService->getJtiKey('*')]);
146			foreach ($jtis as $jtiHash) {
			0 ignored issues – show Bug introduced 2018-09-10 16:37 UTC by Report Bug Copy Issue Report The expression `$jtis` of type `boolean\|string\|null\|array` is not guaranteed to be traversable. How about adding an additional type check? There are different options of fixing this problem. If you want to be on the safe side, you can add an additional type-check: $collection = json_decode($data, true); if ( ! is_array($collection)) { throw new \RuntimeException('$collection must be an array.'); } foreach ($collection as $item) { /** ... / } If you are sure that the expression is traversable, you might want to add a doc comment cast* to improve IDE auto-completion and static analysis: /** @var array $collection / $collection = json_decode($data, true); foreach ($collection as $item) { /* .. / } Mark the issue as a false-positive*: Just hover the remove button, in the top-right corner of this issue for more options. Loading history...
147			if ($db->executeCommand('TYPE', [$jtiHash]) !== 'hash') {
148			continue;
149			}
150			$jtiData = $db->executeCommand('HGETALL', [$jtiHash]);
151			if (!empty($jtiData)) {
152			/** @var JtiModelInterface $jti */
153			$jti = $jtiClass::findOne($jtiData[1]); // id
154			if (!empty($jti)) {
155			$jti->delete();
156			$jti->save();
157			}
158			}
159			}
160			$this->stdout('Done migrating Jtis !' . "\n");
161
162			///////////////
163			///
164			/// RefreshToken
165			///
166			///////////////
167			$this->stdout('Start migrating RefreshTokens ...' . "\n");
168			/** @var RefreshTokenService $refreshTokenService */
169			$refreshTokenService = Yii::createObject('sweelix\oauth2\server\interfaces\RefreshTokenServiceInterface');
170			$refreshTokenList = $refreshTokenService->getRefreshTokenListKey();
171			if ($db->executeCommand('EXISTS', [$refreshTokenList]) == 1) {
172			$prompt = $this->prompt('The key "'.$refreshTokenList.'" already exists. Do you want to continue ? (yes, no)', [
173			'required' => true,
174			]);
175			switch ($prompt) {
176			case 'no':
177			case 'n':
178			exit();
179			}
180			}
181			$refreshToken = Yii::createObject('sweelix\oauth2\server\interfaces\RefreshTokenModelInterface');
182			$refreshTokenClass = get_class($refreshToken);
183			$refreshTokens = $db->executeCommand('KEYS', [$refreshTokenService->getUserRefreshTokensKey('*')]);
184			if (!empty($refreshTokens)) {
185			$db->executeCommand('DEL', $refreshTokens);
186			}
187			$refreshTokens = $db->executeCommand('KEYS', [$refreshTokenService->getClientRefreshTokensKey('*')]);
188			if (!empty($refreshTokens)) {
189			$db->executeCommand('DEL', $refreshTokens);
190			}
191			$refreshTokens = $db->executeCommand('KEYS', [$refreshTokenService->getRefreshTokenKey('*')]);
192			foreach ($refreshTokens as $refreshTokenHash) {
			0 ignored issues – show Bug introduced 2018-09-10 16:37 UTC by Report Bug Copy Issue Report The expression `$refreshTokens` of type `boolean\|string\|null\|array` is not guaranteed to be traversable. How about adding an additional type check? There are different options of fixing this problem. If you want to be on the safe side, you can add an additional type-check: $collection = json_decode($data, true); if ( ! is_array($collection)) { throw new \RuntimeException('$collection must be an array.'); } foreach ($collection as $item) { /** ... / } If you are sure that the expression is traversable, you might want to add a doc comment cast* to improve IDE auto-completion and static analysis: /** @var array $collection / $collection = json_decode($data, true); foreach ($collection as $item) { /* .. / } Mark the issue as a false-positive*: Just hover the remove button, in the top-right corner of this issue for more options. Loading history...
193			if ($db->executeCommand('TYPE', [$refreshTokenHash]) !== 'hash') {
194			continue;
195			}
196			$refreshTokenData = $db->executeCommand('HGETALL', [$refreshTokenHash]);
197			if (!empty($refreshTokenData)) {
198			/** @var RefreshTokenModelInterface $refreshToken */
199			$refreshToken = $refreshTokenClass::findOne($refreshTokenData[1]); // id
200			if (!empty($refreshToken)) {
201			$refreshToken->delete();
202			$refreshToken->save();
203			}
204			}
205			}
206			$this->stdout('Done migrating RefreshTokens !' . "\n");
207
208			$this->stdout('Migration done !' . "\n");
209			$exitCode = ExitCode::OK;
210			} catch (\Exception $e) {
211			$this->stderr($e->getMessage() . "\n");
212			$exitCode = ExitCode::getReason($e->getCode());
213			}
214			return $exitCode;
215			}
216			}
217

pgaultier / yii2-oauth2

MigrateRedisController A last analyzed 2018-11-06 00:45 UTC

Complexity

Size/Duplication

Coupling/Cohesion

Importance

1 Method

Duplication Side-by-Side

Filter issues like

MigrateRedisController A
last analyzed 2018-11-06 00:45 UTC