EVOLUTION-MANAGER
Edit File: Curl.php
<?php defined("ABSPATH") or die(""); /* * Copyright 2014 Google Inc. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ /** * Curl based implementation of Duplicator_Pro_Google_IO. * * @author Stuart Langley <slangley@google.com> */ if (!class_exists('Duplicator_Pro_Google_Client')) { require_once dirname(__FILE__) . '/../autoload.php'; } class Duplicator_Pro_Google_IO_Curl extends Duplicator_Pro_Google_IO_Abstract { // cURL hex representation of version 7.30.0 const NO_QUIRK_VERSION = 0x071E00; private $options = array(); /** @var bool $disableProxyWorkaround */ private $disableProxyWorkaround; public function __construct(Duplicator_Pro_Google_Client $client) { if (!extension_loaded('curl')) { $error = 'The cURL IO handler requires the cURL extension to be enabled'; $client->getLogger()->critical($error); throw new Duplicator_Pro_Google_IO_Exception($error); } parent::__construct($client); $this->disableProxyWorkaround = $this->client->getClassConfig( 'Duplicator_Pro_Google_IO_Curl', 'disable_proxy_workaround' ); } /** * Execute an HTTP Request * * @param Duplicator_Pro_Google_Http_Request $request the http request to be executed * @return array containing response headers, body, and http code * @throws Duplicator_Pro_Google_IO_Exception on curl or IO error */ public function executeRequest(Duplicator_Pro_Google_Http_Request $request) { $curl = curl_init(); if ($request->getPostBody()) { curl_setopt($curl, CURLOPT_POSTFIELDS, $request->getPostBody()); } $requestHeaders = $request->getRequestHeaders(); if ($requestHeaders && is_array($requestHeaders)) { $curlHeaders = array(); foreach ($requestHeaders as $k => $v) { $curlHeaders[] = "$k: $v"; } curl_setopt($curl, CURLOPT_HTTPHEADER, $curlHeaders); } curl_setopt($curl, CURLOPT_URL, $request->getUrl()); curl_setopt($curl, CURLOPT_CUSTOMREQUEST, $request->getRequestMethod()); curl_setopt($curl, CURLOPT_USERAGENT, $request->getUserAgent()); curl_setopt($curl, CURLOPT_FOLLOWLOCATION, false); curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, true); // The SSL version will be determined by the underlying library // @see https://github.com/google/google-api-php-client/pull/644 //curl_setopt($curl, CURLOPT_SSLVERSION, 1); curl_setopt($curl, CURLOPT_RETURNTRANSFER, true); curl_setopt($curl, CURLOPT_HEADER, true); if ($request->canGzip()) { curl_setopt($curl, CURLOPT_ENCODING, 'gzip,deflate'); } $options = $this->client->getClassConfig('Duplicator_Pro_Google_IO_Curl', 'options'); if (is_array($options)) { $this->setOptions($options); } foreach ($this->options as $key => $var) { curl_setopt($curl, $key, $var); } if (!isset($this->options[CURLOPT_CAINFO])) { curl_setopt($curl, CURLOPT_CAINFO, dirname(__FILE__) . '/cacerts.pem'); } $this->client->getLogger()->debug( 'cURL request', array( 'url' => $request->getUrl(), 'method' => $request->getRequestMethod(), 'headers' => $requestHeaders, 'body' => $request->getPostBody() ) ); $response = curl_exec($curl); /* error_log('--------------------'); error_log('$response :'.var_export($response, true)); error_log('--------------------'); */ if ($response === false) { $error = curl_error($curl); $code = curl_errno($curl); $map = $this->client->getClassConfig('Duplicator_Pro_Google_IO_Exception', 'retry_map'); /* error_log('==========================='); error_log('response false: '.$code.' '.$error); error_log('==========================='); */ $this->client->getLogger()->error('cURL ' . $error); throw new Duplicator_Pro_Google_IO_Exception($error, $code, null, $map); } $headerSize = curl_getinfo($curl, CURLINFO_HEADER_SIZE); list($responseHeaders, $responseBody) = $this->parseHttpResponse($response, $headerSize); $responseCode = curl_getinfo($curl, CURLINFO_HTTP_CODE); $this->client->getLogger()->debug( 'cURL response', array( 'code' => $responseCode, 'headers' => $responseHeaders, 'body' => $responseBody, ) ); return array($responseBody, $responseHeaders, $responseCode); } /** * Set options that update the transport implementation's behavior. * @param $options */ public function setOptions($options) { $this->options = $options + $this->options; } /** * Set the maximum request time in seconds. * @param $timeout in seconds */ public function setTimeout($timeout) { // Since this timeout is really for putting a bound on the time // we'll set them both to the same. If you need to specify a longer // CURLOPT_TIMEOUT, or a higher CONNECTTIMEOUT, the best thing to // do is use the setOptions method for the values individually. $this->options[CURLOPT_CONNECTTIMEOUT] = $timeout; $this->options[CURLOPT_TIMEOUT] = $timeout; } /** * Get the maximum request time in seconds. * @return timeout in seconds */ public function getTimeout() { return $this->options[CURLOPT_TIMEOUT]; } /** * Test for the presence of a cURL header processing bug * * {@inheritDoc} * * @return boolean */ protected function needsQuirk() { if ($this->disableProxyWorkaround) { return false; } $ver = curl_version(); $versionNum = $ver['version_number']; return $versionNum < Duplicator_Pro_Google_IO_Curl::NO_QUIRK_VERSION; } }