Nekland / Woketo

src/Http/HttpHeadersBag.php

Doc Comments +1 added lines, -1 removed lines

@@ -57,7 +57,7 @@
 
     /**
      * @param string $name
-     * @param mixed  $value
+     * @param string  $value
      * @return self
      */
     public function add(string $name, $value)

Spacing +1 added lines, -1 removed lines

@@ -63,7 +63,7 @@
     public function add(string $name, $value)
     {
         if (!empty($this->headers[$name])) {
-            if (!is_array($this->headers[$name])){
+            if (!is_array($this->headers[$name])) {
                 $this->headers[$name] = [$this->headers[$name]];
             }
             $this->headers[$name][] = $value;

src/Server/Connection.php

Doc Comments +1 added lines, -1 removed lines

@@ -141,7 +141,7 @@
     }
 
     /**
-     * @param string|Frame $frame
+     * @param string $frame
      * @param int          $opCode An int representing binary or text data (const of Frame class)
      * @throws \Nekland\Woketo\Exception\RuntimeException
      */

Spacing +3 added lines, -3 removed lines

@@ -83,7 +83,7 @@ 
 
     private function initListeners()
     {
-        $this->socketStream->on('data', function ($data) {
+        $this->socketStream->on('data', function($data) {
             $this->processData($data);
         });
         $this->socketStream->on('error', [$this, 'error']);
@@ -124,7 +124,7 @@ 
             $this->currentMessage = $message;
             if ($this->currentMessage->isComplete()) {
                 // Sending the message through the woketo API.
-                switch($this->currentMessage->getOpcode()) {
+                switch ($this->currentMessage->getOpcode()) {
                     case Frame::OP_TEXT:
                         $this->handler->onMessage($this->currentMessage->getContent(), $this);
                         break;
@@ -136,7 +136,7 @@ 
 
             } else {
                 // We wait for more data so we start a timeout.
-                $this->timeout = $this->loop->addTimer(Connection::DEFAULT_TIMEOUT, function () {
+                $this->timeout = $this->loop->addTimer(Connection::DEFAULT_TIMEOUT, function() {
                     $this->messageProcessor->timeout($this->socketStream);
                 });
             }

src/Http/Request.php

Spacing +1 added lines, -1 removed lines

@@ -96,7 +96,7 @@
 
             if (count($explodingHeader)) {
                 unset($explodingHeader[0]); // removing the name of the extension
-                foreach($explodingHeader as $variable) {
+                foreach ($explodingHeader as $variable) {
                     $explodeVariable = explode('=', $variable);
 
                     // The value can be with or without quote. We need to remove extra quotes.

src/Http/Response.php

Spacing +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
         $stringResponse = $this->getHttpVersion() . ' ' . $this->httpResponse . "\r\n";
 
         foreach ($this->getHeaders() as $name => $content) {
-            $stringResponse .= $name . ': '. $content . "\r\n";
+            $stringResponse .= $name . ': ' . $content . "\r\n";
         }
         
         // No content to concatenate

src/Utils/BitManipulation.php

Spacing +3 added lines, -3 removed lines

@@ -8,7 +8,7 @@ 
  * For the full license, take a look to the LICENSE file
  * on the root directory of this project
  */
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace Nekland\Woketo\Utils;
 
@@ -58,7 +58,7 @@ 
         if (is_string($frame)) {
             $len = BitManipulation::frameSize($frame);
 
-            if ($byteNumber < 0 || $byteNumber > ($len-1)) {
+            if ($byteNumber < 0 || $byteNumber > ($len - 1)) {
                 throw new \InvalidArgumentException(
                     sprintf('The frame is only %s bytes larges but you tried to get the %sth byte.', $len, $byteNumber)
                 );
@@ -166,7 +166,7 @@ 
             $res = 0;
 
             // for each byte, getting ord
-            for($i = 0; $i < $subStringLength; $i++) {
+            for ($i = 0; $i < $subStringLength; $i++) {
                 $res <<= 8;
                 $res += ord($subString[$i]);
             }

src/Server/Websocket.php

Spacing +2 added lines, -2 removed lines

@@ -92,13 +92,13 @@
 
     public function setMessageHandler($messageHandler)
     {
-        if (!$messageHandler instanceof MessageHandlerInterface &&  !is_string($messageHandler)) {
+        if (!$messageHandler instanceof MessageHandlerInterface && !is_string($messageHandler)) {
             throw new \InvalidArgumentException('The message handler must be an instance of MessageHandlerInterface or a string.');
         }
         if (is_string($messageHandler)) {
             try {
                 $reflection = new \ReflectionClass($messageHandler);
-                if(!$reflection->implementsInterface('Nekland\Woketo\Message\MessageHandlerInterface')) {
+                if (!$reflection->implementsInterface('Nekland\Woketo\Message\MessageHandlerInterface')) {
                     throw new \InvalidArgumentException('The messageHandler must implement MessageHandlerInterface');
                 }
             } catch (\ReflectionException $e) {

src/Rfc6455/Frame.php

Doc Comments +3 added lines

@@ -130,6 +130,9 @@
      */
     private $infoBytesLen;
 
+    /**
+     * @param string $data
+     */
     public function __construct($data=null)
     {
         if (null !== $data) {

Spacing +7 added lines, -7 removed lines

@@ -8,7 +8,7 @@ 
  * on the root directory of this project
  */
 
-declare(strict_types=1);
+declare(strict_types = 1);
 namespace Nekland\Woketo\Rfc6455;
 
 use Nekland\Woketo\Exception\Frame\ControlFrameException;
@@ -25,11 +25,11 @@ 
  */
 class Frame
 {
-    const OP_CONTINUE =  0;
-    const OP_TEXT     =  1;
-    const OP_BINARY   =  2;
-    const OP_CLOSE    =  8;
-    const OP_PING     =  9;
+    const OP_CONTINUE = 0;
+    const OP_TEXT     = 1;
+    const OP_BINARY   = 2;
+    const OP_CLOSE    = 8;
+    const OP_PING     = 9;
     const OP_PONG     = 10;
 
     // To understand codes, please refer to RFC:
@@ -130,7 +130,7 @@ 
      */
     private $infoBytesLen;
 
-    public function __construct($data=null)
+    public function __construct($data = null)
     {
         if (null !== $data) {
             $this->setRawData($data);

src/Rfc6455/Message.php

Spacing +1 added lines, -1 removed lines

@@ -50,7 +50,7 @@
             } catch (IncompleteFrameException $e) {
                 return ''; // There is no more frame we can generate, the data is saved as buffer.
             }
-        } while(!$this->isComplete() && !empty($this->buffer));
+        } while (!$this->isComplete() && !empty($this->buffer));
 
         if ($this->isComplete()) {
             return $this->buffer;

src/Rfc6455/MessageProcessor.php

Spacing +1 added lines, -1 removed lines

@@ -81,7 +81,7 @@
                 $socket->end();
                 $data = '';
             }
-        } while(!empty($data));
+        } while (!empty($data));
 
         return $messages;
     }