Nekland / Woketo

src/Client/Connection.php

Doc Comments +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
     }

 

     /**

-     * @param \Exception|string $error

+     * @param \Exception $error

      */

     private function onError($error)

     {

Spacing +5 added lines, -5 removed lines

@@ -52,17 +52,17 @@ 
         $this->buffer = '';

         $this->handler = $handler;

 

-        $clientPromise->then(function (Stream $stream) {

+        $clientPromise->then(function(Stream $stream) {

             $this->stream = $stream;

             $this->onConnection($stream);

-        }, function (\Exception $error){

+        }, function(\Exception $error) {

             $this->onError($error);

         });

     }

 

     private function onConnection(Stream $stream)

     {

-        $stream->on('data', function (string $data) {

+        $stream->on('data', function(string $data) {

             $this->onMessage($data);

         });

 

@@ -114,7 +114,7 @@ 
 

             if ($this->currentMessage->isComplete()) {

                 // Sending the message through the woketo API.

-                switch($this->currentMessage->getOpcode()) {

+                switch ($this->currentMessage->getOpcode()) {

                     case Frame::OP_TEXT:

                         $this->getHandler()->onMessage($this->currentMessage->getContent(), $this);

                         break;

@@ -126,7 +126,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->getLogger()->notice('Connection to ' . $this->getIp() . ' timed out.');

                     $this->messageProcessor->timeout($this->stream);

                 });

Unused Use Statements +12 added lines, -12 removed lines

@@ -12,18 +12,18 @@
 namespace Nekland\Woketo\Client;

 

 

-use Nekland\Woketo\Core\AbstractConnection;

-use Nekland\Woketo\Exception\Http\IncompleteHttpMessageException;

-use Nekland\Woketo\Exception\RuntimeException;

-use Nekland\Woketo\Exception\WebsocketException;

-use Nekland\Woketo\Http\Response;

-use Nekland\Woketo\Http\Url;

-use Nekland\Woketo\Message\MessageHandlerInterface;

-use Nekland\Woketo\Rfc6455\Frame;

-use Nekland\Woketo\Rfc6455\Handshake\ClientHandshake;

-use Nekland\Woketo\Rfc6455\MessageProcessor;

-use React\EventLoop\LoopInterface;

-use React\Promise\PromiseInterface;

+use Nekland\Woketo\Core\AbstractConnection;
+use Nekland\Woketo\Exception\Http\IncompleteHttpMessageException;
+use Nekland\Woketo\Exception\RuntimeException;
+use Nekland\Woketo\Exception\WebsocketException;
+use Nekland\Woketo\Http\Response;
+use Nekland\Woketo\Http\Url;
+use Nekland\Woketo\Message\MessageHandlerInterface;
+use Nekland\Woketo\Rfc6455\Frame;
+use Nekland\Woketo\Rfc6455\Handshake\ClientHandshake;
+use Nekland\Woketo\Rfc6455\MessageProcessor;
+use React\EventLoop\LoopInterface;
+use React\Promise\PromiseInterface;
 use React\Stream\Stream;

 

 class Connection extends AbstractConnection

src/Server/Connection.php

Spacing +4 added lines, -4 removed lines

@@ -69,10 +69,10 @@ 
 
     private function initListeners()
     {
-        $this->stream->on('data', function ($data) {
+        $this->stream->on('data', function($data) {
             $this->processData($data);
         });
-        $this->stream->on('error', function ($data) {
+        $this->stream->on('error', function($data) {
             $this->error($data);
         });
     }
@@ -114,7 +114,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->getHandler()->onMessage($this->currentMessage->getContent(), $this);
                         break;
@@ -126,7 +126,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->logger->notice('Connection to ' . $this->getIp() . ' timed out.');
                     $this->messageProcessor->timeout($this->stream);
                 });

src/Http/Response.php

Spacing +3 added lines, -3 removed lines

@@ -99,7 +99,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
@@ -124,7 +124,7 @@ 
      * @return Response
      * @throws HttpException
      */
-    public static function create(string &$data) : Response
+    public static function create(string & $data) : Response
     {
         if (!\preg_match('/\\r\\n\\r\\n/', $data)) {
             throw new IncompleteHttpMessageException();
@@ -162,7 +162,7 @@ 
     {
         $httpElements = \explode(' ', $firstLine);
 
-        if (!\preg_match('/HTTP\/[1-2\.]+/',$httpElements[0])) {
+        if (!\preg_match('/HTTP\/[1-2\.]+/', $httpElements[0])) {
             throw Response::createNotHttpException($firstLine);
         }
         $response->setHttpVersion($httpElements[0]);

src/Rfc6455/Handshake/ClientHandshake.php

Spacing +2 added lines, -2 removed lines

@@ -31,7 +31,7 @@ 
 

         $key = '';

         for ($i = 0; $i < 16; $i++) {

-            $key .= chr(mt_rand(0,255));

+            $key .= chr(mt_rand(0, 255));

         }

 

         $key = base64_encode($key);

@@ -110,7 +110,7 @@ 
     {

         $bytes = '';

 

-        for($i = 0; $i < 16; $i++) {

+        for ($i = 0; $i < 16; $i++) {

             $bytes .= chr(mt_rand(0, 255));

         }

 

src/Core/AbstractConnection.php

Unused Use Statements +12 added lines, -12 removed lines

@@ -11,18 +11,18 @@
 

 namespace Nekland\Woketo\Core;

 

-use Nekland\Woketo\Exception\NoHandlerException;

-use Nekland\Woketo\Exception\WebsocketException;

-use Nekland\Woketo\Message\MessageHandlerInterface;

-use Nekland\Woketo\Rfc6455\Frame;

-use Nekland\Woketo\Rfc6455\Handshake\HandshakeInterface;

-use Nekland\Woketo\Rfc6455\Message;

-use Nekland\Woketo\Rfc6455\MessageProcessor;

-use Nekland\Woketo\Utils\SimpleLogger;

-use Psr\Log\LoggerAwareTrait;

-use Psr\Log\LoggerInterface;

-use React\EventLoop\LoopInterface;

-use React\EventLoop\Timer\TimerInterface;

+use Nekland\Woketo\Exception\NoHandlerException;
+use Nekland\Woketo\Exception\WebsocketException;
+use Nekland\Woketo\Message\MessageHandlerInterface;
+use Nekland\Woketo\Rfc6455\Frame;
+use Nekland\Woketo\Rfc6455\Handshake\HandshakeInterface;
+use Nekland\Woketo\Rfc6455\Message;
+use Nekland\Woketo\Rfc6455\MessageProcessor;
+use Nekland\Woketo\Utils\SimpleLogger;
+use Psr\Log\LoggerAwareTrait;
+use Psr\Log\LoggerInterface;
+use React\EventLoop\LoopInterface;
+use React\EventLoop\Timer\TimerInterface;
 use React\Socket\Connection;

 

 abstract class AbstractConnection

src/Server/WebSocketServer.php

Unused Use Statements -1 removed lines

@@ -24,7 +24,6 @@
 use Nekland\Woketo\Rfc6455\MessageProcessor;
 use Nekland\Woketo\Utils\SimpleLogger;
 use Psr\Log\LoggerInterface;
-use Psr\Log\LogLevel;
 use React\EventLoop\LoopInterface;
 use React\Socket\ConnectionInterface;
 use React\Socket\ServerInterface;

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;
 use Nekland\Woketo\Exception\Utils\NotLongEnoughException;
@@ -65,7 +65,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)
                 );
@@ -173,7 +173,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]);
             }