miniflux-legacy/vendor/fguillot/picofeed/lib/PicoFeed/Client/Curl.php

419 lines
12 KiB
PHP
Raw Normal View History

2013-07-17 01:54:44 +02:00
<?php
namespace PicoFeed\Client;
2013-07-17 01:54:44 +02:00
use PicoFeed\Logging\Logger;
2014-05-20 20:20:27 +02:00
/**
* cURL HTTP client
*
* @author Frederic Guillot
* @package Client
2014-05-20 20:20:27 +02:00
*/
class Curl extends Client
2013-07-17 01:54:44 +02:00
{
2015-02-01 20:48:05 +01:00
/**
* HTTP response body
*
* @access private
* @var string
*/
private $body = '';
/**
* Body size
*
* @access private
* @var integer
*/
private $body_length = 0;
/**
* HTTP response headers
*
* @access private
* @var array
*/
2015-04-11 02:34:48 +02:00
private $response_headers = array();
2015-02-01 20:48:05 +01:00
/**
* Counter on the number of header received
*
* @access private
* @var integer
*/
2015-04-11 02:34:48 +02:00
private $response_headers_count = 0;
2015-02-01 20:48:05 +01:00
2014-05-20 20:20:27 +02:00
/**
* cURL callback to read the HTTP body
*
* If the function return -1, curl stop to read the HTTP response
*
* @access public
* @param resource $ch cURL handler
* @param string $buffer Chunk of data
* @return integer Length of the buffer
*/
2013-07-17 01:54:44 +02:00
public function readBody($ch, $buffer)
{
$length = strlen($buffer);
$this->body_length += $length;
2014-05-20 20:20:27 +02:00
if ($this->body_length > $this->max_body_size) {
return -1;
}
2013-07-17 01:54:44 +02:00
$this->body .= $buffer;
return $length;
}
2014-05-20 20:20:27 +02:00
/**
* cURL callback to read HTTP headers
*
* @access public
* @param resource $ch cURL handler
* @param string $buffer Header line
* @return integer Length of the buffer
*/
2013-07-17 01:54:44 +02:00
public function readHeaders($ch, $buffer)
{
$length = strlen($buffer);
if ($buffer === "\r\n") {
2015-04-11 02:34:48 +02:00
$this->response_headers_count++;
2013-07-17 01:54:44 +02:00
}
else {
2015-04-11 02:34:48 +02:00
if (! isset($this->response_headers[$this->response_headers_count])) {
$this->response_headers[$this->response_headers_count] = '';
2013-07-17 01:54:44 +02:00
}
2015-04-11 02:34:48 +02:00
$this->response_headers[$this->response_headers_count] .= $buffer;
2013-07-17 01:54:44 +02:00
}
return $length;
}
2015-02-06 03:16:34 +01:00
/**
* cURL callback to passthrough the HTTP status header to the client
*
* @access public
* @param resource $ch cURL handler
* @param string $buffer Header line
* @return integer Length of the buffer
*/
public function passthroughHeaders($ch, $buffer)
{
list($status, $headers) = HttpHeaders::parse(array($buffer));
if ($status !== 0) {
header(':', true, $status);
}
elseif (isset($headers['Content-Type'])) {
header($buffer);
}
return $this->readHeaders($ch, $buffer);
}
/**
* cURL callback to passthrough the HTTP body to the client
*
* If the function return -1, curl stop to read the HTTP response
*
* @access public
* @param resource $ch cURL handler
* @param string $buffer Chunk of data
* @return integer Length of the buffer
*/
public function passthroughBody($ch, $buffer)
{
echo $buffer;
return strlen($buffer);
}
2014-05-20 20:20:27 +02:00
/**
2014-10-19 20:42:31 +02:00
* Prepare HTTP headers
2014-05-20 20:20:27 +02:00
*
2014-10-19 20:42:31 +02:00
* @access private
* @return string[]
2014-05-20 20:20:27 +02:00
*/
2014-10-19 20:42:31 +02:00
private function prepareHeaders()
2013-07-17 01:54:44 +02:00
{
2014-10-19 20:42:31 +02:00
$headers = array(
'Connection: close',
);
2013-07-17 01:54:44 +02:00
2014-10-19 20:42:31 +02:00
if ($this->etag) {
$headers[] = 'If-None-Match: '.$this->etag;
}
2013-07-17 01:54:44 +02:00
2014-10-19 20:42:31 +02:00
if ($this->last_modified) {
$headers[] = 'If-Modified-Since: '.$this->last_modified;
}
2013-07-17 01:54:44 +02:00
2015-04-11 02:34:48 +02:00
$headers = array_merge($headers, $this->request_headers);
2014-10-19 20:42:31 +02:00
return $headers;
}
2013-09-24 01:22:13 +02:00
2014-10-19 20:42:31 +02:00
/**
* Prepare curl proxy context
*
* @access private
* @return resource $ch
2014-10-19 20:42:31 +02:00
*/
private function prepareProxyContext($ch)
{
2014-05-20 20:20:27 +02:00
if ($this->proxy_hostname) {
2013-09-24 01:22:13 +02:00
Logger::setMessage(get_called_class().' Proxy: '.$this->proxy_hostname.':'.$this->proxy_port);
2014-05-20 20:20:27 +02:00
curl_setopt($ch, CURLOPT_PROXYPORT, $this->proxy_port);
2013-09-24 01:22:13 +02:00
curl_setopt($ch, CURLOPT_PROXYTYPE, 'HTTP');
2014-05-20 20:20:27 +02:00
curl_setopt($ch, CURLOPT_PROXY, $this->proxy_hostname);
2013-09-24 01:22:13 +02:00
2014-05-20 20:20:27 +02:00
if ($this->proxy_username) {
Logger::setMessage(get_called_class().' Proxy credentials: Yes');
2014-05-20 20:20:27 +02:00
curl_setopt($ch, CURLOPT_PROXYUSERPWD, $this->proxy_username.':'.$this->proxy_password);
}
else {
Logger::setMessage(get_called_class().' Proxy credentials: No');
2013-09-24 01:22:13 +02:00
}
}
2014-10-19 20:42:31 +02:00
return $ch;
}
2014-12-24 19:50:20 +01:00
/**
* Prepare curl auth context
*
* @access private
* @return resource $ch
*/
private function prepareAuthContext($ch)
{
if ($this->username && $this->password) {
curl_setopt($ch, CURLOPT_USERPWD, $this->username.':'.$this->password);
}
return $ch;
}
2015-02-06 03:16:34 +01:00
/**
* Set write/header functions
*
* @access private
* @return resource $ch
*/
private function prepareDownloadMode($ch)
{
$write_function = 'readBody';
$header_function = 'readHeaders';
if ($this->isPassthroughEnabled()) {
$write_function = 'passthroughBody';
$header_function = 'passthroughHeaders';
}
curl_setopt($ch, CURLOPT_WRITEFUNCTION, array($this, $write_function));
curl_setopt($ch, CURLOPT_HEADERFUNCTION, array($this, $header_function));
return $ch;
}
2014-10-19 20:42:31 +02:00
/**
* Prepare curl context
*
* @access private
* @return resource
*/
private function prepareContext()
{
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $this->url);
curl_setopt($ch, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_1);
2015-04-11 15:40:09 +02:00
curl_setopt($ch, CURLOPT_TIMEOUT, $this->timeout);
2014-10-19 20:42:31 +02:00
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $this->timeout);
2015-03-01 19:56:11 +01:00
curl_setopt($ch, CURLOPT_USERAGENT, $this->user_agent);
2014-10-19 20:42:31 +02:00
curl_setopt($ch, CURLOPT_HTTPHEADER, $this->prepareHeaders());
curl_setopt($ch, CURLOPT_FOLLOWLOCATION, ini_get('open_basedir') === '');
curl_setopt($ch, CURLOPT_MAXREDIRS, $this->max_redirects);
curl_setopt($ch, CURLOPT_ENCODING, '');
curl_setopt($ch, CURLOPT_COOKIEJAR, 'php://memory');
curl_setopt($ch, CURLOPT_COOKIEFILE, 'php://memory');
2015-03-01 19:56:11 +01:00
// Disable SSLv3 by enforcing TLSv1.x for curl >= 7.34.0 and < 7.39.0.
// Versions prior to 7.34 and at least when compiled against openssl
// interpret this parameter as "limit to TLSv1.0" which fails for sites
// which enforce TLS 1.1+.
// Starting with curl 7.39.0 SSLv3 is disabled by default.
$version = curl_version();
if ($version['version_number'] >= 467456 && $version['version_number'] < 468736) {
curl_setopt($ch, CURLOPT_SSLVERSION, 1);
}
2014-10-19 20:42:31 +02:00
2015-02-06 03:16:34 +01:00
$ch = $this->prepareDownloadMode($ch);
2014-10-19 20:42:31 +02:00
$ch = $this->prepareProxyContext($ch);
2014-12-24 19:50:20 +01:00
$ch = $this->prepareAuthContext($ch);
2014-10-19 20:42:31 +02:00
return $ch;
}
/**
* Execute curl context
*
* @access private
*/
private function executeContext()
{
$ch = $this->prepareContext();
2013-07-17 01:54:44 +02:00
curl_exec($ch);
Logger::setMessage(get_called_class().' cURL total time: '.curl_getinfo($ch, CURLINFO_TOTAL_TIME));
Logger::setMessage(get_called_class().' cURL dns lookup time: '.curl_getinfo($ch, CURLINFO_NAMELOOKUP_TIME));
Logger::setMessage(get_called_class().' cURL connect time: '.curl_getinfo($ch, CURLINFO_CONNECT_TIME));
Logger::setMessage(get_called_class().' cURL speed download: '.curl_getinfo($ch, CURLINFO_SPEED_DOWNLOAD));
Logger::setMessage(get_called_class().' cURL effective url: '.curl_getinfo($ch, CURLINFO_EFFECTIVE_URL));
2013-07-17 01:54:44 +02:00
$curl_errno = curl_errno($ch);
if ($curl_errno) {
Logger::setMessage(get_called_class().' cURL error: '.curl_error($ch));
2013-07-17 01:54:44 +02:00
curl_close($ch);
$this->handleError($curl_errno);
2013-07-17 01:54:44 +02:00
}
// Update the url if there where redirects
$this->url = curl_getinfo($ch, CURLINFO_EFFECTIVE_URL);
2013-07-17 01:54:44 +02:00
curl_close($ch);
2014-10-19 20:42:31 +02:00
}
2014-10-19 20:42:31 +02:00
/**
* Do the HTTP request
*
* @access public
* @param bool $follow_location Flag used when there is an open_basedir restriction
* @return array HTTP response ['body' => ..., 'status' => ..., 'headers' => ...]
*/
public function doRequest($follow_location = true)
{
$this->executeContext();
2015-04-11 02:34:48 +02:00
list($status, $headers) = HttpHeaders::parse(explode("\r\n", $this->response_headers[$this->response_headers_count - 1]));
// When restricted with open_basedir
2014-10-19 20:42:31 +02:00
if ($this->needToHandleRedirection($follow_location, $status)) {
return $this->handleRedirection($headers['Location']);
}
2013-07-17 01:54:44 +02:00
return array(
'status' => $status,
'body' => $this->body,
'headers' => $headers
);
}
2014-10-19 20:42:31 +02:00
/**
* Check if the redirection have to be handled manually
*
* @access private
* @param boolean $follow_location Flag
* @param integer $status HTTP status code
* @return boolean
*/
private function needToHandleRedirection($follow_location, $status)
{
return $follow_location && ini_get('open_basedir') !== '' && ($status == 301 || $status == 302);
}
2015-02-01 20:48:05 +01:00
/**
* Handle manually redirections when there is an open base dir restriction
*
* @access private
* @param string $location Redirected URL
* @return array
*/
private function handleRedirection($location)
{
$nb_redirects = 0;
$result = array();
$this->url = Url::resolve($location, $this->url);
$this->body = '';
$this->body_length = 0;
2015-04-11 02:34:48 +02:00
$this->response_headers = array();
$this->response_headers_count = 0;
2015-02-01 20:48:05 +01:00
while (true) {
$nb_redirects++;
if ($nb_redirects >= $this->max_redirects) {
throw new MaxRedirectException('Maximum number of redirections reached');
}
$result = $this->doRequest(false);
if ($result['status'] == 301 || $result['status'] == 302) {
$this->url = Url::resolve($result['headers']['Location'], $this->url);
$this->body = '';
$this->body_length = 0;
2015-04-11 02:34:48 +02:00
$this->response_headers = array();
$this->response_headers_count = 0;
2015-02-01 20:48:05 +01:00
}
else {
break;
}
}
return $result;
}
/**
* Handle cURL errors (throw individual exceptions)
*
* We don't use constants because they are not necessary always available
* (depends of the version of libcurl linked to php)
*
* @see http://curl.haxx.se/libcurl/c/libcurl-errors.html
* @access private
* @param integer $errno cURL error code
*/
private function handleError($errno)
{
switch ($errno) {
case 78: // CURLE_REMOTE_FILE_NOT_FOUND
throw new InvalidUrlException('Resource not found');
case 6: // CURLE_COULDNT_RESOLVE_HOST
throw new InvalidUrlException('Unable to resolve hostname');
case 7: // CURLE_COULDNT_CONNECT
throw new InvalidUrlException('Unable to connect to the remote host');
case 23: // CURLE_WRITE_ERROR
throw new MaxSizeException('Maximum response size exceeded');
case 28: // CURLE_OPERATION_TIMEDOUT
throw new TimeoutException('Operation timeout');
case 35: // CURLE_SSL_CONNECT_ERROR
case 51: // CURLE_PEER_FAILED_VERIFICATION
case 58: // CURLE_SSL_CERTPROBLEM
case 60: // CURLE_SSL_CACERT
case 59: // CURLE_SSL_CIPHER
case 64: // CURLE_USE_SSL_FAILED
case 66: // CURLE_SSL_ENGINE_INITFAILED
case 77: // CURLE_SSL_CACERT_BADFILE
case 83: // CURLE_SSL_ISSUER_ERROR
throw new InvalidCertificateException('Invalid SSL certificate');
case 47: // CURLE_TOO_MANY_REDIRECTS
throw new MaxRedirectException('Maximum number of redirections reached');
case 63: // CURLE_FILESIZE_EXCEEDED
throw new MaxSizeException('Maximum response size exceeded');
default:
throw new InvalidUrlException('Unable to fetch the URL');
}
2014-10-19 20:42:31 +02:00
}
2014-05-20 20:20:27 +02:00
}