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

Go to the documentation of this file.

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

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

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

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

require_once 'Zend/Http/Client.php';

require_once 'Zend/Http/Response.php';

abstract class Zend_Service_WindowsAzure_Storage_BatchStorageAbstract
    extends Zend_Service_WindowsAzure_Storage
{       
    protected $_currentBatch = null;
    
    public function setCurrentBatch(Zend_Service_WindowsAzure_Storage_Batch $batch = null)
    {
        if (!is_null($batch) && $this->isInBatch()) {
            throw new Zend_Service_WindowsAzure_Exception('Only one batch can be active at a time.');
        }
        $this->_currentBatch = $batch;
    }
    
    public function getCurrentBatch()
    {
        return $this->_currentBatch;
    }
    
    public function isInBatch()
    {
        return !is_null($this->_currentBatch);
    }
    
    public function startBatch()
    {
        return new Zend_Service_WindowsAzure_Storage_Batch($this, $this->getBaseUrl());
    }
        
        public function performBatch($operations = array(), $forTableStorage = false, $isSingleSelect = false, $resourceType = Zend_Service_WindowsAzure_Storage::RESOURCE_UNKNOWN, $requiredPermission = Zend_Service_WindowsAzure_Credentials_CredentialsAbstract::PERMISSION_READ)
        {
            // Generate boundaries
            $batchBoundary = 'batch_' . md5(time() . microtime());
            $changesetBoundary = 'changeset_' . md5(time() . microtime());
            
            // Set headers
            $headers = array();
            
                // Add version header
                $headers['x-ms-version'] = $this->_apiVersion;
                
                // Add content-type header
                $headers['Content-Type'] = 'multipart/mixed; boundary=' . $batchBoundary;

                // Set path and query string
                $path           = '/$batch';
                $queryString    = '';
                
                // Set verb
                $httpVerb = Zend_Http_Client::POST;
                
                // Generate raw data
        $rawData = '';
                
                // Single select?
                if ($isSingleSelect) {
                    $operation = $operations[0];
                    $rawData .= '--' . $batchBoundary . "\n";
            $rawData .= 'Content-Type: application/http' . "\n";
            $rawData .= 'Content-Transfer-Encoding: binary' . "\n\n";
            $rawData .= $operation; 
            $rawData .= '--' . $batchBoundary . '--';
                } else {
                $rawData .= '--' . $batchBoundary . "\n";
                $rawData .= 'Content-Type: multipart/mixed; boundary=' . $changesetBoundary . "\n\n";
                
                        // Add operations
                        foreach ($operations as $operation)
                        {
                    $rawData .= '--' . $changesetBoundary . "\n";
                        $rawData .= 'Content-Type: application/http' . "\n";
                        $rawData .= 'Content-Transfer-Encoding: binary' . "\n\n";
                        $rawData .= $operation;
                        }
                        $rawData .= '--' . $changesetBoundary . '--' . "\n";
                                    
                $rawData .= '--' . $batchBoundary . '--';
                }

                // Generate URL and sign request
                $requestUrl     = $this->_credentials->signRequestUrl($this->getBaseUrl() . $path . $queryString, $resourceType, $requiredPermission);
                $requestHeaders = $this->_credentials->signRequestHeaders($httpVerb, $path, $queryString, $headers, $forTableStorage, $resourceType, $requiredPermission);

                // Prepare request
                $this->_httpClientChannel->resetParameters(true);
                $this->_httpClientChannel->setUri($requestUrl);
                $this->_httpClientChannel->setHeaders($requestHeaders);
                $this->_httpClientChannel->setRawData($rawData);
                
                // Execute request
                $response = $this->_retryPolicy->execute(
                    array($this->_httpClientChannel, 'request'),
                    array($httpVerb)
                );

                return $response;
        }
}