Server : Apache/2.4.6 (CentOS) OpenSSL/1.0.2k-fips PHP/7.4.20 System : Linux st2.domain.com 3.10.0-1127.10.1.el7.x86_64 #1 SMP Wed Jun 3 14:28:03 UTC 2020 x86_64 User : apache ( 48) PHP Version : 7.4.20 Disable Function : NONE Directory : /var/www/html/trader/vendor/zaloplatform/zalo-php-sdk/src/HttpClients/ |
<?php
/**
* Zalo © 2019
*
*/
namespace Zalo\HttpClients;
use Zalo\Http\GraphRawResponse;
use Zalo\Exceptions\ZaloSDKException;
use Zalo\HttpClients\ZaloCurl;
use Zalo\HttpClients\ZaloHttpClientInterface;
/**
* Class ZaloCurlHttpClient
*
* @package Zalo
*/
class ZaloCurlHttpClient implements ZaloHttpClientInterface
{
/**
* @var string The client error message
*/
protected $curlErrorMessage = '';
/**
* @var int The curl client error code
*/
protected $curlErrorCode = 0;
/**
* @var string|boolean The raw response from the server
*/
protected $rawResponse;
/**
* @var ZaloCurl Procedural curl as object
*/
protected $zaloCurl;
/**
* @param ZaloCurl|null Procedural curl as object
*/
public function __construct(ZaloCurl $zaloCurl = null)
{
$this->zaloCurl = $zaloCurl ?: new ZaloCurl();
}
/**
* @inheritdoc
*/
public function send($url, $method, $body, array $headers, $timeOut)
{
$this->openConnection($url, $method, $body, $headers, $timeOut);
$this->sendRequest();
if ($curlErrorCode = $this->zaloCurl->errno()) {
throw new ZaloSDKException($this->zaloCurl->error(), $curlErrorCode);
}
// Separate the raw headers from the raw body
list($rawHeaders, $rawBody) = $this->extractResponseHeadersAndBody();
$this->closeConnection();
return new GraphRawResponse($rawHeaders, $rawBody);
}
/**
* Opens a new curl connection.
*
* @param string $url The endpoint to send the request to.
* @param string $method The request method.
* @param string $body The body of the request.
* @param array $headers The request headers.
* @param int $timeOut The timeout in seconds for the request.
*/
public function openConnection($url, $method, $body, array $headers, $timeOut)
{
$options = [
CURLOPT_CUSTOMREQUEST => $method,
CURLOPT_HTTPHEADER => $this->compileRequestHeaders($headers),
CURLOPT_URL => $url,
CURLOPT_CONNECTTIMEOUT => 10,
CURLOPT_TIMEOUT => $timeOut,
CURLOPT_RETURNTRANSFER => true, // Follow 301 redirects
CURLOPT_HEADER => true, // Enable header processing
CURLOPT_SSL_VERIFYHOST => 2,
CURLOPT_SSL_VERIFYPEER => true,
];
if ($method !== "GET") {
$options[CURLOPT_POSTFIELDS] = $body;
}
$this->zaloCurl->init();
$this->zaloCurl->setoptArray($options);
}
/**
* Closes an existing curl connection
*/
public function closeConnection()
{
$this->zaloCurl->close();
}
/**
* Send the request and get the raw response from curl
*/
public function sendRequest()
{
$this->rawResponse = $this->zaloCurl->exec();
}
/**
* Compiles the request headers into a curl-friendly format.
*
* @param array $headers The request headers.
*
* @return array
*/
public function compileRequestHeaders(array $headers)
{
$return = [];
foreach ($headers as $key => $value) {
$return[] = $key . ': ' . $value;
}
return $return;
}
/**
* Extracts the headers and the body into a two-part array
*
* @return array
*/
public function extractResponseHeadersAndBody()
{
$parts = explode("\r\n\r\n", $this->rawResponse);
$rawBody = array_pop($parts);
$rawHeaders = implode("\r\n\r\n", $parts);
return [trim($rawHeaders), trim($rawBody)];
}
}