C:/xampp/htdocs/moodle/lib/zend/Zend/Service/WindowsAzure/Storage/Blob.php

Go to the documentation of this file.

<?php
require_once 'Zend/Service/WindowsAzure/Credentials/SharedKey.php';

require_once 'Zend/Service/WindowsAzure/Credentials/SharedAccessSignature.php';

require_once 'Zend/Service/WindowsAzure/RetryPolicy/RetryPolicyAbstract.php';

require_once 'Zend/Http/Client.php';

require_once 'Zend/Http/Response.php';

require_once 'Zend/Service/WindowsAzure/Storage.php';

require_once 'Zend/Service/WindowsAzure/Storage/BlobContainer.php';

require_once 'Zend/Service/WindowsAzure/Storage/BlobInstance.php';

require_once 'Zend/Service/WindowsAzure/Storage/SignedIdentifier.php';

require_once 'Zend/Service/WindowsAzure/Exception.php';


class Zend_Service_WindowsAzure_Storage_Blob extends Zend_Service_WindowsAzure_Storage
{
        const ACL_PRIVATE = false;
        
        const ACL_PUBLIC = true;
        
        const MAX_BLOB_SIZE = 67108864;

        const MAX_BLOB_TRANSFER_SIZE = 4194304;
        
    protected static $_wrapperClients = array();
    
    private $_sharedAccessSignatureCredentials = null;
        
        public function __construct($host = Zend_Service_WindowsAzure_Storage::URL_DEV_BLOB, $accountName = Zend_Service_WindowsAzure_Credentials_CredentialsAbstract::DEVSTORE_ACCOUNT, $accountKey = Zend_Service_WindowsAzure_Credentials_CredentialsAbstract::DEVSTORE_KEY, $usePathStyleUri = false, Zend_Service_WindowsAzure_RetryPolicy_RetryPolicyAbstract $retryPolicy = null)
        {
                parent::__construct($host, $accountName, $accountKey, $usePathStyleUri, $retryPolicy);
                
                // API version
                $this->_apiVersion = '2009-07-17';
                
                // SharedAccessSignature credentials
                $this->_sharedAccessSignatureCredentials = new Zend_Service_WindowsAzure_Credentials_SharedAccessSignature($accountName, $accountKey, $usePathStyleUri);
        }
        
        public function blobExists($containerName = '', $blobName = '')
        {
                if ($containerName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Container name is not specified.');
                }
                if (!self::isValidContainerName($containerName)) {
                    throw new Zend_Service_WindowsAzure_Exception('Container name does not adhere to container naming conventions. See http://msdn.microsoft.com/en-us/library/dd135715.aspx for more information.');
                }
                if ($blobName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Blob name is not specified.');
                }
                
                // List blobs
        $blobs = $this->listBlobs($containerName, $blobName, '', 1);
        foreach ($blobs as $blob) {
            if ($blob->Name == $blobName) {
                return true;
            }
        }
        
        return false;
        }
        
        public function containerExists($containerName = '')
        {
                if ($containerName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Container name is not specified.');
                }
                if (!self::isValidContainerName($containerName)) {
                    throw new Zend_Service_WindowsAzure_Exception('Container name does not adhere to container naming conventions. See http://msdn.microsoft.com/en-us/library/dd135715.aspx for more information.');
                }
                        
                // List containers
        $containers = $this->listContainers($containerName, 1);
        foreach ($containers as $container) {
            if ($container->Name == $containerName) {
                return true;
            }
        }
        
        return false;
        }
        
        public function createContainer($containerName = '', $metadata = array())
        {
                if ($containerName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Container name is not specified.');
                }
                if (!self::isValidContainerName($containerName)) {
                    throw new Zend_Service_WindowsAzure_Exception('Container name does not adhere to container naming conventions. See http://msdn.microsoft.com/en-us/library/dd135715.aspx for more information.');
                }
                if (!is_array($metadata)) {
                        throw new Zend_Service_WindowsAzure_Exception('Meta data should be an array of key and value pairs.');
                }
                        
                // Create metadata headers
                $headers = array();
                $headers = array_merge($headers, $this->_generateMetadataHeaders($metadata));
                
                // Perform request
                $response = $this->_performRequest($containerName, '?restype=container', Zend_Http_Client::PUT, $headers, false, null, Zend_Service_WindowsAzure_Storage::RESOURCE_CONTAINER, Zend_Service_WindowsAzure_Credentials_CredentialsAbstract::PERMISSION_WRITE);                     
                if ($response->isSuccessful()) {
                    return new Zend_Service_WindowsAzure_Storage_BlobContainer(
                        $containerName,
                        $response->getHeader('Etag'),
                        $response->getHeader('Last-modified'),
                        $metadata
                    );
                } else {
                    throw new Zend_Service_WindowsAzure_Exception($this->_getErrorMessage($response, 'Resource could not be accessed.'));
                }
        }
        
