<?php
/**
* Zend Framework
*
* LICENSE
*
* This source file is subject to the new BSD license that is bundled
* with this package in the file LICENSE.txt.
* It is also available through the world-wide-web at this URL:
* http://framework.zend.com/license/new-bsd
* If you did not receive a copy of the license and are unable to
* obtain it through the world-wide-web, please send an email
* to [email protected] so we can send you a copy immediately.
*
* @category Zend
* @package Zend_Service
* @subpackage Amazon_S3
* @copyright Copyright (c) 2005-2014 Zend Technologies USA Inc. (http://www.zend.com)
* @license http://framework.zend.com/license/new-bsd New BSD License
* @version $Id$
*/
/**
* @see Zend_Service_Amazon_Abstract
*/
require_once 'Zend/Service/Amazon/Abstract.php';
/**
* @see Zend_Crypt_Hmac
*/
require_once 'Zend/Crypt/Hmac.php';
/**
* Amazon S3 PHP connection class
*
* @category Zend
* @package Zend_Service
* @subpackage Amazon_S3
* @copyright Copyright (c) 2005-2014 Zend Technologies USA Inc. (http://www.zend.com)
* @license http://framework.zend.com/license/new-bsd New BSD License
* @see http://docs.amazonwebservices.com/AmazonS3/2006-03-01/
*/
class Zend_Service_Amazon_S3 extends Zend_Service_Amazon_Abstract
{
/**
* Store for stream wrapper clients
*
* @var array
*/
protected static $_wrapperClients = array();
/**
* Endpoint for the service
*
* @var Zend_Uri_Http
*/
protected $_endpoint;
const S3_ENDPOINT = 's3.amazonaws.com';
const S3_ACL_PRIVATE = 'private';
const S3_ACL_PUBLIC_READ = 'public-read';
const S3_ACL_PUBLIC_WRITE = 'public-read-write';
const S3_ACL_AUTH_READ = 'authenticated-read';
const S3_REQUESTPAY_HEADER = 'x-amz-request-payer';
const S3_ACL_HEADER = 'x-amz-acl';
const S3_CONTENT_TYPE_HEADER = 'Content-Type';
/**
* Set S3 endpoint to use
*
* @param string|Zend_Uri_Http $endpoint
* @return Zend_Service_Amazon_S3
*/
public function setEndpoint($endpoint)
{
if (!($endpoint instanceof Zend_Uri_Http)) {
$endpoint = Zend_Uri::factory($endpoint);
}
if (!$endpoint->valid()) {
/**
* @see Zend_Service_Amazon_S3_Exception
*/
require_once 'Zend/Service/Amazon/S3/Exception.php';
throw new Zend_Service_Amazon_S3_Exception('Invalid endpoint supplied');
}
$this->_endpoint = $endpoint;
return $this;
}
/**
* Get current S3 endpoint
*
* @return Zend_Uri_Http
*/
public function getEndpoint()
{
return $this->_endpoint;
}
/**
* Constructor
*
* @param string $accessKey
* @param string $secretKey
* @param string $region
*/
public function __construct($accessKey=null, $secretKey=null, $region=null)
{
parent::__construct($accessKey, $secretKey, $region);
$this->setEndpoint('http://'.self::S3_ENDPOINT);
}
/**
* Verify if the bucket name is valid
*
* @param string $bucket
* @return boolean
*/
public function _validBucketName($bucket)
{
$len = strlen($bucket);
if ($len < 3 || $len > 255) {
/**
* @see Zend_Service_Amazon_S3_Exception
*/
require_once 'Zend/Service/Amazon/S3/Exception.php';
throw new Zend_Service_Amazon_S3_Exception("Bucket name \"$bucket\" must be between 3 and 255 characters long");
}
if (preg_match('/[^a-z0-9\._-]/', $bucket)) {
/**
* @see Zend_Service_Amazon_S3_Exception
*/
require_once 'Zend/Service/Amazon/S3/Exception.php';
throw new Zend_Service_Amazon_S3_Exception("Bucket name \"$bucket\" contains invalid characters");
}
if (preg_match('/(\d){1,3}\.(\d){1,3}\.(\d){1,3}\.(\d){1,3}/', $bucket)) {
/**
* @see Zend_Service_Amazon_S3_Exception
*/
require_once 'Zend/Service/Amazon/S3/Exception.php';
throw new Zend_Service_Amazon_S3_Exception("Bucket name \"$bucket\" cannot be an IP address");
}
return true;
}
/**
* Add a new bucket
*
* @param string $bucket
* @return boolean
*/
public function createBucket($bucket, $location = null)
{
$this->_validBucketName($bucket);
$headers=array();
if($location) {
$data = '<CreateBucketConfiguration><LocationConstraint>'.$location.'</LocationConstraint></CreateBucketConfiguration>';
$headers[self::S3_CONTENT_TYPE_HEADER]= 'text/plain';
$headers['Content-size']= strlen($data);
} else {
$data = null;
}
$response = $this->_makeRequest('PUT', $bucket, null, $headers, $data);
return ($response->getStatus() == 200);
}
/**
* Checks if a given bucket name is available
*
* @param string $bucket
* @return boolean
*/
public function isBucketAvailable($bucket)
{
$response = $this->_makeRequest('HEAD', $bucket, array('max-keys'=>0));
return ($response->getStatus() != 404);
}
/**
* Checks if a given object exists
*
* @param string $object
* @return boolean
*/
public function isObjectAvailable($object)
{
$object = $this->_fixupObjectName($object);
$response = $this->_makeRequest('HEAD', $object);
return ($response->getStatus() == 200);
}
/**
* Remove a given bucket. All objects in the bucket must be removed prior
* to removing the bucket.
*
* @param string $bucket
* @return boolean
*/
public function removeBucket($bucket)
{
$response = $this->_makeRequest('DELETE', $bucket);
// Look for a 204 No Content response
return ($response->getStatus() == 204);
}
/**
* Get metadata information for a given object
*
* @param string $object
* @return array|false
*/
public function getInfo($object)
{
$info = array();
$object = $this->_fixupObjectName($object);
$response = $this->_makeRequest('HEAD', $object);
if ($response->getStatus() == 200) {
$info['type'] = $response->getHeader('Content-type');
$info['size'] = $response->getHeader('Content-length');
$info['mtime'] = strtotime($response->getHeader('Last-modified'));
$info['etag'] = $response->getHeader('ETag');
}
else {
return false;
}
return $info;
}
/**
* List the S3 buckets
*
* @return array|false
*/
public function getBuckets()
{
$response = $this->_makeRequest('GET');
if ($response->getStatus() != 200) {
return false;
}
$xml = new SimpleXMLElement($response->getBody());
$buckets = array();
foreach ($xml->Buckets->Bucket as $bucket) {
$buckets[] = (string)$bucket->Name;
}
return $buckets;
}
/**
* Remove all objects in the bucket.
*
* @param string $bucket
* @return boolean
*/
public function cleanBucket($bucket)
{
$objects = $this->getObjectsByBucket($bucket);
if (!$objects) {
return false;
}
while (!empty($objects)) {
foreach ($objects as $object) {
$this->removeObject("$bucket/$object");
}
$params= array (
'marker' => $objects[count($objects)-1]
);
$objects = $this->getObjectsByBucket($bucket,$params);
}
return true;
}
/**
* List the objects in a bucket.
*
* Provides the list of object keys that are contained in the bucket. Valid params include the following.
* prefix - Limits the response to keys which begin with the indicated prefix. You can use prefixes to separate a bucket into different sets of keys in a way similar to how a file system uses folders.
* marker - Indicates where in the bucket to begin listing. The list will only include keys that occur lexicographically after marker. This is convenient for pagination: To get the next page of results use the last key of the current page as the marker.
* max-keys - The maximum number of keys you'd like to see in the response body. The server might return fewer than this many keys, but will not return more.
* delimiter - Causes keys that contain the same string between the prefix and the first occurrence of the delimiter to be rolled up into a single result element in the CommonPrefixes collection. These rolled-up keys are not returned elsewhere in the response.
*
* @param string $bucket
* @param array $params S3 GET Bucket Paramater
* @return array|false
*/
public function getObjectsByBucket($bucket, $params = array())
{
$response = $this->_makeRequest('GET', $bucket, $params);
if ($response->getStatus() != 200) {
return false;
}
$xml = new SimpleXMLElement($response->getBody());
$objects = array();
if (isset($xml->Contents)) {
foreach ($xml->Contents as $contents) {
foreach ($contents->Key as $object) {
$objects[] = (string)$object;
}
}
}
return $objects;
}
/**
* List the objects and common prefixes in a bucket.
*
* Provides the list of object keys and common prefixes that are contained in the bucket. Valid params include the following.
* prefix - Limits the response to keys which begin with the indicated prefix. You can use prefixes to separate a bucket into different sets of keys in a way similar to how a file system uses folders.
* marker - Indicates where in the bucket to begin listing. The list will only include keys that occur lexicographically after marker. This is convenient for pagination: To get the next page of results use the last key of the current page as the marker.
* max-keys - The maximum number of keys you'd like to see in the response body. The server might return fewer than this many keys, but will not return more.
* delimiter - Causes keys that contain the same string between the prefix and the first occurrence of the delimiter to be rolled up into a single result element in the CommonPrefixes collection. These rolled-up keys are not returned elsewhere in the response.
*
* @see ZF-11401
* @param string $bucket
* @param array $params S3 GET Bucket Paramater
* @return array|false
*/
public function getObjectsAndPrefixesByBucket($bucket, $params = array())
{
$response = $this->_makeRequest('GET', $bucket, $params);
if ($response->getStatus() != 200) {
return false;
}
$xml = new SimpleXMLElement($response->getBody());
$objects = array();
if (isset($xml->Contents)) {
foreach ($xml->Contents as $contents) {
foreach ($contents->Key as $object) {
$objects[] = (string)$object;
}
}
}
$prefixes = array();
if (isset($xml->CommonPrefixes)) {
foreach ($xml->CommonPrefixes as $prefix) {
foreach ($prefix->Prefix as $object) {
$prefixes[] = (string)$object;
}
}
}
return array(
'objects' => $objects,
'prefixes' => $prefixes
);
}
/**
* Make sure the object name is valid
*
* @param string $object
* @return string
*/
protected function _fixupObjectName($object)
{
$nameparts = explode('/', $object);
$this->_validBucketName($nameparts[0]);
$firstpart = array_shift($nameparts);
if (count($nameparts) == 0) {
return $firstpart;
}
return $firstpart.'/'.join('/', array_map('rawurlencode', $nameparts));
}
/**
* Get an object
*
* @param string $object
* @param bool $paidobject This is "requestor pays" object
* @return string|false
*/
public function getObject($object, $paidobject=false)
{
$object = $this->_fixupObjectName($object);
if ($paidobject) {
$response = $this->_makeRequest('GET', $object, null, array(self::S3_REQUESTPAY_HEADER => 'requester'));
}
else {
$response = $this->_makeRequest('GET', $object);
}
if ($response->getStatus() != 200) {
return false;
}
return $response->getBody();
}
/**
* Get an object using streaming
*
* Can use either provided filename for storage or create a temp file if none provided.
*
* @param string $object Object path
* @param string $streamfile File to write the stream to
* @param bool $paidobject This is "requestor pays" object
* @return Zend_Http_Response_Stream|false
*/
public function getObjectStream($object, $streamfile = null, $paidobject=false)
{
$object = $this->_fixupObjectName($object);
self::getHttpClient()->setStream($streamfile?$streamfile:true);
if ($paidobject) {
$response = $this->_makeRequest('GET', $object, null, array(self::S3_REQUESTPAY_HEADER => 'requester'));
}
else {
$response = $this->_makeRequest('GET', $object);
}
self::getHttpClient()->setStream(null);
if ($response->getStatus() != 200 || !($response instanceof Zend_Http_Response_Stream)) {
return false;
}
return $response;
}
/**
* Upload an object by a PHP string
*
* @param string $object Object name
* @param string|resource $data Object data (can be string or stream)
* @param array $meta Metadata
* @return boolean
*/
public function putObject($object, $data, $meta=null)
{
$object = $this->_fixupObjectName($object);
$headers = (is_array($meta)) ? $meta : array();
if(!is_resource($data)) {
$headers['Content-MD5'] = base64_encode(md5($data, true));
}
$headers['Expect'] = '100-continue';
if (!isset($headers[self::S3_CONTENT_TYPE_HEADER])) {
$headers[self::S3_CONTENT_TYPE_HEADER] = self::getMimeType($object);
}
$response = $this->_makeRequest('PUT', $object, null, $headers, $data);
// Check the MD5 Etag returned by S3 against and MD5 of the buffer
if ($response->getStatus() == 200) {
// It is escaped by double quotes for some reason
$etag = str_replace('"', '', $response->getHeader('Etag'));
if (is_resource($data) || $etag == md5($data)) {
return true;
}
}
return false;
}
/**
* Put file to S3 as object
*
* @param string $path File name
* @param string $object Object name
* @param array $meta Metadata
* @return boolean
*/
public function putFile($path, $object, $meta=null)
{
$data = @file_get_contents($path);
if ($data === false) {
/**
* @see Zend_Service_Amazon_S3_Exception
*/
require_once 'Zend/Service/Amazon/S3/Exception.php';
throw new Zend_Service_Amazon_S3_Exception("Cannot read file $path");
}
if (!is_array($meta)) {
$meta = array();
}
if (!isset($meta[self::S3_CONTENT_TYPE_HEADER])) {
$meta[self::S3_CONTENT_TYPE_HEADER] = self::getMimeType($path);
}
return $this->putObject($object, $data, $meta);
}
/**
* Put file to S3 as object, using streaming
*
* @param string $path File name
* @param string $object Object name
* @param array $meta Metadata
* @return boolean
*/
public function putFileStream($path, $object, $meta=null)
{
$data = @fopen($path, "rb");
if ($data === false) {
/**
* @see Zend_Service_Amazon_S3_Exception
*/
require_once 'Zend/Service/Amazon/S3/Exception.php';
throw new Zend_Service_Amazon_S3_Exception("Cannot open file $path");
}
if (!is_array($meta)) {
$meta = array();
}
if (!isset($meta[self::S3_CONTENT_TYPE_HEADER])) {
$meta[self::S3_CONTENT_TYPE_HEADER] = self::getMimeType($path);
}
if(!isset($meta['Content-MD5'])) {
$meta['Content-MD5'] = base64_encode(md5_file($path, true));
}
return $this->putObject($object, $data, $meta);
}
/**
* Remove a given object
*
* @param string $object
* @return boolean
*/
public function removeObject($object)
{
$object = $this->_fixupObjectName($object);
$response = $this->_makeRequest('DELETE', $object);
// Look for a 204 No Content response
return ($response->getStatus() == 204);
}
/**
* Copy an object
*
* @param string $sourceObject Source object name
* @param string $destObject Destination object name
* @param array $meta (OPTIONAL) Metadata to apply to desination object.
* Set to null to copy metadata from source object.
* @return boolean
*/
public function copyObject($sourceObject, $destObject, $meta = null)
{
$sourceObject = $this->_fixupObjectName($sourceObject);
$destObject = $this->_fixupObjectName($destObject);
$headers = (is_array($meta)) ? $meta : array();
$headers['x-amz-copy-source'] = $sourceObject;
$headers['x-amz-metadata-directive'] = $meta === null ? 'COPY' : 'REPLACE';
$response = $this->_makeRequest('PUT', $destObject, null, $headers);
if ($response->getStatus() == 200 && !stristr($response->getBody(), '<Error>')) {
return true;
}
return false;
}
/**
* Move an object
*
* Performs a copy to dest + verify + remove source
*
* @param string $sourceObject Source object name
* @param string $destObject Destination object name
* @param array $meta (OPTIONAL) Metadata to apply to destination object.
* Set to null to retain existing metadata.
*/
public function moveObject($sourceObject, $destObject, $meta = null)
{
$sourceInfo = $this->getInfo($sourceObject);
$this->copyObject($sourceObject, $destObject, $meta);
$destInfo = $this->getInfo($destObject);
if ($sourceInfo['etag'] === $destInfo['etag']) {
return $this->removeObject($sourceObject);
} else {
return false;
}
}
/**
* Make a request to Amazon S3
*
* @param string $method Request method
* @param string $path Path to requested object
* @param array $params Request parameters
* @param array $headers HTTP headers
* @param string|resource $data Request data
* @return Zend_Http_Response
*/
public function _makeRequest($method, $path='', $params=null, $headers=array(), $data=null)
{
$retry_count = 0;
if (!is_array($headers)) {
$headers = array($headers);
}
$headers['Date'] = gmdate(DATE_RFC1123, time());
if(is_resource($data) && $method != 'PUT') {
/**
* @see Zend_Service_Amazon_S3_Exception
*/
require_once 'Zend/Service/Amazon/S3/Exception.php';
throw new Zend_Service_Amazon_S3_Exception("Only PUT request supports stream data");
}
// build the end point out
$parts = explode('/', $path, 2);
$endpoint = clone($this->_endpoint);
if ($parts[0]) {
// prepend bucket name to the hostname
$endpoint->setHost($parts[0].'.'.$endpoint->getHost());
}
if (!empty($parts[1])) {
// ZF-10218, ZF-10122
$pathparts = explode('?',$parts[1]);
$endpath = $pathparts[0];
$endpoint->setPath('/'.$endpath);
}
else {
$endpoint->setPath('/');
if ($parts[0]) {
$path = $parts[0].'/';
}
}
self::addSignature($method, $path, $headers);
$client = self::getHttpClient();
$client->resetParameters(true);
$client->setUri($endpoint);
$client->setAuth(false);
// Work around buglet in HTTP client - it doesn't clean headers
// Remove when ZHC is fixed
/*
$client->setHeaders(array('Content-MD5' => null,
'Content-Encoding' => null,
'Expect' => null,
'Range' => null,
'x-amz-acl' => null,
'x-amz-copy-source' => null,
'x-amz-metadata-directive' => null));
*/
$client->setHeaders($headers);
if (is_array($params)) {
foreach ($params as $name=>$value) {
$client->setParameterGet($name, $value);
}
}
if (($method == 'PUT') && ($data !== null)) {
if (!isset($headers['Content-type'])) {
$headers['Content-type'] = self::getMimeType($path);
}
$client->setRawData($data, $headers['Content-type']);
}
do {
$retry = false;
$response = $client->request($method);
$response_code = $response->getStatus();
// Some 5xx errors are expected, so retry automatically
if ($response_code >= 500 && $response_code < 600 && $retry_count <= 5) {
$retry = true;
$retry_count++;
sleep($retry_count / 4 * $retry_count);
}
else if ($response_code == 307) {
// Need to redirect, new S3 endpoint given
// This should never happen as Zend_Http_Client will redirect automatically
}
else if ($response_code == 100) {
// echo 'OK to Continue';
}
} while ($retry);
return $response;
}
/**
* Add the S3 Authorization signature to the request headers
*
* @param string $method
* @param string $path
* @param array &$headers
* @return string
*/
protected function addSignature($method, $path, &$headers)
{
if (!is_array($headers)) {
$headers = array($headers);
}
$type = $md5 = $date = '';
// Search for the Content-type, Content-MD5 and Date headers
foreach ($headers as $key=>$val) {
if (strcasecmp($key, 'content-type') == 0) {
$type = $val;
}
else if (strcasecmp($key, 'content-md5') == 0) {
$md5 = $val;
}
else if (strcasecmp($key, 'date') == 0) {
$date = $val;
}
}
// If we have an x-amz-date header, use that instead of the normal Date
if (isset($headers['x-amz-date']) && isset($date)) {
$date = '';
}
$sig_str = "$method\n$md5\n$type\n$date\n";
// For x-amz- headers, combine like keys, lowercase them, sort them
// alphabetically and remove excess spaces around values
$amz_headers = array();
foreach ($headers as $key=>$val) {
$key = strtolower($key);
if (substr($key, 0, 6) == 'x-amz-') {
if (is_array($val)) {
$amz_headers[$key] = $val;
}
else {
$amz_headers[$key][] = preg_replace('/\s+/', ' ', $val);
}
}
}
if (!empty($amz_headers)) {
ksort($amz_headers);
foreach ($amz_headers as $key=>$val) {
$sig_str .= $key.':'.implode(',', $val)."\n";
}
}
$sig_str .= '/'.parse_url($path, PHP_URL_PATH);
if (strpos($path, '?location') !== false) {
$sig_str .= '?location';
}
else if (strpos($path, '?acl') !== false) {
$sig_str .= '?acl';
}
else if (strpos($path, '?torrent') !== false) {
$sig_str .= '?torrent';
}
else if (strpos($path, '?versions') !== false) {
$sig_str .= '?versions';
}
$signature = base64_encode(Zend_Crypt_Hmac::compute($this->_getSecretKey(), 'sha1', utf8_encode($sig_str), Zend_Crypt_Hmac::BINARY));
$headers['Authorization'] = 'AWS '.$this->_getAccessKey().':'.$signature;
return $sig_str;
}
/**
* Attempt to get the content-type of a file based on the extension
*
* @param string $path
* @return string
*/
public static function getMimeType($path)
{
$ext = substr(strrchr($path, '.'), 1);
if(!$ext) {
// shortcut
return 'binary/octet-stream';
}
switch (strtolower($ext)) {
case 'xls':
$content_type = 'application/excel';
break;
case 'hqx':
$content_type = 'application/macbinhex40';
break;
case 'doc':
case 'dot':
case 'wrd':
$content_type = 'application/msword';
break;
case 'pdf':
$content_type = 'application/pdf';
break;
case 'pgp':
$content_type = 'application/pgp';
break;
case 'ps':
case 'eps':
case 'ai':
$content_type = 'application/postscript';
break;
case 'ppt':
$content_type = 'application/powerpoint';
break;
case 'rtf':
$content_type = 'application/rtf';
break;
case 'tgz':
case 'gtar':
$content_type = 'application/x-gtar';
break;
case 'gz':
$content_type = 'application/x-gzip';
break;
case 'php':
case 'php3':
case 'php4':
$content_type = 'application/x-httpd-php';
break;
case 'js':
$content_type = 'application/x-javascript';
break;
case 'ppd':
case 'psd':
$content_type = 'application/x-photoshop';
break;
case 'swf':
case 'swc':
case 'rf':
$content_type = 'application/x-shockwave-flash';
break;
case 'tar':
$content_type = 'application/x-tar';
break;
case 'zip':
$content_type = 'application/zip';
break;
case 'mid':
case 'midi':
case 'kar':
$content_type = 'audio/midi';
break;
case 'mp2':
case 'mp3':
case 'mpga':
$content_type = 'audio/mpeg';
break;
case 'ra':
$content_type = 'audio/x-realaudio';
break;
case 'wav':
$content_type = 'audio/wav';
break;
case 'bmp':
$content_type = 'image/bitmap';
break;
case 'gif':
$content_type = 'image/gif';
break;
case 'iff':
$content_type = 'image/iff';
break;
case 'jb2':
$content_type = 'image/jb2';
break;
case 'jpg':
case 'jpe':
case 'jpeg':
$content_type = 'image/jpeg';
break;
case 'jpx':
$content_type = 'image/jpx';
break;
case 'png':
$content_type = 'image/png';
break;
case 'tif':
case 'tiff':
$content_type = 'image/tiff';
break;
case 'wbmp':
$content_type = 'image/vnd.wap.wbmp';
break;
case 'xbm':
$content_type = 'image/xbm';
break;
case 'css':
$content_type = 'text/css';
break;
case 'txt':
$content_type = 'text/plain';
break;
case 'htm':
case 'html':
$content_type = 'text/html';
break;
case 'xml':
$content_type = 'text/xml';
break;
case 'xsl':
$content_type = 'text/xsl';
break;
case 'mpg':
case 'mpe':
case 'mpeg':
$content_type = 'video/mpeg';
break;
case 'qt':
case 'mov':
$content_type = 'video/quicktime';
break;
case 'avi':
$content_type = 'video/x-ms-video';
break;
case 'eml':
$content_type = 'message/rfc822';
break;
default:
$content_type = 'binary/octet-stream';
break;
}
return $content_type;
}
/**
* Register this object as stream wrapper client
*
* @param string $name
* @return Zend_Service_Amazon_S3
*/
public function registerAsClient($name)
{
self::$_wrapperClients[$name] = $this;
return $this;
}
/**
* Unregister this object as stream wrapper client
*
* @param string $name
* @return Zend_Service_Amazon_S3
*/
public function unregisterAsClient($name)
{
unset(self::$_wrapperClients[$name]);
return $this;
}
/**
* Get wrapper client for stream type
*
* @param string $name
* @return Zend_Service_Amazon_S3
*/
public static function getWrapperClient($name)
{
return self::$_wrapperClients[$name];
}
/**
* Register this object as stream wrapper
*
* @param string $name
* @return Zend_Service_Amazon_S3
*/
public function registerStreamWrapper($name='s3')
{
/**
* @see Zend_Service_Amazon_S3_Stream
*/
require_once 'Zend/Service/Amazon/S3/Stream.php';
stream_register_wrapper($name, 'Zend_Service_Amazon_S3_Stream');
$this->registerAsClient($name);
}
/**
* Unregister this object as stream wrapper
*
* @param string $name
* @return Zend_Service_Amazon_S3
*/
public function unregisterStreamWrapper($name='s3')
{
stream_wrapper_unregister($name);
$this->unregisterAsClient($name);
}
}