@@ -1,5 +1,5 @@ |
||
1 | 1 | <?php |
2 | -declare(strict_types=1); |
|
2 | +declare(strict_types = 1); |
|
3 | 3 | |
4 | 4 | namespace TBolier\RethinkQL\Connection; |
5 | 5 |
@@ -1,5 +1,5 @@ discard block |
||
1 | 1 | <?php |
2 | -declare(strict_types=1); |
|
2 | +declare(strict_types = 1); |
|
3 | 3 | |
4 | 4 | namespace TBolier\RethinkQL\Connection; |
5 | 5 | |
@@ -277,9 +277,9 @@ discard block |
||
277 | 277 | } |
278 | 278 | |
279 | 279 | $requestSize = pack('V', \strlen($request)); |
280 | - $binaryToken = pack('V', $token) . pack('V', 0); |
|
280 | + $binaryToken = pack('V', $token).pack('V', 0); |
|
281 | 281 | |
282 | - return $this->stream->write($binaryToken . $requestSize . $request); |
|
282 | + return $this->stream->write($binaryToken.$requestSize.$request); |
|
283 | 283 | } |
284 | 284 | |
285 | 285 | /** |
@@ -390,22 +390,22 @@ discard block |
||
390 | 390 | } |
391 | 391 | |
392 | 392 | if ($response->getType() === ResponseType::CLIENT_ERROR) { |
393 | - throw new ConnectionException('Client error: ' . $response->getData()[0] . ' jsonQuery: ' . json_encode($message)); |
|
393 | + throw new ConnectionException('Client error: '.$response->getData()[0].' jsonQuery: '.json_encode($message)); |
|
394 | 394 | } |
395 | 395 | |
396 | 396 | if ($responseToken !== $token) { |
397 | 397 | throw new ConnectionException( |
398 | 398 | 'Received wrong token. Response does not match the request. ' |
399 | - . 'Expected ' . $token . ', received ' . $responseToken |
|
399 | + . 'Expected '.$token.', received '.$responseToken |
|
400 | 400 | ); |
401 | 401 | } |
402 | 402 | |
403 | 403 | if ($response->getType() === ResponseType::COMPILE_ERROR) { |
404 | - throw new ConnectionException('Compile error: ' . $response->getData()[0] . ', jsonQuery: ' . json_encode($message)); |
|
404 | + throw new ConnectionException('Compile error: '.$response->getData()[0].', jsonQuery: '.json_encode($message)); |
|
405 | 405 | } |
406 | 406 | |
407 | 407 | if ($response->getType() === ResponseType::RUNTIME_ERROR) { |
408 | - throw new ConnectionException('Runtime error: ' . $response->getData()[0] . ', jsonQuery: ' . json_encode($message)); |
|
408 | + throw new ConnectionException('Runtime error: '.$response->getData()[0].', jsonQuery: '.json_encode($message)); |
|
409 | 409 | } |
410 | 410 | } |
411 | 411 | } |
@@ -1,5 +1,5 @@ |
||
1 | 1 | <?php |
2 | -declare(strict_types=1); |
|
2 | +declare(strict_types = 1); |
|
3 | 3 | |
4 | 4 | namespace TBolier\RethinkQL\Connection; |
5 | 5 |
@@ -1,5 +1,5 @@ |
||
1 | 1 | <?php |
2 | -declare(strict_types=1); |
|
2 | +declare(strict_types = 1); |
|
3 | 3 | |
4 | 4 | namespace TBolier\RethinkQL\Connection; |
5 | 5 |
@@ -1,5 +1,5 @@ |
||
1 | 1 | <?php |
2 | -declare(strict_types=1); |
|
2 | +declare(strict_types = 1); |
|
3 | 3 | |
4 | 4 | namespace TBolier\RethinkQL\Response; |
5 | 5 |
@@ -1,5 +1,5 @@ |
||
1 | 1 | <?php |
2 | -declare(strict_types=1); |
|
2 | +declare(strict_types = 1); |
|
3 | 3 | |
4 | 4 | namespace TBolier\RethinkQL\Response; |
5 | 5 |
@@ -1,5 +1,5 @@ |
||
1 | 1 | <?php |
2 | -declare(strict_types=1); |
|
2 | +declare(strict_types = 1); |
|
3 | 3 | |
4 | 4 | namespace TBolier\RethinkQL\Response; |
5 | 5 |
@@ -1,5 +1,5 @@ |
||
1 | 1 | <?php |
2 | -declare(strict_types=1); |
|
2 | +declare(strict_types = 1); |
|
3 | 3 | |
4 | 4 | namespace TBolier\RethinkQL\Message; |
5 | 5 |
@@ -1,5 +1,5 @@ discard block |
||
1 | 1 | <?php |
2 | -declare(strict_types=1); |
|
2 | +declare(strict_types = 1); |
|
3 | 3 | |
4 | 4 | namespace TBolier\RethinkQL\Message; |
5 | 5 | |
@@ -90,7 +90,7 @@ discard block |
||
90 | 90 | return [ |
91 | 91 | $this->queryType, |
92 | 92 | $this->query, |
93 | - (object)$this->getOptions() |
|
93 | + (object) $this->getOptions() |
|
94 | 94 | ]; |
95 | 95 | } |
96 | 96 |