manticoresoftware / manticoresearch-php

src/Manticoresearch/Request.php

Spacing +2 added lines, -2 removed lines

@@ -31,9 +31,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/Client.php

Spacing +1 added lines, -1 removed lines

@@ -325,7 +325,7 @@
             ]);
             throw $e;
         } catch (ConnectionException $e) {
-            $this->_logger->warning('Manticore Search Request failed '.$this->_connectionPool->retries_attempts.':', [
+            $this->_logger->warning('Manticore Search Request failed ' . $this->_connectionPool->retries_attempts . ':', [
                 'exception' => $e->getMessage(),
                 'request' => $e->getRequest()->toArray()
             ]);

src/Manticoresearch/Transport.php

Spacing +1 added lines, -1 removed lines

@@ -89,7 +89,7 @@
                     $query[$k] = $v ? 'true' : 'false';
                 }
             }
-            $uri .=  '?' . http_build_query($query);
+            $uri .= '?' . http_build_query($query);
         }
         return $uri;
     }

src/Manticoresearch/Transport/TransportInterface.php

Spacing +1 added lines, -1 removed lines

@@ -19,7 +19,7 @@
      * @param array $params
      * @return mixed
      */
-    public function execute(Request $request, $params=[]);
+    public function execute(Request $request, $params = []);
 
     /**
      * @return mixed

src/Manticoresearch/Transport/Http.php

Braces +2 added lines, -2 removed lines

@@ -54,7 +54,7 @@ 
                     $content = $data;
                 }
                 curl_setopt($conn, CURLOPT_POSTFIELDS, $content);
-            }else{
+            } else{
                 curl_setopt($conn, CURLOPT_POSTFIELDS, '');
             }
             curl_setopt($conn, CURLOPT_CUSTOMREQUEST, $method);
@@ -87,7 +87,7 @@ 
             if(isset($params['responseClass'])) {
                 $responseClass = $params['responseClass'];
                 $response = new $responseClass($responseString,$status);
-            }else{
+            } else{
                 $response = new Response($responseString,$status);
             }
 

Spacing +25 added lines, -25 removed lines

@@ -28,16 +28,16 @@ 
      * @param array $params
      * @return Response
      */
-    public function execute(Request $request, $params=[])
+    public function execute(Request $request, $params = [])
         {
             $connection = $this->getConnection();
             //@todo add persistent
             //@todo add custom headers
             $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());
+            $url = $this->setupURI($url, $request->getQuery());
 
             curl_setopt($conn, CURLOPT_URL, $url);
             curl_setopt($conn, CURLOPT_TIMEOUT, $connection->getTimeout());
@@ -47,32 +47,32 @@ 
             $method = $request->getMethod();
             $headers = $connection->getHeaders();
             $headers[] = sprintf('Content-Type: %s', $request->getContentType());
