1
|
|
|
<?php |
2
|
|
|
|
3
|
|
|
/** |
4
|
|
|
* Nextcloud - OCR |
5
|
|
|
* This file is licensed under the Affero General Public License version 3 or |
6
|
|
|
* later. |
7
|
|
|
* See the COPYING file. |
8
|
|
|
* |
9
|
|
|
* @author Janis Koehr <[email protected]> |
10
|
|
|
* @copyright Janis Koehr 2017 |
11
|
|
|
*/ |
12
|
|
|
namespace OCA\Ocr\Util; |
13
|
|
|
|
14
|
|
|
use OCP\ILogger; |
15
|
|
|
use OCP\IL10N; |
16
|
|
|
use OCA\Ocr\Service\NotFoundException; |
17
|
|
|
use OCA\Ocr\Constants\OcrConstants; |
18
|
|
|
use OCP\IConfig; |
19
|
|
|
|
20
|
|
|
|
21
|
|
|
/** |
22
|
|
|
* Class RedisUtil |
23
|
|
|
* |
24
|
|
|
* @package OCA\Ocr\Util |
25
|
|
|
*/ |
26
|
|
|
class RedisUtil { |
27
|
|
|
|
28
|
|
|
/** |
29
|
|
|
* |
30
|
|
|
* @var IL10N |
31
|
|
|
*/ |
32
|
|
|
private $l10n; |
33
|
|
|
|
34
|
|
|
/** |
35
|
|
|
* |
36
|
|
|
* @var ILogger |
37
|
|
|
*/ |
38
|
|
|
private $logger; |
39
|
|
|
|
40
|
|
|
/** |
41
|
|
|
* |
42
|
|
|
* @var IConfig |
43
|
|
|
*/ |
44
|
|
|
private $config; |
45
|
|
|
|
46
|
|
|
/** |
47
|
|
|
* |
48
|
|
|
* @var string |
49
|
|
|
*/ |
50
|
|
|
private $appName = 'ocr'; |
51
|
|
|
|
52
|
|
|
/** |
53
|
|
|
* |
54
|
|
|
* @param IL10N $l10n |
55
|
|
|
* @param ILogger $logger |
56
|
|
|
* @param IConfig $config |
57
|
|
|
*/ |
58
|
7 |
|
public function __construct(IL10N $l10n, ILogger $logger, IConfig $config) { |
59
|
7 |
|
$this->l10n = $l10n; |
60
|
7 |
|
$this->logger = $logger; |
61
|
7 |
|
$this->config = $config; |
62
|
7 |
|
} |
63
|
|
|
|
64
|
|
|
/** |
65
|
|
|
* Setup the Redis instance and return to whom ever it needs. |
66
|
|
|
* @codeCoverageIgnore |
67
|
|
|
* |
68
|
|
|
* @throws NotFoundException |
69
|
|
|
* @return \Redis |
70
|
|
|
*/ |
71
|
|
|
public function setupRedisInstance() { |
72
|
|
|
try { |
73
|
|
View Code Duplication |
if (!extension_loaded('redis')) { |
|
|
|
|
74
|
|
|
$this->logger->debug( |
75
|
|
|
'It seems that the message queueing capabilities are not available in your local php installation. Please install php-redis.', ['app' => OcrConstants::APP_NAME]); |
76
|
|
|
throw new NotFoundException($this->l10n->t('Message queueing capabilities are missing on the server (package php-redis).')); |
77
|
|
|
} |
78
|
|
|
$redis = new \Redis(); |
79
|
|
|
if (!$redis->connect($this->config->getAppValue($this->appName, 'redisHost'), |
80
|
|
|
intval($this->config->getAppValue($this->appName, 'redisPort')), 2.5, null, 100)) { |
81
|
|
|
$this->logger->debug('Cannot connect to Redis.', ['app' => OcrConstants::APP_NAME]); |
82
|
|
|
throw new NotFoundException($this->l10n->t('Cannot connect to Redis.')); |
83
|
|
|
} |
84
|
|
|
$password = $this->config->getAppValue($this->appName, 'redisPassword', ''); |
85
|
|
|
if($password !== '') { |
86
|
|
|
$authenticated = $redis->auth($password); |
87
|
|
|
} |
88
|
|
View Code Duplication |
if ($password !== '' && !$authenticated) { |
|
|
|
|
89
|
|
|
$this->logger->debug('Redis authentication error.', ['app' => OcrConstants::APP_NAME]); |
90
|
|
|
throw new NotFoundException($this->l10n->t('Redis authentication error.')); |
91
|
|
|
} |
92
|
|
|
if (!$redis->select(intval($this->config->getAppValue($this->appName, 'redisDb')))) { |
93
|
|
|
throw new NotFoundException($this->l10n->t('Cannot connect to the right Redis database.')); |
94
|
|
|
} |
95
|
|
|
$redis->setOption(\Redis::OPT_PREFIX, OcrConstants::REDIS_KEY_PREFIX); |
96
|
|
|
return $redis; |
97
|
|
|
} catch (\RedisException $e) { |
98
|
|
|
if($e->getMessage() === 'Failed to AUTH connection') { |
99
|
|
|
throw new NotFoundException($this->l10n->t('Redis authentication error.')); |
100
|
|
|
} |
101
|
|
|
} |
102
|
|
|
} |
103
|
|
|
} |
Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation.
You can also find more detailed suggestions in the “Code” section of your repository.