Improve redis configuration

- basic authentication
- switch database (0 - 15)
This commit is contained in:
Philipp Holzer 2019-04-20 13:40:40 +02:00
parent 048501be34
commit fa71a9a0ce
No known key found for this signature in database
GPG key ID: 517BE60E2CE5C8A5
3 changed files with 27 additions and 5 deletions

View file

@ -22,9 +22,11 @@ class RedisCacheDriver extends AbstractCacheDriver implements IMemoryCacheDriver
/** /**
* @param string $redis_host * @param string $redis_host
* @param int $redis_port * @param int $redis_port
* @param int $redis_db (Default = 0, maximum is 15)
* @param string? $redis_pw
* @throws Exception * @throws Exception
*/ */
public function __construct($redis_host, $redis_port) public function __construct($redis_host, $redis_port, $redis_db = 0, $redis_pw = null)
{ {
if (!class_exists('Redis', false)) { if (!class_exists('Redis', false)) {
throw new Exception('Redis class isn\'t available'); throw new Exception('Redis class isn\'t available');
@ -35,6 +37,14 @@ class RedisCacheDriver extends AbstractCacheDriver implements IMemoryCacheDriver
if (!$this->redis->connect($redis_host, $redis_port)) { if (!$this->redis->connect($redis_host, $redis_port)) {
throw new Exception('Expected Redis server at ' . $redis_host . ':' . $redis_port . ' isn\'t available'); throw new Exception('Expected Redis server at ' . $redis_host . ':' . $redis_port . ' isn\'t available');
} }
if (isset($redis_pw) && !$this->redis->auth($redis_pw)) {
throw new Exception('Cannot authenticate redis server at ' . $redis_host . ':' . $redis_port);
}
if ($redis_db !== 0 && !$this->redis->select($redis_db)) {
throw new Exception('Cannot switch to redis db ' . $redis_db . ' at ' . $redis_host . ':' . $redis_port);
}
} }
/** /**

View file

@ -2,9 +2,9 @@
namespace Friendica\Factory; namespace Friendica\Factory;
use Friendica\Core\Cache;
use Friendica\Core\Cache\ICacheDriver; use Friendica\Core\Cache\ICacheDriver;
use Friendica\Core\Config; use Friendica\Core\Config;
use Friendica\Core\Cache;
/** /**
* Class CacheDriverFactory * Class CacheDriverFactory
@ -40,8 +40,10 @@ class CacheDriverFactory
case 'redis': case 'redis':
$redis_host = Config::get('system', 'redis_host'); $redis_host = Config::get('system', 'redis_host');
$redis_port = Config::get('system', 'redis_port'); $redis_port = Config::get('system', 'redis_port');
$redis_pw = Config::get('system', 'redis_password');
$redis_db = Config::get('system', 'redis_db', 0);
return new Cache\RedisCacheDriver($redis_host, $redis_port); return new Cache\RedisCacheDriver($redis_host, $redis_port, $redis_db, $redis_pw);
break; break;
default: default:
return new Cache\DatabaseCacheDriver(); return new Cache\DatabaseCacheDriver();

View file

@ -22,6 +22,16 @@ class RedisCacheDriverTest extends MemoryCacheTest
->with('system', 'redis_port') ->with('system', 'redis_port')
->andReturn(null); ->andReturn(null);
$this->configMock
->shouldReceive('get')
->with('system', 'redis_db')
->andReturn(3);
$this->configMock
->shouldReceive('get')
->with('system', 'redis_password')
->andReturn(null);
$this->cache = CacheDriverFactory::create('redis'); $this->cache = CacheDriverFactory::create('redis');
return $this->cache; return $this->cache;
} }