        public function getContainerAcl($containerName = '', $signedIdentifiers = false)
        {
                if ($containerName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Container name is not specified.');
                }
                if (!self::isValidContainerName($containerName)) {
                    throw new Zend_Service_WindowsAzure_Exception('Container name does not adhere to container naming conventions. See http://msdn.microsoft.com/en-us/library/dd135715.aspx for more information.');
                }

                // Perform request
                $response = $this->_performRequest($containerName, '?restype=container&comp=acl', Zend_Http_Client::GET, array(), false, null, Zend_Service_WindowsAzure_Storage::RESOURCE_CONTAINER, Zend_Service_WindowsAzure_Credentials_CredentialsAbstract::PERMISSION_READ);
                if ($response->isSuccessful()) {
                    if ($signedIdentifiers == false)  {
                        // Only public/private
                            return $response->getHeader('x-ms-prop-publicaccess') == 'True';
                    } else {
                    // Parse result
                    $result = $this->_parseResponse($response);
                    if (!$result) {
                        return array();
                    }
    
                    $entries = null;
                    if ($result->SignedIdentifier) {
                            if (count($result->SignedIdentifier) > 1) {
                                $entries = $result->SignedIdentifier;
                            } else {
                                $entries = array($result->SignedIdentifier);
                            }
                    }
                    
                    // Return value
                    $returnValue = array();
                    foreach ($entries as $entry) {
                        $returnValue[] = new Zend_Service_WindowsAzure_Storage_SignedIdentifier(
                            $entry->Id,
                            $entry->AccessPolicy ? $entry->AccessPolicy->Start ? $entry->AccessPolicy->Start : '' : '',
                            $entry->AccessPolicy ? $entry->AccessPolicy->Expiry ? $entry->AccessPolicy->Expiry : '' : '',
                            $entry->AccessPolicy ? $entry->AccessPolicy->Permission ? $entry->AccessPolicy->Permission : '' : ''
                        );
                    }
                    
                    // Return
                    return $returnValue;
                    }                      
                } else {
                    throw new Zend_Service_WindowsAzure_Exception($this->_getErrorMessage($response, 'Resource could not be accessed.'));
                }
        }
        
        public function setContainerAcl($containerName = '', $acl = self::ACL_PRIVATE, $signedIdentifiers = array())
        {
                if ($containerName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Container name is not specified.');
                }
                if (!self::isValidContainerName($containerName)) {
                    throw new Zend_Service_WindowsAzure_Exception('Container name does not adhere to container naming conventions. See http://msdn.microsoft.com/en-us/library/dd135715.aspx for more information.');
                }

                // Policies
                $policies = null;
                if (is_array($signedIdentifiers) && count($signedIdentifiers) > 0) {
                    $policies  = '';
                    $policies .= '<?xml version="1.0" encoding="utf-8"?>' . "\r\n";
                    $policies .= '<SignedIdentifiers>' . "\r\n";
                    foreach ($signedIdentifiers as $signedIdentifier) {
                        $policies .= '  <SignedIdentifier>' . "\r\n";
                        $policies .= '    <Id>' . $signedIdentifier->Id . '</Id>' . "\r\n";
                        $policies .= '    <AccessPolicy>' . "\r\n";
                        if ($signedIdentifier->Start != '')
                            $policies .= '      <Start>' . $signedIdentifier->Start . '</Start>' . "\r\n";
                        if ($signedIdentifier->Expiry != '')
                            $policies .= '      <Expiry>' . $signedIdentifier->Expiry . '</Expiry>' . "\r\n";
                        if ($signedIdentifier->Permissions != '')
                            $policies .= '      <Permission>' . $signedIdentifier->Permissions . '</Permission>' . "\r\n";
                        $policies .= '    </AccessPolicy>' . "\r\n";
                        $policies .= '  </SignedIdentifier>' . "\r\n";
                    }
                    $policies .= '</SignedIdentifiers>' . "\r\n";
                }
                
                // Perform request
                $response = $this->_performRequest($containerName, '?restype=container&comp=acl', Zend_Http_Client::PUT, array('x-ms-prop-publicaccess' => $acl), false, $policies, Zend_Service_WindowsAzure_Storage::RESOURCE_CONTAINER, Zend_Service_WindowsAzure_Credentials_CredentialsAbstract::PERMISSION_WRITE);
                if (!$response->isSuccessful()) {
                    throw new Zend_Service_WindowsAzure_Exception($this->_getErrorMessage($response, 'Resource could not be accessed.'));
                }
        }
        
        public function getContainer($containerName = '')
        {
                if ($containerName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Container name is not specified.');
                }
                if (!self::isValidContainerName($containerName)) {
                    throw new Zend_Service_WindowsAzure_Exception('Container name does not adhere to container naming conventions. See http://msdn.microsoft.com/en-us/library/dd135715.aspx for more information.');
                }
                    
                // Perform request
                $response = $this->_performRequest($containerName, '?restype=container', Zend_Http_Client::GET, array(), false, null, Zend_Service_WindowsAzure_Storage::RESOURCE_CONTAINER, Zend_Service_WindowsAzure_Credentials_CredentialsAbstract::PERMISSION_READ);       
                if ($response->isSuccessful()) {
                    // Parse metadata
                    $metadata = $this->_parseMetadataHeaders($response->getHeaders());

                    // Return container
                    return new Zend_Service_WindowsAzure_Storage_BlobContainer(
                        $containerName,
                        $response->getHeader('Etag'),
                        $response->getHeader('Last-modified'),
                        $metadata
                    );
                } else {
                    throw new Zend_Service_WindowsAzure_Exception($this->_getErrorMessage($response, 'Resource could not be accessed.'));
                }
        }
        
