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');

src/Redis/Command/Compose/ApiSetSortedTrait.php

Spacing +13 added lines, -13 removed lines

@@ -103,11 +103,11 @@ 
         $args = [$key, $star, $stop];
         if ($withScores) {
             $args[] = 'WITHSCORES';
-            return $this->dispatch(Builder::build($command, $args))->then(function ($value) {
+            return $this->dispatch(Builder::build($command, $args))->then(function($value) {
                 $len = count($value);
                 $ret = [];
-                for ($i=0; $i<$len; $i+=2) {
-                    $ret[$value[$i]] = $value[$i+1];
+                for ($i = 0; $i < $len; $i += 2) {
+                    $ret[$value[$i]] = $value[$i + 1];
                 }
                 return $ret;
             });
@@ -124,7 +124,7 @@ 
     {
         $command = Enum::ZRANGEBYLEX;
         $args = [$key, $min, $max];
-        $args = array_merge($args,$options);
+        $args = array_merge($args, $options);
 
         return $this->dispatch(Builder::build($command, $args));
     }
@@ -136,8 +136,8 @@ 
     public function zRevRangeByLex($key, $max, $min, array $options = [])
     {
         $command = Enum::ZREVRANGEBYLEX;
-        $args = [$key, $max,$min];
-        $args = array_merge($args,$options);
+        $args = [$key, $max, $min];
+        $args = array_merge($args, $options);
 
         return $this->dispatch(Builder::build($command, $args));
     }
@@ -149,7 +149,7 @@ 
     public function zRangeByScore($key, $min, $max, array $options = [])
     {
         $command = Enum::ZRANGEBYSCORE;
-        $args = [$key, $min,$max];
+        $args = [$key, $min, $max];
         $args = array_merge($args, $options);
 
         return $this->dispatch(Builder::build($command, $args));
@@ -162,7 +162,7 @@ 
     public function zRank($key, $member)
     {
         $command = Enum::ZRANK;
-        $args = [$key,$member];
+        $args = [$key, $member];
 
         return $this->dispatch(Builder::build($command, $args));
     }
@@ -200,7 +200,7 @@ 
     public function zRemRangeByRank($key, $start, $stop)
     {
         $command = Enum::ZREMRANGEBYRANK;
-        $args = [$key, $start,$stop];
+        $args = [$key, $start, $stop];
 
         return $this->dispatch(Builder::build($command, $args));
     }
@@ -238,7 +238,7 @@ 
     public function zRevRangeByScore($key, $max, $min, array $options = [])
     {
         $command = Enum::ZREVRANGEBYSCORE;
-        $args = [$key,$max,$min];
+        $args = [$key, $max, $min];
         $args = array_merge($args, $options);
 
         return $this->dispatch(Builder::build($command, $args));
@@ -251,7 +251,7 @@ 
     public function zRevRank($key, $member)
     {
         $command = Enum::ZREVRANK;
-        $args = [$key,$member];
+        $args = [$key, $member];
 
         return $this->dispatch(Builder::build($command, $args));
     }
@@ -263,7 +263,7 @@ 
     public function zScore($key, $member)
     {
         $command = Enum::ZSCORE;
-        $args = [$key,$member];
+        $args = [$key, $member];
 
         return $this->dispatch(Builder::build($command, $args));
     }
@@ -276,7 +276,7 @@ 
     {
         // TODO: Implement zScan() method.
         $command = Enum::ZSCAN;
-        $args = [$key , $cursor];
+        $args = [$key, $cursor];
         $args = array_merge($args, $options);
 
         return $this->dispatch(Builder::build($command, $args));

Braces +8 added lines, -4 removed lines

@@ -22,8 +22,10 @@ 
     {
         $command = Enum::ZADD;
         $args = array_merge([$key], $options);
-        if (!empty($scoreMembers)) {
-            foreach ($scoreMembers as $score => $member) {
+        if (!empty($scoreMembers))
+        {
+            foreach ($scoreMembers as $score => $member)
+            {
                 $args[] = (float) $score;
                 $args[] = $member;
             }
@@ -101,12 +103,14 @@ 
     {
         $command = Enum::ZRANGE;
         $args = [$key, $star, $stop];
-        if ($withScores) {
+        if ($withScores)
+        {
             $args[] = 'WITHSCORES';
             return $this->dispatch(Builder::build($command, $args))->then(function ($value) {
                 $len = count($value);
                 $ret = [];
-                for ($i=0; $i<$len; $i+=2) {
+                for ($i=0; $i<$len; $i+=2)
+                {
                     $ret[$value[$i]] = $value[$i+1];
                 }
                 return $ret;