ppshobi / psonic

src/Control.php

Spacing +1 added lines, -1 removed lines

@@ -21,7 +21,7 @@
 
         $response = $this->send(new StartControlChannelCommand());
 
-        if($bufferSize = $response->get('bufferSize')){
+        if ($bufferSize = $response->get('bufferSize')) {
             $this->bufferSize = (int) $bufferSize;
         }
 

src/Channels/Channel.php

Spacing +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
     {
         $this->client->connect();
         $response = $this->client->read();
-        if($response->getStatus() == "CONNECTED") {
+        if ($response->getStatus() == "CONNECTED") {
             return;
         }
         throw new ConnectionException;

src/SonicResponse.php

Indentation +1 added lines, -1 removed lines

@@ -63,4 +63,4 @@
         return $this->get('count') ?? 0;
     }
 }
- 
\ No newline at end of file
+    
\ No newline at end of file

Spacing +5 added lines, -5 removed lines

@@ -27,21 +27,21 @@ 
     {
         $this->pieces = explode(" ", $this->message);
 
-        if(preg_match_all("/buffer\((\d+)\)/", $this->message, $matches)) {
+        if (preg_match_all("/buffer\((\d+)\)/", $this->message, $matches)) {
             $this->pieces['bufferSize'] = $matches[1][0];
         }
 
         $this->pieces['status'] = $this->pieces[0];
         unset($this->pieces[0]);
 
-        if($this->pieces['status'] === 'RESULT') {
+        if ($this->pieces['status'] === 'RESULT') {
             $this->pieces['count'] = (int) $this->pieces[1];
             unset($this->pieces[1]);
         }
 
-        if($this->pieces['status'] === 'EVENT') {
+        if ($this->pieces['status'] === 'EVENT') {
             $this->pieces['query_key'] = $this->pieces[2];
-            $this->results = array_slice($this->pieces, 2, count($this->pieces)-4);
+            $this->results = array_slice($this->pieces, 2, count($this->pieces) - 4);
         }
     }
 
@@ -67,7 +67,7 @@ 
      */
     public function get($key)
     {
-        if(isset($this->pieces[$key])){
+        if (isset($this->pieces[$key])) {
             return $this->pieces[$key];
         }
     }

utils/functions.php

Spacing +1 added lines, -1 removed lines

@@ -4,7 +4,7 @@
  *
  */
 
-if(! function_exists('quote')) {
+if (!function_exists('quote')) {
     /**
      * append and prepend a string with double quotes
      * @param string $string

src/Contracts/Command.php

Spacing +1 added lines, -1 removed lines

@@ -9,5 +9,5 @@
      * @return string
      * ultimately a command instance get translated into a string
      */
-    public function __toString(): string ;
+    public function __toString(): string;
 }
\ No newline at end of file

src/Ingest.php

Spacing +6 added lines, -6 removed lines

@@ -34,7 +34,7 @@ 
 
         $response = $this->send(new StartIngestChannelCommand);
 
-        if($bufferSize = $response->get('bufferSize')){
+        if ($bufferSize = $response->get('bufferSize')) {
             $this->bufferSize = (int) $bufferSize;
         }
 
@@ -50,14 +50,14 @@ 
      */
     public function push(string $collection, string $bucket, string $object, string $text)
     {
-        $chunks = $this->splitString($collection,$bucket, $object, $text);
+        $chunks = $this->splitString($collection, $bucket, $object, $text);
 
-        if($text == "" || empty($chunks)) {
+        if ($text == "" || empty($chunks)) {
             throw new InvalidArgumentException("The parameter \$text is empty");
         }
         foreach ($chunks as $chunk) {
             $message = $this->send(new PushCommand($collection, $bucket, $object, $chunk));
-            if($message == false || $message == "") {
+            if ($message == false || $message == "") {
                 throw new InvalidArgumentException();
             }
         }
@@ -73,11 +73,11 @@ 
      */
     public function pop(string $collection, string $bucket, string $object, string $text)
     {
-        $chunks = $this->splitString($collection,$bucket, $object, $text);
+        $chunks = $this->splitString($collection, $bucket, $object, $text);
         $count  = 0;
         foreach ($chunks as $chunk) {
             $message = $this->send(new PopCommand($collection, $bucket, $object, $chunk));
-            if($message == false || $message == "") {
+            if ($message == false || $message == "") {
                 throw new InvalidArgumentException();
             }
             $count += $message->get('count');

src/Commands/Search/QueryCommand.php

Spacing +1 added lines, -1 removed lines

@@ -22,7 +22,7 @@
             'collection' => $collection,
             'bucket'     => $bucket,
             'terms'      => quote($terms),
-            'limit'      => $limit ? "LIMIT($limit)": null,
+            'limit'      => $limit ? "LIMIT($limit)" : null,
         ];
 
         parent::__construct($this->command, $this->parameters);

src/Search.php

Spacing +6 added lines, -6 removed lines

@@ -31,7 +31,7 @@ 
 
         $response = $this->send(new StartSearchChannelCommand());
 
-        if($bufferSize = $response->get('bufferSize')){
+        if ($bufferSize = $response->get('bufferSize')) {
             $this->bufferSize = (int) $bufferSize;
         }
 
@@ -50,13 +50,13 @@ 
     {
         $response = $this->send(new QueryCommand($collection, $bucket, $terms, $limit));
 
-        if(! $response->getStatus() == 'PENDING') {
+        if (!$response->getStatus() == 'PENDING') {
             throw new CommandFailedException;
         }
 
         $results = $this->read();
 
-        if(! $results->getStatus() == 'EVENT') {
+        if (!$results->getStatus() == 'EVENT') {
             throw new CommandFailedException;
         }
 
@@ -71,17 +71,17 @@ 
      * @return array
      * @throws CommandFailedException
      */
-    public function suggest($collection, $bucket, $terms, $limit=null): array
+    public function suggest($collection, $bucket, $terms, $limit = null): array
     {
         $response = $this->send(new SuggestCommand($collection, $bucket, $terms, $limit));
 
-        if(! $response->getStatus() == 'PENDING') {
+        if (!$response->getStatus() == 'PENDING') {
             throw new CommandFailedException;
         }
 
         $results = $this->read();
 
-        if(! $results->getStatus() == 'EVENT') {
+        if (!$results->getStatus() == 'EVENT') {
             throw new CommandFailedException;
         }