        public function getContainerMetadata($containerName = '')
        {
                if ($containerName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Container name is not specified.');
                }
                if (!self::isValidContainerName($containerName)) {
                    throw new Zend_Service_WindowsAzure_Exception('Container name does not adhere to container naming conventions. See http://msdn.microsoft.com/en-us/library/dd135715.aspx for more information.');
                }
                
            return $this->getContainer($containerName)->Metadata;
        }
        
        public function setContainerMetadata($containerName = '', $metadata = array(), $additionalHeaders = array())
        {
                if ($containerName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Container name is not specified.');
                }
                if (!self::isValidContainerName($containerName)) {
                    throw new Zend_Service_WindowsAzure_Exception('Container name does not adhere to container naming conventions. See http://msdn.microsoft.com/en-us/library/dd135715.aspx for more information.');
                }
                if (!is_array($metadata)) {
                        throw new Zend_Service_WindowsAzure_Exception('Meta data should be an array of key and value pairs.');
                }
                if (count($metadata) == 0) {
                    return;
                }
                    
                // Create metadata headers
                $headers = array();
                $headers = array_merge($headers, $this->_generateMetadataHeaders($metadata)); 
                
                // Additional headers?
                foreach ($additionalHeaders as $key => $value) {
                    $headers[$key] = $value;
                }
                
                // Perform request
                $response = $this->_performRequest($containerName, '?restype=container&comp=metadata', Zend_Http_Client::PUT, $headers, false, null, Zend_Service_WindowsAzure_Storage::RESOURCE_CONTAINER, Zend_Service_WindowsAzure_Credentials_CredentialsAbstract::PERMISSION_WRITE);
                if (!$response->isSuccessful()) {
                    throw new Zend_Service_WindowsAzure_Exception($this->_getErrorMessage($response, 'Resource could not be accessed.'));
                }
        }
        
        public function deleteContainer($containerName = '', $additionalHeaders = array())
        {
                if ($containerName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Container name is not specified.');
                }
                if (!self::isValidContainerName($containerName)) {
                    throw new Zend_Service_WindowsAzure_Exception('Container name does not adhere to container naming conventions. See http://msdn.microsoft.com/en-us/library/dd135715.aspx for more information.');
                }
                        
                // Additional headers?
                $headers = array();
                foreach ($additionalHeaders as $key => $value) {
                    $headers[$key] = $value;
                }
                
                // Perform request
                $response = $this->_performRequest($containerName, '?restype=container', Zend_Http_Client::DELETE, $headers, false, null, Zend_Service_WindowsAzure_Storage::RESOURCE_CONTAINER, Zend_Service_WindowsAzure_Credentials_CredentialsAbstract::PERMISSION_WRITE);
                if (!$response->isSuccessful()) {
                    throw new Zend_Service_WindowsAzure_Exception($this->_getErrorMessage($response, 'Resource could not be accessed.'));
                }
        }
        
        public function listContainers($prefix = null, $maxResults = null, $marker = null, $currentResultCount = 0)
        {
            // Build query string
            $queryString = '?comp=list';
            if (!is_null($prefix)) {
                $queryString .= '&prefix=' . $prefix;
            }
            if (!is_null($maxResults)) {
                $queryString .= '&maxresults=' . $maxResults;
            }
            if (!is_null($marker)) {
                $queryString .= '&marker=' . $marker;
            }
                
                // Perform request
                $response = $this->_performRequest('', $queryString, Zend_Http_Client::GET, array(), false, null, Zend_Service_WindowsAzure_Storage::RESOURCE_CONTAINER, Zend_Service_WindowsAzure_Credentials_CredentialsAbstract::PERMISSION_LIST);   
                if ($response->isSuccessful()) {
                        $xmlContainers = $this->_parseResponse($response)->Containers->Container;
                        $xmlMarker = (string)$this->_parseResponse($response)->NextMarker;

                        $containers = array();
                        if (!is_null($xmlContainers)) {
                                for ($i = 0; $i < count($xmlContainers); $i++) {
                                        $containers[] = new Zend_Service_WindowsAzure_Storage_BlobContainer(
                                                (string)$xmlContainers[$i]->Name,
                                                (string)$xmlContainers[$i]->Etag,
                                                (string)$xmlContainers[$i]->LastModified
                                        );
                                }
                        }
                        $currentResultCount = $currentResultCount + count($containers);
                        if (!is_null($maxResults) && $currentResultCount < $maxResults) {
                        if (!is_null($xmlMarker) && $xmlMarker != '') {
                            $containers = array_merge($containers, $this->listContainers($prefix, $maxResults, $xmlMarker, $currentResultCount));
                        }
                        }
                        if (!is_null($maxResults) && count($containers) > $maxResults) {
                            $containers = array_slice($containers, 0, $maxResults);
                        }
                            
                        return $containers;
                } else {
                    throw new Zend_Service_WindowsAzure_Exception($this->_getErrorMessage($response, 'Resource could not be accessed.'));
                }
        }
        
