ikan Uploader :
Directory : /home/ni05r7l36tus/www/poojajewellersbbsr.com/src/src/
Upload File : |
| Current File : //home/ni05r7l36tus/www/poojajewellersbbsr.com/src/src/Request.php |
<?php
namespace Razorpay\Api;
use Requests;
use Exception;
use Requests_Hooks;
use Razorpay\Api\Errors;
use Razorpay\Api\Errors\ErrorCode;
// Available since PHP 5.5.19 and 5.6.3
// https://git.io/fAMVS | https://secure.php.net/manual/en/curl.constants.php
if (defined('CURL_SSLVERSION_TLSv1_1') === false)
{
define('CURL_SSLVERSION_TLSv1_1', 5);
}
/**
* Request class to communicate to the request libarary
*/
class Request
{
public static $OAUTH = 'oauth';
public static $API = 'api';
protected $authType;
public function __construct($authType = null)
{
$this->authType = $authType ?? self::$API;
}
/**
* Headers to be sent with every http request to the API
* @var array
*/
protected static $headers = array(
'Razorpay-API' => 1
);
/**
* Fires a request to the API
* @param string $method HTTP Verb
* @param string $url Relative URL for the request
* @param array $data Data to be passed along the request
* @param array $additionHeader headers to be passed along the request
* @param string $apiVersion version to be passed along the request
* @return array Response data in array format. Not meant
* to be used directly
*/
public function request($method, $url, $data = array(), $apiVersion = "v1")
{
if($this->authType == self::$OAUTH){
$url = OAuth::getFullUrl($url, $apiVersion);
}else{
$url = Api::getFullUrl($url, $apiVersion);
}
$hooks = new Requests_Hooks();
$hooks->register('curl.before_send', array($this, 'setCurlSslOpts'));
$options = array(
'hook' => $hooks,
'timeout' => 60
);
$headers = $this->getRequestHeaders();
if(!Api::getToken()){
$options['auth'] = array(Api::getKey(), Api::getSecret());
}
if(Api::getToken()){
$token = Api::getToken();
$headers['Authorization'] = "Bearer $token";
}
$response = Requests::request($url, $headers, $data, $method, $options);
$this->checkErrors($response);
return json_decode($response->body, true);
}
public function setCurlSslOpts($curl)
{
curl_setopt($curl, CURLOPT_SSLVERSION, CURL_SSLVERSION_TLSv1_1);
}
/**
* Adds an additional header to all API requests
* @param string $key Header key
* @param string $value Header value
* @return null
*/
public static function addHeader($key, $value)
{
self::$headers[$key] = $value;
}
/**
* Removes an additional header from all API requests
* @param string $key Header key
* @return null
*/
public static function removeHeader($key){
unset(self::$headers[$key]);
}
/**
* Returns all headers attached so far
* @return array headers
*/
public static function getHeaders()
{
return self::$headers;
}
/**
* Process the statusCode of the response and throw exception if necessary
* @param Object $response The response object returned by Requests
*/
protected function checkErrors($response)
{
$body = $response->body;
$httpStatusCode = $response->status_code;
try
{
$body = json_decode($response->body, true);
}
catch (Exception $e)
{
$this->throwServerError($body, $httpStatusCode);
}
if (($httpStatusCode < 200) or
($httpStatusCode >= 300))
{
$this->processError($body, $httpStatusCode, $response);
}
}
protected function processError($body, $httpStatusCode, $response)
{
if(isset($body['error']) && $this->authType == self::$OAUTH){
if($httpStatusCode >= 400 && $httpStatusCode < 500){
$body['error']['code'] = ErrorCode::BAD_REQUEST_ERROR;
}else if($httpStatusCode >= 500){
$body['error']['code'] = ErrorCode::SERVER_ERROR;
}
}
$this->verifyErrorFormat($body, $httpStatusCode);
$code = $body['error']['code'];
// We are basically converting the error code to the Error class name
// Replace underscores with space
// Lowercase the words, capitalize first letter of each word
// Remove spaces
$error = str_replace('_', ' ', $code);
$error = ucwords(strtolower($error));
$error = str_replace(' ', '', $error);
// Add namespace
// This is the fully qualified error class name
$error = __NAMESPACE__.'\Errors\\' . $error;
$description = $body['error']['description'];
$field = null;
if (isset($body['error']['field']))
{
$field = $body['error']['field'];
// Create an instance of the error and then throw it
throw new $error($description, $code, $httpStatusCode, $field);
}
throw new $error($description, $code, $httpStatusCode);
}
protected function throwServerError($body, $httpStatusCode)
{
$description = "The server did not send back a well-formed response. " . PHP_EOL .
"Server Response: $body";
throw new Errors\ServerError(
$description,
ErrorCode::SERVER_ERROR,
$httpStatusCode);
}
protected function getRequestHeaders()
{
$uaHeader = array(
'User-Agent' => $this->constructUa()
);
$headers = array_merge(self::$headers, $uaHeader);
return $headers;
}
protected function constructUa()
{
$ua = 'Razorpay/v1 PHPSDK/' . Api::VERSION . ' PHP/' . phpversion();
$ua .= ' ' . $this->getAppDetailsUa();
return $ua;
}
protected function getAppDetailsUa()
{
$appsDetails = Api::$appsDetails;
$appsDetailsUa = '';
foreach ($appsDetails as $app)
{
if ((isset($app['title'])) and (is_string($app['title'])))
{
$appUa = $app['title'];
if ((isset($app['version'])) and (is_scalar($app['version'])))
{
$appUa .= '/' . $app['version'];
}
$appsDetailsUa .= $appUa . ' ';
}
}
return $appsDetailsUa;
}
/**
* Verifies error is in proper format. If not then
* throws ServerErrorException
*
* @param array $body
* @param int $httpStatusCode
* @return void
*/
protected function verifyErrorFormat($body, $httpStatusCode)
{
if (is_array($body) === false)
{
$this->throwServerError($body, $httpStatusCode);
}
if ((isset($body['error']) === false) or
(isset($body['error']['code']) === false))
{
$this->throwServerError($body, $httpStatusCode);
}
$code = $body['error']['code'];
if (Errors\ErrorCode::exists($code) === false)
{
$this->throwServerError($body, $httpStatusCode);
}
}
}
........