-            if(!empty($data)) {
+            if (!empty($data)) {
                 if (is_array($data)) {
                     $content = json_encode($data, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
                 } else {
                     $content = $data;
                 }
                 curl_setopt($conn, CURLOPT_POSTFIELDS, $content);
-            }else{
+            } else {
                 curl_setopt($conn, CURLOPT_POSTFIELDS, '');
             }
             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) {
+            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) {
+            if ($connection->getConfig('proxy') !== null) {
                 curl_setopt($conn, CURLOPT_PROXY, $connection->getConfig('proxy'));
             }
-            if(!empty($connection->getConfig('curl'))) {
-                foreach($connection->getConfig('curl') as $k=>$v) {
+            if (!empty($connection->getConfig('curl'))) {
+                foreach ($connection->getConfig('curl') as $k=>$v) {
                     curl_setopt($conn, $k, $v);
                 }
 
@@ -83,12 +83,12 @@ 
             $responseString = \ob_get_clean();
             $end = microtime(true);
             $errorno = curl_errno($conn);
-            $status = curl_getinfo($conn,CURLINFO_HTTP_CODE);
-            if(isset($params['responseClass'])) {
+            $status = curl_getinfo($conn, CURLINFO_HTTP_CODE);
+            if (isset($params['responseClass'])) {
                 $responseClass = $params['responseClass'];
-                $response = new $responseClass($responseString,$status);
-            }else{
-                $response = new Response($responseString,$status);
+                $response = new $responseClass($responseString, $status);
+            } else {
+                $response = new Response($responseString, $status);
             }
 
             $time = $end-$start;
@@ -99,27 +99,27 @@ 
                 'body' => $request->getBody()
             ]);
             //hard error
-            if($errorno>0) {
+            if ($errorno > 0) {
                 $error = curl_error($conn);
                 self::$_curl = false;
-                throw new ConnectionException($error,$request);
+                throw new ConnectionException($error, $request);
             }
 
 
-            $this->_logger->debug('Request body:',[
+            $this->_logger->debug('Request body:', [
                 'connection' => $connection->getConfig(),
                 'payload'=> $request->getBody()
             ]);
-            $this->_logger->info('Request:',[
+            $this->_logger->info('Request:', [
                     'url' => $url,
                     'status' => $status,
                     'time' => $time
                 ]
             );
-            $this->_logger->debug('Response body:',[json_decode($responseString,true)]);
+            $this->_logger->debug('Response body:', [json_decode($responseString, true)]);
             //soft error
-            if($response->hasError()) {
-                $this->_logger->error('Response error:',[$response->getError()]);
+            if ($response->hasError()) {
+                $this->_logger->error('Response error:', [$response->getError()]);
                 throw new ResponseException($request, $response);
             }
             return $response;
@@ -129,9 +129,9 @@ 
      * @param bool $persistent
      * @return false|resource
      */
-    protected function _getCurlConnection(bool $persistent=true)
+    protected function _getCurlConnection(bool $persistent = true)
         {
-            if(!$persistent || !self::$_curl) {
+            if (!$persistent || !self::$_curl) {
                 self::$_curl = curl_init();
             }
             return self::$_curl;

src/Manticoresearch/Transport/PhpHttp.php

Indentation +1 added lines, -1 removed lines

@@ -84,7 +84,7 @@
             'payload'=> $request->getBody()
         ]);
         $this->_logger->info('Request:',[
-                 'url' => $url,
+                    'url' => $url,
                 'status' => $status,
                 'time' => $time
             ]

Spacing +8 added lines, -8 removed lines

@@ -31,11 +31,11 @@ 
      * @param LoggerInterface|null $logger
      */
 
-    public function __construct(Connection $connection = null,LoggerInterface $logger = null)
+    public function __construct(Connection $connection = null, LoggerInterface $logger = null)
     {
         $this->client = HttpClientDiscovery::find();
         $this->messageFactory = MessageFactoryDiscovery::find();
-        parent::__construct($connection,$logger);
+        parent::__construct($connection, $logger);
     }
 
     /**
@@ -44,7 +44,7 @@ 
      * @return Response
      * @throws \Http\Client\Exception
      */
-    public function execute(Request $request, $params=[])
+    public function execute(Request $request, $params = [])
     {
         $connection = $this->getConnection();
 
@@ -71,25 +71,25 @@ 
         $message = $this->messageFactory->createRequest($method, $url, $headers, $content);
         try {
             $responsePSR = $this->client->sendRequest($message);
-        }catch (\Exception $e) {
-            throw new ConnectionException($e->getMessage(),$request);
+        } catch (\Exception $e) {
+            throw new ConnectionException($e->getMessage(), $request);
         }
         $end = microtime(true);
         $status = $responsePSR->getStatusCode();
         $response = new Response($responsePSR->getBody(), $status);
         $time = $end-$start;
         $response->setTime($time);
-        $this->_logger->debug('Request body:',[
+        $this->_logger->debug('Request body:', [
             'connection' => $connection->getConfig(),
             'payload'=> $request->getBody()
         ]);
-        $this->_logger->info('Request:',[
+        $this->_logger->info('Request:', [
                  'url' => $url,
                 'status' => $status,
                 'time' => $time
             ]
         );
-        $this->_logger->debug('Response body:',$response->getResponse());
+        $this->_logger->debug('Response body:', $response->getResponse());
 
         return $response;
     }

Braces +1 added lines, -1 removed lines

@@ -71,7 +71,7 @@
         $message = $this->messageFactory->createRequest($method, $url, $headers, $content);
         try {
             $responsePSR = $this->client->sendRequest($message);
-        }catch (\Exception $e) {
+        } catch (\Exception $e) {
             throw new ConnectionException($e->getMessage(),$request);
         }
         $end = microtime(true);

src/Manticoresearch/Endpoints/Keywords.php

Spacing +1 added lines, -1 removed lines

@@ -15,7 +15,7 @@
     public function setBody($params = null)
     {
         if (isset($this->_index)) {
-            $binds =[];
+            $binds = [];
             $binds[] = "'" . Utils::escape($params['query']) . "'";
             $binds[] = "'" . $this->_index . "'";
             if (count($params['options']) > 0) {

src/Manticoresearch/Endpoints/Sql.php

Spacing +5 added lines, -5 removed lines

@@ -34,13 +34,13 @@
      */
     public function getBody()
     {
-        if($this->_mode === 'raw') {
+        if ($this->_mode === 'raw') {
             $return = ['mode=raw'];
-            foreach($this->_body as $k=>$v) {
-                $return[]= $k.'='.$v;
+            foreach ($this->_body as $k=>$v) {
+                $return[] = $k . '=' . $v;
             }
-            return implode('&',$return);
-        }else{
+            return implode('&', $return);
+        } else {
             return http_build_query($this->_body);
         }
 

Braces +1 added lines, -1 removed lines

@@ -40,7 +40,7 @@
                 $return[]= $k.'='.$v;
             }
             return implode('&',$return);
-        }else{
+        } else{
             return http_build_query($this->_body);
         }
 

src/Manticoresearch/Endpoints/Cluster/Delete.php

Spacing +1 added lines, -1 removed lines

@@ -23,7 +23,7 @@
     {
         if (isset($this->_cluster)) {
 
-            return parent::setBody(['query' => "DELETE CLUSTER ".$this->_cluster]);
+            return parent::setBody(['query' => "DELETE CLUSTER " . $this->_cluster]);
         }
         throw new RuntimeException('Cluster name is missing.');
     }