Update PHP Facebook SDK

This commit is contained in:
RainLoop Team 2017-02-28 23:10:47 +03:00
parent 77fb74bc4a
commit 075e184f7d
84 changed files with 9906 additions and 7761 deletions

View file

@ -23,166 +23,72 @@
*/
namespace Facebook\HttpClients;
use Facebook\FacebookSDKException;
use Facebook\Http\GraphRawResponse;
use Facebook\Exceptions\FacebookSDKException;
class FacebookStreamHttpClient implements FacebookHttpable {
class FacebookStreamHttpClient implements FacebookHttpClientInterface
{
/**
* @var FacebookStream Procedural stream wrapper as object.
*/
protected $facebookStream;
/**
* @var array The headers to be sent with the request
*/
protected $requestHeaders = array();
/**
* @var array The headers received from the response
*/
protected $responseHeaders = array();
/**
* @var int The HTTP status code returned from the server
*/
protected $responseHttpStatusCode = 0;
/**
* @var FacebookStream Procedural stream wrapper as object
*/
protected static $facebookStream;
/**
* @param FacebookStream|null Procedural stream wrapper as object
*/
public function __construct(FacebookStream $facebookStream = null)
{
self::$facebookStream = $facebookStream ?: new FacebookStream();
}
/**
* The headers we want to send with the request
*
* @param string $key
* @param string $value
*/
public function addRequestHeader($key, $value)
{
$this->requestHeaders[$key] = $value;
}
/**
* The headers returned in the response
*
* @return array
*/
public function getResponseHeaders()
{
return $this->responseHeaders;
}
/**
* The HTTP status response code
*
* @return int
*/
public function getResponseHttpStatusCode()
{
return $this->responseHttpStatusCode;
}
/**
* Sends a request to the server
*
* @param string $url The endpoint to send the request to
* @param string $method The request method
* @param array $parameters The key value pairs to be sent in the body
*
* @return string Raw response from the server
*
* @throws \Facebook\FacebookSDKException
*/
public function send($url, $method = 'GET', $parameters = array())
{
$options = array(
'http' => array(
'method' => $method,
'timeout' => 60,
'ignore_errors' => true
),
'ssl' => array(
'verify_peer' => true,
'cafile' => dirname(__FILE__) . DIRECTORY_SEPARATOR . 'fb_ca_chain_bundle.crt',
),
);
if ($parameters) {
$options['http']['content'] = http_build_query($parameters, null, '&');
$this->addRequestHeader('Content-type', 'application/x-www-form-urlencoded');
/**
* @param FacebookStream|null Procedural stream wrapper as object.
*/
public function __construct(FacebookStream $facebookStream = null)
{
$this->facebookStream = $facebookStream ?: new FacebookStream();
}
$options['http']['header'] = $this->compileHeader();
/**
* @inheritdoc
*/
public function send($url, $method, $body, array $headers, $timeOut)
{
$options = [
'http' => [
'method' => $method,
'header' => $this->compileHeader($headers),
'content' => $body,
'timeout' => $timeOut,
'ignore_errors' => true
],
'ssl' => [
'verify_peer' => true,
'verify_peer_name' => true,
'allow_self_signed' => true, // All root certificates are self-signed
'cafile' => __DIR__ . '/certs/DigiCertHighAssuranceEVRootCA.pem',
],
];
self::$facebookStream->streamContextCreate($options);
$rawResponse = self::$facebookStream->fileGetContents($url);
$rawHeaders = self::$facebookStream->getResponseHeaders();
$this->facebookStream->streamContextCreate($options);
$rawBody = $this->facebookStream->fileGetContents($url);
$rawHeaders = $this->facebookStream->getResponseHeaders();
if ($rawResponse === false || !$rawHeaders) {
throw new FacebookSDKException('Stream returned an empty response', 660);
if ($rawBody === false || !$rawHeaders) {
throw new FacebookSDKException('Stream returned an empty response', 660);
}
$rawHeaders = implode("\r\n", $rawHeaders);
return new GraphRawResponse($rawHeaders, $rawBody);
}
$this->responseHeaders = self::formatHeadersToArray($rawHeaders);
$this->responseHttpStatusCode = self::getStatusCodeFromHeader($this->responseHeaders['http_code']);
/**
* Formats the headers for use in the stream wrapper.
*
* @param array $headers The request headers.
*
* @return string
*/
public function compileHeader(array $headers)
{
$header = [];
foreach ($headers as $k => $v) {
$header[] = $k . ': ' . $v;
}
return $rawResponse;
}
/**
* Formats the headers for use in the stream wrapper
*
* @return string
*/
public function compileHeader()
{
$header = [];
foreach($this->requestHeaders as $k => $v) {
$header[] = $k . ': ' . $v;
return implode("\r\n", $header);
}
return implode("\r\n", $header);
}
/**
* Converts array of headers returned from the wrapper into
* something standard
*
* @param array $rawHeaders
*
* @return array
*/
public static function formatHeadersToArray(array $rawHeaders)
{
$headers = array();
foreach ($rawHeaders as $line) {
if (strpos($line, ':') === false) {
$headers['http_code'] = $line;
} else {
list ($key, $value) = explode(': ', $line);
$headers[$key] = $value;
}
}
return $headers;
}
/**
* Pulls out the HTTP status code from a response header
*
* @param string $header
*
* @return int
*/
public static function getStatusCodeFromHeader($header)
{
preg_match('|HTTP/\d\.\d\s+(\d+)\s+.*|', $header, $match);
return (int) $match[1];
}
}