ccf375e917
The configuration files are currently hard-coded in the configuration classes and error messages. However, the implementation should not rely on specific details like the file name. Instead, the files should be part of the global definition. This commit introduces two global constants for the configuration files - FILE_CONFIG => 'config.ini.php' - FILE_CONFIG_DEFAULT => 'config.default.ini.php'
116 lines
2.9 KiB
PHP
116 lines
2.9 KiB
PHP
<?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 false;
|
|
}
|
|
|
|
$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');
|
|
}
|
|
}
|