manticoresoftware / manticoresearch-php

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 = null)
+    public function alter($operation, $name, $type = null)
     {
-        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/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();
     }
 }

src/Manticoresearch/Response/SqlToArray.php

Spacing +1 added lines, -1 removed lines

@@ -11,7 +11,7 @@
         $response = parent::getResponse();
         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) {

src/Manticoresearch/Endpoints/ExplainQuery.php

Spacing +2 added lines, -2 removed lines

@@ -17,9 +17,9 @@
     public function setBody($params = null)
     {
         if (isset($this->_index)) {
-            if(isset($params['query']))
+            if (isset($params['query']))
             {
-                return parent::setBody(['query' => "EXPLAIN QUERY ".$this->_index. '\''.$params['query'].'\'']);
+                return parent::setBody(['query' => "EXPLAIN QUERY " . $this->_index . '\'' . $params['query'] . '\'']);
             }
             throw new RuntimeException('Query param is missing.');
         }

src/Manticoresearch/Transport/Http.php

Spacing +6 added lines, -6 removed lines

@@ -28,11 +28,11 @@ 
      * @param array $params
      * @return Response
      */
-    public function execute(Request $request, $params=[])
+    public function execute(Request $request, $params = [])
     {
         $connection = $this->getConnection();
         $conn = $this->_getCurlConnection($connection->getConfig('persistent'));
-        $url = $this->_scheme.'://'.$connection->getHost().':'.$connection->getPort();
+        $url = $this->_scheme . '://' . $connection->getHost() . ':' . $connection->getPort();
         $endpoint = $request->getPath();
         $url .= $endpoint;
         $url = $this->setupURI($url, $request->getQuery());
@@ -58,13 +58,13 @@ 
         curl_setopt($conn, CURLOPT_CUSTOMREQUEST, $method);
         curl_setopt($conn, CURLOPT_HTTPHEADER, $headers);
 
-        if ($connection->getConnectTimeout()>0) {
+        if ($connection->getConnectTimeout() > 0) {
             curl_setopt($conn, CURLOPT_CONNECTTIMEOUT, $connection->getConnectTimeout());
         }
 
         if ($connection->getConfig('username') !== null && $connection->getConfig('password') !== null) {
             curl_setopt($conn, CURLOPT_HTTPAUTH, CURLAUTH_ANY);
-            curl_setopt($conn, CURLOPT_USERPWD, $connection->getConfig('username').":".$connection->getConfig('password'));
+            curl_setopt($conn, CURLOPT_USERPWD, $connection->getConfig('username') . ":" . $connection->getConfig('password'));
         }
         if ($connection->getConfig('proxy') !== null) {
             curl_setopt($conn, CURLOPT_PROXY, $connection->getConfig('proxy'));
@@ -96,7 +96,7 @@ 
                 'body' => $request->getBody()
             ]);
         //hard error
-        if ($errorno>0) {
+        if ($errorno > 0) {
             $error = curl_error($conn);
 
             /* @phpstan-ignore-next-line */
@@ -130,7 +130,7 @@ 
      * @param bool $persistent
      * @return false|resource
      */
-    protected function _getCurlConnection(bool $persistent=true)
+    protected function _getCurlConnection(bool $persistent = true)
     {
         if (!$persistent || !self::$_curl) {
             self::$_curl = curl_init();

src/Manticoresearch/Endpoints/Keywords.php

Spacing +2 added lines, -2 removed lines

@@ -15,7 +15,7 @@ 
     public function setBody($params = null)
     {
         if (isset($this->_index)) {
-            $binds =[];
+            $binds = [];
             $binds[] = "'" . self::escape($params['query']) . "'";
             $binds[] = "'" . $this->_index . "'";
             if (count($params['options']) > 0) {
@@ -23,7 +23,7 @@ 
                     $binds[] = "$value AS $name";
                 }
             }
-            return parent::setBody( ['query' => "CALL KEYWORDS(" . implode(",", $binds) . ")"]);
+            return parent::setBody(['query' => "CALL KEYWORDS(" . implode(",", $binds) . ")"]);
         }
         throw new RuntimeException('Index name is missing.');