rss-bridge/caches/MemcachedCache.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"');
        }

        $section = 'MemcachedCache';
        $host = Configuration::getConfig($section, 'host');
        $port = Configuration::getConfig($section, 'port');
        if (empty($host) && empty($port)) {
            returnServerError('Configuration for ' . $section . ' missing. Please check your ' . FILE_CONFIG);
        } elseif (empty($host)) {
            returnServerError('"host" param is not set for ' . $section . '. Please check your ' . FILE_CONFIG);
        } elseif (empty($port)) {
            returnServerError('"port" param is not set for ' . $section . '. Please check your ' . FILE_CONFIG);
        } elseif (!ctype_digit($port)) {
            returnServerError('"port" param is invalid for ' . $section . '. Please check your ' . FILE_CONFIG);
        }

        $port = intval($port);

        if ($port < 1 || $port > 65535) {
            returnServerError('"port" param is invalid for ' . $section . '. 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');
    }
}