Nekland / Woketo

src/Rfc6455/MessageProcessor.php

Spacing +2 added lines, -2 removed lines

@@ -95,7 +95,7 @@ 
                         // Data is now stored in the message, let's clean the variable to stop both loops.
                         $data = null;
                     }
-                } while(!$message->isComplete() && !empty($data));
+                } while (!$message->isComplete() && !empty($data));
 
                 if ($message->isComplete()) {
                     $this->processHelper($message, $socket);
@@ -118,7 +118,7 @@ 
                 $socket->end();
                 $data = '';
             }
-        } while(!empty($data));
+        } while (!empty($data));
     }
 
     /**

src/Http/HttpHeadersBag.php

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/Utils/SimpleLogger.php

Spacing +1 added lines, -1 removed lines

@@ -38,7 +38,7 @@
     {
         // Doesn't log everything in not debug context
         if ($this->debug || \in_array($level, [LogLevel::CRITICAL, LogLevel::ERROR])) {
-            echo '[' . date('Y-m-d H:i:s') . '][' . $level . '] ' . $message ."\n";
+            echo '[' . date('Y-m-d H:i:s') . '][' . $level . '] ' . $message . "\n";
         }
     }
 }

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 +2 added lines, -2 removed lines

@@ -98,7 +98,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
@@ -152,7 +152,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/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;

Spacing +6 added lines, -6 removed lines

@@ -102,7 +102,7 @@ 
         $this->buildMessageProcessor();
 
         // Some optimization
-        \gc_enable();       // As the process never stops, the garbage collector will be usefull, you may need to call it manually sometimes for performance purpose
+        \gc_enable(); // As the process never stops, the garbage collector will be usefull, you may need to call it manually sometimes for performance purpose
         \set_time_limit(0); // It's by default on most server for cli apps but better be sure of that fact
     }
 
@@ -112,13 +112,13 @@ 
      */
     public function setMessageHandler($messageHandler, $uri = '*')
     {
-        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) {
@@ -150,7 +150,7 @@ 
             $this->getLogger()->info('Enabled ssl');
         }
 
-        $this->server->on('connection', function (ConnectionInterface $socketStream) {
+        $this->server->on('connection', function(ConnectionInterface $socketStream) {
             $this->onNewConnection($socketStream);
         });
 
@@ -164,11 +164,11 @@ 
      */
     private function onNewConnection(ConnectionInterface $socketStream)
     {
-        $connection = new Connection($socketStream, function ($uri, Connection $connection) {
+        $connection = new Connection($socketStream, function($uri, Connection $connection) {
             return $this->getMessageHandler($uri, $connection);
         }, $this->loop, $this->messageProcessor);
 
-        $socketStream->on('end', function () use($connection) {
+        $socketStream->on('end', function() use($connection) {
             $this->onDisconnect($connection);
         });
 

src/Client/Connection.php

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\Socket\ConnectionInterface;

 

 class Connection extends AbstractConnection

Spacing +5 added lines, -5 removed lines

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

         $this->handler = $handler;

 

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

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

             $this->stream = $stream;

             $this->onConnection($stream);

-        }, function (\Exception $error) {

+        }, function(\Exception $error) {

             $this->onError($error);

         });

     }

 

     private function onConnection(ConnectionInterface $stream)

     {

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

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

             $this->onMessage($data);

         });

 

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

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

                 });

src/Rfc6455/Frame.php

Spacing +6 added lines, -6 removed lines

@@ -27,11 +27,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:
@@ -593,7 +593,7 @@ 
     {
         $this->config = \array_merge([
             'maxPayloadSize' => Frame::$defaultMaxPayloadSize,
-        ],$config);
+        ], $config);
 
         return $this;
     }