diff options
Diffstat (limited to 'caches/MemcachedCache.php')
| -rw-r--r-- | caches/MemcachedCache.php | 237 |
1 files changed, 124 insertions, 113 deletions
diff --git a/caches/MemcachedCache.php b/caches/MemcachedCache.php index b431279a..8619c255 100644 --- a/caches/MemcachedCache.php +++ b/caches/MemcachedCache.php @@ -1,115 +1,126 @@ <?php -class MemcachedCache implements CacheInterface { - - private $scope; - private $key; - private $conn; - private $expiration = 0; - private $time = false; - private $data = null; - - public function __construct() { - if (!extension_loaded('memcached')) { - returnServerError('"memcached" extension not loaded. Please check "php.ini"'); - } - - $host = Configuration::getConfig(get_called_class(), 'host'); - $port = Configuration::getConfig(get_called_class(), 'port'); - if (empty($host) && empty($port)) { - returnServerError('Configuration for ' . get_called_class() . ' missing. Please check your ' . FILE_CONFIG); - } else if (empty($host)) { - returnServerError('"host" param is not set for ' . get_called_class() . '. Please check your ' . FILE_CONFIG); - } else if (empty($port)) { - returnServerError('"port" param is not set for ' . get_called_class() . '. Please check your ' . FILE_CONFIG); - } else if (!ctype_digit($port)) { - returnServerError('"port" param is invalid for ' . get_called_class() . '. Please check your ' . FILE_CONFIG); - } - - $port = intval($port); - - if ($port < 1 || $port > 65535) { - returnServerError('"port" param is invalid for ' . get_called_class() . '. Please check your ' . FILE_CONFIG); - } - - $conn = new Memcached(); - $conn->addServer($host, $port) or returnServerError('Could not connect to memcached server'); - $this->conn = $conn; - } - - public function loadData(){ - if ($this->data) return $this->data; - $result = $this->conn->get($this->getCacheKey()); - if ($result === false) { - return null; - } - - $this->time = $result['time']; - $this->data = $result['data']; - return $result['data']; - } - - public function saveData($datas){ - $time = time(); - $object_to_save = array( - 'data' => $datas, - 'time' => $time, - ); - $result = $this->conn->set($this->getCacheKey(), $object_to_save, $this->expiration); - - if($result === false) { - returnServerError('Cannot write the cache to memcached server'); - } - - $this->time = $time; - - return $this; - } - - public function getTime(){ - if ($this->time === false) { - $this->loadData(); - } - return $this->time; - } - - public function purgeCache($duration){ - // Note: does not purges cache right now - // Just sets cache expiration and leave cache purging for memcached itself - $this->expiration = $duration; - } - - /** - * Set scope - * @return self - */ - public function setScope($scope){ - $this->scope = $scope; - return $this; - } - - /** - * Set key - * @return self - */ - public function setKey($key){ - if (!empty($key) && is_array($key)) { - $key = array_map('strtolower', $key); - } - $key = json_encode($key); - - if (!is_string($key)) { - throw new \Exception('The given key is invalid!'); - } - - $this->key = $key; - return $this; - } - - private function getCacheKey(){ - if(is_null($this->key)) { - returnServerError('Call "setKey" first!'); - } - - return 'rss_bridge_cache_' . hash('md5', $this->scope . $this->key . 'A'); - } + +class MemcachedCache implements CacheInterface +{ + private $scope; + private $key; + private $conn; + private $expiration = 0; + private $time = false; + private $data = null; + + public function __construct() + { + if (!extension_loaded('memcached')) { + returnServerError('"memcached" extension not loaded. Please check "php.ini"'); + } + + $host = Configuration::getConfig(get_called_class(), 'host'); + $port = Configuration::getConfig(get_called_class(), 'port'); + if (empty($host) && empty($port)) { + returnServerError('Configuration for ' . get_called_class() . ' missing. Please check your ' . FILE_CONFIG); + } elseif (empty($host)) { + returnServerError('"host" param is not set for ' . get_called_class() . '. Please check your ' . FILE_CONFIG); + } elseif (empty($port)) { + returnServerError('"port" param is not set for ' . get_called_class() . '. Please check your ' . FILE_CONFIG); + } elseif (!ctype_digit($port)) { + returnServerError('"port" param is invalid for ' . get_called_class() . '. Please check your ' . FILE_CONFIG); + } + + $port = intval($port); + + if ($port < 1 || $port > 65535) { + returnServerError('"port" param is invalid for ' . get_called_class() . '. Please check your ' . FILE_CONFIG); + } + + $conn = new Memcached(); + $conn->addServer($host, $port) or returnServerError('Could not connect to memcached server'); + $this->conn = $conn; + } + + public function loadData() + { + if ($this->data) { + return $this->data; + } + $result = $this->conn->get($this->getCacheKey()); + if ($result === false) { + return null; + } + + $this->time = $result['time']; + $this->data = $result['data']; + return $result['data']; + } + + public function saveData($datas) + { + $time = time(); + $object_to_save = [ + 'data' => $datas, + 'time' => $time, + ]; + $result = $this->conn->set($this->getCacheKey(), $object_to_save, $this->expiration); + + if ($result === false) { + returnServerError('Cannot write the cache to memcached server'); + } + + $this->time = $time; + + return $this; + } + + public function getTime() + { + if ($this->time === false) { + $this->loadData(); + } + return $this->time; + } + + public function purgeCache($duration) + { + // Note: does not purges cache right now + // Just sets cache expiration and leave cache purging for memcached itself + $this->expiration = $duration; + } + + /** + * Set scope + * @return self + */ + public function setScope($scope) + { + $this->scope = $scope; + return $this; + } + + /** + * Set key + * @return self + */ + public function setKey($key) + { + if (!empty($key) && is_array($key)) { + $key = array_map('strtolower', $key); + } + $key = json_encode($key); + + if (!is_string($key)) { + throw new \Exception('The given key is invalid!'); + } + + $this->key = $key; + return $this; + } + + private function getCacheKey() + { + if (is_null($this->key)) { + returnServerError('Call "setKey" first!'); + } + + return 'rss_bridge_cache_' . hash('md5', $this->scope . $this->key . 'A'); + } } |