tbolier / php-rethink-ql

src/Connection/Socket/Handshake.php

Spacing +11 added lines, -11 removed lines

@@ -1,5 +1,5 @@ 
 <?php
-declare(strict_types=1);
+declare(strict_types = 1);
 
 /**
  * @license http://www.apache.org/licenses/ Apache License 2.0
@@ -145,7 +145,7 @@ 
      */
     private function pkbdf2Hmac(string $password, string $salt, int $iterations): string
     {
-        $t = hash_hmac('sha256', $salt . "\x00\x00\x00\x01", $password, true);
+        $t = hash_hmac('sha256', $salt."\x00\x00\x00\x01", $password, true);
         $u = $t;
         for ($i = 0; $i < $iterations - 1; ++$i) {
             $t = hash_hmac('sha256', $t, $password, true);
@@ -164,7 +164,7 @@ 
         $response === null or die('Illegal handshake state');
 
         $this->myR = base64_encode(openssl_random_pseudo_bytes(18));
-        $this->clientFirstMessage = 'n=' . $this->username . ',r=' . $this->myR;
+        $this->clientFirstMessage = 'n='.$this->username.',r='.$this->myR;
 
         $binaryVersion = pack('V', $this->version);
 
@@ -176,7 +176,7 @@ 
                 [
                     'protocol_version' => $this->protocolVersion,
                     'authentication_method' => 'SCRAM-SHA-256',
-                    'authentication' => 'n,,' . $this->clientFirstMessage,
+                    'authentication' => 'n,,'.$this->clientFirstMessage,
                 ]
             )
             . \chr(0);
@@ -199,7 +199,7 @@ 
 
         $json = json_decode($response, true);
         if ($json['success'] === false) {
-            throw new Exception('Handshake failed: ' . $json["error"]);
+            throw new Exception('Handshake failed: '.$json["error"]);
         }
         if ($this->protocolVersion > $json['max_protocol_version']
             || $this->protocolVersion < $json['min_protocol_version']) {
@@ -220,7 +220,7 @@ 
     {
         $json = json_decode($response, true);
         if ($json['success'] === false) {
-            throw new Exception('Handshake failed: ' . $json['error']);
+            throw new Exception('Handshake failed: '.$json['error']);
         }
         $serverFirstMessage = $json['authentication'];
         $authentication = [];
@@ -233,15 +233,15 @@ 
             throw new Exception('Invalid nonce from server.');
         }
         $salt = base64_decode($authentication['s']);
-        $iterations = (int)$authentication['i'];
+        $iterations = (int) $authentication['i'];
 
-        $clientFinalMessageWithoutProof = 'c=biws,r=' . $serverR;
+        $clientFinalMessageWithoutProof = 'c=biws,r='.$serverR;
         $saltedPassword = $this->pkbdf2Hmac($this->password, $salt, $iterations);
         $clientKey = hash_hmac('sha256', 'Client Key', $saltedPassword, true);
         $storedKey = hash('sha256', $clientKey, true);
 
         $authMessage =
-            $this->clientFirstMessage . ',' . $serverFirstMessage . ',' . $clientFinalMessageWithoutProof;
+            $this->clientFirstMessage.','.$serverFirstMessage.','.$clientFinalMessageWithoutProof;
 
         $clientSignature = hash_hmac('sha256', $authMessage, $storedKey, true);
 
@@ -256,7 +256,7 @@ 
         return
             json_encode(
                 [
-                    'authentication' => $clientFinalMessageWithoutProof . ',p=' . base64_encode($clientProof),
+                    'authentication' => $clientFinalMessageWithoutProof.',p='.base64_encode($clientProof),
                 ]
             )
             . \chr(0);
@@ -271,7 +271,7 @@ 
     {
         $json = json_decode($response, true);
         if ($json['success'] === false) {
-            throw new Exception('Handshake failed: ' . $json['error']);
+            throw new Exception('Handshake failed: '.$json['error']);
         }
         $authentication = [];
         foreach (explode(',', $json['authentication']) as $var) {

src/Connection/Socket/Exception.php

Spacing +1 added lines, -1 removed lines

@@ -1,5 +1,5 @@
 <?php
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace TBolier\RethinkQL\Connection\Socket;
 

src/Connection/Socket/Socket.php

Spacing +2 added lines, -2 removed lines

@@ -1,5 +1,5 @@ 
 <?php
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace TBolier\RethinkQL\Connection\Socket;
 
@@ -29,7 +29,7 @@ 
     public function __construct(OptionsInterface $options)
     {
         $this->openStream(
-            ($options->isSsl() ? 'ssl' : 'tcp') . '://' . $options->getHostname() . ':' . $options->getPort(),
+            ($options->isSsl() ? 'ssl' : 'tcp').'://'.$options->getHostname().':'.$options->getPort(),
             $options->getTimeout(),
             $options->getTimeoutStream()
         );

src/Connection/Connection.php

Spacing +7 added lines, -7 removed lines

@@ -1,5 +1,5 @@ 
 <?php
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace TBolier\RethinkQL\Connection;
 
@@ -277,9 +277,9 @@ 
         }
 
         $requestSize = pack('V', \strlen($request));
-        $binaryToken = pack('V', $token) . pack('V', 0);
+        $binaryToken = pack('V', $token).pack('V', 0);
 
-        return $this->stream->write($binaryToken . $requestSize . $request);
+        return $this->stream->write($binaryToken.$requestSize.$request);
     }
 
     /**
@@ -390,22 +390,22 @@ 
         }
 
         if ($response->getType() === ResponseType::CLIENT_ERROR) {
-            throw new ConnectionException('Client error: ' . $response->getData()[0] . ' jsonQuery: ' . json_encode($message));
+            throw new ConnectionException('Client error: '.$response->getData()[0].' jsonQuery: '.json_encode($message));
         }
 
         if ($responseToken !== $token) {
             throw new ConnectionException(
                 'Received wrong token. Response does not match the request. '
-                . 'Expected ' . $token . ', received ' . $responseToken
+                . 'Expected '.$token.', received '.$responseToken
             );
         }
 
         if ($response->getType() === ResponseType::COMPILE_ERROR) {
-            throw new ConnectionException('Compile error: ' . $response->getData()[0] . ', jsonQuery: ' . json_encode($message));
+            throw new ConnectionException('Compile error: '.$response->getData()[0].', jsonQuery: '.json_encode($message));
         }
 
         if ($response->getType() === ResponseType::RUNTIME_ERROR) {
-            throw new ConnectionException('Runtime error: ' . $response->getData()[0] . ', jsonQuery: ' . json_encode($message));
+            throw new ConnectionException('Runtime error: '.$response->getData()[0].', jsonQuery: '.json_encode($message));
         }
     }
 }

src/Response/Response.php

Spacing +1 added lines, -1 removed lines

@@ -1,5 +1,5 @@
 <?php
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace TBolier\RethinkQL\Response;
 

src/Message/MessageInterface.php

Spacing +1 added lines, -1 removed lines

@@ -1,5 +1,5 @@
 <?php
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace TBolier\RethinkQL\Message;
 

src/Message/Message.php

Spacing +2 added lines, -2 removed lines

@@ -1,5 +1,5 @@ 
 <?php
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace TBolier\RethinkQL\Message;
 
@@ -90,7 +90,7 @@ 
         return [
             $this->queryType,
             $this->query,
-            (object)$this->getOptions()
+            (object) $this->getOptions()
         ];
     }
 

src/Message/ExprMessage.php

Spacing +1 added lines, -1 removed lines

@@ -89,7 +89,7 @@
         return [
             $this->queryType,
             $this->query,
-            (object)$this->getOptions(),
+            (object) $this->getOptions(),
         ];
     }
 

src/Serializer/QueryNormalizer.php

Spacing +4 added lines, -4 removed lines

@@ -1,5 +1,5 @@ 
 <?php
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace TBolier\RethinkQL\Serializer;
 
@@ -21,7 +21,7 @@ 
         }
 
         if (!$object instanceof \JsonSerializable && !$object instanceof \stdClass) {
-            throw new InvalidArgumentException(sprintf('The ' . get_class($object) . ' must implement "%s".', \JsonSerializable::class));
+            throw new InvalidArgumentException(sprintf('The '.get_class($object).' must implement "%s".', \JsonSerializable::class));
         }
 
         if (!$this->serializer instanceof NormalizerInterface) {
@@ -29,11 +29,11 @@ 
         }
 
         if ($object instanceof \stdClass) {
-            return (array)$object;
+            return (array) $object;
         }
 
         if ($object instanceof OptionsInterface) {
-            return (object)$object->jsonSerialize();
+            return (object) $object->jsonSerialize();
         }
 
         return $this->serializer->normalize($object->jsonSerialize(), $format, $context);