        public function putBlob($containerName = '', $blobName = '', $localFileName = '', $metadata = array(), $additionalHeaders = array())
        {
                if ($containerName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Container name is not specified.');
                }
                if (!self::isValidContainerName($containerName)) {
                    throw new Zend_Service_WindowsAzure_Exception('Container name does not adhere to container naming conventions. See http://msdn.microsoft.com/en-us/library/dd135715.aspx for more information.');
                }
                if ($blobName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Blob name is not specified.');
                }
                if ($localFileName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Local file name is not specified.');
                }
                if (!file_exists($localFileName)) {
                        throw new Zend_Service_WindowsAzure_Exception('Local file not found.');
                }
                if ($containerName === '$root' && strpos($blobName, '/') !== false) {
                    throw new Zend_Service_WindowsAzure_Exception('Blobs stored in the root container can not have a name containing a forward slash (/).');
                }
                        
                // Check file size
                if (filesize($localFileName) >= self::MAX_BLOB_SIZE) {
                        return $this->putLargeBlob($containerName, $blobName, $localFileName, $metadata);
                }

                // Create metadata headers
                $headers = array();
                $headers = array_merge($headers, $this->_generateMetadataHeaders($metadata)); 
                
                // Additional headers?
                foreach ($additionalHeaders as $key => $value) {
                    $headers[$key] = $value;
                }
                
                // File contents
                $fileContents = file_get_contents($localFileName);
                
                // Resource name
                $resourceName = self::createResourceName($containerName , $blobName);
                
                // Perform request
                $response = $this->_performRequest($resourceName, '', Zend_Http_Client::PUT, $headers, false, $fileContents, Zend_Service_WindowsAzure_Storage::RESOURCE_BLOB, Zend_Service_WindowsAzure_Credentials_CredentialsAbstract::PERMISSION_WRITE);    
                if ($response->isSuccessful()) {
                        return new Zend_Service_WindowsAzure_Storage_BlobInstance(
                                $containerName,
                                $blobName,
                                $response->getHeader('Etag'),
                                $response->getHeader('Last-modified'),
                                $this->getBaseUrl() . '/' . $containerName . '/' . $blobName,
                                strlen($fileContents),
                                '',
                                '',
                                '',
                                false,
                        $metadata
                        );
                } else {
                    throw new Zend_Service_WindowsAzure_Exception($this->_getErrorMessage($response, 'Resource could not be accessed.'));
                }
        }
        
        public function putLargeBlob($containerName = '', $blobName = '', $localFileName = '', $metadata = array())
        {
                if ($containerName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Container name is not specified.');
                }
                if (!self::isValidContainerName($containerName)) {
                    throw new Zend_Service_WindowsAzure_Exception('Container name does not adhere to container naming conventions. See http://msdn.microsoft.com/en-us/library/dd135715.aspx for more information.');
                }
                if ($blobName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Blob name is not specified.');
                }
                if ($localFileName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Local file name is not specified.');
                }
                if (!file_exists($localFileName)) {
                        throw new Zend_Service_WindowsAzure_Exception('Local file not found.');
                }
                if ($containerName === '$root' && strpos($blobName, '/') !== false) {
                    throw new Zend_Service_WindowsAzure_Exception('Blobs stored in the root container can not have a name containing a forward slash (/).');
                }
                        
                // Check file size
                if (filesize($localFileName) < self::MAX_BLOB_SIZE) {
                        return $this->putBlob($containerName, $blobName, $localFileName, $metadata);
                }
                        
                // Determine number of parts
                $numberOfParts = ceil( filesize($localFileName) / self::MAX_BLOB_TRANSFER_SIZE );
                
                // Generate block id's
                $blockIdentifiers = array();
                for ($i = 0; $i < $numberOfParts; $i++) {
                        $blockIdentifiers[] = $this->_generateBlockId($i);
                }
                
                // Open file
                $fp = fopen($localFileName, 'r');
                if ($fp === false) {
                        throw new Zend_Service_WindowsAzure_Exception('Could not open local file.');
                }
                        
                // Upload parts
                for ($i = 0; $i < $numberOfParts; $i++) {
                        // Seek position in file
                        fseek($fp, $i * self::MAX_BLOB_TRANSFER_SIZE);
                        
                        // Read contents
                        $fileContents = fread($fp, self::MAX_BLOB_TRANSFER_SIZE);
                        
                        // Put block
                        $this->putBlock($containerName, $blobName, $blockIdentifiers[$i], $fileContents);
                        
                        // Dispose file contents
                        $fileContents = null;
                        unset($fileContents);
                }
                
                // Close file
                fclose($fp);
                
                // Put block list
                $this->putBlockList($containerName, $blobName, $blockIdentifiers, $metadata);
                
                // Return information of the blob
                return $this->getBlobInstance($containerName, $blobName);
        }                       
                        
        public function putBlock($containerName = '', $blobName = '', $identifier = '', $contents = '')
        {
                if ($containerName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Container name is not specified.');
                }
                if (!self::isValidContainerName($containerName)) {
                    throw new Zend_Service_WindowsAzure_Exception('Container name does not adhere to container naming conventions. See http://msdn.microsoft.com/en-us/library/dd135715.aspx for more information.');
                }
                if ($identifier === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Block identifier is not specified.');
                }
                if (strlen($contents) > self::MAX_BLOB_TRANSFER_SIZE) {
                        throw new Zend_Service_WindowsAzure_Exception('Block size is too big.');
                }
                if ($containerName === '$root' && strpos($blobName, '/') !== false) {
                    throw new Zend_Service_WindowsAzure_Exception('Blobs stored in the root container can not have a name containing a forward slash (/).');
                }
                        
                // Resource name
                $resourceName = self::createResourceName($containerName , $blobName);
                
        // Upload
                $response = $this->_performRequest($resourceName, '?comp=block&blockid=' . base64_encode($identifier), Zend_Http_Client::PUT, null, false, $contents, Zend_Service_WindowsAzure_Storage::RESOURCE_BLOB, Zend_Service_WindowsAzure_Credentials_CredentialsAbstract::PERMISSION_WRITE);
                if (!$response->isSuccessful()) {
                    throw new Zend_Service_WindowsAzure_Exception($this->_getErrorMessage($response, 'Resource could not be accessed.'));
                }
        }
        
