$value ) { $k = isset( $prefix ) ? $prefix . '[' . $key . ']' : $key; if ( is_array( $value ) OR is_object( $value ) ) { Unirest::http_build_query_for_curl( $value, $new, $k ); } else { $new[$k] = $value; } } } /** * 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); } foreach (Unirest::$defaultHeaders as $key => $val) { $lowercaseHeaders[] = Unirest::getHeader($key, $val); } $lowercaseHeaders[] = "user-agent: unirest-php/1.1"; $lowercaseHeaders[] = "expect:"; $ch = curl_init(); if ($httpMethod != HttpMethod::GET) { curl_setopt ($ch, CURLOPT_CUSTOMREQUEST, $httpMethod); if( is_array($body) || $body instanceof Traversable ) { Unirest::http_build_query_for_curl($body, $postBody); curl_setopt ($ch, CURLOPT_POSTFIELDS, $postBody); } else { curl_setopt ($ch, CURLOPT_POSTFIELDS, $body); } } else if (is_array($body)) { if (strpos($url,'?') !== false) { $url .= "&"; } else { $url .= "?"; } Unirest::http_build_query_for_curl($body, $postBody); $url .= http_build_query($postBody); } 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, 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)); } $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); } private static function getArrayFromQuerystring($querystring) { $pairs = explode("&", $querystring); $vars = array(); foreach ($pairs as $pair) { $nv = explode("=", $pair); $name = $nv[0]; $value = $nv[1]; $vars[$name] = $value; } return $vars; } /** * 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) { $query = '?' . http_build_query(Unirest::getArrayFromQuerystring($url_parsed['query'])); } 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); } ?>