mirror of
https://github.com/the-djmaze/snappymail.git
synced 2026-09-02 14:07:04 +03:00
34b8a4395a
\Predis\Client\setex doesn't return a boolean, but the current Redis caching functionality expects it to do so.
111 lines
2 KiB
PHP
111 lines
2 KiB
PHP
<?php
|
|
|
|
/*
|
|
* This file is part of MailSo.
|
|
*
|
|
* (c) 2014 Usenko Timur
|
|
*
|
|
* For the full copyright and license information, please view the LICENSE
|
|
* file that was distributed with this source code.
|
|
*/
|
|
|
|
namespace MailSo\Cache\Drivers;
|
|
|
|
/**
|
|
* @category MailSo
|
|
* @package Cache
|
|
* @subpackage Drivers
|
|
*/
|
|
class Redis implements \MailSo\Cache\DriverInterface
|
|
{
|
|
/**
|
|
* @var int
|
|
*/
|
|
private $iExpire;
|
|
|
|
/**
|
|
* @var \Memcache|null
|
|
*/
|
|
private $oRedis;
|
|
|
|
/**
|
|
* @var string
|
|
*/
|
|
private $sKeyPrefix;
|
|
|
|
|
|
function __construct(string $sHost = '127.0.0.1', int $iPort = 6379, int $iExpire = 43200, string $sKeyPrefix = '')
|
|
{
|
|
$this->iExpire = 0 < $iExpire ? $iExpire : 43200;
|
|
|
|
$this->oRedis = null;
|
|
|
|
try
|
|
{
|
|
$this->oRedis = new \Predis\Client(\strpos($sHost, ':/') ? $sHost : array(
|
|
'host' => $sHost,
|
|
'port' => $iPort
|
|
));
|
|
|
|
$this->oRedis->connect();
|
|
|
|
if (!$this->oRedis->isConnected())
|
|
{
|
|
$this->oRedis = null;
|
|
}
|
|
}
|
|
catch (\Throwable $oExc)
|
|
{
|
|
$this->oRedis = null;
|
|
unset($oExc);
|
|
}
|
|
|
|
$this->sKeyPrefix = $sKeyPrefix;
|
|
if (!empty($this->sKeyPrefix))
|
|
{
|
|
$this->sKeyPrefix =
|
|
\preg_replace('/[^a-zA-Z0-9_]/', '_', rtrim(trim($this->sKeyPrefix), '\\/')).'/';
|
|
}
|
|
}
|
|
|
|
public function Set(string $sKey, string $sValue) : bool
|
|
{
|
|
if (!$this->oRedis)
|
|
{
|
|
return false;
|
|
}
|
|
|
|
$sValue = $this->oRedis->setex($this->generateCachedKey($sKey), $this->iExpire, $sValue);
|
|
|
|
return $sValue === true || $sValue == 'OK';
|
|
}
|
|
|
|
public function Get(string $sKey) : string
|
|
{
|
|
$sValue = $this->oRedis ? $this->oRedis->get($this->generateCachedKey($sKey)) : '';
|
|
return \is_string($sValue) ? $sValue : '';
|
|
}
|
|
|
|
public function Delete(string $sKey) : void
|
|
{
|
|
if ($this->oRedis)
|
|
{
|
|
$this->oRedis->del($this->generateCachedKey($sKey));
|
|
}
|
|
}
|
|
|
|
public function GC(int $iTimeToClearInHours = 24) : bool
|
|
{
|
|
if (0 === $iTimeToClearInHours && $this->oRedis)
|
|
{
|
|
return $this->oRedis->flushdb();
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
private function generateCachedKey(string $sKey) : string
|
|
{
|
|
return $this->sKeyPrefix.\sha1($sKey);
|
|
}
|
|
}
|