CurlSoapClient::___curlCall() - Code Metrics - Inspection of "Merge pull request #7 from aaharu/refactoring" - aaharu/curlsoapclient - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( b680fe...336258 )

by Haruaki

created 2017-01-01 16:28 UTC

CurlSoapClient::___curlCall() C

↳ Parent: CurlSoapClient

Complexity

Conditions	15
Paths	26

Size

Total Lines	60
Code Lines	40

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	44
CRAP Score	15

Importance

Changes

Metric	Value
dl	0
loc	60
ccs	44
cts	44
cp	1
rs	6.305
c	0
b	0
f	0
cc	15
eloc	40
nc	26
nop	1
crap	15

How to fix Long Method Complexity

<?php
/**
 * curlsoapclient - SoapClient with ext-curl. -
 *
 * @author    aaharu
 * @copyright Copyright (c) 2014 aaharu
 * @license   MIT License
 */

namespace Aaharu\Soap;

use SoapClient;
use SoapFault;

/**
 * @see https://github.com/php/php-src/tree/master/ext/soap
 */
class CurlSoapClient extends SoapClient
{
    protected $curl = null; ///< cURL handle
    protected $redirect_max; ///< max redirect counts
    protected $curl_timeout; ///< cURL request time-out seconds
    private $redirect_count = 0;

    public function __construct($wsdl, array $options)
    {
        parent::__construct($wsdl, $options);
        $this->redirect_max = 5;
        if (isset($options['redirect_max'])) {
            $this->redirect_max = (int)$options['redirect_max'];
        }
        $this->curl_timeout = 30;
        if (isset($options['curl_timeout'])) {
            $this->curl_timeout = (int)$options['curl_timeout'];
        }
        $this->curl = curl_init();
        $this->_cookies = array();
    }

    public function __destruct()
    {
        if (isset($this->curl)) {
            curl_close($this->curl);
        }
    }

    public function ___curlSetOpt($option, $value)
    {
        curl_setopt($this->curl, $option, $value);
    }

    public function __getCookies()
    {
        return $this->_cookies;
    }

    public function __setCookie($name, $value = null)
    {
        if (!isset($value)) {
            unset($this->_cookies[$name]);
            return;
        }
        $this->_cookies[$name] = (array)$value;
    }

