manticoresoftware / manticoresearch-php

src/Manticoresearch/Transport/Http.php

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

Spacing +3 added lines, -3 removed lines

@@ -173,7 +173,7 @@ 
      */
     public function getTransportHandler(LoggerInterface $logger)
     {
-        return Transport::create($this->getTransport(), $this,$logger);
+        return Transport::create($this->getTransport(), $this, $logger);
     }
 
     /**
@@ -192,9 +192,9 @@ 
      * @param string|null
      * @return mixed|null
      */
-    public function getConfig($key =  null)
+    public function getConfig($key = null)
     {
-        if($key === null) {
+        if ($key === null) {
             return $this->config;
         }
         return $this->config[$key] ?? null;

src/Manticoresearch/Endpoints/Indices/Create.php

Spacing +6 added lines, -6 removed lines

@@ -22,7 +22,7 @@ 
     {
         if (isset($this->_index)) {
             $columns = [];
-            if(isset($params['columns'] )) {
+            if (isset($params['columns'])) {
                 foreach ($params['columns'] as $name => $settings) {
                     $column = $name . ' ' . $settings['type'];
                     if (isset($settings['options']) && count($settings['options']) > 0) {
@@ -32,14 +32,14 @@ 
                 }
             }
             $options = "";
-            if(isset($params['settings'] )) {
-                foreach($params['settings'] as $name=>$value) {
-                    $options.=" ".$name." = ".$value;
+            if (isset($params['settings'])) {
+                foreach ($params['settings'] as $name=>$value) {
+                    $options .= " " . $name . " = " . $value;
                 }
 
             }
-            return parent::setBody(['query' => "CREATE TABLE ".$this->_index.
-                (count($columns)>0?"(".implode(",",$columns).")":" ")
+            return parent::setBody(['query' => "CREATE TABLE " . $this->_index .
+                (count($columns) > 0 ? "(" . implode(",", $columns) . ")" : " ")
                 .$options]);
         }
         throw new RuntimeException('Index name is missing.');

src/Manticoresearch/Endpoints/Nodes/CreatePlugin.php

Spacing +2 added lines, -2 removed lines

@@ -15,8 +15,8 @@
 
     public function setBody($params = null)
     {
-        if(isset($params['name'], $params['type']) && $params['library']) {
-            return parent::setBody(['query' => "CREATE PLUGIN " . $params['name']." TYPE ".strtoupper($params['type']). " SONAME ".$params['library']]);
+        if (isset($params['name'], $params['type']) && $params['library']) {
+            return parent::setBody(['query' => "CREATE PLUGIN " . $params['name'] . " TYPE " . strtoupper($params['type']) . " SONAME " . $params['library']]);
         }
 
         throw new RuntimeException('Incomplete request for /nodes/createplugin');

src/Manticoresearch/Response/SqlToArray.php

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