Zend/Gdata/HttpAdapterStreamingSocket.php

   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 license@zend.com 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
  22  */
  23
  24 /**
  25  * @see Zend_Http_Client_Adapter_Socket
  26  */
  27 require_once 'Zend/Http/Client/Adapter/Socket.php';
  28
  29 /**
  30  * Extends the default 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_HttpAdapterStreamingSocket extends Zend_Http_Client_Adapter_Socket
  40 {
  41
  42     /**
  43      * The amount read from a stream source at a time.
  44      *
  45      * @var integer
  46      */
  47     const CHUNK_SIZE = 1024;
  48
  49     /**
  50      * Send request to the remote server with streaming support.
  51      *
  52      * @param string        $method
  53      * @param Zend_Uri_Http $uri
  54      * @param string        $http_ver
  55      * @param array         $headers
  56      * @param string        $body
  57      * @return string Request as string
  58      */
  59     public function write($method, $uri, $http_ver = '1.1', $headers = array(),
  60         $body = '')
  61     {
  62         // Make sure we're properly connected
  63         if (! $this->socket) {
  64             require_once 'Zend/Http/Client/Adapter/Exception.php';
  65             throw new Zend_Http_Client_Adapter_Exception(
  66                 'Trying to write but we are not connected');
  67         }
  68
  69         $host = $uri->getHost();
  70         $host = (strtolower($uri->getScheme()) == 'https' ? $this->config['ssltransport'] : 'tcp') . '://' . $host;
  71         if ($this->connected_to[0] != $host || $this->connected_to[1] != $uri->getPort()) {
  72             require_once 'Zend/Http/Client/Adapter/Exception.php';
  73             throw new Zend_Http_Client_Adapter_Exception(
  74                 'Trying to write but we are connected to the wrong host');
  75         }
  76
  77         // Save request method for later
  78         $this->method = $method;
  79
  80         // Build request headers
  81         $path = $uri->getPath();
  82         if ($uri->getQuery()) $path .= '?' . $uri->getQuery();
  83         $request = "{$method} {$path} HTTP/{$http_ver}\r\n";
  84         foreach ($headers as $k => $v) {
  85             if (is_string($k)) $v = ucfirst($k) . ": $v";
  86             $request .= "$v\r\n";
  87         }
  88
  89         // Send the headers over
  90         $request .= "\r\n";
  91         if (! @fwrite($this->socket, $request)) {
  92             require_once 'Zend/Http/Client/Adapter/Exception.php';
  93             throw new Zend_Http_Client_Adapter_Exception(
  94                 'Error writing request to server');
  95         }
  96
  97
  98         //read from $body, write to socket
  99         $chunk = $body->read(self::CHUNK_SIZE);
 100         while ($chunk !== FALSE) {
 101             if (! @fwrite($this->socket, $chunk)) {
 102                 require_once 'Zend/Http/Client/Adapter/Exception.php';
 103                 throw new Zend_Http_Client_Adapter_Exception(
 104                     'Error writing request to server');
 105             }
 106             $chunk = $body->read(self::CHUNK_SIZE);
 107         }
 108         $body->closeFileHandle();
 109         return 'Large upload, request is not cached.';
 110     }
 111 }