ppshobi / psonic

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

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];
         }
     }

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