ppshobi / psonic

src/Commands/Ingest/PopCommand.php

Spacing +1 added lines, -1 removed lines

@@ -23,6 +23,6 @@
 
     private function quote(string $string)
     {
-        return "\"" . $string ."\"";
+        return "\"" . $string . "\"";
     }
 }
\ No newline at end of file

src/Commands/Ingest/PushCommand.php

Spacing +1 added lines, -1 removed lines

@@ -23,6 +23,6 @@
 
     private function quote(string $string)
     {
-        return "\"" . $string ."\"";
+        return "\"" . $string . "\"";
     }
 }
\ No newline at end of file

src/Commands/Search/SuggestCommand.php

Spacing +1 added lines, -1 removed lines

@@ -23,6 +23,6 @@
 
     private function quote(string $string)
     {
-        return "\"" . $string ."\"";
+        return "\"" . $string . "\"";
     }
 }
\ No newline at end of file

src/Commands/Search/QueryCommand.php

Spacing +1 added lines, -1 removed lines

@@ -23,6 +23,6 @@
 
     private function quote(string $string)
     {
-        return "\"" . $string ."\"";
+        return "\"" . $string . "\"";
     }
 }
\ No newline at end of file

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/Search.php

Spacing +5 added lines, -5 removed lines

@@ -23,7 +23,7 @@ 
 
         $response = $this->send(new StartSearchChannelCommand());
 
-        if($bufferSize = $response->get('bufferSize')){
+        if ($bufferSize = $response->get('bufferSize')) {
             $this->bufferSize = (int) $bufferSize;
         }
 
@@ -34,13 +34,13 @@ 
     {
         $response = $this->send(new QueryCommand($collection, $bucket, $terms));
 
-        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;
         }
 
@@ -51,13 +51,13 @@ 
     {
         $response = $this->send(new SuggestCommand($collection, $bucket, $terms));
 
-        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;
         }
 

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/Ingest.php

Spacing +7 added lines, -7 removed lines

@@ -26,7 +26,7 @@ 
 
         $response = $this->send(new StartIngestChannelCommand);
 
-        if($bufferSize = $response->get('bufferSize')){
+        if ($bufferSize = $response->get('bufferSize')) {
             $this->bufferSize = (int) $bufferSize;
         }
 
@@ -36,14 +36,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();
             }
         }
@@ -52,11 +52,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);
 
         foreach ($chunks as $chunk) {
             $message = $this->send(new PopCommand($collection, $bucket, $object, $chunk));
-            if($message == false || $message == "") {
+            if ($message == false || $message == "") {
                 throw new InvalidArgumentException();
             }
         }
@@ -77,7 +77,7 @@ 
         return $message->getCount();
     }
 
-    public function flushb($collection,$bucket)
+    public function flushb($collection, $bucket)
     {
         $message = $this->send(new FlushBucketCommand($collection, $bucket));
         return $message->getCount();

src/SonicResponse.php

Spacing +5 added lines, -5 removed lines

@@ -19,21 +19,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);
         }
     }
 
@@ -48,7 +48,7 @@ 
 
     public function get($key)
     {
-        if(isset($this->pieces[$key])){
+        if (isset($this->pieces[$key])) {
             return $this->pieces[$key];
         }
     }