manticoresoftware / manticoresearch-php

src/Manticoresearch/Endpoints/Nodes/DropFunction.php

Spacing +1 added lines, -1 removed lines

@@ -15,7 +15,7 @@
 
     public function setBody($params = null)
     {
-        if(isset($params['name'])) {
+        if (isset($params['name'])) {
             return parent::setBody(['query' => "DROP FUNCTION " . $params['name']]);
         }
         throw new RuntimeException('Missing function name in /nodes/dropfunction');

src/Manticoresearch/Endpoints/Nodes/Threads.php

Spacing +1 added lines, -1 removed lines

@@ -21,6 +21,6 @@
             }
         }
 
-        return parent::setBody(['query' => "SHOW THREADS " . ((count($options)>0)?' OPTION '.implode(",", $options):'')]);
+        return parent::setBody(['query' => "SHOW THREADS " . ((count($options) > 0) ? ' OPTION ' . implode(",", $options) : '')]);
     }
 }
\ No newline at end of file

src/Manticoresearch/Endpoints/Nodes/DropPlugin.php

Spacing +2 added lines, -2 removed lines

@@ -15,8 +15,8 @@
 
     public function setBody($params = null)
     {
-        if(isset($params['name'])) {
-            return parent::setBody(['query' => "DROP PLUGIN " . $params['name']." TYPE".$params['type']]);
+        if (isset($params['name'])) {
+            return parent::setBody(['query' => "DROP PLUGIN " . $params['name'] . " TYPE" . $params['type']]);
         }
         throw new RuntimeException('Missing plugin name in /nodes/dropplugin');
     }

src/Manticoresearch/Cluster.php

Spacing +6 added lines, -6 removed lines

@@ -25,7 +25,7 @@ 
     public function __construct($client)
     {
         $this->_client = $client;
-        $this->_params =['responseClass'=>'Manticoresearch\\Response\\SqlToArray'];
+        $this->_params = ['responseClass'=>'Manticoresearch\\Response\\SqlToArray'];
 
     }
 
@@ -36,7 +36,7 @@ 
         $endpoint = new Alter();
         $endpoint->setCluster($cluster);
         $endpoint->setBody($body);
-        $response = $this->_client->request($endpoint,$this->_params);
+        $response = $this->_client->request($endpoint, $this->_params);
         return  $response->getResponse();
 
     }
@@ -48,7 +48,7 @@ 
         $endpoint = new Create();
         $endpoint->setCluster($cluster);
         $endpoint->setBody($body);
-        $response = $this->_client->request($endpoint,$this->_params);
+        $response = $this->_client->request($endpoint, $this->_params);
         return  $response->getResponse();
 
     }
@@ -60,7 +60,7 @@ 
         $endpoint = new Delete();
         $endpoint->setCluster($cluster);
         $endpoint->setBody($body);
-        $response = $this->_client->request($endpoint,$this->_params);
+        $response = $this->_client->request($endpoint, $this->_params);
         return  $response->getResponse();
 
     }
@@ -72,7 +72,7 @@ 
         $endpoint = new Join();
         $endpoint->setCluster($cluster);
         $endpoint->setBody($body);
-        $response = $this->_client->request($endpoint,$this->_params);
+        $response = $this->_client->request($endpoint, $this->_params);
         return  $response->getResponse();
 
     }
@@ -84,7 +84,7 @@ 
         $endpoint = new Set();
         $endpoint->setCluster($cluster);
         $endpoint->setBody($body);
-        $response = $this->_client->request($endpoint,$this->_params);
+        $response = $this->_client->request($endpoint, $this->_params);
         return  $response->getResponse();
 
     }

src/Manticoresearch/Response.php

Spacing +1 added lines, -1 removed lines

@@ -35,7 +35,7 @@
      */
     protected $_response;
 
-    public function __construct( $responseString, $status = null)
+    public function __construct($responseString, $status = null)
     {
         if (is_array($responseString)) {
             $this->_response = $responseString;

src/Manticoresearch/Nodes.php

Spacing +27 added lines, -27 removed lines

@@ -37,15 +37,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();
     }
 
@@ -54,7 +54,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();
     }
 
@@ -63,7 +63,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();
     }
 
@@ -72,7 +72,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();
     }
 
@@ -81,7 +81,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();
     }
 
@@ -90,52 +90,52 @@ 
         $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();
     }
 
@@ -144,7 +144,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();
     }
 
@@ -152,40 +152,40 @@ 
      * @param $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();
     }
 }
\ No newline at end of file

src/Manticoresearch/Exceptions/ConnectionException.php

Spacing +1 added lines, -1 removed lines

@@ -23,7 +23,7 @@
      * @param string $message
      * @param Request|null $request
      */
-    public function __construct($message = '', Request $request=null)
+    public function __construct($message = '', Request $request = null)
     {
         $this->_request = $request;
         parent::__construct($message);

src/Manticoresearch/Response/SqlToArray.php

Braces +1 added lines, -1 removed lines

@@ -19,7 +19,7 @@
             foreach($response['data'] as $property) {
                 if(count($response['columns'])>2) {
                     $data[array_shift($property)] = $property;
-                }else{
+                } else{
                     $data[$property[$response['columns'][0]]] = $property[$response['columns'][1]];
                 }
             }

Spacing +6 added lines, -6 removed lines

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

src/Manticoresearch/Connection/ConnectionPool.php

Spacing +3 added lines, -3 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,8 +52,8 @@ 
     public function getConnection(): Connection
     {
         $this->retries_attempts++;
-        $connection =   $this->strategy->getConnection($this->_connections);
-        if($connection->isAlive()) {
+        $connection = $this->strategy->getConnection($this->_connections);
+        if ($connection->isAlive()) {
             return $connection;
         }
         if ($this->retries_attempts < $this->retries) {