    /**
     * Execute SOAP requests.
     *
     * @param string $request SOAP request
     * @param string $location SOAP address
     * @param string $action SOAP action
     * @param int $version SOAP version
     * @param int $one_way
     * @throws \Exception
     * @throws \SoapFault
     * @return string|object (string) SOAP response / (object) SoapFault object
     */
    public function __doRequest($request, $location, $action, $version, $one_way = 0)
    {
        curl_setopt($this->curl, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($this->curl, CURLOPT_HEADER, true);
        curl_setopt($this->curl, CURLOPT_POSTFIELDS, $request);
        if (isset($this->trace) && $this->trace) {
            curl_setopt($this->curl, CURLINFO_HEADER_OUT, true);
        }

        $this->___configHeader($action, $version);
        $this->___configCompression();
        $this->___configTimeout();
        if (!$this->___isEmptyExtProperty('_user_agent')) {
            curl_setopt($this->curl, CURLOPT_USERAGENT, $this->_user_agent);
        }
        $this->___configHttpAuthentication();
        $this->___configProxy();
        if (!$this->___isEmptyExtProperty('_ssl_method')) {
            switch ($this->_ssl_method) {
                case SOAP_SSL_METHOD_SSLv2:
                    curl_setopt($this->curl, CURLOPT_SSLVERSION, CURL_SSLVERSION_SSLv2);
                    break;
                case SOAP_SSL_METHOD_SSLv3:
                    curl_setopt($this->curl, CURLOPT_SSLVERSION, CURL_SSLVERSION_SSLv3);
                    break;
                default:
                    curl_setopt($this->curl, CURLOPT_SSLVERSION, CURL_SSLVERSION_DEFAULT);
                    break;
            }
        }

        try {
            $response = $this->___curlCall($location);
        } catch (SoapFault $fault) {
            if (isset($this->_exceptions) && empty($this->_exceptions)) {
                // if exceptions option is false, return SoapFault object
                return $fault;
            }
            throw $fault;
        }

        if ($one_way) {
            return '';
        }

        return $response;
    }

    /**
     * set CURLOPT_HTTPHEADER.
     *
     * @param string $action SOAP action
     * @param int $version SOAP version
     */
    private function ___configHeader($action, $version)
    {
        $header = array();
        if (isset($this->_keep_alive) && empty($this->_keep_alive)) {
            $header[] = 'Connection: close';
        } else {
            $header[] = 'Connection: Keep-Alive';
        }
        if ($version === SOAP_1_2) {
            $header[] = "Content-Type: application/soap+xml; charset=utf-8; action=\"{$action}\"";
        } else {
            $header[] = 'Content-Type: text/xml; charset=utf-8';
            $header[] = "SOAPAction: \"{$action}\"";
        }
        curl_setopt($this->curl, CURLOPT_HTTPHEADER, $header);
    }

    /**
     * set CURLOPT_ENCODING.
     */
    private function ___configCompression()
    {
        if (!isset($this->compression)) {
            return;
        }
        if ($this->compression & SOAP_COMPRESSION_ACCEPT) {
            curl_setopt($this->curl, CURLOPT_ENCODING, '');
        } elseif ($this->compression & SOAP_COMPRESSION_DEFLATE) {
            curl_setopt($this->curl, CURLOPT_ENCODING, 'deflate');
        } else {
            curl_setopt($this->curl, CURLOPT_ENCODING, 'gzip');
        }
    }

    /**
     * set CURLOPT_CONNECTTIMEOUT and CURLOPT_TIMEOUT.
     */
    private function ___configTimeout()
    {
        $connection_timeout = 10; // default
        if (!$this->___isEmptyExtProperty('_connection_timeout')) {
            $connection_timeout = $this->_connection_timeout;
        }
        curl_setopt($this->curl, CURLOPT_CONNECTTIMEOUT, $connection_timeout);
        curl_setopt($this->curl, CURLOPT_TIMEOUT, $this->curl_timeout);
    }

    /**
     * set CURLOPT_USERPWD and CURLOPT_HTTPAUTH.
     */
    private function ___configHttpAuthentication()
    {
        if ($this->___isEmptyExtProperty('_login') || $this->___isEmptyExtProperty('_password')) {
            return;
        }
        curl_setopt($this->curl, CURLOPT_USERPWD, $this->_login . ':' . $this->_password);
        if (property_exists($this, '_digest')) {
            curl_setopt($this->curl, CURLOPT_HTTPAUTH, CURLAUTH_ANYSAFE);
        } else {
            curl_setopt($this->curl, CURLOPT_HTTPAUTH, CURLAUTH_ANY);
        }
    }

    /**
     * set proxy options.
     */
    private function ___configProxy()
    {
        if ($this->___isEmptyExtProperty('_proxy_host')) {
            return;
        }
        curl_setopt($this->curl, CURLOPT_PROXY, $this->_proxy_host);
        if (!$this->___isEmptyExtProperty('_proxy_port')) {
            curl_setopt($this->curl, CURLOPT_PROXYPORT, $this->_proxy_port);
        }

        if ($this->___isEmptyExtProperty('_proxy_login') || $this->___isEmptyExtProperty('_proxy_password')) {
            return;
        }
        curl_setopt($this->curl, CURLOPT_PROXYUSERPWD, $this->_proxy_login . ':' . $this->_proxy_password);
        if (property_exists($this, '_digest')) {
            curl_setopt($this->curl, CURLOPT_PROXYAUTH, CURLAUTH_ANYSAFE);
        } else {
            curl_setopt($this->curl, CURLOPT_PROXYAUTH, CURLAUTH_ANY);
        }
    }

    /**
     * Request cURL.
     *
     * @param string $location SOAP address
     * @param string $location
     * @throws \SoapFault
     * @return mixed response body
     */
    private function ___curlCall($location)
    {
        curl_setopt($this->curl, CURLOPT_URL, $location);

        if (!empty($this->_cookies)) {
            $cookies = array();
            foreach ($this->_cookies as $cookie_name => $cookie_value) {
                $cookies[] = $cookie_name . '=' . $cookie_value[0];
            }
            curl_setopt($this->curl, CURLOPT_COOKIE, implode('; ', $cookies));
        }

        $response = curl_exec($this->curl);
        if ($response === false) {
            throw new SoapFault(
                'HTTP',
                'Error Fetching http, ' . curl_error($this->curl) . ' (' . curl_errno($this->curl) . ')'
            );
        }

        $header_size = curl_getinfo($this->curl, CURLINFO_HEADER_SIZE);
        $response_header = substr($response, 0, $header_size);
        $response_body = substr($response, $header_size);
        $http_code = curl_getinfo($this->curl, CURLINFO_HTTP_CODE);

        if (isset($this->trace) && $this->trace) {
            $this->__last_request_headers = curl_getinfo($this->curl, CURLINFO_HEADER_OUT);
            $this->__last_response_headers = $response_header;
        }

        if ($http_code >= 300 && $http_code < 400) {
            $tmp = stristr($response_header, 'Location:');
            $line_end = strpos($tmp, "\n"); // "\r" will be trimmed
            if ($line_end === false) {
                throw new SoapFault('HTTP', 'Error Redirecting, No Location');
            }
            $new_location = trim(substr($tmp, 9, $line_end - 9));
            $url = parse_url($new_location);
            if ($url === false ||
                empty($url['scheme']) ||
                preg_match('/^https?$/i', $url['scheme']) !== 1
            ) {
                throw new SoapFault('HTTP', 'Error Redirecting, Invalid Location');
            }
            if (++$this->redirect_count > $this->redirect_max) {
                throw new SoapFault('HTTP', 'Redirection limit reached, aborting');
            }
            return $this->___curlCall($new_location);
        }

        if ($http_code >= 400 && $this->___isErrorResponse($response_body)) {
            $string_http_code = (string)$http_code;
            $code_position = strpos($response_header, $string_http_code);
            $tmp = substr($response_header, $code_position + strlen($string_http_code));
            $http_message = trim(strstr($tmp, "\n", true));
            throw new SoapFault('HTTP', $http_message);
        }

        return $response_body;
    }

    /**
     * check body is XML or not
     *
     * @param string $response_body server response body
     * @return boolean
     */
    private function ___isErrorResponse($response_body) {
        $response_length = strlen($response_body);
        if ($response_length === 0) {
            return true;
        }
        $content_type = curl_getinfo($this->curl, CURLINFO_CONTENT_TYPE);
        if (!empty($content_type)) {
            $tmp = explode(';', $content_type, 2);
            $content_type = $tmp[0];
        }
        if ($content_type === 'text/xml' || $content_type === 'application/soap+xml') {
            return false;
        }
        $str = ltrim($response_body);
        if (strncmp($str, '<?xml', 5)) {
            return true;
        }
        return false;
    }


    /**
     * SoapClient property util
     *
     * @param string $property property name
     * @return boolean
     */
    private function ___isEmptyExtProperty($property)
    {
        if (!isset($this->{$property})) {
            return true;
        }
        if (is_string($this->{$property})) {
            return strlen($this->{$property}) === 0;
        }

        return false;
    }
}


1		<?php
2		/**
3		* curlsoapclient - SoapClient with ext-curl. -
4		*
5		* @author aaharu
6		* @copyright Copyright (c) 2014 aaharu
7		* @license MIT License
8		*/
9
10		namespace Aaharu\Soap;
11
12		use SoapClient;
13		use SoapFault;
14
15		/**
16		* @see https://github.com/php/php-src/tree/master/ext/soap
17		*/
18		class CurlSoapClient extends SoapClient
19		{
20		protected $curl = null; ///< cURL handle
21		protected $redirect_max; ///< max redirect counts
22		protected $curl_timeout; ///< cURL request time-out seconds
23		private $redirect_count = 0;
24	12
25		public function __construct($wsdl, array $options)
26	12	{
27	12	parent::__construct($wsdl, $options);
28	12	$this->redirect_max = 5;
29	1	if (isset($options['redirect_max'])) {
30	1	$this->redirect_max = (int)$options['redirect_max'];
31	12	}
32	12	$this->curl_timeout = 30;
33	1	if (isset($options['curl_timeout'])) {
34	1	$this->curl_timeout = (int)$options['curl_timeout'];
35	12	}
36	12	$this->curl = curl_init();
37	12	$this->_cookies = array();
38		}
39	12
40		public function __destruct()
41	12	{
42	12	if (isset($this->curl)) {
43	12	curl_close($this->curl);
44	12	}
45		}
46	1
47		public function ___curlSetOpt($option, $value)
48	1	{
49	1	curl_setopt($this->curl, $option, $value);
50		}
51	1
52		public function __getCookies()
53	1	{
54		return $this->_cookies;
55		}
56	1
57		public function __setCookie($name, $value = null)
58	1	{
59		if (!isset($value)) {
60		unset($this->_cookies[$name]);
61		return;
62	1	}
63	1	$this->_cookies[$name] = (array)$value;
64		}
65
66		/**
67		* Execute SOAP requests.
68		*
69		* @param string $request SOAP request
70		* @param string $location SOAP address
71		* @param string $action SOAP action
72		* @param int $version SOAP version
73		* @param int $one_way
74		* @throws \Exception
75		* @throws \SoapFault
76		* @return string\|object (string) SOAP response / (object) SoapFault object
77	12	*/
78		public function __doRequest($request, $location, $action, $version, $one_way = 0)
79	12	{
80	12	curl_setopt($this->curl, CURLOPT_RETURNTRANSFER, true);
81	12	curl_setopt($this->curl, CURLOPT_HEADER, true);
82	12	curl_setopt($this->curl, CURLOPT_POSTFIELDS, $request);
83	3	if (isset($this->trace) && $this->trace) {
84	3	curl_setopt($this->curl, CURLINFO_HEADER_OUT, true);
85		}
86	12
87	12	$this->___configHeader($action, $version);
88	12	$this->___configCompression();
89	12	$this->___configTimeout();
90	1	if (!$this->___isEmptyExtProperty('_user_agent')) {
91	1	curl_setopt($this->curl, CURLOPT_USERAGENT, $this->_user_agent);
92	12	}
93	12	$this->___configHttpAuthentication();
94	12	$this->___configProxy();
95		if (!$this->___isEmptyExtProperty('_ssl_method')) {
96		switch ($this->_ssl_method) {
97		case SOAP_SSL_METHOD_SSLv2:
98		curl_setopt($this->curl, CURLOPT_SSLVERSION, CURL_SSLVERSION_SSLv2);
99		break;
100		case SOAP_SSL_METHOD_SSLv3:
101		curl_setopt($this->curl, CURLOPT_SSLVERSION, CURL_SSLVERSION_SSLv3);
102		break;
103		default:
104		curl_setopt($this->curl, CURLOPT_SSLVERSION, CURL_SSLVERSION_DEFAULT);
105		break;
106		}
107		}
108
109	12	try {
110	12	$response = $this->___curlCall($location);
111	7	} catch (SoapFault $fault) {
112		if (isset($this->_exceptions) && empty($this->_exceptions)) {
113	1	// if exceptions option is false, return SoapFault object
114		return $fault;
115	6	}
116		throw $fault;
117		}
118	5
119		if ($one_way) {
120		return '';
121		}
122	5
123		return $response;
124		}
125
126		/**
127		* set CURLOPT_HTTPHEADER.
128		*
129		* @param string $action SOAP action
130		* @param int $version SOAP version
131		*/
132	12	private function ___configHeader($action, $version)
133		{
134	12	$header = array();
135	12	if (isset($this->_keep_alive) && empty($this->_keep_alive)) {
136	1	$header[] = 'Connection: close';
137	1	} else {
138	11	$header[] = 'Connection: Keep-Alive';
139		}
140	12	if ($version === SOAP_1_2) {
141	1	$header[] = "Content-Type: application/soap+xml; charset=utf-8; action=\"{$action}\"";
142	1	} else {
143	11	$header[] = 'Content-Type: text/xml; charset=utf-8';
144	11	$header[] = "SOAPAction: \"{$action}\"";
145		}
146	12	curl_setopt($this->curl, CURLOPT_HTTPHEADER, $header);
147	12	}
148
149		/**
150		* set CURLOPT_ENCODING.
151		*/
152		private function ___configCompression()
153		{
154	12	if (!isset($this->compression)) {
155		return;
156	12	}
157	3	if ($this->compression & SOAP_COMPRESSION_ACCEPT) {
158	1	curl_setopt($this->curl, CURLOPT_ENCODING, '');
159	3	} elseif ($this->compression & SOAP_COMPRESSION_DEFLATE) {
160	1	curl_setopt($this->curl, CURLOPT_ENCODING, 'deflate');
161	1	} else {
162	1	curl_setopt($this->curl, CURLOPT_ENCODING, 'gzip');
163		}
164	3	}
165	12
166		/**
167		* set CURLOPT_CONNECTTIMEOUT and CURLOPT_TIMEOUT.
168		*/
169		private function ___configTimeout()
170		{
171		$connection_timeout = 10; // default
172	12	if (!$this->___isEmptyExtProperty('_connection_timeout')) {
173		$connection_timeout = $this->_connection_timeout;
174	12	}
175	12	curl_setopt($this->curl, CURLOPT_CONNECTTIMEOUT, $connection_timeout);
176	1	curl_setopt($this->curl, CURLOPT_TIMEOUT, $this->curl_timeout);
177	1	}
178	12
179	12	/**
180	12	* set CURLOPT_USERPWD and CURLOPT_HTTPAUTH.
181		*/
182		private function ___configHttpAuthentication()
183		{
184		if ($this->___isEmptyExtProperty('_login') \|\| $this->___isEmptyExtProperty('_password')) {
185		return;
186		}
187	12	curl_setopt($this->curl, CURLOPT_USERPWD, $this->_login . ':' . $this->_password);
188		if (property_exists($this, '_digest')) {
189	12	curl_setopt($this->curl, CURLOPT_HTTPAUTH, CURLAUTH_ANYSAFE);
190	12	} else {
191	2	curl_setopt($this->curl, CURLOPT_HTTPAUTH, CURLAUTH_ANY);
192	2	}
193	1	}
194	1
195	1	/**
196		* set proxy options.
197	2	*/
198	12	private function ___configProxy()
199		{
200		if ($this->___isEmptyExtProperty('_proxy_host')) {
201		return;
202		}
203		curl_setopt($this->curl, CURLOPT_PROXY, $this->_proxy_host);
204		if (!$this->___isEmptyExtProperty('_proxy_port')) {
205	12	curl_setopt($this->curl, CURLOPT_PROXYPORT, $this->_proxy_port);
206		}
207	12
208		if ($this->___isEmptyExtProperty('_proxy_login') \|\| $this->___isEmptyExtProperty('_proxy_password')) {
209		return;
210	12	}
211		curl_setopt($this->curl, CURLOPT_PROXYUSERPWD, $this->_proxy_login . ':' . $this->_proxy_password);
212		if (property_exists($this, '_digest')) {
213	12	curl_setopt($this->curl, CURLOPT_PROXYAUTH, CURLAUTH_ANYSAFE);
214	12	} else {
215		curl_setopt($this->curl, CURLOPT_PROXYAUTH, CURLAUTH_ANY);
216		}
217		}
218
219		/**
220		* Request cURL.
221		*
222	12	* @param string $location SOAP address
223		* @param string $location
224		* @throws \SoapFault
225		* @return mixed response body
226		*/
227		private function ___curlCall($location)
228		{
229		curl_setopt($this->curl, CURLOPT_URL, $location);
230
231	12	if (!empty($this->_cookies)) {
232		$cookies = array();
233	12	foreach ($this->_cookies as $cookie_name => $cookie_value) {
234		$cookies[] = $cookie_name . '=' . $cookie_value[0];
235	12	}
236	1	curl_setopt($this->curl, CURLOPT_COOKIE, implode('; ', $cookies));
237	1	}
238	1
239	1	$response = curl_exec($this->curl);
240	1	if ($response === false) {
241	1	throw new SoapFault(
242		'HTTP',
243	12	'Error Fetching http, ' . curl_error($this->curl) . ' (' . curl_errno($this->curl) . ')'
244	12	);
245	2	}
246	2
247	2	$header_size = curl_getinfo($this->curl, CURLINFO_HEADER_SIZE);
248	2	$response_header = substr($response, 0, $header_size);
249		$response_body = substr($response, $header_size);
250		$http_code = curl_getinfo($this->curl, CURLINFO_HTTP_CODE);
251	10
252	10	if (isset($this->trace) && $this->trace) {
253	10	$this->__last_request_headers = curl_getinfo($this->curl, CURLINFO_HEADER_OUT);
254	10	$this->__last_response_headers = $response_header;
255		}
256	10
257	3	if ($http_code >= 300 && $http_code < 400) {
258	3	$tmp = stristr($response_header, 'Location:');
259	3	$line_end = strpos($tmp, "\n"); // "\r" will be trimmed
260		if ($line_end === false) {
261	10	throw new SoapFault('HTTP', 'Error Redirecting, No Location');
262	4	}
263	4	$new_location = trim(substr($tmp, 9, $line_end - 9));
264	4	$url = parse_url($new_location);
265	1	if ($url === false \|\|
266		empty($url['scheme']) \|\|
267	3	preg_match('/^https?$/i', $url['scheme']) !== 1
268	3	) {
269	3	throw new SoapFault('HTTP', 'Error Redirecting, Invalid Location');
270	3	}
271	2	if (++$this->redirect_count > $this->redirect_max) {
272	3	throw new SoapFault('HTTP', 'Redirection limit reached, aborting');
273	1	}
274		return $this->___curlCall($new_location);
275	2	}
276	1
277		if ($http_code >= 400 && $this->___isErrorResponse($response_body)) {
278	2	$string_http_code = (string)$http_code;
279		$code_position = strpos($response_header, $string_http_code);
280		$tmp = substr($response_header, $code_position + strlen($string_http_code));
281	7	$http_message = trim(strstr($tmp, "\n", true));
282	3	throw new SoapFault('HTTP', $http_message);
283	3	}
284	3
285	1	return $response_body;
286	3	}
287	2
288	2	/**
289	2	* check body is XML or not
290	2	*
291	2	* @param string $response_body server response body
292	2	* @return boolean
293	2	*/
294	2	private function ___isErrorResponse($response_body) {
295	1	$response_length = strlen($response_body);
296	1	if ($response_length === 0) {
297	2	return true;
298	2	}
299	1	$content_type = curl_getinfo($this->curl, CURLINFO_CONTENT_TYPE);
300	1	if (!empty($content_type)) {
301	1	$tmp = explode(';', $content_type, 2);
302	1	$content_type = $tmp[0];
303	1	}
304	2	if ($content_type === 'text/xml' \|\| $content_type === 'application/soap+xml') {
305		return false;
306	3	}
307	2	$str = ltrim($response_body);
308	2	if (strncmp($str, '<?xml', 5)) {
309	2	return true;
310	2	}
311	2	return false;
312		}
313	1
314
315	5	/**
316		* SoapClient property util
317		*
318		* @param string $property property name
319		* @return boolean
320		*/
321		private function ___isEmptyExtProperty($property)
322		{
323		if (!isset($this->{$property})) {
324		return true;
325		}
326		if (is_string($this->{$property})) {
327		return strlen($this->{$property}) === 0;
328		}
329
330		return false;
331		}
332		}
333

aaharu / curlsoapclient

Push — master ( b680fe...336258 )

CurlSoapClient::___curlCall() C

Complexity

Size

Duplication

Code Coverage

Importance

How to fix Long Method Complexity

Long Method

Duplication Side-by-Side

Filter issues like