Http::getCurlConnection() - Code Metrics - Inspection of "Merge commit '6c7ca1d' into 1.x" - manticoresoftware/manticoresearch-php - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — 1.x ( 747b4c...b6bf38 )

by Adrian

created 2020-07-09 10:24 UTC

Http::getCurlConnection() A

↳ Parent: Http

Complexity

Conditions	3
Paths	2

Size

Total Lines	6
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	3
eloc	3
c	0
b	0
f	0
nc	2
nop	1
dl	0
loc	6
rs	10

<?php
namespace Manticoresearch\Transport;

use Manticoresearch\Exceptions\ConnectionException;
use Manticoresearch\Exceptions\ResponseException;
use Manticoresearch\Request;
use Manticoresearch\Response;

/**
 * Class Http
 * @package Manticoresearch\Transport
 */
class Http extends \Manticoresearch\Transport implements TransportInterface
{

    /**
     * @var string
     */
    protected $scheme = 'http';

    /**
     * @var resource
     */
    protected static $curl;

    /**
     * @param Request $request
     * @param array $params
     * @return Response
     */
    public function execute(Request $request, $params = [])
    {
        $connection = $this->getConnection();
        $conn = $this->getCurlConnection($connection->getConfig('persistent'));
        $conn = $this->getCurlConnection(/** @scrutinizer ignore-type */ $connection->getConfig('persistent'));
        $url = $this->scheme.'://'.$connection->getHost().':'.$connection->getPort();
        $endpoint = $request->getPath();
        $url .= $endpoint;
        $url = $this->setupURI($url, $request->getQuery());
        $url = $this->setupURI($url, /** @scrutinizer ignore-type */ $request->getQuery());

        curl_setopt($conn, CURLOPT_URL, $url);
        curl_setopt($conn, CURLOPT_TIMEOUT, $connection->getTimeout());
        curl_setopt($conn, CURLOPT_ENCODING, '');
        curl_setopt($conn, CURLOPT_FORBID_REUSE, 0);
        $data = $request->getBody();
        $method = $request->getMethod();
        $headers = $connection->getHeaders();
        $headers[] = sprintf('Content-Type: %s', $request->getContentType());
        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 {
            curl_setopt($conn, CURLOPT_POSTFIELDS, '');
        }
        curl_setopt($conn, CURLOPT_CUSTOMREQUEST, $method);
        curl_setopt($conn, CURLOPT_HTTPHEADER, $headers);

        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')
            );
        }
        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) {
                curl_setopt($conn, $k, $v);
            }
        }
        $start = microtime(true);
        ob_start();
        curl_exec($conn);
        $responseString = \ob_get_clean();
        $end = microtime(true);
        $errorno = curl_errno($conn);
        $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);
        }

        $time = $end-$start;
        $response->setTime($time);
        $response->setTransportInfo([
                'url' => $url,
                'headers' => $headers,
                'body' => $request->getBody()
            ]);
        //hard error
        if ($errorno>0) {
            $error = curl_error($conn);

            /* @phpstan-ignore-next-line */
            self::$curl = false;

            throw new ConnectionException($error, $request);
        }


        $this->logger->debug('Request body:', [
                'connection' => $connection->getConfig(),
                'payload'=> $request->getBody()
            ]);
        $this->logger->info(
            'Request:',
            [
                    'url' => $url,
                    'status' => $status,
                    'time' => $time
                ]
        );
        $this->logger->debug('Response body:', [json_decode($responseString, true)]);
        //soft error
        if ($response->hasError()) {
            $this->logger->error('Response error:', [$response->getError()]);
            throw new ResponseException($request, $response);
        }
        return $response;
    }

    /**
     * @param bool $persistent
     * @return false|resource
     */
    protected function getCurlConnection(bool $persistent = true)
    {
        if (!$persistent || !self::$curl) {
            self::$curl = curl_init();
class Id
{
    public $id;

    public function __construct($id)
    {
        $this->id = $id;
    }

}

class Account
{
    /** @var  Id $id */
    public $id;
}

$account_id = false;

if (starsAreRight()) {
    $account_id = new Id(42);
}

$account = new Account();
if ($account instanceof Id)
{
    $account->id = $account_id;
}
        }
        return self::$curl;
    }
}


manticoresoftware / manticoresearch-php

Push — 1.x ( 747b4c...b6bf38 )

Http::getCurlConnection() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like