dazzle-php / redis

src/Redis/Driver/DriverInterface.php

Doc Comments +3 added lines

@@ -6,5 +6,8 @@
 
 interface DriverInterface
 {
+    /**
+     * @return string
+     */
     public function commands(Request $request);
 }
\ No newline at end of file

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/Redis.php

Indentation +1 added lines, -1 removed lines

@@ -162,7 +162,7 @@
 
         $this->reqs = [];
 
-         // TODO patch missing pub/sub, pipeline, auth
+            // TODO patch missing pub/sub, pipeline, auth
         $this->handleStop();
         $this->emit('stop', [ $this ]);
 

Spacing +34 added lines, -34 removed lines

@@ -133,7 +133,7 @@ 
 
         // TODO patch missing pub/sub, pipeline, auth
         $this->handleStart();
-        $this->emit('start', [ $this ]);
+        $this->emit('start', [$this]);
 
         return true;
     }
@@ -164,7 +164,7 @@ 
 
          // TODO patch missing pub/sub, pipeline, auth
         $this->handleStop();
-        $this->emit('stop', [ $this ]);
+        $this->emit('stop', [$this]);
 
         return true;
     }
@@ -216,8 +216,8 @@ 
     {
         if ($this->stream !== null)
         {
-            $this->stream->on('data', [ $this, 'handleData' ]);
-            $this->stream->on('close', [ $this, 'stop' ]);
+            $this->stream->on('data', [$this, 'handleData']);
+            $this->stream->on('close', [$this, 'stop']);
         }
     }
 
@@ -228,8 +228,8 @@ 
     {
         if ($this->stream !== null)
         {
-            $this->stream->removeListener('data', [ $this, 'handleData' ]);
-            $this->stream->removeListener('close', [ $this, 'stop' ]);
+            $this->stream->removeListener('data', [$this, 'handleData']);
+            $this->stream->removeListener('close', [$this, 'stop']);
         }
     }
 
@@ -246,7 +246,7 @@ 
         }
         catch (ParserException $error)
         {
-            $this->emit('error', [ $this, $error ]);
+            $this->emit('error', [$this, $error]);
             $this->stop();
             return;
         }
@@ -259,7 +259,7 @@ 
             }
             catch (UnderflowException $error)
             {
-                $this->emit('error', [ $this, $error ]);
+                $this->emit('error', [$this, $error]);
                 $this->stop();
                 return;
             }
@@ -413,9 +413,9 @@ 
         $keys[] = $timeout;
         $args = $keys;
         $promise = $this->dispatch(Builder::build($command, $args));
