refactoring and working on redis.

laravel/redis.php

@@ -0,0 +1,155 @@
+<?php namespace Laravel;
+
+class Redis {
+
+	/**
+	 * The active Redis connections.
+	 *
+	 * @var array
+	 */
+	protected static $connections = array();
+
+	/**
+	 * The name of the Redis connection.
+	 *
+	 * @var string
+	 */
+	public $name;
+
+	/**
+	 * The configuration array for the Redis connection.
+	 *
+	 * @var array
+	 */
+	public $config = array();
+
+	/**
+	 * The connection to the Redis database.
+	 *
+	 * @var resource
+	 */
+	protected $connection;
+
+	/**
+	 * Create a new Redis connection instance.
+	 *
+	 * @param  string  $name
+	 * @param  array   $config
+	 * @return void
+	 */
+	public function __construct($name, $config)
+	{
+		$this->name = $name;
+		$this->config = $config;
+	}
+
+	/**
+	 * Create a new Redis connection instance.
+	 *
+	 * @param  string  $connection
+	 * @param  array   $config
+	 * @return Redis
+	 */
+	public static function make($name, $config)
+	{
+		return new static($name, $config);
+	}
+
+	/**
+	 * Create a new Redis connection instance.
+	 *
+	 * Redis connections are managed as singletons, so if the connection has
+	 * already been established, that same connection instance will be returned
+	 * on subsequent requests for the connection.
+	 *
+	 * @param  string  $connection
+	 * @return Redis
+	 */
+	public static function connection($name)
+	{
+		if ( ! array_key_exists($name, static::$connections))
+		{
+			$config = Config::get("database.redis.{$name}");
+
+			if (is_null($config))
+			{
+				throw new \Exception("Redis connection [$name] has not been configured.");
+			}
+
+			static::$connections[$name] = static::make($name, $config)->connect();
+		}
+
+		return static::$connections[$name];
+	}
+
+	/**
+	 * Connect to the Redis database.
+	 *
+	 * The Redis instance itself will be returned by the method.
+	 *
+	 * @return Redis
+	 */
+	public function connect()
+	{
+		$this->connection = @fsockopen($this->config['host'], $this->config['port'], $error, $message);		
+
+		if ($this->connection === false)
+		{
+			throw new \Exception("Error establishing Redis connection [{$this->name}]: {$error} - {$message}");
+		}
+
+		return $this;
+	}
+
+	/**
+	 * Execute a command agaisnt the Redis database.
+	 *
+	 * @param  string  $method
+	 * @param  array   $parameters
+	 * @return mixed
+	 */
+	public function do($method, $parameters)
+	{
+		fwrite($this->connection, $this->command($method, $parameters));
+
+		$reply = trim(fgets($this->connection, 512));
+	}
+
+	/**
+	 * Build the Redis command based from a given method and parameters.
+	 *
+	 * @param  string  $method
+	 * @param  array   $parameters
+	 * @return string
+	 */
+	protected function command($method, $parameters)
+	{
+		$command = '*'.(count($parameters) + 1).CRLF.'$'.strlen($method).CRLF.strtoupper($method).CRLF;
+
+		foreach ($parameters as $parameter)
+		{
+			$command .= '$'.strlen($parameter).CRLF.$parameter.CRLF;
+		}
+
+		return $command;
+	}
+
+	/**
+	 * Dynamically make calls to the Redis database.
+	 */
+	public function __call($method, $parameters)
+	{
+		return $this->do($method, $parameters);
+	}
+
+	/**
+	 * Close the connection to the Redis database.
+	 *
+	 * @return void
+	 */
+	public function __destruct()
+	{
+		fclose($this->connection);
+	}
+
+}