MicrosoftAzure\Storage\Blob\BlobRestProxy::uploadPageBlobAsync()

Complexity

Conditions	4
Paths	2

Size

Total Lines	102
Code Lines	66

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    private function uploadPageBlobAsync(
        $container,
        $blob,
        $content,
        Models\CreateBlobOptions $options = null
    ) {
        Validate::isString($container, 'container');
        Validate::notNullOrEmpty($container, 'container');

        Validate::isString($blob, 'blob');
        Validate::notNullOrEmpty($blob, 'blob');

        if (is_null($options)) {
            $options = new CreateBlobOptions();
        }
        
        $method      = Resources::HTTP_PUT;
        $postParams  = array();
        $queryParams = array();
        $path        = $this->_createPath($container, $blob);

        $this->addOptionalQueryParam($queryParams, Resources::QP_COMP, 'page');
        $this->addOptionalQueryParam(
            $queryParams,
            Resources::QP_TIMEOUT,
            $options->getTimeout()
        );

        $pageSize = Resources::MB_IN_BYTES_4;
        $start = 0;
        $end = -1;

        //create the generator for requests.
        $generator = function () use (
            $content,
            $pageSize,
            $method,
            $postParams,
            $queryParams,
            $path,
            &$start,
            &$end,
            $options
        ) {
            //read the content.
            $pageContent;

The variable $pageContent seems to be never defined.

            $size;

The variable $size seems to be never defined.

            
            do {
                $pageContent = $content->read($pageSize);
                $size = strlen($pageContent);

                if ($size == 0) {
                    return null;
                }
                
                $end += $size;
                $start = ($end - $size + 1);
                
                // If all Zero, skip this range
            } while (Utilities::allZero($pageContent));

            $headers = array();
            $headers = $this->_addOptionalRangeHeader(
                $headers,
                $start,
                $end
            );
            $headers = $this->addOptionalAccessConditionHeader(
                $headers,
                $options->getAccessConditions()
            );
            $this->addOptionalHeader(
                $headers,
                Resources::X_MS_LEASE_ID,
                $options->getLeaseId()
            );
            $this->addOptionalHeader(
                $headers,
                Resources::X_MS_PAGE_WRITE,
                PageWriteOption::UPDATE_OPTION
            );

            //return the array of requests.
            return $this->createRequest(
                $method,
                $headers,
                $queryParams,
                $postParams,
                $path,
                LocationMode::PRIMARY_ONLY,
                $pageContent
            );
        };

        //Send the request concurrently.
        //Does not need to evaluate the results. If operation is not successful,
        //exception will be thrown.
        return $this->sendConcurrentAsync(

The expression return $this->sendConcurrentAsync($generator, MicrosoftAzure\Storage\Common\Internal\Resources::STATUS_CREATED, $options->getRequestOptions()) returns the type array which is incompatible with the documented return type GuzzleHttp\Promise\PromiseInterface.

            $generator,
            Resources::STATUS_CREATED,
            $options->getRequestOptions()

The method getRequestOptions() does not exist on MicrosoftAzure\Storage\Blob\Models\CreateBlobOptions.

        );