        public function putBlockList($containerName = '', $blobName = '', $blockList = array(), $metadata = array(), $additionalHeaders = array())
        {
                if ($containerName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Container name is not specified.');
                }
                if (!self::isValidContainerName($containerName)) {
                    throw new Zend_Service_WindowsAzure_Exception('Container name does not adhere to container naming conventions. See http://msdn.microsoft.com/en-us/library/dd135715.aspx for more information.');
                }
                if ($blobName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Blob name is not specified.');
                }
                if (count($blockList) == 0) {
                        throw new Zend_Service_WindowsAzure_Exception('Block list does not contain any elements.');
                }
                if ($containerName === '$root' && strpos($blobName, '/') !== false) {
                    throw new Zend_Service_WindowsAzure_Exception('Blobs stored in the root container can not have a name containing a forward slash (/).');
                }
                
                // Generate block list
                $blocks = '';
                foreach ($blockList as $block) {
                        $blocks .= '  <Latest>' . base64_encode($block) . '</Latest>' . "\n";
                }
                
                // Generate block list request
                $fileContents = utf8_encode(implode("\n", array(
                        '<?xml version="1.0" encoding="utf-8"?>',
                        '<BlockList>',
                        $blocks,
                        '</BlockList>'
                )));
                
            // Create metadata headers
                $headers = array();
                $headers = array_merge($headers, $this->_generateMetadataHeaders($metadata)); 
                
                // Additional headers?
                foreach ($additionalHeaders as $key => $value) {
                    $headers[$key] = $value;
                }

                // Resource name
                $resourceName = self::createResourceName($containerName , $blobName);
                
                // Perform request
                $response = $this->_performRequest($resourceName, '?comp=blocklist', Zend_Http_Client::PUT, $headers, false, $fileContents, Zend_Service_WindowsAzure_Storage::RESOURCE_BLOB, Zend_Service_WindowsAzure_Credentials_CredentialsAbstract::PERMISSION_WRITE);
                if (!$response->isSuccessful()) {
                    throw new Zend_Service_WindowsAzure_Exception($this->_getErrorMessage($response, 'Resource could not be accessed.'));
                }
        }
        
        public function getBlockList($containerName = '', $blobName = '', $type = 0)
        {
                if ($containerName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Container name is not specified.');
                }
                if (!self::isValidContainerName($containerName)) {
                    throw new Zend_Service_WindowsAzure_Exception('Container name does not adhere to container naming conventions. See http://msdn.microsoft.com/en-us/library/dd135715.aspx for more information.');
                }
                if ($blobName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Blob name is not specified.');
                }
                if ($type < 0 || $type > 2) {
                        throw new Zend_Service_WindowsAzure_Exception('Invalid type of block list to retrieve.');
                }
                        
                // Set $blockListType
                $blockListType = 'all';
                if ($type == 1) {
                    $blockListType = 'committed';
                }
                if ($type == 2) {
                    $blockListType = 'uncommitted';
                }
                    
                // Resource name
                $resourceName = self::createResourceName($containerName , $blobName);
                        
                // Perform request
                $response = $this->_performRequest($resourceName, '?comp=blocklist&blocklisttype=' . $blockListType, Zend_Http_Client::GET, array(), false, null, Zend_Service_WindowsAzure_Storage::RESOURCE_BLOB, Zend_Service_WindowsAzure_Credentials_CredentialsAbstract::PERMISSION_READ);
                if ($response->isSuccessful()) {
                    // Parse response
                    $blockList = $this->_parseResponse($response);
                    
                    // Create return value
                    $returnValue = array();
                    if ($blockList->CommittedBlocks) {
                            foreach ($blockList->CommittedBlocks->Block as $block) {
                                $returnValue['CommittedBlocks'][] = (object)array(
                                    'Name' => (string)$block->Name,
                                    'Size' => (string)$block->Size
                                );
                            }
                    }
                    if ($blockList->UncommittedBlocks)  {
                            foreach ($blockList->UncommittedBlocks->Block as $block) {
                                $returnValue['UncommittedBlocks'][] = (object)array(
                                    'Name' => (string)$block->Name,
                                    'Size' => (string)$block->Size
                                );
                            }
                    }
                    
                    return $returnValue;
                } else {
                    throw new Zend_Service_WindowsAzure_Exception($this->_getErrorMessage($response, 'Resource could not be accessed.'));
                }
        }
                        
