manticoresoftware / manticoresearch-php

src/Manticoresearch/Client.php

Spacing +3 added lines, -3 removed lines

@@ -159,13 +159,13 @@
      * @param bool $obj
      * @return array|Response
      */
-    public function search(array $params = [],$obj=false)
+    public function search(array $params = [], $obj = false)
     {
         $endpoint = new Endpoints\Search($params);
         $response = $this->request($endpoint);
-        if($obj ===true) {
+        if ($obj === true) {
             return $response;
-        }else{
+        } else {
             return $response->getResponse();
         }
     }

Braces +1 added lines, -1 removed lines

@@ -165,7 +165,7 @@
         $response = $this->request($endpoint);
         if($obj ===true) {
             return $response;
-        }else{
+        } else{
             return $response->getResponse();
         }
     }

src/Manticoresearch/Query.php

Spacing +1 added lines, -1 removed lines

@@ -25,7 +25,7 @@
             } elseif (is_array($v)) {
                 $return[$k] = $this->_toArray($v);
             } else {
-                if ($v!==null) {
+                if ($v !== null) {
                     $return[$k] = $v;
                 } else {
                     return null;

src/Manticoresearch/Endpoints/Nodes/Variables.php

Spacing +3 added lines, -3 removed lines

@@ -16,11 +16,11 @@
     {
         $option = "";
         if (isset($params['pattern'])) {
-            $option = "LIKE '".$params['pattern']."'";
+            $option = "LIKE '" . $params['pattern'] . "'";
         }
         if (isset($params['where'])) {
-            $option = "WHERE variable_name='".$params['where']['variable_name']."'";
+            $option = "WHERE variable_name='" . $params['where']['variable_name'] . "'";
         }
-        return parent::setBody(['query' => "SHOW ".($params['type'] ?? '')." VARIABLES ".$option]);
+        return parent::setBody(['query' => "SHOW " . ($params['type'] ?? '') . " VARIABLES " . $option]);
     }
 }

src/Manticoresearch/Connection/ConnectionPool.php

Spacing +2 added lines, -2 removed lines

@@ -25,7 +25,7 @@ 
 
     public $retries;
 
-    public $retries_attempts =0;
+    public $retries_attempts = 0;
 
     public function __construct(array $connections, SelectorInterface $strategy, int $retries)
     {
@@ -52,7 +52,7 @@ 
     public function getConnection(): Connection
     {
         $this->retries_attempts++;
-        $connection =   $this->strategy->getConnection($this->_connections);
+        $connection = $this->strategy->getConnection($this->_connections);
         if ($connection->isAlive()) {
             return $connection;
         }

src/Manticoresearch/Request.php

Spacing +2 added lines, -2 removed lines

@@ -30,9 +30,9 @@
      */
     protected $_content_type;
 
-    public function __construct($params=[])
+    public function __construct($params = [])
     {
-        if (count($params)>0) {
+        if (count($params) > 0) {
             $this->setBody($params['body'] ?? []);
             $this->setQuery($params['query'] ?? []);
             $this->setContentType($params['content_type'] ?? 'application/json');

src/Manticoresearch/Index.php

Braces +1 added lines, -1 removed lines

@@ -237,7 +237,7 @@
                 ]
             ];
 
-        }elseif($operation==='drop'){
+        } elseif($operation==='drop'){
             $params = [
                 'index' => $this->_index,
                 'body' => [

Spacing +7 added lines, -7 removed lines

@@ -87,7 +87,7 @@ 
 
     public function deleteDocuments($query)
     {
-        if($query instanceof Query) {
+        if ($query instanceof Query) {
             $query = $query->toArray();
         }
         $params = [
@@ -113,7 +113,7 @@ 
 
     public function updateDocuments($data, $query)
     {
-        if($query instanceof Query) {
+        if ($query instanceof Query) {
             $query = $query->toArray();
         }
         $params = [
@@ -155,7 +155,7 @@ 
         return $this->_client->bulk(['body' => $toreplace]);
     }
 
-    public function create($fields, $settings = [],$silent=false)
+    public function create($fields, $settings = [], $silent = false)
     {
         $params = [
             'index' => $this->_index,
@@ -164,7 +164,7 @@ 
                 'settings' => $settings
             ]
         ];
-        if($silent===true) {
+        if ($silent === true) {
             $params['body']['silent'] = true;
         }
         return $this->_client->indices()->create($params);
@@ -232,9 +232,9 @@ 
         $this->_client->indices()->flushramchunk($params);
     }
 
-    public function alter($operation,$name, $type)
+    public function alter($operation, $name, $type)
     {
-        if($operation==='add') {
+        if ($operation === 'add') {
             $params = [
                 'index' => $this->_index,
                 'body' => [
@@ -243,7 +243,7 @@ 
                 ]
             ];
 
-        }elseif($operation==='drop'){
+        }elseif ($operation === 'drop') {
             $params = [
                 'index' => $this->_index,
                 'body' => [

src/Manticoresearch/Response/SqlToArray.php

Indentation +1 added lines, -1 removed lines

@@ -13,7 +13,7 @@
 
         if (isset($response['columns'], $response['data'])) {
             $data=[];
-           array_walk($response['columns'], static function (&$value, $key) {
+            array_walk($response['columns'], static function (&$value, $key) {
                 $value= array_keys($value)[0];
             });
             foreach ($response['data'] as $property) {

Spacing +4 added lines, -4 removed lines

@@ -12,12 +12,12 @@
         $response = parent::getResponse();
 
         if (isset($response['columns'], $response['data'])) {
-            $data=[];
-           array_walk($response['columns'], static function (&$value, $key) {
-                $value= array_keys($value)[0];
+            $data = [];
+           array_walk($response['columns'], static function(&$value, $key) {
+                $value = array_keys($value)[0];
             });
             foreach ($response['data'] as $property) {
-                if (count($response['columns'])>2) {
+                if (count($response['columns']) > 2) {
                     $data[array_shift($property)] = $property;
                 } else {
                     $data[$property[$response['columns'][0]]] = $property[$response['columns'][1]];

src/Manticoresearch/Endpoints/Nodes/Set.php

Spacing +2 added lines, -2 removed lines

@@ -18,8 +18,8 @@
         $this->_body = $params;
         if (isset($params['variable']) && is_array($params['variable'])) {
             return parent::setBody([
-                'query' =>  "SET " . (isset($params['type']) ?  $params['type'] . "'" : "")." ".
-                    $params['variable']['name']."=" . $params['variable']['value']
+                'query' =>  "SET " . (isset($params['type']) ? $params['type'] . "'" : "") . " " .
+                    $params['variable']['name'] . "=" . $params['variable']['value']
             ]);
 
         }

src/Manticoresearch/Nodes.php

Spacing +29 added lines, -29 removed lines

@@ -38,15 +38,15 @@ 
     public function __construct($client)
     {
         $this->_client = $client;
-        $this->_params =['responseClass'=>'Manticoresearch\\Response\\SqlToArray'];
+        $this->_params = ['responseClass'=>'Manticoresearch\\Response\\SqlToArray'];
     }
 
-    public function agentstatus($params=[])
+    public function agentstatus($params = [])
     {
         $body = $params['body']??[];
         $endpoint = new AgentStatus();
         $endpoint->setBody($body);
-        $response = $this->_client->request($endpoint,$this->_params);
+        $response = $this->_client->request($endpoint, $this->_params);
         return  $response->getResponse();
     }
 
@@ -55,7 +55,7 @@ 
         $body = $params['body'];
         $endpoint = new CreateFunction();
         $endpoint->setBody($body);
-        $response = $this->_client->request($endpoint,$this->_params);
+        $response = $this->_client->request($endpoint, $this->_params);
         return  $response->getResponse();
     }
 
@@ -64,7 +64,7 @@ 
         $body = $params['body'];
         $endpoint = new CreatePlugin();
         $endpoint->setBody($body);
-        $response = $this->_client->request($endpoint,$this->_params);
+        $response = $this->_client->request($endpoint, $this->_params);
         return  $response->getResponse();
     }
 
@@ -73,7 +73,7 @@ 
         $body = $params['body'];
         $endpoint = new Debug();
         $endpoint->setBody($body);
-        $response = $this->_client->request($endpoint,$this->_params);
+        $response = $this->_client->request($endpoint, $this->_params);
         return  $response->getResponse();
     }
 
@@ -82,7 +82,7 @@ 
         $body = $params['body'];
         $endpoint = new DropFunction();
         $endpoint->setBody($body);
-        $response = $this->_client->request($endpoint,$this->_params);
+        $response = $this->_client->request($endpoint, $this->_params);
         return  $response->getResponse();
     }
 
@@ -91,61 +91,61 @@ 
         $body = $params['body'];
         $endpoint = new DropPlugin();
         $endpoint->setBody($body);
-        $response = $this->_client->request($endpoint,$this->_params);
+        $response = $this->_client->request($endpoint, $this->_params);
         return  $response->getResponse();
     }
 
-    public function flushattributes($params=[])
+    public function flushattributes($params = [])
     {
         $body = $params['body']??[];
         $endpoint = new FlushAttributes();
         $endpoint->setBody($body);
-        $response = $this->_client->request($endpoint,$this->_params);
+        $response = $this->_client->request($endpoint, $this->_params);
         return  $response->getResponse();
     }
 
-    public function flushhostnames($params=[])
+    public function flushhostnames($params = [])
     {
         $body = $params['body']??[];
         $endpoint = new FlushHostnames();
         $endpoint->setBody($body);
-        $response = $this->_client->request($endpoint,$this->_params);
+        $response = $this->_client->request($endpoint, $this->_params);
         return  $response->getResponse();
     }
 
-    public function flushlogs($params=[])
+    public function flushlogs($params = [])
     {
         $body = $params['body']??[];
         $endpoint = new FlushLogs();
         $endpoint->setBody($body);
-        $response = $this->_client->request($endpoint,$this->_params);
+        $response = $this->_client->request($endpoint, $this->_params);
         return  $response->getResponse();
     }
 
-    public function plugins($params=[])
+    public function plugins($params = [])
     {
         $body = $params['body']??[];
         $endpoint = new Plugins();
         $endpoint->setBody($body);
-        $response = $this->_client->request($endpoint,$this->_params);
+        $response = $this->_client->request($endpoint, $this->_params);
         return  $response->getResponse();
     }
 
-    public function reloadindexes($params=[])
+    public function reloadindexes($params = [])
     {
         $body = $params['body']??[];
         $endpoint = new ReloadIndexes();
         $endpoint->setBody($body);
-        $response = $this->_client->request($endpoint,$this->_params);
+        $response = $this->_client->request($endpoint, $this->_params);
         return  $response->getResponse();
     }
 
-    public function reloadplugins($params=[])
+    public function reloadplugins($params = [])
     {
         $body = $params['body']??[];
         $endpoint = new ReloadPlugins();
         $endpoint->setBody($body);
-        $response = $this->_client->request($endpoint,$this->_params);
+        $response = $this->_client->request($endpoint, $this->_params);
         return  $response->getResponse();
     }
 
@@ -154,7 +154,7 @@ 
         $body = $params['body'];
         $endpoint = new Set();
         $endpoint->setBody($body);
-        $response = $this->_client->request($endpoint,$this->_params);
+        $response = $this->_client->request($endpoint, $this->_params);
         return  $response->getResponse();
     }
 
@@ -162,40 +162,40 @@ 
      * @param array $params
      * @return mixed
      */
-    public function status($params=[])
+    public function status($params = [])
     {
         $body = $params['body']??[];
         $endpoint = new Status();
         $endpoint->setBody($body);
-        $response = $this->_client->request($endpoint,$this->_params);
+        $response = $this->_client->request($endpoint, $this->_params);
         return  $response->getResponse();
 
     }
 
-    public function tables($params=[])
+    public function tables($params = [])
     {
         $body = $params['body']??[];
         $endpoint = new Tables();
         $endpoint->setBody($body);
-        $response = $this->_client->request($endpoint,$this->_params);
+        $response = $this->_client->request($endpoint, $this->_params);
         return  $response->getResponse();
     }
 
-    public function threads($params=[])
+    public function threads($params = [])
     {
         $body = $params['body']??[];
         $endpoint = new Threads();
         $endpoint->setBody($body);
-        $response = $this->_client->request($endpoint,$this->_params);
+        $response = $this->_client->request($endpoint, $this->_params);
         return  $response->getResponse();
     }
 
-    public function variables($params=[])
+    public function variables($params = [])
     {
         $body = $params['body']??[];
         $endpoint = new Variables();
         $endpoint->setBody($body);
-        $response = $this->_client->request($endpoint,$this->_params);
+        $response = $this->_client->request($endpoint, $this->_params);
         return  $response->getResponse();
     }
 }