Curl::buildOptions() - Code Metrics - cakephp/cakephp - Measure and Improve Code Quality continuously with Scrutinizer

Curl::buildOptions() F
last analyzed 2019-12-15 12:43 UTC

↳ Parent: Curl

Complexity

Conditions	16
Paths	2592

Size

Total Lines

Duplication

Lines	6
Ratio	8 %

Importance

Changes

Metric	Value
cc	16
nc	2592
nop	2
dl	6
loc	75
rs	1.4
c	0
b	0
f	0

How to fix Long Method Complexity

<?php
/**
 * CakePHP(tm) : Rapid Development Framework (https://cakephp.org)
 * Copyright (c) Cake Software Foundation, Inc. (https://cakefoundation.org)
 *
 * Licensed under The MIT License
 * Redistributions of files must retain the above copyright notice.
 *
 * @copyright     Copyright (c) Cake Software Foundation, Inc. (https://cakefoundation.org)
 * @link          https://cakephp.org CakePHP(tm) Project
 * @since         3.7.0
 * @license       https://opensource.org/licenses/mit-license.php MIT License
 */
namespace Cake\Http\Client\Adapter;

use Cake\Http\Client\AdapterInterface;
use Cake\Http\Client\Request;
use Cake\Http\Client\Response;
use Cake\Http\Exception\HttpException;

/**
 * Implements sending Cake\Http\Client\Request via ext/curl.
 *
 * In addition to the standard options documented in Cake\Http\Client,
 * this adapter supports all available curl options. Additional curl options
 * can be set via the `curl` option key when making requests or configuring
 * a client.
 */
class Curl implements AdapterInterface
{
    /**
     * {@inheritDoc}
     */
    public function send(Request $request, array $options)
    {
        $ch = curl_init();
        $options = $this->buildOptions($request, $options);
        curl_setopt_array($ch, $options);

        $body = $this->exec($ch);
        if ($body === false) {
            $errorCode = curl_errno($ch);
            $error = curl_error($ch);
            curl_close($ch);

            $status = 500;
            if ($errorCode === CURLE_OPERATION_TIMEOUTED) {
                $status = 504;
            }
            throw new HttpException("cURL Error ({$errorCode}) {$error}", $status);
        }

        $responses = $this->createResponse($ch, $body);
        curl_close($ch);

        return $responses;
    }

    /**
     * Convert client options into curl options.
     *
     * @param \Cake\Http\Client\Request $request The request.
     * @param array $options The client options
     * @return array
     */
    public function buildOptions(Request $request, array $options)
    {
        $headers = [];
        foreach ($request->getHeaders() as $key => $values) {
            $headers[] = $key . ': ' . implode(', ', $values);
        }

        $out = [
            CURLOPT_URL => (string)$request->getUri(),
            CURLOPT_HTTP_VERSION => $this->getProtocolVersion($request),
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_HEADER => true,
            CURLOPT_HTTPHEADER => $headers,
        ];
        switch ($request->getMethod()) {
            case Request::METHOD_GET:
                $out[CURLOPT_HTTPGET] = true;
                break;

            case Request::METHOD_POST:
                $out[CURLOPT_POST] = true;
                break;

            default:
                $out[CURLOPT_POST] = true;
                $out[CURLOPT_CUSTOMREQUEST] = $request->getMethod();
                break;
        }

        $body = $request->getBody();
        if ($body) {
            $body->rewind();
            $out[CURLOPT_POSTFIELDS] = $body->getContents();
            // GET requests with bodies require custom request to be used.
            if (isset($out[CURLOPT_HTTPGET])) {
                $out[CURLOPT_CUSTOMREQUEST] = 'get';
            }
        }

        if (empty($options['ssl_cafile'])) {
            $options['ssl_cafile'] = CORE_PATH . 'config' . DIRECTORY_SEPARATOR . 'cacert.pem';
        }
        if (!empty($options['ssl_verify_host'])) {
            // Value of 1 or true is deprecated. Only 2 or 0 should be used now.
            $options['ssl_verify_host'] = 2;
        }
        $optionMap = [
            'timeout' => CURLOPT_TIMEOUT,
            'ssl_verify_peer' => CURLOPT_SSL_VERIFYPEER,
            'ssl_verify_host' => CURLOPT_SSL_VERIFYHOST,
            'ssl_cafile' => CURLOPT_CAINFO,
            'ssl_local_cert' => CURLOPT_SSLCERT,
            'ssl_passphrase' => CURLOPT_SSLCERTPASSWD,
        ];
        foreach ($optionMap as $option => $curlOpt) {
            if (isset($options[$option])) {
                $out[$curlOpt] = $options[$option];
            }
        }
        if (isset($options['proxy']['proxy'])) {
            $out[CURLOPT_PROXY] = $options['proxy']['proxy'];
        }
        if (isset($options['proxy']['username'])) {
            $password = !empty($options['proxy']['password']) ? $options['proxy']['password'] : '';
            $out[CURLOPT_PROXYUSERPWD] = $options['proxy']['username'] . ':' . $password;
        }
        if (isset($options['curl']) && is_array($options['curl'])) {
            // Can't use array_merge() because keys will be re-ordered.
            foreach ($options['curl'] as $key => $value) {
                $out[$key] = $value;
            }
        }

        return $out;
    }

