4 * This module contains the CURL-based HTTP fetcher implementation.
8 * LICENSE: See the COPYING file included in this distribution.
11 * @author JanRain, Inc. <openid@janrain.com>
12 * @copyright 2005-2008 Janrain, Inc.
13 * @license http://www.apache.org/licenses/LICENSE-2.0 Apache
19 require_once "Auth/Yadis/HTTPFetcher.php";
21 require_once "Auth/OpenID.php";
24 * A paranoid {@link Auth_Yadis_HTTPFetcher} class which uses CURL
29 class Auth_Yadis_ParanoidHTTPFetcher extends Auth_Yadis_HTTPFetcher {
30 function Auth_Yadis_ParanoidHTTPFetcher()
37 $this->headers = array();
44 function _writeHeader($ch, $header)
46 array_push($this->headers, rtrim($header));
47 return strlen($header);
53 function _writeData($ch, $data)
55 if (strlen($this->data) > 1024*Auth_OpenID_FETCHER_MAX_RESPONSE_KB) {
64 * Does this fetcher support SSL URLs?
66 function supportsSSL()
70 return in_array('https', $v['protocols']);
71 } elseif (is_string($v)) {
72 return preg_match('/OpenSSL/i', $v);
78 function get($url, $extra_headers = null)
80 if (!$this->canFetchURL($url)) {
84 $stop = time() + $this->timeout;
85 $off = $this->timeout;
89 while ($redir && ($off > 0)) {
96 "curl_init returned false; could not " .
97 "initialize for URL '%s'", $url);
101 if (defined('CURLOPT_NOSIGNAL')) {
102 curl_setopt($c, CURLOPT_NOSIGNAL, true);
105 if (!$this->allowedURL($url)) {
106 Auth_OpenID::log("Fetching URL not allowed: %s",
111 curl_setopt($c, CURLOPT_WRITEFUNCTION,
112 array(&$this, "_writeData"));
113 curl_setopt($c, CURLOPT_HEADERFUNCTION,
114 array(&$this, "_writeHeader"));
116 if ($extra_headers) {
117 curl_setopt($c, CURLOPT_HTTPHEADER, $extra_headers);
120 $cv = curl_version();
122 $curl_user_agent = 'curl/'.$cv['version'];
124 $curl_user_agent = $cv;
126 curl_setopt($c, CURLOPT_USERAGENT,
127 Auth_OpenID_USER_AGENT.' '.$curl_user_agent);
128 curl_setopt($c, CURLOPT_TIMEOUT, $off);
129 curl_setopt($c, CURLOPT_URL, $url);
133 $code = curl_getinfo($c, CURLINFO_HTTP_CODE);
135 $headers = $this->headers;
138 Auth_OpenID::log("Got no response code when fetching %s", $url);
139 Auth_OpenID::log("CURL error (%s): %s",
140 curl_errno($c), curl_error($c));
144 if (in_array($code, array(301, 302, 303, 307))) {
145 $url = $this->_findRedirect($headers);
151 $new_headers = array();
153 foreach ($headers as $header) {
154 if (strpos($header, ': ')) {
155 list($name, $value) = explode(': ', $header, 2);
156 $new_headers[$name] = $value;
161 "Successfully fetched '%s': GET response code %s",
164 return new Auth_Yadis_HTTPResponse($url, $code,
165 $new_headers, $body);
168 $off = $stop - time();
174 function post($url, $body, $extra_headers = null)
176 if (!$this->canFetchURL($url)) {
184 if (defined('CURLOPT_NOSIGNAL')) {
185 curl_setopt($c, CURLOPT_NOSIGNAL, true);
188 curl_setopt($c, CURLOPT_POST, true);
189 curl_setopt($c, CURLOPT_POSTFIELDS, $body);
190 curl_setopt($c, CURLOPT_TIMEOUT, $this->timeout);
191 curl_setopt($c, CURLOPT_URL, $url);
192 curl_setopt($c, CURLOPT_WRITEFUNCTION,
193 array(&$this, "_writeData"));
197 $code = curl_getinfo($c, CURLINFO_HTTP_CODE);
200 Auth_OpenID::log("Got no response code when fetching %s", $url);
208 $new_headers = $extra_headers;
210 foreach ($this->headers as $header) {
211 if (strpos($header, ': ')) {
212 list($name, $value) = explode(': ', $header, 2);
213 $new_headers[$name] = $value;
218 Auth_OpenID::log("Successfully fetched '%s': POST response code %s",
221 return new Auth_Yadis_HTTPResponse($url, $code,
222 $new_headers, $body);