tbolier / php-rethink-ql

src/Rethink.php

Spacing +1 added lines, -1 removed lines

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

src/Connection/Options.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;
 

src/Connection/RegistryInterface.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;
 

src/Connection/ConnectionCursorInterface.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;
 

src/Connection/ConnectionException.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;
 

src/Connection/Registry.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;
 
@@ -47,7 +47,7 @@ 
 
         // TODO: Create factory for instantiation Connection.
         $this->connections[$name] = new Connection(
-            function () use ($options) {
+            function() use ($options) {
                 return new Socket(
                     $options
                 );

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()
         );