        public function copyBlob($sourceContainerName = '', $sourceBlobName = '', $destinationContainerName = '', $destinationBlobName = '', $metadata = array(), $additionalHeaders = array())
        {
                if ($sourceContainerName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Source container name is not specified.');
                }
                if (!self::isValidContainerName($sourceContainerName)) {
                    throw new Zend_Service_WindowsAzure_Exception('Source container name does not adhere to container naming conventions. See http://msdn.microsoft.com/en-us/library/dd135715.aspx for more information.');
                }
                if ($sourceBlobName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Source blob name is not specified.');
                }
                if ($destinationContainerName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Destination container name is not specified.');
                }
                if (!self::isValidContainerName($destinationContainerName)) {
                    throw new Zend_Service_WindowsAzure_Exception('Destination container name does not adhere to container naming conventions. See http://msdn.microsoft.com/en-us/library/dd135715.aspx for more information.');
                }
                if ($destinationBlobName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Destination blob name is not specified.');
                }
                if ($sourceContainerName === '$root' && strpos($sourceBlobName, '/') !== false) {
                    throw new Zend_Service_WindowsAzure_Exception('Blobs stored in the root container can not have a name containing a forward slash (/).');
                }
                if ($destinationContainerName === '$root' && strpos($destinationBlobName, '/') !== false) {
                    throw new Zend_Service_WindowsAzure_Exception('Blobs stored in the root container can not have a name containing a forward slash (/).');
                }

                // Create metadata headers
                $headers = array();
                $headers = array_merge($headers, $this->_generateMetadataHeaders($metadata)); 
                
                // Additional headers?
                foreach ($additionalHeaders as $key => $value) {
                    $headers[$key] = $value;
                }
                
                // Resource names
                $sourceResourceName = self::createResourceName($sourceContainerName, $sourceBlobName);
                $destinationResourceName = self::createResourceName($destinationContainerName, $destinationBlobName);
                
                // Set source blob
                $headers["x-ms-copy-source"] = '/' . $this->_accountName . '/' . $sourceResourceName;

                // Perform request
                $response = $this->_performRequest($destinationResourceName, '', Zend_Http_Client::PUT, $headers, false, null, Zend_Service_WindowsAzure_Storage::RESOURCE_BLOB, Zend_Service_WindowsAzure_Credentials_CredentialsAbstract::PERMISSION_WRITE);
                if ($response->isSuccessful()) {
                        return new Zend_Service_WindowsAzure_Storage_BlobInstance(
                                $destinationContainerName,
                                $destinationBlobName,
                                $response->getHeader('Etag'),
                                $response->getHeader('Last-modified'),
                                $this->getBaseUrl() . '/' . $destinationContainerName . '/' . $destinationBlobName,
                                0,
                                '',
                                '',
                                '',
                                false,
                        $metadata
                        );
                } else {
                    throw new Zend_Service_WindowsAzure_Exception($this->_getErrorMessage($response, 'Resource could not be accessed.'));
                }
        }
        
        public function getBlob($containerName = '', $blobName = '', $localFileName = '', $additionalHeaders = array())
        {
                if ($containerName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Container name is not specified.');
                }
                if (!self::isValidContainerName($containerName)) {
                    throw new Zend_Service_WindowsAzure_Exception('Container name does not adhere to container naming conventions. See http://msdn.microsoft.com/en-us/library/dd135715.aspx for more information.');
                }
                if ($blobName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Blob name is not specified.');
                }
                if ($localFileName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Local file name is not specified.');
                }
                        
                // Additional headers?
                $headers = array();
                foreach ($additionalHeaders as $key => $value) {
                    $headers[$key] = $value;
                }
                
                // Resource name
                $resourceName = self::createResourceName($containerName , $blobName);
                
                // Perform request
                $response = $this->_performRequest($resourceName, '', Zend_Http_Client::GET, $headers, false, null, Zend_Service_WindowsAzure_Storage::RESOURCE_BLOB, Zend_Service_WindowsAzure_Credentials_CredentialsAbstract::PERMISSION_READ);
                if ($response->isSuccessful()) {
                        file_put_contents($localFileName, $response->getBody());
                } else {
                    throw new Zend_Service_WindowsAzure_Exception($this->_getErrorMessage($response, 'Resource could not be accessed.'));
                }
        }
        
        public function getBlobInstance($containerName = '', $blobName = '', $additionalHeaders = array())
        {
                if ($containerName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Container name is not specified.');
                }
                if (!self::isValidContainerName($containerName)) {
                    throw new Zend_Service_WindowsAzure_Exception('Container name does not adhere to container naming conventions. See http://msdn.microsoft.com/en-us/library/dd135715.aspx for more information.');
                }
                if ($blobName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Blob name is not specified.');
                }
                if ($containerName === '$root' && strpos($blobName, '/') !== false) {
                    throw new Zend_Service_WindowsAzure_Exception('Blobs stored in the root container can not have a name containing a forward slash (/).');
                }
                
                // Additional headers?
                $headers = array();
                foreach ($additionalHeaders as $key => $value) {
                    $headers[$key] = $value;
                }
                
        // Resource name
                $resourceName = self::createResourceName($containerName , $blobName);
                    
                // Perform request
                $response = $this->_performRequest($resourceName, '', Zend_Http_Client::HEAD, $headers, false, null, Zend_Service_WindowsAzure_Storage::RESOURCE_BLOB, Zend_Service_WindowsAzure_Credentials_CredentialsAbstract::PERMISSION_READ);
                if ($response->isSuccessful()) {
                    // Parse metadata
                    $metadata = $this->_parseMetadataHeaders($response->getHeaders());

                    // Return blob
                        return new Zend_Service_WindowsAzure_Storage_BlobInstance(
                                $containerName,
                                $blobName,
                                $response->getHeader('Etag'),
                                $response->getHeader('Last-modified'),
                                $this->getBaseUrl() . '/' . $containerName . '/' . $blobName,
                                $response->getHeader('Content-Length'),
                                $response->getHeader('Content-Type'),
                                $response->getHeader('Content-Encoding'),
                                $response->getHeader('Content-Language'),
                                false,
                        $metadata
                        );
                } else {
                    throw new Zend_Service_WindowsAzure_Exception($this->_getErrorMessage($response, 'Resource could not be accessed.'));
                }
        }
        
