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

Braces +8 added lines, -4 removed lines

@@ -128,9 +128,11 @@ 
             $stream = $this->createClient($this->endpoint);
         }
         catch (Error $ex)
-        {}
+        {
+}
         catch (Exception $ex)
-        {}
+        {
+}
 
         if ($ex !== null)
         {
@@ -320,9 +322,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);
     }

Spacing +8 added lines, -8 removed lines

@@ -149,7 +149,7 @@ 
         $this->isBeingDisconnected = false;
         $this->stream = $stream;
         $this->handleStart();
-        $this->emit('start', [ $this ]);
+        $this->emit('start', [$this]);
 
         return Promise::doResolve($this);
     }
@@ -178,7 +178,7 @@ 
 
         $this->reqs = [];
         $this->handleStop();
-        $this->emit('stop', [ $this ]);
+        $this->emit('stop', [$this]);
 
         if ($this->endPromise !== null)
         {
@@ -243,8 +243,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']);
         }
     }
 
@@ -255,8 +255,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']);
         }
     }
 
@@ -273,7 +273,7 @@ 
         }
         catch (ParserException $error)
         {
-            $this->emit('error', [ $this, $error ]);
+            $this->emit('error', [$this, $error]);
             $this->stop();
             return;
         }
@@ -286,7 +286,7 @@ 
             }
             catch (UnderflowException $error)
             {
-                $this->emit('error', [ $this, $error ]);
+                $this->emit('error', [$this, $error]);
                 $this->stop();
                 return;
             }

src/Redis/Command/Api/ApiConnInterface.php

Spacing +1 added lines, -1 removed lines

@@ -18,7 +18,7 @@
      * @param string $message
      * @return mixed
      */
-    public function ping($message='pong');
+    public function ping($message = 'pong');
 
     /**
      * @doc https://redis.io/commands/quit

src/Redis/Command/Compose/ApiSetHashTrait.php

Spacing +3 added lines, -3 removed lines

@@ -48,13 +48,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;

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;
@@ -134,8 +136,10 @@ 
         //TODO: replace param $fvMap to ...$fvs,cauz hash map not allow duplicate key
         $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/ApiGeospatialTrait.php

Spacing +1 added lines, -1 removed lines

@@ -60,7 +60,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));
     }

src/Redis/Command/Compose/ApiKeyValTrait.php

Spacing +1 added lines, -1 removed lines

@@ -347,7 +347,7 @@
      * @override
      * @inheritDoc
      */
-    public function del($key,...$keys)
+    public function del($key, ...$keys)
     {
         $command = Enum::DEL;
         $keys[] = $key;

Braces +10 added lines, -5 removed lines

@@ -47,7 +47,8 @@ 
         $command = Enum::BITFIELD;
         $subCommand = strtoupper($subCommand);
         //TODO: control flow improvement
-        switch ($subCommand) {
+        switch ($subCommand)
+        {
             case 'GET' : {
                 @list ($type, $offset) = $param;
                 $args = [$key, $subCommand, $type, $offset];
@@ -305,8 +306,10 @@ 
         //TODO: change the param $kvMap to ...$kv,cauz map not allow duplicate key
         $command = Enum::MSET;
         $args = [];
-        if (!empty($kvMap)) {
-            foreach ($kvMap as $key => $val) {
+        if (!empty($kvMap))
+        {
+            foreach ($kvMap as $key => $val)
+            {
                 $args[] = $key;
                 $args[] = $val;
             }
@@ -323,8 +326,10 @@ 
     {
         $command = Enum::MSETNX;
         $args = [];
-        if (!empty($kvMap)) {
-            foreach ($kvMap as $key => $val) {
+        if (!empty($kvMap))
+        {
+            foreach ($kvMap as $key => $val)
+            {
                 $args[] = $key;
                 $args[] = $val;
             }

src/Redis/Command/Compose/ApiListTrait.php

Spacing +5 added lines, -5 removed lines

@@ -25,9 +25,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,
@@ -52,9 +52,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,
@@ -137,7 +137,7 @@ 
      * @override
      * @inheritDoc
      */
-    public function lPush($key,...$values)
+    public function lPush($key, ...$values)
     {
         $command = Enum::LPUSH;
         array_unshift($values, $key);

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/Command/Api/ApiSetSortedInterface.php

Doc Comments -1 removed lines

@@ -66,7 +66,6 @@
      * @param $key
      * @param $star
      * @param $stop
-     * @param array $options
      * @return mixed
      */
     public function zRange($key, $star = 0, $stop = -1, $withScores = false);