balmet.com

Unnamed repository; edit this file 'description' to name the repository.
Log | Files | Refs

Redis.php (4063B)

      1 <?php
      2 
      3 /**
      4  * SimplePie Redis Cache Extension
      5  *
      6  * @package SimplePie
      7  * @author Jan Kozak <galvani78@gmail.com>
      8  * @link http://galvani.cz/
      9  * @license http://www.opensource.org/licenses/bsd-license.php BSD License
     10  * @version 0.2.9
     11  */
     12 
     13 
     14 /**
     15  * Caches data to redis
     16  *
     17  * Registered for URLs with the "redis" protocol
     18  *
     19  * For example, `redis://localhost:6379/?timeout=3600&prefix=sp_&dbIndex=0` will
     20  * connect to redis on `localhost` on port 6379. All tables will be
     21  * prefixed with `simple_primary-` and data will expire after 3600 seconds
     22  *
     23  * @package SimplePie
     24  * @subpackage Caching
     25  * @uses Redis
     26  */
     27 class SimplePie_Cache_Redis implements SimplePie_Cache_Base {
     28     /**
     29      * Redis instance
     30      *
     31      * @var \Redis
     32      */
     33     protected $cache;
     34 
     35     /**
     36      * Options
     37      *
     38      * @var array
     39      */
     40     protected $options;
     41 
     42     /**
     43      * Cache name
     44      *
     45      * @var string
     46      */
     47     protected $name;
     48 
     49     /**
     50      * Cache Data
     51      *
     52      * @var type
     53      */
     54     protected $data;
     55 
     56     /**
     57      * Create a new cache object
     58      *
     59      * @param string $location Location string (from SimplePie::$cache_location)
     60      * @param string $name Unique ID for the cache
     61      * @param string $type Either TYPE_FEED for SimplePie data, or TYPE_IMAGE for image data
     62      */
     63     public function __construct($location, $name, $options = null) {
     64         //$this->cache = \flow\simple\cache\Redis::getRedisClientInstance();
     65         $parsed = SimplePie_Cache::parse_URL($location);
     66         $redis = new Redis();
     67         $redis->connect($parsed['host'], $parsed['port']);
     68         if (isset($parsed['pass'])) {
     69             $redis->auth($parsed['pass']);
     70         }
     71         if (isset($parsed['path'])) {
     72             $redis->select((int)substr($parsed['path'], 1));
     73         }
     74         $this->cache = $redis;
     75 
     76         if (!is_null($options) && is_array($options)) {
     77             $this->options = $options;
     78         } else {
     79             $this->options = array (
     80                 'prefix' => 'rss:simple_primary:',
     81                 'expire' => 0,
     82             );
     83         }
     84 
     85         $this->name = $this->options['prefix'] . $name;
     86     }
     87 
     88     /**
     89      * @param \Redis $cache
     90      */
     91     public function setRedisClient(\Redis $cache) {
     92         $this->cache = $cache;
     93     }
     94 
     95     /**
     96      * Save data to the cache
     97      *
     98      * @param array|SimplePie $data Data to store in the cache. If passed a SimplePie object, only cache the $data property
     99      * @return bool Successfulness
    100      */
    101     public function save($data) {
    102         if ($data instanceof SimplePie) {
    103             $data = $data->data;
    104         }
    105         $response = $this->cache->set($this->name, serialize($data));
    106         if ($this->options['expire']) {
    107             $this->cache->expire($this->name, $this->options['expire']);
    108         }
    109 
    110         return $response;
    111     }
    112 
    113     /**
    114      * Retrieve the data saved to the cache
    115      *
    116      * @return array Data for SimplePie::$data
    117      */
    118     public function load() {
    119         $data = $this->cache->get($this->name);
    120 
    121         if ($data !== false) {
    122             return unserialize($data);
    123         }
    124         return false;
    125     }
    126 
    127     /**
    128      * Retrieve the last modified time for the cache
    129      *
    130      * @return int Timestamp
    131      */
    132     public function mtime() {
    133 
    134         $data = $this->cache->get($this->name);
    135 
    136         if ($data !== false) {
    137             return time();
    138         }
    139 
    140         return false;
    141     }
    142 
    143     /**
    144      * Set the last modified time to the current time
    145      *
    146      * @return bool Success status
    147      */
    148     public function touch() {
    149 
    150         $data = $this->cache->get($this->name);
    151 
    152         if ($data !== false) {
    153             $return = $this->cache->set($this->name, $data);
    154             if ($this->options['expire']) {
    155                 return $this->cache->expire($this->name, $this->ttl);
    156             }
    157             return $return;
    158         }
    159 
    160         return false;
    161     }
    162 
    163     /**
    164      * Remove the cache
    165      *
    166      * @return bool Success status
    167      */
    168     public function unlink() {
    169         return $this->cache->set($this->name, null);
    170     }
    171 
    172 }