| New file |
|---|
| 0,0 → 1,245 |
|---|
| <?php |
| |
| /** |
| * This module contains the plain non-curl HTTP fetcher |
| * implementation. |
| * |
| * PHP versions 4 and 5 |
| * |
| * LICENSE: See the COPYING file included in this distribution. |
| * |
| * @package Yadis |
| * @author JanRain, Inc. <openid@janrain.com> |
| * @copyright 2005 Janrain, Inc. |
| * @license http://www.gnu.org/copyleft/lesser.html LGPL |
| */ |
| |
| /** |
| * Interface import |
| */ |
| require_once "Services/Yadis/HTTPFetcher.php"; |
| |
| /** |
| * This class implements a plain, hand-built socket-based fetcher |
| * which will be used in the event that CURL is unavailable. |
| * |
| * @package Yadis |
| */ |
| class Services_Yadis_PlainHTTPFetcher extends Services_Yadis_HTTPFetcher { |
| function get($url, $extra_headers = null) |
| { |
| if (!$this->allowedURL($url)) { |
| trigger_error("Bad URL scheme in url: " . $url, |
| E_USER_WARNING); |
| return null; |
| } |
| |
| $redir = true; |
| |
| $stop = time() + $this->timeout; |
| $off = $this->timeout; |
| |
| while ($redir && ($off > 0)) { |
| |
| $parts = parse_url($url); |
| |
| $specify_port = true; |
| |
| // Set a default port. |
| if (!array_key_exists('port', $parts)) { |
| $specify_port = false; |
| if ($parts['scheme'] == 'http') { |
| $parts['port'] = 80; |
| } elseif ($parts['scheme'] == 'https') { |
| $parts['port'] = 443; |
| } else { |
| trigger_error("fetcher post method doesn't support " . |
| " scheme '" . $parts['scheme'] . |
| "', no default port available", |
| E_USER_WARNING); |
| return null; |
| } |
| } |
| |
| $host = $parts['host']; |
| |
| if ($parts['scheme'] == 'https') { |
| $host = 'ssl://' . $host; |
| } |
| |
| $user_agent = "PHP Yadis Library Fetcher"; |
| |
| $headers = array( |
| "GET ".$parts['path']. |
| (array_key_exists('query', $parts) ? |
| "?".$parts['query'] : ""). |
| " HTTP/1.0", |
| "User-Agent: $user_agent", |
| "Host: ".$parts['host']. |
| ($specify_port ? ":".$parts['port'] : ""), |
| "Port: ".$parts['port']); |
| |
| $errno = 0; |
| $errstr = ''; |
| |
| if ($extra_headers) { |
| foreach ($extra_headers as $h) { |
| $headers[] = $h; |
| } |
| } |
| |
| @$sock = fsockopen($host, $parts['port'], $errno, $errstr, |
| $this->timeout); |
| if ($sock === false) { |
| return false; |
| } |
| |
| stream_set_timeout($sock, $this->timeout); |
| |
| fputs($sock, implode("\r\n", $headers) . "\r\n\r\n"); |
| |
| $data = ""; |
| while (!feof($sock)) { |
| $data .= fgets($sock, 1024); |
| } |
| |
| fclose($sock); |
| |
| // Split response into header and body sections |
| list($headers, $body) = explode("\r\n\r\n", $data, 2); |
| $headers = explode("\r\n", $headers); |
| |
| $http_code = explode(" ", $headers[0]); |
| $code = $http_code[1]; |
| |
| if (in_array($code, array('301', '302'))) { |
| $url = $this->_findRedirect($headers); |
| $redir = true; |
| } else { |
| $redir = false; |
| } |
| |
| $off = $stop - time(); |
| } |
| |
| $new_headers = array(); |
| |
| foreach ($headers as $header) { |
| if (preg_match("/:/", $header)) { |
| list($name, $value) = explode(": ", $header, 2); |
| $new_headers[$name] = $value; |
| } |
| |
| } |
| |
| return new Services_Yadis_HTTPResponse($url, $code, $new_headers, $body); |
| } |
| |
| function post($url, $body, $extra_headers = null) |
| { |
| if (!$this->allowedURL($url)) { |
| trigger_error("Bad URL scheme in url: " . $url, |
| E_USER_WARNING); |
| return null; |
| } |
| |
| $parts = parse_url($url); |
| |
| $headers = array(); |
| |
| $post_path = $parts['path']; |
| if (isset($parts['query'])) { |
| $post_path .= '?' . $parts['query']; |
| } |
| |
| $headers[] = "POST ".$post_path." HTTP/1.0"; |
| $headers[] = "Host: " . $parts['host']; |
| $headers[] = "Content-type: application/x-www-form-urlencoded"; |
| $headers[] = "Content-length: " . strval(strlen($body)); |
| |
| if ($extra_headers && |
| is_array($extra_headers)) { |
| $headers = array_merge($headers, $extra_headers); |
| } |
| |
| // Join all headers together. |
| $all_headers = implode("\r\n", $headers); |
| |
| // Add headers, two newlines, and request body. |
| $request = $all_headers . "\r\n\r\n" . $body; |
| |
| // Set a default port. |
| if (!array_key_exists('port', $parts)) { |
| if ($parts['scheme'] == 'http') { |
| $parts['port'] = 80; |
| } elseif ($parts['scheme'] == 'https') { |
| $parts['port'] = 443; |
| } else { |
| trigger_error("fetcher post method doesn't support scheme '" . |
| $parts['scheme'] . |
| "', no default port available", |
| E_USER_WARNING); |
| return null; |
| } |
| } |
| |
| if ($parts['scheme'] == 'https') { |
| $parts['host'] = sprintf("ssl://%s", $parts['host']); |
| } |
| |
| // Connect to the remote server. |
| $errno = 0; |
| $errstr = ''; |
| |
| $sock = fsockopen($parts['host'], $parts['port'], $errno, $errstr, |
| $this->timeout); |
| |
| if ($sock === false) { |
| trigger_error("Could not connect to " . $parts['host'] . |
| " port " . $parts['port'], |
| E_USER_WARNING); |
| return null; |
| } |
| |
| stream_set_timeout($sock, $this->timeout); |
| |
| // Write the POST request. |
| fputs($sock, $request); |
| |
| // Get the response from the server. |
| $response = ""; |
| while (!feof($sock)) { |
| if ($data = fgets($sock, 128)) { |
| $response .= $data; |
| } else { |
| break; |
| } |
| } |
| |
| // Split the request into headers and body. |
| list($headers, $response_body) = explode("\r\n\r\n", $response, 2); |
| |
| $headers = explode("\r\n", $headers); |
| |
| // Expect the first line of the headers data to be something |
| // like HTTP/1.1 200 OK. Split the line on spaces and take |
| // the second token, which should be the return code. |
| $http_code = explode(" ", $headers[0]); |
| $code = $http_code[1]; |
| |
| $new_headers = array(); |
| |
| foreach ($headers as $header) { |
| if (preg_match("/:/", $header)) { |
| list($name, $value) = explode(": ", $header, 2); |
| $new_headers[$name] = $value; |
| } |
| |
| } |
| |
| return new Services_Yadis_HTTPResponse($url, $code, |
| $headers, $response_body); |
| } |
| } |
| |
| ?> |