mako\Redis

public function __construct($name = null)
{
	$config = Config::get('redis');

	$name = ($name === null) ? $config['default'] : $name;

	if(isset($config['configurations'][$name]) === false)
	{
		throw new RuntimeException(vsprintf("%s(): '%s' has not been defined in the redis configuration.", array(__METHOD__, $name)));
	}

	$this->config = $config['configurations'][$name];

	$this->connect();
}

public static function factory($name = null)
{
	return new static($name);
}

public function __destruct()
{
	$this->disconnect();
}

protected function connect()
{
	$this->connection = @fsockopen('tcp://' . $this->config['host'], $this->config['port'], $errNo, $errStr);

	if(!$this->connection)
	{
		throw new RuntimeException(vsprintf("%s(): %s", array(__METHOD__, $errStr)));
	}

	if(!empty($this->config['password']))
	{
		$this->auth($this->config['password']);
	}

	if(!empty($this->config['database']) && $this->config['database'] !== 0)
	{
		$this->select($this->config['database']);
	}
}

protected function disconnect()
{
	if(is_resource($this->connection))
	{
		fclose($this->connection);	
	}
}

protected function response()
{
	$response = trim(fgets($this->connection));

	switch(substr($response, 0, 1))
	{
		case '-': // error reply
			throw new RuntimeException(vsprintf("%s(): %s.", array(__METHOD__, substr($response, 5))));
		break;
		case '+': // status reply
			return trim(substr($response, 1));
		break;
		case ':': // integer reply
			return (int) trim(substr($response, 1));
		break;
		case '$': // bulk reply
			if($response === '$-1')
			{
				return null;
			}

			$length = (int) substr($response, 1);

			return substr(fread($this->connection, $length + strlen(static::CRLF)), 0, - strlen(static::CRLF));
		break;
		case '*': // multi-bulk reply
			if($response === '*-1')
			{
				return null;
			}

			$data = array();

			$count = substr($response, 1);

			for($i = 0; $i < $count; $i++)
			{
				$data[] = $this->response();
			}

			return $data;
		break;
		default:
			throw new RuntimeException(vsprintf("%s(): Unable to handle server response.", array(__METHOD__)));
	}
}

public function __call($name, $args)
{
	// Build command

	array_unshift($args, strtoupper($name));

	$command = '*' . count($args) . static::CRLF;

	foreach($args as $arg)
	{
		$command .= '$' . strlen($arg) . static::CRLF . $arg . static::CRLF;
	}

	// Send command to server

	fwrite($this->connection, $command);

	// Return response

	return $this->response();
}

public static function __callStatic($name, $arguments)
{
	return call_user_func_array(array(static::factory(), $name), $arguments);
}