dazzle-php / redis

src/Redis/Config.php

Spacing +1 added lines, -1 removed lines

@@ -54,7 +54,7 @@
         $this->host = $parts['host'];
         $this->port = $parts['port'];
         $this->auth = $auth;
-        $this->db =  $parts['db'];
+        $this->db = $parts['db'];
     }
 
     public function getHost()

Braces +18 added lines, -9 removed lines

@@ -8,44 +8,53 @@
 {
     public function __construct($target)
     {
-        if ($target === null) {
+        if ($target === null)
+        {
             $target = 'tcp://127.0.0.1';
         }
 
-        if (strpos($target, '://') === false) {
+        if (strpos($target, '://') === false)
+        {
             $target = 'tcp://' . $target;
         }
 
         $parts = parse_url($target);
-        if ($parts === false || !isset($parts['host']) || $parts['scheme'] !== 'tcp') {
+        if ($parts === false || !isset($parts['host']) || $parts['scheme'] !== 'tcp')
+        {
             throw new InvalidArgumentException('Given URL can not be parsed');
         }
 
-        if (!isset($parts['port'])) {
+        if (!isset($parts['port']))
+        {
             $parts['port'] = 6379;
             $this->port = 6379;
         }
 
-        if ($parts['host'] === 'localhost') {
+        if ($parts['host'] === 'localhost')
+        {
             $parts['host'] = '127.0.0.1';
             $this->host = '127.0.0.1';
         }
 
         $auth = null;
-        if (isset($parts['user'])) {
+        if (isset($parts['user']))
+        {
             $auth = $parts['user'];
             $this->auth = $auth;
         }
 
-        if (isset($parts['pass'])) {
+        if (isset($parts['pass']))
+        {
             $auth .= ':' . $parts['pass'];
         }
 
-        if ($auth !== null) {
+        if ($auth !== null)
+        {
             $parts['auth'] = $auth;
         }
 
-        if (isset($parts['path']) && $parts['path'] !== '') {
+        if (isset($parts['path']) && $parts['path'] !== '')
+        {
             $parts['db'] = substr($parts['path'], 1);
         }
 

src/Redis/Redis.php

Spacing +1 added lines, -1 removed lines

@@ -71,7 +71,7 @@
         {
             $payload = $this->driver->commands($command);
 
-            $this->dispatcher->on('request', function () use ($payload) {
+            $this->dispatcher->on('request', function() use ($payload) {
                 $this->dispatcher->handleRequest($payload);
             });
 

Braces +2 added lines, -2 removed lines

@@ -66,8 +66,8 @@
         if ($this->dispatcher->isEnding())
         {
             $request->reject(new RuntimeException('Connection closed'));
-        } 
-        else 
+        }
+        else
         {
             $payload = $this->driver->commands($command);
 

src/Redis/Dispatcher.php

Indentation +7 added lines, -7 removed lines

@@ -82,13 +82,13 @@
         }
     }
 
-     /**
-     * Create socket client with connection to Redis database.
-     *
-     * @param string $endpoint
-     * @return SocketInterface
-     * @throws ExecutionException
-     */
+        /**
+         * Create socket client with connection to Redis database.
+         *
+         * @param string $endpoint
+         * @return SocketInterface
+         * @throws ExecutionException
+         */
     protected function createClient($endpoint)
     {
         $ex = null;

Spacing +4 added lines, -4 removed lines

@@ -62,8 +62,8 @@ 
         $this->closed = false;
         $this->protocol = new Driver();
         $this->on('connect', [$this, 'handleConnect']);
-        $this->on('response',[$this, 'handleResponse']);
-        $this->on('disconnect',[$this, 'handleDisconnect']);
+        $this->on('response', [$this, 'handleResponse']);
+        $this->on('disconnect', [$this, 'handleDisconnect']);
         $this->on('close', [$this, 'handleClose']);
     }
 
@@ -120,7 +120,7 @@ 
      */
     public function isEnding()
     {
-        return $this->ending? true: false;
+        return $this->ending ? true : false;
     }
 
     /**
@@ -227,7 +227,7 @@ 
     {
         $this->ending = true;
         // reject all remaining requests in the queue
-        while($this->reqs) {
+        while ($this->reqs) {
             $req = array_shift($this->reqs);
             /* @var $req Deferred */
             $req->reject(new RuntimeException('Connection closing'));

Braces +39 added lines, -18 removed lines

@@ -76,7 +76,7 @@ 
         {
             $this->handleDisconnect();        
         }
-        else 
+        else
         {
             $this->handleClose();        
         }
@@ -98,9 +98,11 @@ 
             return new Socket($endpoint, $this->loop);
         }
         catch (Error $ex)
-        {}
+        {
+}
         catch (Exception $ex)
-        {}
+        {
+}
 
         throw new ExecutionException('Redis connection socket could not be created!', 0, $ex);
     }
@@ -138,17 +140,22 @@ 
      */
     public function watch($endpoint)
     {
-        if ($this->stream !== null) {
+        if ($this->stream !== null)
+        {
             return;
         }
 
-        try {
+        try
+        {
             $this->stream = $this->createClient($endpoint);
-        } catch (\Exception $e) {
+        }
+        catch (\Exception $e)
+        {
             $this->emit('error', [$e]);
         }
 
-        if ($this->stream->isOpen()) {
+        if ($this->stream->isOpen())
+        {
             $this->emit('connect', [$this]);
         }
 
@@ -170,18 +177,25 @@ 
      */
     public function handleData($_, $data)
     {
-        try {
+        try
+        {
             $models = $this->protocol->parseResponse($data);
-        } catch (ParserException $error) {
+        }
+        catch (ParserException $error)
+        {
             $this->emit('error', [$error]);
 
             return;
         }
 
-        foreach ($models as $data) {
-            try {
+        foreach ($models as $data)
+        {
+            try
+            {
                 $this->emit('response', [$data]);
-            } catch (UnderflowException $error) {
+            }
+            catch (UnderflowException $error)
+            {
                 $this->emit('error', [$error]);
 
                 break;
@@ -203,19 +217,24 @@ 
      */
     public function handleResponse(ModelInterface $message)
     {
-        if (!$this->reqs) {
+        if (!$this->reqs)
+        {
             throw new UnderflowException('Unexpected reply received, no matching request found');
         }
         /* @var Deferred $req */
         $req = array_shift($this->reqs);
 
-        if ($message instanceof ErrorReply) {
+        if ($message instanceof ErrorReply)
+        {
             $req->reject($message);
-        } else {
+        }
+        else
+        {
             $req->resolve($message->getValueNative());
         }
 
-        if (count($this->reqs) <= 0) {
+        if (count($this->reqs) <= 0)
+        {
             $this->emit('disconnect');
         }
     }
@@ -227,7 +246,8 @@ 
     {
         $this->ending = true;
         // reject all remaining requests in the queue
-        while($this->reqs) {
+        while($this->reqs)
+        {
             $req = array_shift($this->reqs);
             /* @var $req Deferred */
             $req->reject(new RuntimeException('Connection closing'));
@@ -241,7 +261,8 @@ 
      */
     public function handleClose()
     {
-        if ($this->closed) {
+        if ($this->closed)
+        {
             return;
         }
         $this->removeListeners('connect');