Support Joomla!

Joomla! 1.5 Documentation

Packages

Package: Yadis

Developer Network License

The Joomla! Developer Network content is © copyright 2006 by the individual contributors and can be used in accordance with the Creative Commons License, Attribution- NonCommercial- ShareAlike 2.5
Source code for file /openid/Services/Yadis/ParanoidHTTPFetcher.php

Documentation is available at ParanoidHTTPFetcher.php

  1. <?php
  2.  
  3. /**
  4.  * This module contains the CURL-based HTTP fetcher implementation.
  5.  *
  6.  * PHP versions 4 and 5
  7.  *
  8.  * LICENSE: See the COPYING file included in this distribution.
  9.  *
  10.  * @package Yadis
  11.  * @author JanRain, Inc. <[email protected]>
  12.  * @copyright 2005 Janrain, Inc.
  13.  * @license http://www.gnu.org/copyleft/lesser.html LGPL
  14.  */
  15.  
  16. /**
  17.  * Interface import
  18.  */
  19. require_once "Services/Yadis/HTTPFetcher.php";
  20.  
  21. /**
  22.  * A paranoid {@link Services_Yadis_HTTPFetcher} class which uses CURL
  23.  * for fetching.
  24.  *
  25.  * @package Yadis
  26.  */
  27. class Services_Yadis_ParanoidHTTPFetcher extends Services_Yadis_HTTPFetcher {
  28.     function Services_Yadis_ParanoidHTTPFetcher()
  29.     {
  30.         $this->reset();
  31.     }
  32.  
  33.     function reset()
  34.     {
  35.         $this->headers = array();
  36.         $this->data = "";
  37.     }
  38.  
  39.     /**
  40.      * @access private
  41.      */
  42.     function _writeHeader($ch, $header)
  43.     {
  44.         array_push($this->headers, rtrim($header));
  45.         return strlen($header);
  46.     }
  47.  
  48.     /**
  49.      * @access private
  50.      */
  51.     function _writeData($ch, $data)
  52.     {
  53.         $this->data .= $data;
  54.         return strlen($data);
  55.     }
  56.  
  57.     function get($url, $extra_headers = null)
  58.     {
  59.         $stop = time() + $this->timeout;
  60.         $off = $this->timeout;
  61.  
  62.         $redir = true;
  63.  
  64.         while ($redir && ($off > 0)) {
  65.             $this->reset();
  66.  
  67.             $c = curl_init();
  68.             if (defined('CURLOPT_NOSIGNAL')) {
  69.                 curl_setopt($c, CURLOPT_NOSIGNAL, true);
  70.             }
  71.  
  72.             if (!$this->allowedURL($url)) {
  73.                 trigger_error(sprintf("Fetching URL not allowed: %s", $url),
  74.                               E_USER_WARNING);
  75.                 return null;
  76.             }
  77.  
  78.             curl_setopt($c, CURLOPT_WRITEFUNCTION,
  79.                         array(&$this, "_writeData"));
  80.             curl_setopt($c, CURLOPT_HEADERFUNCTION,
  81.                         array(&$this, "_writeHeader"));
  82.  
  83.             if ($extra_headers) {
  84.                 curl_setopt($c, CURLOPT_HTTPHEADER, $extra_headers);
  85.             }
  86.  
  87.             curl_setopt($c, CURLOPT_TIMEOUT, $off);
  88.             curl_setopt($c, CURLOPT_URL, $url);
  89.  
  90.             curl_exec($c);
  91.  
  92.             $code = curl_getinfo($c, CURLINFO_HTTP_CODE);
  93.             $body = $this->data;
  94.             $headers = $this->headers;
  95.  
  96.             if (!$code) {
  97.                 return null;
  98.             }
  99.  
  100.             if (in_array($code, array(301, 302, 303, 307))) {
  101.                 $url = $this->_findRedirect($headers);
  102.                 $redir = true;
  103.             } else {
  104.                 $redir = false;
  105.                 curl_close($c);
  106.  
  107.                 $new_headers = array();
  108.  
  109.                 foreach ($headers as $header) {
  110.                     if (preg_match("/:/", $header)) {
  111.                         list($name, $value) = explode(": ", $header, 2);
  112.                         $new_headers[$name] = $value;
  113.                     }
  114.                 }
  115.  
  116.                 return new Services_Yadis_HTTPResponse($url, $code,
  117.                                                     $new_headers, $body);
  118.             }
  119.  
  120.             $off = $stop - time();
  121.         }
  122.  
  123.         trigger_error(sprintf("Timed out fetching: %s", $url),
  124.                       E_USER_WARNING);
  125.  
  126.         return null;
  127.     }
  128.  
  129.     function post($url, $body)
  130.     {
  131.         $this->reset();
  132.  
  133.         if (!$this->allowedURL($url)) {
  134.             trigger_error(sprintf("Fetching URL not allowed: %s", $url),
  135.                           E_USER_WARNING);
  136.             return null;
  137.         }
  138.  
  139.         $c = curl_init();
  140.  
  141.         curl_setopt($c, CURLOPT_NOSIGNAL, true);
  142.         curl_setopt($c, CURLOPT_POST, true);
  143.         curl_setopt($c, CURLOPT_POSTFIELDS, $body);
  144.         curl_setopt($c, CURLOPT_TIMEOUT, $this->timeout);
  145.         curl_setopt($c, CURLOPT_URL, $url);
  146.         curl_setopt($c, CURLOPT_WRITEFUNCTION,
  147.                     array(&$this, "_writeData"));
  148.  
  149.         curl_exec($c);
  150.  
  151.         $code = curl_getinfo($c, CURLINFO_HTTP_CODE);
  152.  
  153.         if (!$code) {
  154.             trigger_error("No HTTP code returned", E_USER_WARNING);
  155.             return null;
  156.         }
  157.  
  158.         $body = $this->data;
  159.  
  160.         curl_close($c);
  161.  
  162.         $new_headers = array();
  163.  
  164.         foreach ($this->headers as $header) {
  165.             if (preg_match("/:/", $header)) {
  166.                 list($name, $value) = explode(": ", $header, 2);
  167.                 $new_headers[$name] = $value;
  168.             }
  169.  
  170.         }
  171.  
  172.         return new Services_Yadis_HTTPResponse($url, $code,
  173.                                                $new_headers, $body);
  174.     }
  175. }
  176.  
  177. ?>
Documentation generated on Mon, 05 Mar 2007 21:13:26 +0000 by phpDocumentor 1.3.1