<?php

/*
 * khoaofgod@gmail.com
 * Website: http://www.phpfastcache.com
 * Example at our website, any bugs, problems, please visit http://faster.phpfastcache.com
 *
 * Redis Extension with:
 * http://pecl.php.net/package/redis
 */


class phpfastcache_predis extends BasePhpFastCache implements phpfastcache_driver {

	var $checked_redis = false;

    function checkdriver() {
        // Check memcache
        if (! class_exists("\\Predis\\Client")) {
	    $this->required_extension("predis-1.0/autoload.php");
	    try {
		    Predis\Autoloader::register();
	    } catch(Exception $e) {

	    }
        }
        return true;
    }

    function __construct($config = array()) {
        $this->setup($config);
        if (! class_exists("\\Predis\\Client")) {
	    $this->required_extension("predis-1.0/autoload.php");
        }
    }

    function connectServer() {

	    $server = isset($this->config['redis']) ? $this->config['redis'] : array(
																			    "host" => "127.0.0.1",
																			    "port"  =>  "6379",
																			    "password"  =>  "",
																			    "database"  =>  ""
																		    );


	    if($this->checked_redis === false) {
			$c = array(
					"host"  => $server['host'],
			);

		    $port = isset($server['port']) ? $server['port'] : "";
		    if($port!="") {
			    $c['port'] = $port;
		    }

		    $password = isset($server['password']) ? $server['password'] : "";
		    if($password!="") {
			    $c['password'] = $password;
		    }

		    $database = isset($server['database']) ? $server['database'] : "";
		    if($database!="") {
			    $c['database'] = $database;
		    }

		    $timeout = isset($server['timeout']) ? $server['timeout'] : "";
		    if($timeout!="") {
			    $c['timeout'] = $timeout;
		    }

		    $read_write_timeout = isset($server['read_write_timeout']) ? $server['read_write_timeout'] : "";
		    if($read_write_timeout!="") {
			    $c['read_write_timeout'] = $read_write_timeout;
		    }

		    $this->instant = new Predis\Client($c);

		    $this->checked_redis = true;

		    if(!$this->instant) {
			    $this->fallback = true;
			    return false;
		    } else {
			    return true;
		    }
	    }

	    return true;
    }

    function driver_set($keyword, $value = "", $time = 300, $option = array() ) {
        if($this->connectServer()) {
	        $value = $this->encode($value);
	        if (isset($option['skipExisting']) && $option['skipExisting'] == true) {
		        return $this->instant->setex($keyword, $time, $value);
	        } else {
		        return $this->instant->setex($keyword, $time, $value );
	        }
        } else {
			return $this->backup()->set($keyword, $value, $time, $option);
        }
    }

    function driver_get($keyword, $option = array()) {
        if($this->connectServer()) {
	        // return null if no caching
	        // return value if in caching'
	        $x = $this->instant->get($keyword);
	        if($x == false) {
		        return null;
	        } else {

		        return $this->decode($x);
	        }
        } else {
			$this->backup()->get($keyword, $option);
        }

    }

    function driver_delete($keyword, $option = array()) {

        if($this->connectServer()) {
	        $this->instant->del($keyword);
        }

    }

    function driver_stats($option = array()) {
        if($this->connectServer()) {
	        $res = array(
		        "info"  => "",
		        "size"  =>  "",
		        "data"  => $this->instant->info(),
	        );

	        return $res;
        }

	    return array();

    }

    function driver_clean($option = array()) {
        if($this->connectServer()) {
	        $this->instant->flushDB();
        }

    }

    function driver_isExisting($keyword) {
        if($this->connectServer()) {
	        $x = $this->instant->exists($keyword);
	        if($x == null) {
		        return false;
	        } else {
		        return true;
	        }
        } else {
	        return $this->backup()->isExisting($keyword);
        }

    }


}