File.php (10051B)
1 <?php 2 /** 3 * SimplePie 4 * 5 * A PHP-Based RSS and Atom Feed Framework. 6 * Takes the hard work out of managing a complete RSS/Atom solution. 7 * 8 * Copyright (c) 2004-2016, Ryan Parman, Sam Sneddon, Ryan McCue, and contributors 9 * All rights reserved. 10 * 11 * Redistribution and use in source and binary forms, with or without modification, are 12 * permitted provided that the following conditions are met: 13 * 14 * * Redistributions of source code must retain the above copyright notice, this list of 15 * conditions and the following disclaimer. 16 * 17 * * Redistributions in binary form must reproduce the above copyright notice, this list 18 * of conditions and the following disclaimer in the documentation and/or other materials 19 * provided with the distribution. 20 * 21 * * Neither the name of the SimplePie Team nor the names of its contributors may be used 22 * to endorse or promote products derived from this software without specific prior 23 * written permission. 24 * 25 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS 26 * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY 27 * AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDERS 28 * AND CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR 29 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR 30 * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY 31 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR 32 * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE 33 * POSSIBILITY OF SUCH DAMAGE. 34 * 35 * @package SimplePie 36 * @copyright 2004-2016 Ryan Parman, Sam Sneddon, Ryan McCue 37 * @author Ryan Parman 38 * @author Sam Sneddon 39 * @author Ryan McCue 40 * @link http://simplepie.org/ SimplePie 41 * @license http://www.opensource.org/licenses/bsd-license.php BSD License 42 */ 43 44 /** 45 * Used for fetching remote files and reading local files 46 * 47 * Supports HTTP 1.0 via cURL or fsockopen, with spotty HTTP 1.1 support 48 * 49 * This class can be overloaded with {@see SimplePie::set_file_class()} 50 * 51 * @package SimplePie 52 * @subpackage HTTP 53 * @todo Move to properly supporting RFC2616 (HTTP/1.1) 54 */ 55 class SimplePie_File 56 { 57 var $url; 58 var $useragent; 59 var $success = true; 60 var $headers = array(); 61 var $body; 62 var $status_code; 63 var $redirects = 0; 64 var $error; 65 var $method = SIMPLEPIE_FILE_SOURCE_NONE; 66 var $permanent_url; 67 68 public function __construct($url, $timeout = 10, $redirects = 5, $headers = null, $useragent = null, $force_fsockopen = false, $curl_options = array()) 69 { 70 if (class_exists('idna_convert')) 71 { 72 $idn = new idna_convert(); 73 $parsed = SimplePie_Misc::parse_url($url); 74 $url = SimplePie_Misc::compress_parse_url($parsed['scheme'], $idn->encode($parsed['authority']), $parsed['path'], $parsed['query'], NULL); 75 } 76 $this->url = $url; 77 $this->permanent_url = $url; 78 $this->useragent = $useragent; 79 if (preg_match('/^http(s)?:\/\//i', $url)) 80 { 81 if ($useragent === null) 82 { 83 $useragent = ini_get('user_agent'); 84 $this->useragent = $useragent; 85 } 86 if (!is_array($headers)) 87 { 88 $headers = array(); 89 } 90 if (!$force_fsockopen && function_exists('curl_exec')) 91 { 92 $this->method = SIMPLEPIE_FILE_SOURCE_REMOTE | SIMPLEPIE_FILE_SOURCE_CURL; 93 $fp = curl_init(); 94 $headers2 = array(); 95 foreach ($headers as $key => $value) 96 { 97 $headers2[] = "$key: $value"; 98 } 99 if (version_compare(SimplePie_Misc::get_curl_version(), '7.10.5', '>=')) 100 { 101 curl_setopt($fp, CURLOPT_ENCODING, ''); 102 } 103 curl_setopt($fp, CURLOPT_URL, $url); 104 curl_setopt($fp, CURLOPT_HEADER, 1); 105 curl_setopt($fp, CURLOPT_RETURNTRANSFER, 1); 106 curl_setopt($fp, CURLOPT_FAILONERROR, 1); 107 curl_setopt($fp, CURLOPT_TIMEOUT, $timeout); 108 curl_setopt($fp, CURLOPT_CONNECTTIMEOUT, $timeout); 109 curl_setopt($fp, CURLOPT_REFERER, $url); 110 curl_setopt($fp, CURLOPT_USERAGENT, $useragent); 111 curl_setopt($fp, CURLOPT_HTTPHEADER, $headers2); 112 foreach ($curl_options as $curl_param => $curl_value) { 113 curl_setopt($fp, $curl_param, $curl_value); 114 } 115 116 $this->headers = curl_exec($fp); 117 if (curl_errno($fp) === 23 || curl_errno($fp) === 61) 118 { 119 curl_setopt($fp, CURLOPT_ENCODING, 'none'); 120 $this->headers = curl_exec($fp); 121 } 122 if (curl_errno($fp)) 123 { 124 $this->error = 'cURL error ' . curl_errno($fp) . ': ' . curl_error($fp); 125 $this->success = false; 126 } 127 else 128 { 129 // Use the updated url provided by curl_getinfo after any redirects. 130 if ($info = curl_getinfo($fp)) { 131 $this->url = $info['url']; 132 } 133 curl_close($fp); 134 $this->headers = SimplePie_HTTP_Parser::prepareHeaders($this->headers, $info['redirect_count'] + 1); 135 $parser = new SimplePie_HTTP_Parser($this->headers); 136 if ($parser->parse()) 137 { 138 $this->headers = $parser->headers; 139 $this->body = trim($parser->body); 140 $this->status_code = $parser->status_code; 141 if ((in_array($this->status_code, array(300, 301, 302, 303, 307)) || $this->status_code > 307 && $this->status_code < 400) && isset($this->headers['location']) && $this->redirects < $redirects) 142 { 143 $this->redirects++; 144 $location = SimplePie_Misc::absolutize_url($this->headers['location'], $url); 145 $previousStatusCode = $this->status_code; 146 $this->__construct($location, $timeout, $redirects, $headers, $useragent, $force_fsockopen, $curl_options); 147 $this->permanent_url = ($previousStatusCode == 301) ? $location : $url; 148 return; 149 } 150 } 151 } 152 } 153 else 154 { 155 $this->method = SIMPLEPIE_FILE_SOURCE_REMOTE | SIMPLEPIE_FILE_SOURCE_FSOCKOPEN; 156 $url_parts = parse_url($url); 157 $socket_host = $url_parts['host']; 158 if (isset($url_parts['scheme']) && strtolower($url_parts['scheme']) === 'https') 159 { 160 $socket_host = "ssl://$url_parts[host]"; 161 $url_parts['port'] = 443; 162 } 163 if (!isset($url_parts['port'])) 164 { 165 $url_parts['port'] = 80; 166 } 167 $fp = @fsockopen($socket_host, $url_parts['port'], $errno, $errstr, $timeout); 168 if (!$fp) 169 { 170 $this->error = 'fsockopen error: ' . $errstr; 171 $this->success = false; 172 } 173 else 174 { 175 stream_set_timeout($fp, $timeout); 176 if (isset($url_parts['path'])) 177 { 178 if (isset($url_parts['query'])) 179 { 180 $get = "$url_parts[path]?$url_parts[query]"; 181 } 182 else 183 { 184 $get = $url_parts['path']; 185 } 186 } 187 else 188 { 189 $get = '/'; 190 } 191 $out = "GET $get HTTP/1.1\r\n"; 192 $out .= "Host: $url_parts[host]\r\n"; 193 $out .= "User-Agent: $useragent\r\n"; 194 if (extension_loaded('zlib')) 195 { 196 $out .= "Accept-Encoding: x-gzip,gzip,deflate\r\n"; 197 } 198 199 if (isset($url_parts['user']) && isset($url_parts['pass'])) 200 { 201 $out .= "Authorization: Basic " . base64_encode("$url_parts[user]:$url_parts[pass]") . "\r\n"; 202 } 203 foreach ($headers as $key => $value) 204 { 205 $out .= "$key: $value\r\n"; 206 } 207 $out .= "Connection: Close\r\n\r\n"; 208 fwrite($fp, $out); 209 210 $info = stream_get_meta_data($fp); 211 212 $this->headers = ''; 213 while (!$info['eof'] && !$info['timed_out']) 214 { 215 $this->headers .= fread($fp, 1160); 216 $info = stream_get_meta_data($fp); 217 } 218 if (!$info['timed_out']) 219 { 220 $parser = new SimplePie_HTTP_Parser($this->headers); 221 if ($parser->parse()) 222 { 223 $this->headers = $parser->headers; 224 $this->body = $parser->body; 225 $this->status_code = $parser->status_code; 226 if ((in_array($this->status_code, array(300, 301, 302, 303, 307)) || $this->status_code > 307 && $this->status_code < 400) && isset($this->headers['location']) && $this->redirects < $redirects) 227 { 228 $this->redirects++; 229 $location = SimplePie_Misc::absolutize_url($this->headers['location'], $url); 230 $previousStatusCode = $this->status_code; 231 $this->__construct($location, $timeout, $redirects, $headers, $useragent, $force_fsockopen, $curl_options); 232 $this->permanent_url = ($previousStatusCode == 301) ? $location : $url; 233 return; 234 } 235 if (isset($this->headers['content-encoding'])) 236 { 237 // Hey, we act dumb elsewhere, so let's do that here too 238 switch (strtolower(trim($this->headers['content-encoding'], "\x09\x0A\x0D\x20"))) 239 { 240 case 'gzip': 241 case 'x-gzip': 242 $decoder = new SimplePie_gzdecode($this->body); 243 if (!$decoder->parse()) 244 { 245 $this->error = 'Unable to decode HTTP "gzip" stream'; 246 $this->success = false; 247 } 248 else 249 { 250 $this->body = trim($decoder->data); 251 } 252 break; 253 254 case 'deflate': 255 if (($decompressed = gzinflate($this->body)) !== false) 256 { 257 $this->body = $decompressed; 258 } 259 else if (($decompressed = gzuncompress($this->body)) !== false) 260 { 261 $this->body = $decompressed; 262 } 263 else if (function_exists('gzdecode') && ($decompressed = gzdecode($this->body)) !== false) 264 { 265 $this->body = $decompressed; 266 } 267 else 268 { 269 $this->error = 'Unable to decode HTTP "deflate" stream'; 270 $this->success = false; 271 } 272 break; 273 274 default: 275 $this->error = 'Unknown content coding'; 276 $this->success = false; 277 } 278 } 279 } 280 } 281 else 282 { 283 $this->error = 'fsocket timed out'; 284 $this->success = false; 285 } 286 fclose($fp); 287 } 288 } 289 } 290 else 291 { 292 $this->method = SIMPLEPIE_FILE_SOURCE_LOCAL | SIMPLEPIE_FILE_SOURCE_FILE_GET_CONTENTS; 293 if (empty($url) || !($this->body = trim(file_get_contents($url)))) 294 { 295 $this->error = 'file_get_contents could not read the file'; 296 $this->success = false; 297 } 298 } 299 } 300 }