Файл: sngine-v2.8/Script/includes/libs/Embed/Http/CurlResult.php
Строк: 94
<?php
namespace EmbedHttp;
/**
* Class to dispatch urls using curl and get the result.
*/
class CurlResult
{
protected $resource;
protected $body;
protected $headers = [];
protected $onHeader;
protected $onBody;
protected $data;
/**
* Creates a new response.
*
* @param resource $resource The curl resource
*/
public function __construct($resource)
{
$this->resource = $resource;
$this->data = (object) [];
curl_setopt($this->resource, CURLOPT_HEADERFUNCTION, [$this, 'headerCallback']);
curl_setopt($this->resource, CURLOPT_WRITEFUNCTION, [$this, 'writeCallback']);
}
/**
* Returns the response result.
*/
public function getResult()
{
$result = curl_getinfo($this->resource);
if (curl_errno($this->resource)) {
$result['error'] = curl_error($this->resource);
}
return [
'url' => isset($result['url']) ? $result['url'] : null,
'statusCode' => isset($result['http_code']) ? $result['http_code'] : null,
'contentType' => isset($result['content_type']) ? $result['content_type'] : null,
'info' => $result,
'content' => $this->body,
'headers' => $this->headers,
'data' => $this->data,
];
}
/**
* Returns the resource.
*
* @return resource
*/
public function getResource()
{
return $this->resource;
}
/**
* Callback used on receive a header.
*
* @param callable $callback
*/
public function onHeader(callable $callback)
{
$this->onHeader = $callback;
}
/**
* Callback used on receive a body string portion.
*
* @param callable $callback
*/
public function onBody(callable $callback)
{
$this->onBody = $callback;
}
/**
* Callback used to collect the headers.
*
* @param resource $resource
* @param string $string
*
* @return int
*/
public function headerCallback($resource, $string)
{
if (!strpos($string, ':')) {
return strlen($string);
}
list($name, $value) = array_map('trim', explode(':', $string, 2));
$name = strtolower($name);
if (!isset($this->headers[$name])) {
$this->headers[$name] = [];
}
$this->headers[$name][] = $value;
if ($this->onHeader === null || call_user_func($this->onHeader, $name, $value, $this->data) !== false) {
return strlen($string);
}
return -1;
}
/**
* Callback used to get the body content.
*
* @param resource $resource
* @param string $string
*
* @return int
*/
public function writeCallback($resource, $string)
{
$this->body .= $string;
if ($this->onBody === null || call_user_func($this->onBody, $this->body, $this->data) !== false) {
return strlen($string);
}
//Cancel
$this->body = null;
return -1;
}
}