dazzle-php / redis

src/Redis/Driver/RequestInterface.php

Braces +2 added lines, -1 removed lines

@@ -5,4 +5,5 @@
 use Clue\Redis\Protocol\Model\ModelInterface as ClueModelInterface;
 
 interface RequestInterface extends ClueModelInterface
-{}
+{
+}

src/Redis/Command/Compose/ApiSetHashTrait.php

Braces +8 added lines, -4 removed lines

@@ -49,10 +49,12 @@ 
         $args = [$key];
 
         return $this->dispatch(Builder::build($command, $args))->then(function ($value) {
-            if (!empty($value)) {
+            if (!empty($value))
+            {
                 $tmp = [];
                 $size = count($value);
-                for ($i=0; $i<$size; $i+=2) {
+                for ($i=0; $i<$size; $i+=2)
+                {
                     $field = $value[$i];
                     $val = $value[$i+1];
                     $tmp[$field] = $val;
@@ -133,8 +135,10 @@ 
     {
         $command = Enum::HMSET;
         $args = [$key];
-        if (!empty($fvMap)) {
-            foreach ($fvMap as $field => $value) {
+        if (!empty($fvMap))
+        {
+            foreach ($fvMap as $field => $value)
+            {
                 $tmp[] = $field;
                 $tmp[] = $value;
             }

src/Redis/Command/Compose/ApiCoreTrait.php

Braces +8 added lines, -4 removed lines

@@ -104,18 +104,22 @@
         $command = Enum::INFO;
 
         return $this->dispatch(Builder::build($command, $section))->then(function ($value) {
-            if ($value) {
+            if ($value)
+            {
                 $ret = explode(PHP_EOL, $value);
                 $handled = [];
                 $lastKey = '';
-                foreach ($ret as $_ => $v) {
-                    if (($pos = strpos($v, '#')) !== false) {
+                foreach ($ret as $_ => $v)
+                {
+                    if (($pos = strpos($v, '#')) !== false)
+                    {
                         $lastKey = strtolower(substr($v,$pos+2));
                         $handled[$lastKey] = [];
                         continue;
                     }
                     $statMap = explode(':', $v);
-                    if ($statMap[0]) {
+                    if ($statMap[0])
+                    {
                         list($name, $stat) = explode(':', $v);
                         $handled[$lastKey][$name] = $stat;
                     }

src/Redis/Command/Compose/ApiKeyValTrait.php

Braces +2 added lines, -1 removed lines

@@ -45,7 +45,8 @@
     public function bitField($key, $subCommand = null, ...$param)
     {
         $command = Enum::BITFIELD;
-        switch ($subCommand = strtoupper($subCommand)) {
+        switch ($subCommand = strtoupper($subCommand))
+        {
             case 'GET' : {
                 list ($type, $offset) = $param;
                 $args = [$subCommand, $type, $offset];

src/Redis/Command/Compose/ApiListTrait.php

Braces +4 added lines, -2 removed lines

@@ -26,7 +26,8 @@ 
         $args = $keys;
         $promise = $this->dispatch(Builder::build($command, $args));
         $promise = $promise->then(function ($value) {
-            if (is_array($value)) {
+            if (is_array($value))
+            {
                 list($k,$v) = $value;
 
                 return [
@@ -53,7 +54,8 @@ 
         $args = $keys;
         $promise = $this->dispatch(Builder::build($command, $args));
         $promise = $promise->then(function ($value) {
-            if (is_array($value)) {
+            if (is_array($value))
+            {
                 list($k,$v) = $value;
 
                 return [

src/Redis/Config.php

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

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

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