SimplePie_File

Used for fetching remote files and reading local files.

Defined (1)

The class is defined in the following location(s).

/wp-includes/SimplePie/File.php  
  1. class SimplePie_File 
  2. { 
  3.     var $url; 
  4.     var $useragent; 
  5.     var $success = true; 
  6.     var $headers = array(); 
  7.     var $body; 
  8.     var $status_code; 
  9.     var $redirects = 0; 
  10.     var $error; 
  11.     var $method = SIMPLEPIE_FILE_SOURCE_NONE; 
  12.  
  13.     public function __construct($url, $timeout = 10, $redirects = 5, $headers = null, $useragent = null, $force_fsockopen = false) 
  14.     { 
  15.         if (class_exists('idna_convert')) 
  16.         { 
  17.             $idn = new idna_convert(); 
  18.             $parsed = SimplePie_Misc::parse_url($url); 
  19.             $url = SimplePie_Misc::compress_parse_url($parsed['scheme'], $idn->encode($parsed['authority']), $parsed['path'], $parsed['query'], $parsed['fragment']); 
  20.         } 
  21.         $this->url = $url; 
  22.         $this->useragent = $useragent; 
  23.         if (preg_match('/^http(s)?:\/\//i', $url)) 
  24.         { 
  25.             if ($useragent === null) 
  26.             { 
  27.                 $useragent = ini_get('user_agent'); 
  28.                 $this->useragent = $useragent; 
  29.             } 
  30.             if (!is_array($headers)) 
  31.             { 
  32.                 $headers = array(); 
  33.             } 
  34.             if (!$force_fsockopen && function_exists('curl_exec')) 
  35.             { 
  36.                 $this->method = SIMPLEPIE_FILE_SOURCE_REMOTE | SIMPLEPIE_FILE_SOURCE_CURL; 
  37.                 $fp = curl_init(); 
  38.                 $headers2 = array(); 
  39.                 foreach ($headers as $key => $value) 
  40.                 { 
  41.                     $headers2[] = "$key: $value"; 
  42.                 } 
  43.                 if (version_compare(SimplePie_Misc::get_curl_version(), '7.10.5', '>=')) 
  44.                 { 
  45.                     curl_setopt($fp, CURLOPT_ENCODING, ''); 
  46.                 } 
  47.                 curl_setopt($fp, CURLOPT_URL, $url); 
  48.                 curl_setopt($fp, CURLOPT_HEADER, 1); 
  49.                 curl_setopt($fp, CURLOPT_RETURNTRANSFER, 1); 
  50.                 curl_setopt($fp, CURLOPT_TIMEOUT, $timeout); 
  51.                 curl_setopt($fp, CURLOPT_CONNECTTIMEOUT, $timeout); 
  52.                 curl_setopt($fp, CURLOPT_REFERER, $url); 
  53.                 curl_setopt($fp, CURLOPT_USERAGENT, $useragent); 
  54.                 curl_setopt($fp, CURLOPT_HTTPHEADER, $headers2); 
  55.                 if (!ini_get('open_basedir') && !ini_get('safe_mode') && version_compare(SimplePie_Misc::get_curl_version(), '7.15.2', '>=')) 
  56.                 { 
  57.                     curl_setopt($fp, CURLOPT_FOLLOWLOCATION, 1); 
  58.                     curl_setopt($fp, CURLOPT_MAXREDIRS, $redirects); 
  59.                 } 
  60.  
  61.                 $this->headers = curl_exec($fp); 
  62.                 if (curl_errno($fp) === 23 || curl_errno($fp) === 61) 
  63.                 { 
  64.                     curl_setopt($fp, CURLOPT_ENCODING, 'none'); 
  65.                     $this->headers = curl_exec($fp); 
  66.                 } 
  67.                 if (curl_errno($fp)) 
  68.                 { 
  69.                     $this->error = 'cURL error ' . curl_errno($fp) . ': ' . curl_error($fp); 
  70.                     $this->success = false; 
  71.                 } 
  72.                 else 
  73.                 { 
  74.                     $info = curl_getinfo($fp); 
  75.                     curl_close($fp); 
  76.                     $this->headers = explode("\r\n\r\n", $this->headers, $info['redirect_count'] + 1); 
  77.                     $this->headers = array_pop($this->headers); 
  78.                     $parser = new SimplePie_HTTP_Parser($this->headers); 
  79.                     if ($parser->parse()) 
  80.                     { 
  81.                         $this->headers = $parser->headers; 
  82.                         $this->body = $parser->body; 
  83.                         $this->status_code = $parser->status_code; 
  84.                         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) 
  85.                         { 
  86.                             $this->redirects++; 
  87.                             $location = SimplePie_Misc::absolutize_url($this->headers['location'], $url); 
  88.                             return $this->__construct($location, $timeout, $redirects, $headers, $useragent, $force_fsockopen); 
  89.                         } 
  90.                     } 
  91.                 } 
  92.             } 
  93.             else 
  94.             { 
  95.                 $this->method = SIMPLEPIE_FILE_SOURCE_REMOTE | SIMPLEPIE_FILE_SOURCE_FSOCKOPEN; 
  96.                 $url_parts = parse_url($url); 
  97.                 $socket_host = $url_parts['host']; 
  98.                 if (isset($url_parts['scheme']) && strtolower($url_parts['scheme']) === 'https') 
  99.                 { 
  100.                     $socket_host = "ssl://$url_parts[host]"; 
  101.                     $url_parts['port'] = 443; 
  102.                 } 
  103.                 if (!isset($url_parts['port'])) 
  104.                 { 
  105.                     $url_parts['port'] = 80; 
  106.                 } 
  107.                 $fp = @fsockopen($socket_host, $url_parts['port'], $errno, $errstr, $timeout); 
  108.                 if (!$fp) 
  109.                 { 
  110.                     $this->error = 'fsockopen error: ' . $errstr; 
  111.                     $this->success = false; 
  112.                 } 
  113.                 else 
  114.                 { 
  115.                     stream_set_timeout($fp, $timeout); 
  116.                     if (isset($url_parts['path'])) 
  117.                     { 
  118.                         if (isset($url_parts['query'])) 
  119.                         { 
  120.                             $get = "$url_parts[path]?$url_parts[query]"; 
  121.                         } 
  122.                         else 
  123.                         { 
  124.                             $get = $url_parts['path']; 
  125.                         } 
  126.                     } 
  127.                     else 
  128.                     { 
  129.                         $get = '/'; 
  130.                     } 
  131.                     $out = "GET $get HTTP/1.1\r\n"; 
  132.                     $out .= "Host: $url_parts[host]\r\n"; 
  133.                     $out .= "User-Agent: $useragent\r\n"; 
  134.                     if (extension_loaded('zlib')) 
  135.                     { 
  136.                         $out .= "Accept-Encoding: x-gzip, gzip, deflate\r\n"; 
  137.                     } 
  138.  
  139.                     if (isset($url_parts['user']) && isset($url_parts['pass'])) 
  140.                     { 
  141.                         $out .= "Authorization: Basic " . base64_encode("$url_parts[user]:$url_parts[pass]") . "\r\n"; 
  142.                     } 
  143.                     foreach ($headers as $key => $value) 
  144.                     { 
  145.                         $out .= "$key: $value\r\n"; 
  146.                     } 
  147.                     $out .= "Connection: Close\r\n\r\n"; 
  148.                     fwrite($fp, $out); 
  149.  
  150.                     $info = stream_get_meta_data($fp); 
  151.  
  152.                     $this->headers = ''; 
  153.                     while (!$info['eof'] && !$info['timed_out']) 
  154.                     { 
  155.                         $this->headers .= fread($fp, 1160); 
  156.                         $info = stream_get_meta_data($fp); 
  157.                     } 
  158.                     if (!$info['timed_out']) 
  159.                     { 
  160.                         $parser = new SimplePie_HTTP_Parser($this->headers); 
  161.                         if ($parser->parse()) 
  162.                         { 
  163.                             $this->headers = $parser->headers; 
  164.                             $this->body = $parser->body; 
  165.                             $this->status_code = $parser->status_code; 
  166.                             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) 
  167.                             { 
  168.                                 $this->redirects++; 
  169.                                 $location = SimplePie_Misc::absolutize_url($this->headers['location'], $url); 
  170.                                 return $this->__construct($location, $timeout, $redirects, $headers, $useragent, $force_fsockopen); 
  171.                             } 
  172.                             if (isset($this->headers['content-encoding'])) 
  173.                             { 
  174.                                 // Hey, we act dumb elsewhere, so let's do that here too 
  175.                                 switch (strtolower(trim($this->headers['content-encoding'], "\x09\x0A\x0D\x20"))) 
  176.                                 { 
  177.                                     case 'gzip': 
  178.                                     case 'x-gzip': 
  179.                                         $decoder = new SimplePie_gzdecode($this->body); 
  180.                                         if (!$decoder->parse()) 
  181.                                         { 
  182.                                             $this->error = 'Unable to decode HTTP "gzip" stream'; 
  183.                                             $this->success = false; 
  184.                                         } 
  185.                                         else 
  186.                                         { 
  187.                                             $this->body = $decoder->data; 
  188.                                         } 
  189.                                         break; 
  190.  
  191.                                     case 'deflate': 
  192.                                         if (($decompressed = gzinflate($this->body)) !== false) 
  193.                                         { 
  194.                                             $this->body = $decompressed; 
  195.                                         } 
  196.                                         else if (($decompressed = gzuncompress($this->body)) !== false) 
  197.                                         { 
  198.                                             $this->body = $decompressed; 
  199.                                         } 
  200.                                         else if (function_exists('gzdecode') && ($decompressed = gzdecode($this->body)) !== false) 
  201.                                         { 
  202.                                             $this->body = $decompressed; 
  203.                                         } 
  204.                                         else 
  205.                                         { 
  206.                                             $this->error = 'Unable to decode HTTP "deflate" stream'; 
  207.                                             $this->success = false; 
  208.                                         } 
  209.                                         break; 
  210.  
  211.                                     default: 
  212.                                         $this->error = 'Unknown content coding'; 
  213.                                         $this->success = false; 
  214.                                 } 
  215.                             } 
  216.                         } 
  217.                     } 
  218.                     else 
  219.                     { 
  220.                         $this->error = 'fsocket timed out'; 
  221.                         $this->success = false; 
  222.                     } 
  223.                     fclose($fp); 
  224.                 } 
  225.             } 
  226.         } 
  227.         else 
  228.         { 
  229.             $this->method = SIMPLEPIE_FILE_SOURCE_LOCAL | SIMPLEPIE_FILE_SOURCE_FILE_GET_CONTENTS; 
  230.             if (!$this->body = file_get_contents($url)) 
  231.             { 
  232.                 $this->error = 'file_get_contents could not read the file'; 
  233.                 $this->success = false; 
  234.             } 
  235.         } 
  236.     } 
  237. }