        public function getBlobMetadata($containerName = '', $blobName = '')
        {
                if ($containerName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Container name is not specified.');
                }
                if (!self::isValidContainerName($containerName)) {
                    throw new Zend_Service_WindowsAzure_Exception('Container name does not adhere to container naming conventions. See http://msdn.microsoft.com/en-us/library/dd135715.aspx for more information.');
                }
                if ($blobName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Blob name is not specified.');
                }
                if ($containerName === '$root' && strpos($blobName, '/') !== false) {
                    throw new Zend_Service_WindowsAzure_Exception('Blobs stored in the root container can not have a name containing a forward slash (/).');
                }
                
            return $this->getBlobInstance($containerName, $blobName)->Metadata;
        }
        
        public function setBlobMetadata($containerName = '', $blobName = '', $metadata = array(), $additionalHeaders = array())
        {
                if ($containerName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Container name is not specified.');
                }
                if (!self::isValidContainerName($containerName)) {
                    throw new Zend_Service_WindowsAzure_Exception('Container name does not adhere to container naming conventions. See http://msdn.microsoft.com/en-us/library/dd135715.aspx for more information.');
                }
                if ($blobName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Blob name is not specified.');
                }
                if ($containerName === '$root' && strpos($blobName, '/') !== false) {
                    throw new Zend_Service_WindowsAzure_Exception('Blobs stored in the root container can not have a name containing a forward slash (/).');
                }
                if (count($metadata) == 0) {
                    return;
                }
                    
                // Create metadata headers
                $headers = array();
                $headers = array_merge($headers, $this->_generateMetadataHeaders($metadata)); 
                
                // Additional headers?
                foreach ($additionalHeaders as $key => $value) {
                    $headers[$key] = $value;
                }
                
                // Perform request
                $response = $this->_performRequest($containerName . '/' . $blobName, '?comp=metadata', Zend_Http_Client::PUT, $headers, false, null, Zend_Service_WindowsAzure_Storage::RESOURCE_BLOB, Zend_Service_WindowsAzure_Credentials_CredentialsAbstract::PERMISSION_WRITE);
                if (!$response->isSuccessful()) {
                    throw new Zend_Service_WindowsAzure_Exception($this->_getErrorMessage($response, 'Resource could not be accessed.'));
                }
        }
        
        public function deleteBlob($containerName = '', $blobName = '', $additionalHeaders = array())
        {
                if ($containerName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Container name is not specified.');
                }
                if (!self::isValidContainerName($containerName)) {
                    throw new Zend_Service_WindowsAzure_Exception('Container name does not adhere to container naming conventions. See http://msdn.microsoft.com/en-us/library/dd135715.aspx for more information.');
                }
                if ($blobName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Blob name is not specified.');
                }
                if ($containerName === '$root' && strpos($blobName, '/') !== false) {
                    throw new Zend_Service_WindowsAzure_Exception('Blobs stored in the root container can not have a name containing a forward slash (/).');
                }
                        
                // Additional headers?
                $headers = array();
                foreach ($additionalHeaders as $key => $value) {
                    $headers[$key] = $value;
                }
                
                // Resource name
                $resourceName = self::createResourceName($containerName , $blobName);
                
                // Perform request
                $response = $this->_performRequest($resourceName, '', Zend_Http_Client::DELETE, $headers, false, null, Zend_Service_WindowsAzure_Storage::RESOURCE_BLOB, Zend_Service_WindowsAzure_Credentials_CredentialsAbstract::PERMISSION_WRITE);
                if (!$response->isSuccessful()) {
                    throw new Zend_Service_WindowsAzure_Exception($this->_getErrorMessage($response, 'Resource could not be accessed.'));
                }
        }
        
