Skip to content

Commit

Permalink
Added possibility to switch off/on SSL verify peer option using Unire…
Browse files Browse the repository at this point in the history 
…st::$verifyPeer Kong#27
  • Loading branch information
@jasir
jasir committed Dec 18, 2013
1 parent 45cb590 commit 8415527
Showing 1 changed file with 108 additions and 102 deletions.
210 changes: 108 additions & 102 deletions lib/Unirest/Unirest.php
View file
Original file line number Diff line number Diff line change
@@ -1,14 +1,20 @@
<?php

use Unirest\HttpMethod;
use Unirest\HttpResponse;
use Unirest\HttpMethod;
use Unirest\HttpResponse;

class Unirest
{
class Unirest
{

private static $socketTimeout = null;
private static $socketTimeout = null;
private static $defaultHeaders = array();

/**
* Verify SSL peer
* @var bool
*/
public static $verifyPeer = true;

/**
* Set a timeout
* @param integer $seconds timeout value in seconds
Expand Down Expand Up @@ -46,7 +52,7 @@ public static function get($url, $headers = array(), $parameters = NULL, $userna
{
return Unirest::request(HttpMethod::GET, $url, $parameters, $headers, $username, $password);
}

/**
* Send POST request to a URL
* @param string $url URL to send the POST request to
Expand All @@ -60,7 +66,7 @@ public static function post($url, $headers = array(), $body = NULL, $username =
{
return Unirest::request(HttpMethod::POST, $url, $body, $headers, $username, $password);
}

/**
* Send DELETE request to a URL
* @param string $url URL to send the DELETE request to
Expand Down Expand Up @@ -88,7 +94,7 @@ public static function put($url, $headers = array(), $body = NULL, $username = N
{
return Unirest::request(HttpMethod::PUT, $url, $body, $headers, $username, $password);
}

/**
* Send PATCH request to a URL
* @param string $url URL to send the PATCH request to
Expand All @@ -103,20 +109,20 @@ public static function patch($url, $headers = array(), $body = NULL, $username =
return Unirest::request(HttpMethod::PATCH, $url, $body, $headers, $username, $password);
}

/**
* Send a cURL request
* @param string $httpMethod HTTP method to use (based off \Unirest\HttpMethod constants)
* @param string $url URL to send the request to
* @param mixed $body request body
* @param array $headers additional headers to send
* @param string $username Basic Authentication username
* @param string $password Basic Authentication password
* @throws Exception if a cURL error occurs
* @return HttpResponse
*/
private static function request($httpMethod, $url, $body = NULL, $headers = array(), $username = NULL, $password = NULL)
{
if ($headers == NULL) $headers = array();
/**
* Send a cURL request
* @param string $httpMethod HTTP method to use (based off \Unirest\HttpMethod constants)
* @param string $url URL to send the request to
* @param mixed $body request body
* @param array $headers additional headers to send
* @param string $username Basic Authentication username
* @param string $password Basic Authentication password
* @throws Exception if a cURL error occurs
* @return HttpResponse
*/
private static function request($httpMethod, $url, $body = NULL, $headers = array(), $username = NULL, $password = NULL)
{
if ($headers == NULL) $headers = array();
$lowercaseHeaders = array();
foreach ($headers as $key => $val) {
$lowercaseHeaders[] = Unirest::getHeader($key, $val);
Expand All @@ -138,118 +144,118 @@ private static function request($httpMethod, $url, $body = NULL, $headers = arra
} else {
$url .= "?";
}

foreach ($body as $parameter => $val) {
$url .= $parameter . "=" . $val . "&";
}
$url = substr($url, 0, strlen($url) - 1);
}

curl_setopt ($ch, CURLOPT_URL, Unirest::encodeUrl($url));
curl_setopt ($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt ($ch, CURLOPT_FOLLOWLOCATION, true);
curl_setopt ($ch, CURLOPT_MAXREDIRS, 10);
curl_setopt ($ch, CURLOPT_HTTPHEADER, $lowercaseHeaders);
curl_setopt ($ch, CURLOPT_HEADER, true);
curl_setopt ($ch, CURLOPT_SSL_VERIFYPEER, true);
curl_setopt ($ch, CURLOPT_SSL_VERIFYPEER, Unirest::$verifyPeer);
curl_setopt ($ch, CURLOPT_ENCODING, ""); // If an empty string, "", is set, a header containing all supported encoding types is sent.
if (Unirest::$socketTimeout != null) {
curl_setopt ($ch, CURLOPT_TIMEOUT, Unirest::$socketTimeout);
}
if (!empty($username)) {
curl_setopt($ch, CURLOPT_USERPWD, $username . ":" . ((empty($password)) ? "" : $password));
curl_setopt($ch, CURLOPT_USERPWD, $username . ":" . ((empty($password)) ? "" : $password));
}

$response = curl_exec($ch);
$error = curl_error($ch);
if ($error) {
throw new Exception($error);
}

// Split the full response in its headers and body
$curl_info = curl_getinfo($ch);
$header_size = $curl_info["header_size"];
$header = substr($response, 0, $header_size);
$body = substr($response, $header_size);
$httpCode = $curl_info["http_code"];

return new HttpResponse($httpCode, $body, $header);
}

/**
* Ensure that a URL is encoded and safe to use with cURL
* @param string $url URL to encode
* @return string
*/
private static function encodeUrl($url)
{
$url_parsed = parse_url($url);

$scheme = $url_parsed['scheme'] . '://';
$host = $url_parsed['host'];
$port = (isset($url_parsed['port']) ? $url_parsed['port'] : null);
$path = (isset($url_parsed['path']) ? $url_parsed['path'] : null);
$query = (isset($url_parsed['query']) ? $url_parsed['query'] : null);

if ($query != null) {
parse_str($url_parsed['query'], $query_parsed);
$query = '?' . http_build_query($query_parsed);
}
if ($port && $port[0] != ":")
$port = ":" . $port;

$result = $scheme . $host . $port . $path . $query;
return $result;
}

private static function getHeader($key, $val) {
}

/**
* Ensure that a URL is encoded and safe to use with cURL
* @param string $url URL to encode
* @return string
*/
private static function encodeUrl($url)
{
$url_parsed = parse_url($url);

$scheme = $url_parsed['scheme'] . '://';
$host = $url_parsed['host'];
$port = (isset($url_parsed['port']) ? $url_parsed['port'] : null);
$path = (isset($url_parsed['path']) ? $url_parsed['path'] : null);
$query = (isset($url_parsed['query']) ? $url_parsed['query'] : null);

if ($query != null) {
parse_str($url_parsed['query'], $query_parsed);
$query = '?' . http_build_query($query_parsed);
}

if ($port && $port[0] != ":")
$port = ":" . $port;

$result = $scheme . $host . $port . $path . $query;
return $result;
}

private static function getHeader($key, $val) {
$key = trim(strtolower($key));
if ($key == "user-agent" || $key == "expect") continue;
return $key . ": " . $val;
}

}

if (!function_exists('http_chunked_decode')) {
/**
* Dechunk an http 'transfer-encoding: chunked' message
* @param string $chunk the encoded message
* @return string the decoded message
*/
function http_chunked_decode($chunk)
{
$pos = 0;
$len = strlen($chunk);
$dechunk = null;

while (($pos < $len)
&& ($chunkLenHex = substr($chunk, $pos, ($newlineAt = strpos($chunk, "\n", $pos + 1)) - $pos))) {
if (!is_hex($chunkLenHex)) {
trigger_error('Value is not properly chunk encoded', E_USER_WARNING);
return $chunk;
}

$pos = $newlineAt + 1;
$chunkLen = hexdec(rtrim($chunkLenHex, "\r\n"));
$dechunk .= substr($chunk, $pos, $chunkLen);
$pos = strpos($chunk, "\n", $pos + $chunkLen) + 1;
}
return $dechunk;
}
}

/**
* determine if a string can represent a number in hexadecimal
* @link http://uk1.php.net/ctype_xdigit
* @param string $hex
* @return boolean true if the string is a hex, otherwise false
*/
function is_hex($hex)
{
return ctype_xdigit($hex);
}
}

if (!function_exists('http_chunked_decode')) {
/**
* Dechunk an http 'transfer-encoding: chunked' message
* @param string $chunk the encoded message
* @return string the decoded message
*/
function http_chunked_decode($chunk)
{
$pos = 0;
$len = strlen($chunk);
$dechunk = null;

while (($pos < $len)
&& ($chunkLenHex = substr($chunk, $pos, ($newlineAt = strpos($chunk, "\n", $pos + 1)) - $pos))) {

if (!is_hex($chunkLenHex)) {
trigger_error('Value is not properly chunk encoded', E_USER_WARNING);
return $chunk;
}

$pos = $newlineAt + 1;
$chunkLen = hexdec(rtrim($chunkLenHex, "\r\n"));
$dechunk .= substr($chunk, $pos, $chunkLen);
$pos = strpos($chunk, "\n", $pos + $chunkLen) + 1;
}

return $dechunk;
}
}

/**
* determine if a string can represent a number in hexadecimal
* @link http://uk1.php.net/ctype_xdigit
* @param string $hex
* @return boolean true if the string is a hex, otherwise false
*/
function is_hex($hex)
{
return ctype_xdigit($hex);
}

?>

0 comments on commit 8415527

Please sign in to comment.