    /**
     * Convert HTTP version number into curl value.
     *
     * @param \Cake\Http\Client\Request $request The request to get a protocol version for.
     * @return int
     */
    protected function getProtocolVersion(Request $request)
    {
        switch ($request->getProtocolVersion()) {
            case '1.0':
                return CURL_HTTP_VERSION_1_0;
            case '1.1':
                return CURL_HTTP_VERSION_1_1;
            case '2':
            case '2.0':
                if (defined('CURL_HTTP_VERSION_2TLS')) {
                    return CURL_HTTP_VERSION_2TLS;
                }
                if (defined('CURL_HTTP_VERSION_2_0')) {
                    return CURL_HTTP_VERSION_2_0;
                }
                throw new HttpException('libcurl 7.33 or greater required for HTTP/2 support');
        }

        return CURL_HTTP_VERSION_NONE;
    }

    /**
     * Convert the raw curl response into an Http\Client\Response
     *
     * @param resource $handle Curl handle
     * @param string $responseData string The response data from curl_exec
     * @return \Cake\Http\Client\Response
     */
    protected function createResponse($handle, $responseData)
    {
        $headerSize = curl_getinfo($handle, CURLINFO_HEADER_SIZE);
        $headers = trim(substr($responseData, 0, $headerSize));
        $body = substr($responseData, $headerSize);
        $response = new Response(explode("\r\n", $headers), $body);

        return [$response];
    }

    /**
     * Execute the curl handle.
     *
     * @param resource $ch Curl Resource handle
     * @return string
     */
    protected function exec($ch)
    {
        return curl_exec($ch);
    }
}