        public function listBlobs($containerName = '', $prefix = '', $delimiter = '', $maxResults = null, $marker = null, $currentResultCount = 0)
        {
                if ($containerName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Container name is not specified.');
                }
                if (!self::isValidContainerName($containerName)) {
                    throw new Zend_Service_WindowsAzure_Exception('Container name does not adhere to container naming conventions. See http://msdn.microsoft.com/en-us/library/dd135715.aspx for more information.');
                }
                        
            // Build query string
            $queryString = '?restype=container&comp=list';
        if (!is_null($prefix)) {
                $queryString .= '&prefix=' . $prefix;
        }
                if ($delimiter !== '') {
                        $queryString .= '&delimiter=' . $delimiter;
                }
            if (!is_null($maxResults)) {
                $queryString .= '&maxresults=' . $maxResults;
            }
            if (!is_null($marker)) {
                $queryString .= '&marker=' . $marker;
            }

            // Perform request
                $response = $this->_performRequest($containerName, $queryString, Zend_Http_Client::GET, array(), false, null, Zend_Service_WindowsAzure_Storage::RESOURCE_BLOB, Zend_Service_WindowsAzure_Credentials_CredentialsAbstract::PERMISSION_LIST);
                if ($response->isSuccessful()) {
                    // Return value
                    $blobs = array();
                    
                        // Blobs
                        $xmlBlobs = $this->_parseResponse($response)->Blobs->Blob;
                        if (!is_null($xmlBlobs)) {
                                for ($i = 0; $i < count($xmlBlobs); $i++) {
                                        $blobs[] = new Zend_Service_WindowsAzure_Storage_BlobInstance(
                                                $containerName,
                                                (string)$xmlBlobs[$i]->Name,
                                                (string)$xmlBlobs[$i]->Etag,
                                                (string)$xmlBlobs[$i]->LastModified,
                                                (string)$xmlBlobs[$i]->Url,
                                                (string)$xmlBlobs[$i]->Size,
                                                (string)$xmlBlobs[$i]->ContentType,
                                                (string)$xmlBlobs[$i]->ContentEncoding,
                                                (string)$xmlBlobs[$i]->ContentLanguage,
                                                false
                                        );
                                }
                        }
                        
                        // Blob prefixes (folders)
                        $xmlBlobs = $this->_parseResponse($response)->Blobs->BlobPrefix;
                        
                        if (!is_null($xmlBlobs)) {
                                for ($i = 0; $i < count($xmlBlobs); $i++) {
                                        $blobs[] = new Zend_Service_WindowsAzure_Storage_BlobInstance(
                                                $containerName,
                                                (string)$xmlBlobs[$i]->Name,
                                                '',
                                                '',
                                                '',
                                                0,
                                                '',
                                                '',
                                                '',
                                                true
                                        );
                                }
                        }
                        
                        // More blobs?
                        $xmlMarker = (string)$this->_parseResponse($response)->NextMarker;
                        $currentResultCount = $currentResultCount + count($blobs);
                        if (!is_null($maxResults) && $currentResultCount < $maxResults) {
                        if (!is_null($xmlMarker) && $xmlMarker != '') {
                            $blobs = array_merge($blobs, $this->listBlobs($containerName, $prefix, $delimiter, $maxResults, $marker, $currentResultCount));
                        }
                        }
                        if (!is_null($maxResults) && count($blobs) > $maxResults) {
                            $blobs = array_slice($blobs, 0, $maxResults);
                        }
                        
                        return $blobs;
                } else {        
                    throw new Zend_Service_WindowsAzure_Exception($this->_getErrorMessage($response, 'Resource could not be accessed.'));
                }
        }
        
        public function generateSharedAccessUrl($containerName = '', $blobName = '', $resource = 'b', $permissions = 'r', $start = '', $expiry = '', $identifier = '')
        {
                if ($containerName === '') {
                        throw new Zend_Service_WindowsAzure_Exception('Container name is not specified.');
                }
                if (!self::isValidContainerName($containerName)) {
                    throw new Zend_Service_WindowsAzure_Exception('Container name does not adhere to container naming conventions. See http://msdn.microsoft.com/en-us/library/dd135715.aspx for more information.');
                }

        // Resource name
                $resourceName = self::createResourceName($containerName , $blobName);

                // Generate URL
                return $this->getBaseUrl() . '/' . $resourceName . '?' .
                    $this->_sharedAccessSignatureCredentials->createSignedQueryString(
                        $resourceName,
                        '',
                        $resource,
                        $permissions,
                        $start,
                        $expiry,
                        $identifier);
        }
        
    public function registerAsClient($name)
    {
        self::$_wrapperClients[$name] = $this;
        return $this;
    }

    public function unregisterAsClient($name)
    {
        unset(self::$_wrapperClients[$name]);
        return $this;
    }

    public static function getWrapperClient($name)
    {
        return self::$_wrapperClients[$name];
    }

    public function registerStreamWrapper($name = 'azure')
    {
        require_once 'Zend/Service/WindowsAzure/Storage/Blob/Stream.php';

        stream_register_wrapper($name, 'Zend_Service_WindowsAzure_Storage_Blob_Stream');
        $this->registerAsClient($name);
    }

    public function unregisterStreamWrapper($name = 'azure')
    {
        stream_wrapper_unregister($name);
        $this->unregisterAsClient($name);
    }
    
    public static function createResourceName($containerName = '', $blobName = '')
    {
                // Resource name
                $resourceName = $containerName . '/' . $blobName;
                if ($containerName === '' || $containerName === '$root') {
                    $resourceName = $blobName;
                }
                if ($blobName === '') {
                    $resourceName = $containerName;
                }
                    
                return $resourceName;
    }
        
    public static function isValidContainerName($containerName = '')
    {
        if ($containerName == '$root') {
            return true;
        }
            
        if (preg_match("/^[a-z0-9][a-z0-9-]*$/", $containerName) === 0) {
            return false;
        }
    
        if (strpos($containerName, '--') !== false) {
            return false;
        }
    
        if (strtolower($containerName) != $containerName) {
            return false;
        }
    
        if (strlen($containerName) < 3 || strlen($containerName) > 63) {
            return false;
        }
            
        if (substr($containerName, -1) == '-') {
            return false;
        }
    
        return true;
    }
    
        protected function _getErrorMessage(Zend_Http_Response $response, $alternativeError = 'Unknown error.')
        {
                $response = $this->_parseResponse($response);
                if ($response && $response->Message) {
                    return (string)$response->Message;
                } else {
                    return $alternativeError;
                }
        }
        
        protected function _generateBlockId($part = 0)
        {
                $returnValue = $part;
                while (strlen($returnValue) < 64) {
                        $returnValue = '0' . $returnValue;
                }
                
                return $returnValue;
        }
}