Файл: sngine-v2.8/Script/includes/libs/PayPal/paypal/rest-api-sdk-php/lib/PayPal/Core/PayPalHttpConnection.php
Строк: 212
<?php
namespace PayPalCore;
use PayPalExceptionPayPalConfigurationException;
use PayPalExceptionPayPalConnectionException;
/**
* A wrapper class based on the curl extension.
* Requires the PHP curl module to be enabled.
* See for full requirements the PHP manual: http://php.net/curl
*/
class PayPalHttpConnection
{
/**
* @var PayPalHttpConfig
*/
private $httpConfig;
/**
* LoggingManager
*
* @var PayPalLoggingManager
*/
private $logger;
/**
* @var array
*/
private $responseHeaders = array();
/**
* @var bool
*/
private $skippedHttpStatusLine = false;
/**
* Default Constructor
*
* @param PayPalHttpConfig $httpConfig
* @param array $config
* @throws PayPalConfigurationException
*/
public function __construct(PayPalHttpConfig $httpConfig, array $config)
{
if (!function_exists("curl_init")) {
throw new PayPalConfigurationException("Curl module is not available on this system");
}
$this->httpConfig = $httpConfig;
$this->logger = PayPalLoggingManager::getInstance(__CLASS__);
}
/**
* Gets all Http Headers
*
* @return array
*/
private function getHttpHeaders()
{
$ret = array();
foreach ($this->httpConfig->getHeaders() as $k => $v) {
$ret[] = "$k: $v";
}
return $ret;
}
/**
* Parses the response headers for debugging.
*
* @param resource $ch
* @param string $data
* @return int
*/
protected function parseResponseHeaders($ch, $data) {
if (!$this->skippedHttpStatusLine) {
$this->skippedHttpStatusLine = true;
return strlen($data);
}
$trimmedData = trim($data);
if (strlen($trimmedData) == 0) {
return strlen($data);
}
// Added condition to ignore extra header which dont have colon ( : )
if (strpos($trimmedData, ":") == false) {
return strlen($data);
}
list($key, $value) = explode(":", $trimmedData, 2);
$key = trim($key);
$value = trim($value);
// This will skip over the HTTP Status Line and any other lines
// that don't look like header lines with values
if (strlen($key) > 0 && strlen($value) > 0) {
// This is actually a very basic way of looking at response headers
// and may miss a few repeated headers with different (appended)
// values but this should work for debugging purposes.
$this->responseHeaders[$key] = $value;
}
return strlen($data);
}
/**
* Implodes a key/value array for printing.
*
* @param array $arr
* @return string
*/
protected function implodeArray($arr) {
$retStr = '';
foreach($arr as $key => $value) {
$retStr .= $key . ': ' . $value . ', ';
}
rtrim($retStr, ', ');
return $retStr;
}
/**
* Executes an HTTP request
*
* @param string $data query string OR POST content as a string
* @return mixed
* @throws PayPalConnectionException
*/
public function execute($data)
{
//Initialize the logger
$this->logger->info($this->httpConfig->getMethod() . ' ' . $this->httpConfig->getUrl());
//Initialize Curl Options
$ch = curl_init($this->httpConfig->getUrl());
$options = $this->httpConfig->getCurlOptions();
if (empty($options[CURLOPT_HTTPHEADER])) {
unset($options[CURLOPT_HTTPHEADER]);
}
curl_setopt_array($ch, $options);
curl_setopt($ch, CURLOPT_URL, $this->httpConfig->getUrl());
curl_setopt($ch, CURLOPT_HEADER, false);
curl_setopt($ch, CURLINFO_HEADER_OUT, true);
curl_setopt($ch, CURLOPT_HTTPHEADER, $this->getHttpHeaders());
//Determine Curl Options based on Method
switch ($this->httpConfig->getMethod()) {
case 'POST':
curl_setopt($ch, CURLOPT_POST, true);
curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
break;
case 'PUT':
case 'PATCH':
case 'DELETE':
curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
break;
}
//Default Option if Method not of given types in switch case
if ($this->httpConfig->getMethod() != null) {
curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $this->httpConfig->getMethod());
}
$this->responseHeaders = array();
$this->skippedHttpStatusLine = false;
curl_setopt($ch, CURLOPT_HEADERFUNCTION, array($this, 'parseResponseHeaders'));
//Execute Curl Request
$result = curl_exec($ch);
//Retrieve Response Status
$httpStatus = curl_getinfo($ch, CURLINFO_HTTP_CODE);
//Retry if Certificate Exception
if (curl_errno($ch) == 60) {
$this->logger->info("Invalid or no certificate authority found - Retrying using bundled CA certs file");
curl_setopt($ch, CURLOPT_CAINFO, dirname(__FILE__) . '/cacert.pem');
$result = curl_exec($ch);
//Retrieve Response Status
$httpStatus = curl_getinfo($ch, CURLINFO_HTTP_CODE);
}
//Throw Exception if Retries and Certificates doenst work
if (curl_errno($ch)) {
$ex = new PayPalConnectionException(
$this->httpConfig->getUrl(),
curl_error($ch),
curl_errno($ch)
);
curl_close($ch);
throw $ex;
}
// Get Request and Response Headers
$requestHeaders = curl_getinfo($ch, CURLINFO_HEADER_OUT);
$this->logger->debug("Request Headers t: " . str_replace("rn", ", ", $requestHeaders));
$this->logger->debug(($data && $data != '' ? "Request Datatt: " . $data : "No Request Payload") . "n" . str_repeat('-', 128) . "n");
$this->logger->info("Response Status t: " . $httpStatus);
$this->logger->debug("Response Headerst: " . $this->implodeArray($this->responseHeaders));
//Close the curl request
curl_close($ch);
//More Exceptions based on HttpStatus Code
if ($httpStatus < 200 || $httpStatus >= 300) {
$ex = new PayPalConnectionException(
$this->httpConfig->getUrl(),
"Got Http response code $httpStatus when accessing {$this->httpConfig->getUrl()}.",
$httpStatus
);
$ex->setData($result);
$this->logger->error("Got Http response code $httpStatus when accessing {$this->httpConfig->getUrl()}. " . $result);
$this->logger->debug("nn" . str_repeat('=', 128) . "n");
throw $ex;
}
$this->logger->debug(($result && $result != '' ? "Response Data t: " . $result : "No Response Body") . "nn" . str_repeat('=', 128) . "n");
//Return result object
return $result;
}
}