-        $promise = $promise->then(function ($value) {
+        $promise = $promise->then(function($value) {
             if (is_array($value)) {
-                list($k,$v) = $value;
+                list($k, $v) = $value;
 
                 return [
                     'key'=>$k,
@@ -436,9 +436,9 @@ 
         $keys[] = $timeout;
         $args = $keys;
         $promise = $this->dispatch(Builder::build($command, $args));
-        $promise = $promise->then(function ($value) {
+        $promise = $promise->then(function($value) {
             if (is_array($value)) {
-                list($k,$v) = $value;
+                list($k, $v) = $value;
 
                 return [
                     'key'=>$k,
@@ -479,7 +479,7 @@ 
         return $this->dispatch(Builder::build($command, $args));
     }
 
-    public function del($key,...$keys)
+    public function del($key, ...$keys)
     {
         $command = Enum::DEL;
         $keys[] = $key;
@@ -850,13 +850,13 @@ 
         $command = Enum::HGETALL;
         $args = [$key];
 
-        return $this->dispatch(Builder::build($command, $args))->then(function ($value) {
+        return $this->dispatch(Builder::build($command, $args))->then(function($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];
+                    $val = $value[$i + 1];
                     $tmp[$field] = $val;
                 }
                 $value = $tmp;
@@ -985,7 +985,7 @@ 
     {
         // TODO: Implement geoDist() method.
         $command = Enum::GEODIST;
-        $args = [$key, $memberA, $memberB ,$unit];
+        $args = [$key, $memberA, $memberB, $unit];
 
         return $this->dispatch(Builder::build($command, $args));
     }
@@ -1088,7 +1088,7 @@ 
         return $this->dispatch(Builder::build($command, $args));
     }
 
-    public function lPush($key,...$values)
+    public function lPush($key, ...$values)
     {
         $command = Enum::LPUSH;
         array_unshift($values, $key);
@@ -1405,14 +1405,14 @@ 
     {
         $command = Enum::INFO;
 
-        return $this->dispatch(Builder::build($command, $section))->then(function ($value) {
+        return $this->dispatch(Builder::build($command, $section))->then(function($value) {
             if ($value) {
                 $ret = explode(PHP_EOL, $value);
                 $handled = [];
                 $lastKey = '';
                 foreach ($ret as $_ => $v) {
                     if (($pos = strpos($v, '#')) !== false) {
-                        $lastKey = strtolower(substr($v,$pos+2));
+                        $lastKey = strtolower(substr($v, $pos + 2));
                         $handled[$lastKey] = [];
                         continue;
                     }
@@ -1489,7 +1489,7 @@ 
     {
         // TODO: Implement zRange() method.
         $command = Enum::ZRANGE;
-        $args = [$key, $star,$stop];
+        $args = [$key, $star, $stop];
         $args = array_merge($args, $options);
 
         return $this->dispatch(Builder::build($command, $args));
@@ -1500,7 +1500,7 @@ 
         // TODO: Implement zRangeByLex() method.
         $command = Enum::ZRANGEBYLEX;
         $args = [$key, $min, $max];
-        $args = array_merge($args,$options);
+        $args = array_merge($args, $options);
 
         return $this->dispatch(Builder::build($command, $args));
     }
@@ -1509,8 +1509,8 @@ 
     {
         // TODO: Implement zRevRangeByLex() method.
         $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));
     }
@@ -1519,7 +1519,7 @@ 
     {
         // TODO: Implement zRangeByScore() method.
         $command = Enum::ZRANGEBYSCORE;
-        $args = [$key, $min,$max];
+        $args = [$key, $min, $max];
         $args = array_merge($args, $options);
 
         return $this->dispatch(Builder::build($command, $args));
@@ -1529,7 +1529,7 @@ 
     {
         // TODO: Implement zRank() method.
         $command = Enum::ZRANK;
-        $args = [$key,$member];
+        $args = [$key, $member];
 
         return $this->dispatch(Builder::build($command, $args));
     }
@@ -1557,7 +1557,7 @@ 
     {
         // TODO: Implement zRemRangeByRank() method.
         $command = Enum::ZREMRANGEBYRANK;
-        $args = [$key, $start,$stop];
+        $args = [$key, $start, $stop];
 
         return $this->dispatch(Builder::build($command, $args));
     }
@@ -1585,7 +1585,7 @@ 
     {
         // TODO: Implement zRevRangeByScore() method.
         $command = Enum::ZREVRANGEBYSCORE;
-        $args = [$key,$max,$min];
+        $args = [$key, $max, $min];
         $args = array_merge($args, $options);
 
         return $this->dispatch(Builder::build($command, $args));
@@ -1595,7 +1595,7 @@ 
     {
         // TODO: Implement zRevRank() method.
         $command = Enum::ZREVRANK;
-        $args = [$key,$member];
+        $args = [$key, $member];
 
         return $this->dispatch(Builder::build($command, $args));
     }
@@ -1604,7 +1604,7 @@ 
     {
         // TODO: Implement zScore() method.
         $command = Enum::ZSCORE;
-        $args = [$key,$member];
+        $args = [$key, $member];
 
         return $this->dispatch(Builder::build($command, $args));
     }
@@ -1642,7 +1642,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));
@@ -1671,7 +1671,7 @@ 
     {
         // TODO: Implement sIsMember() method.
         $command = Enum::SISMEMBER;
-        $args = [$key ,$member];
+        $args = [$key, $member];
 
         return $this->dispatch(Builder::build($command, $args));
     }
@@ -1689,7 +1689,7 @@ 
     {
         // TODO: Implement sLowLog() method.
         $command = Enum::SLOWLOG;
-        $args = array_merge([$command],$args);
+        $args = array_merge([$command], $args);
 
         return $this->dispatch(Builder::build($command, $args));
     }
@@ -1708,7 +1708,7 @@ 
         // TODO: Implement sMove() method.
         $command = Enum::SMOVE;
         $args = [$src, $dst];
-        $args = array_merge( $args, $members);
+        $args = array_merge($args, $members);
 
         return $this->dispatch(Builder::build($command, $args));
     }

Braces +30 added lines, -15 removed lines

@@ -118,9 +118,11 @@ 
             $stream = $this->createClient($this->endpoint);
         }
         catch (Error $ex)
-        {}
+        {
+}
         catch (Exception $ex)
-        {}
+        {
+}
 
         if ($ex !== null)
         {
@@ -310,9 +312,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);
     }
@@ -358,7 +362,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];
@@ -414,7 +419,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 [
@@ -437,7 +443,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 [
@@ -851,10 +858,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;
@@ -911,8 +920,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;
             }
@@ -1406,18 +1417,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/CommandInterface.php

Spacing +4 added lines, -4 removed lines

@@ -42,7 +42,7 @@ 
      * @param int $end
      * @return mixed
      */
-    public function bitCount($key, $start=0, $end=0);
+    public function bitCount($key, $start = 0, $end = 0);
 
     /**
      * @doc https://redis.io/commands/bitfield
@@ -73,7 +73,7 @@ 
      * @param int $end
      * @return mixed
      */
-    public function bitPos($key, $bit, $start=0, $end=0);
+    public function bitPos($key, $bit, $start = 0, $end = 0);
 
     /**
      * @doc https://redis.io/commands/blpop
@@ -567,7 +567,7 @@ 
      * @param string $message
      * @return mixed
      */
-    public function ping($message='pong');
+    public function ping($message = 'pong');
 
     /**
      * @doc https://redis.io/commands/quit
@@ -1357,7 +1357,7 @@ 
      * @param array $args
      * @return mixed
      */
-    public function sLowLog($command, array $args=[]);
+    public function sLowLog($command, array $args = []);
 
     /**
      * @doc https://redis.io/commands/smembers