[Summary view] [Print] [Text view]

   1  <?php
   2  
   3  /**
   4   * Zend Framework
   5   *
   6   * LICENSE
   7   *
   8   * This source file is subject to the new BSD license that is bundled
   9   * with this package in the file LICENSE.txt.
  10   * It is also available through the world-wide-web at this URL:
  11   * http://framework.zend.com/license/new-bsd
  12   * If you did not receive a copy of the license and are unable to
  13   * obtain it through the world-wide-web, please send an email
  14   * to [email protected] so we can send you a copy immediately.
  15   *
  16   * @category   Zend
  17   * @package    Zend_Gdata
  18   * @subpackage Gdata
  19   * @copyright  Copyright (c) 2005-2010 Zend Technologies USA Inc. (http://www.zend.com)
  20   * @license    http://framework.zend.com/license/new-bsd     New BSD License
  21   * @version    $Id$
  22   */
  23  
  24  /**
  25   * @see Zend_Http_Client_Adapter_Proxy
  26   */
  27  require_once 'Zend/Http/Client/Adapter/Proxy.php';
  28  
  29  /**
  30   * Extends the proxy HTTP adapter to handle streams instead of discrete body
  31   * strings.
  32   *
  33   * @category   Zend
  34   * @package    Zend_Gdata
  35   * @subpackage Gdata
  36   * @copyright  Copyright (c) 2005-2010 Zend Technologies USA Inc. (http://www.zend.com)
  37   * @license    http://framework.zend.com/license/new-bsd     New BSD License
  38   */
  39  class Zend_Gdata_HttpAdapterStreamingProxy extends Zend_Http_Client_Adapter_Proxy
  40  {
  41      /**
  42       * The amount read from a stream source at a time.
  43       *
  44       * @var integer
  45       */
  46      const CHUNK_SIZE = 1024;
  47  
  48      /**
  49       * Send request to the proxy server with streaming support
  50       *
  51       * @param string        $method
  52       * @param Zend_Uri_Http $uri
  53       * @param string        $http_ver
  54       * @param array         $headers
  55       * @param string        $body
  56       * @return string Request as string
  57       */
  58      public function write($method, $uri, $http_ver = '1.1', $headers = array(), $body = '')
  59      {
  60          // If no proxy is set, throw an error
  61          if (! $this->config['proxy_host']) {
  62              require_once 'Zend/Http/Client/Adapter/Exception.php';
  63              throw new Zend_Http_Client_Adapter_Exception('No proxy host set!');
  64          }
  65  
  66          // Make sure we're properly connected
  67          if (! $this->socket) {
  68              require_once 'Zend/Http/Client/Adapter/Exception.php';
  69              throw new Zend_Http_Client_Adapter_Exception(
  70                  'Trying to write but we are not connected');
  71          }
  72  
  73          $host = $this->config['proxy_host'];
  74          $port = $this->config['proxy_port'];
  75  
  76          if ($this->connected_to[0] != $host || $this->connected_to[1] != $port) {
  77              require_once 'Zend/Http/Client/Adapter/Exception.php';
  78              throw new Zend_Http_Client_Adapter_Exception(
  79                  'Trying to write but we are connected to the wrong proxy ' .
  80                  'server');
  81          }
  82  
  83          // Add Proxy-Authorization header
  84          if ($this->config['proxy_user'] && ! isset($headers['proxy-authorization'])) {
  85              $headers['proxy-authorization'] = Zend_Http_Client::encodeAuthHeader(
  86                  $this->config['proxy_user'], $this->config['proxy_pass'], $this->config['proxy_auth']
  87              );
  88          }
  89  
  90          // if we are proxying HTTPS, preform CONNECT handshake with the proxy
  91          if ($uri->getScheme() == 'https' && (! $this->negotiated)) {
  92              $this->connectHandshake($uri->getHost(), $uri->getPort(), $http_ver, $headers);
  93              $this->negotiated = true;
  94          }
  95  
  96          // Save request method for later
  97          $this->method = $method;
  98  
  99          // Build request headers
 100          $request = "{$method} {$uri->__toString()} HTTP/{$http_ver}\r\n";
 101  
 102          // Add all headers to the request string
 103          foreach ($headers as $k => $v) {
 104              if (is_string($k)) $v = "$k: $v";
 105              $request .= "$v\r\n";
 106          }
 107  
 108          $request .= "\r\n";
 109  
 110          // Send the request headers
 111          if (! @fwrite($this->socket, $request)) {
 112              require_once 'Zend/Http/Client/Adapter/Exception.php';
 113              throw new Zend_Http_Client_Adapter_Exception(
 114                  'Error writing request to proxy server');
 115          }
 116  
 117          //read from $body, write to socket
 118          while ($body->hasData()) {
 119              if (! @fwrite($this->socket, $body->read(self::CHUNK_SIZE))) {
 120                  require_once 'Zend/Http/Client/Adapter/Exception.php';
 121                  throw new Zend_Http_Client_Adapter_Exception(
 122                      'Error writing request to server');
 123              }
 124          }
 125          return 'Large upload, request is not cached.';
 126      }
 127  }