1		<?php
2		/**
3		* CakePHP(tm) : Rapid Development Framework (https://cakephp.org)
4		* Copyright (c) Cake Software Foundation, Inc. (https://cakefoundation.org)
5		*
6		* Licensed under The MIT License
7		* Redistributions of files must retain the above copyright notice.
8		*
9		* @copyright Copyright (c) Cake Software Foundation, Inc. (https://cakefoundation.org)
10		* @link https://cakephp.org CakePHP(tm) Project
11		* @since 3.7.0
12		* @license https://opensource.org/licenses/mit-license.php MIT License
13		*/
14		namespace Cake\Http\Client\Adapter;
15
16		use Cake\Http\Client\AdapterInterface;
17		use Cake\Http\Client\Request;
18		use Cake\Http\Client\Response;
19		use Cake\Http\Exception\HttpException;
20
21		/**
22		* Implements sending Cake\Http\Client\Request via ext/curl.
23		*
24		* In addition to the standard options documented in Cake\Http\Client,
25		* this adapter supports all available curl options. Additional curl options
26		* can be set via the `curl` option key when making requests or configuring
27		* a client.
28		*/
29		class Curl implements AdapterInterface
30		{
31		/**
32		* {@inheritDoc}
33		*/
34		public function send(Request $request, array $options)
35		{
36		$ch = curl_init();
37		$options = $this->buildOptions($request, $options);
38		curl_setopt_array($ch, $options);
39
40		$body = $this->exec($ch);
41		if ($body === false) {
42		$errorCode = curl_errno($ch);
43		$error = curl_error($ch);
44		curl_close($ch);
45
46		$status = 500;
47		if ($errorCode === CURLE_OPERATION_TIMEOUTED) {
48		$status = 504;
49		}
50		throw new HttpException("cURL Error ({$errorCode}) {$error}", $status);
51		}
52
53		$responses = $this->createResponse($ch, $body);
54		curl_close($ch);
55
56		return $responses;
57		}
58
59		/**
60		* Convert client options into curl options.
61		*
62		* @param \Cake\Http\Client\Request $request The request.
63		* @param array $options The client options
64		* @return array
65		*/
66		public function buildOptions(Request $request, array $options)
67		{
68		$headers = [];
69	View Code Duplication	foreach ($request->getHeaders() as $key => $values) {
70		$headers[] = $key . ': ' . implode(', ', $values);
71		}
72
73		$out = [
74		CURLOPT_URL => (string)$request->getUri(),
75		CURLOPT_HTTP_VERSION => $this->getProtocolVersion($request),
76		CURLOPT_RETURNTRANSFER => true,
77		CURLOPT_HEADER => true,
78		CURLOPT_HTTPHEADER => $headers,
79		];
80		switch ($request->getMethod()) {
81		case Request::METHOD_GET:
82		$out[CURLOPT_HTTPGET] = true;
83		break;
84
85		case Request::METHOD_POST:
86		$out[CURLOPT_POST] = true;
87		break;
88
89		default:
90		$out[CURLOPT_POST] = true;
91		$out[CURLOPT_CUSTOMREQUEST] = $request->getMethod();
92		break;
93		}
94
95		$body = $request->getBody();
96		if ($body) {
97		$body->rewind();
98		$out[CURLOPT_POSTFIELDS] = $body->getContents();
99		// GET requests with bodies require custom request to be used.
100		if (isset($out[CURLOPT_HTTPGET])) {
101		$out[CURLOPT_CUSTOMREQUEST] = 'get';
102		}
103		}
104
105	View Code Duplication	if (empty($options['ssl_cafile'])) {
106		$options['ssl_cafile'] = CORE_PATH . 'config' . DIRECTORY_SEPARATOR . 'cacert.pem';
107		}
108		if (!empty($options['ssl_verify_host'])) {
109		// Value of 1 or true is deprecated. Only 2 or 0 should be used now.
110		$options['ssl_verify_host'] = 2;
111		}
112		$optionMap = [
113		'timeout' => CURLOPT_TIMEOUT,
114		'ssl_verify_peer' => CURLOPT_SSL_VERIFYPEER,
115		'ssl_verify_host' => CURLOPT_SSL_VERIFYHOST,
116		'ssl_cafile' => CURLOPT_CAINFO,
117		'ssl_local_cert' => CURLOPT_SSLCERT,
118		'ssl_passphrase' => CURLOPT_SSLCERTPASSWD,
119		];
120		foreach ($optionMap as $option => $curlOpt) {
121		if (isset($options[$option])) {
122		$out[$curlOpt] = $options[$option];
123		}
124		}
125		if (isset($options['proxy']['proxy'])) {
126		$out[CURLOPT_PROXY] = $options['proxy']['proxy'];
127		}
128		if (isset($options['proxy']['username'])) {
129		$password = !empty($options['proxy']['password']) ? $options['proxy']['password'] : '';
130		$out[CURLOPT_PROXYUSERPWD] = $options['proxy']['username'] . ':' . $password;
131		}
132		if (isset($options['curl']) && is_array($options['curl'])) {
133		// Can't use array_merge() because keys will be re-ordered.
134		foreach ($options['curl'] as $key => $value) {
135		$out[$key] = $value;
136		}
137		}
138
139		return $out;
140		}
141
142		/**
143		* Convert HTTP version number into curl value.
144		*
145		* @param \Cake\Http\Client\Request $request The request to get a protocol version for.
146		* @return int
147		*/
148		protected function getProtocolVersion(Request $request)
149		{
150		switch ($request->getProtocolVersion()) {
151		case '1.0':
152		return CURL_HTTP_VERSION_1_0;
153		case '1.1':
154		return CURL_HTTP_VERSION_1_1;
155		case '2':
156		case '2.0':
157		if (defined('CURL_HTTP_VERSION_2TLS')) {
158		return CURL_HTTP_VERSION_2TLS;
159		}
160		if (defined('CURL_HTTP_VERSION_2_0')) {
161		return CURL_HTTP_VERSION_2_0;
162		}
163		throw new HttpException('libcurl 7.33 or greater required for HTTP/2 support');
164		}
165
166		return CURL_HTTP_VERSION_NONE;
167		}
168
169		/**
170		* Convert the raw curl response into an Http\Client\Response
171		*
172		* @param resource $handle Curl handle
173		* @param string $responseData string The response data from curl_exec
174		* @return \Cake\Http\Client\Response
175		*/
176		protected function createResponse($handle, $responseData)
177		{
178		$headerSize = curl_getinfo($handle, CURLINFO_HEADER_SIZE);
179		$headers = trim(substr($responseData, 0, $headerSize));
180		$body = substr($responseData, $headerSize);
181		$response = new Response(explode("\r\n", $headers), $body);
182
183		return [$response];
184		}
185
186		/**
187		* Execute the curl handle.
188		*
189		* @param resource $ch Curl Resource handle
190		* @return string
191		*/
192		protected function exec($ch)
193		{
194		return curl_exec($ch);
195		}
196		}
197

cakephp / cakephp

Curl::buildOptions() F last analyzed 2019-12-15 12:43 UTC

Complexity

Size

Duplication

Importance

How to fix Long Method Complexity

Long Method

Duplication Side-by-Side

Filter issues like

Curl::buildOptions() F
last analyzed 2019-12-15 12:43 UTC