Elgg-Lorea-Hydra/vendor/knplabs/gaufrette/spec/Gaufrette/Adapter/AzureBlobStorage.php

<?php

namespace spec\Gaufrette\Adapter;

use PHPSpec2\ObjectBehavior;

use WindowsAzure\Blob\Models\Blob;
use WindowsAzure\Common\ServiceException;

class AzureBlobStorage extends ObjectBehavior
{
    /**
     * @param \Gaufrette\Adapter\AzureBlobStorage\BlobProxyFactoryInterface $blobProxyFactory
     */
    public function let($blobProxyFactory)
    {
        $this->beConstructedWith($blobProxyFactory, 'containerName');
    }

    public function it_should_be_initializable()
    {
        $this->shouldHaveType('Gaufrette\Adapter\AzureBlobStorage');
        $this->shouldHaveType('Gaufrette\Adapter');
        $this->shouldHaveType('Gaufrette\Adapter\MetadataSupporter');
    }

    /**
     * @param \Gaufrette\Adapter\AzureBlobStorage\BlobProxyFactoryInterface $blobProxyFactory
     * @param \WindowsAzure\Blob\Internal\IBlob                             $blobProxy
     * @param \WindowsAzure\Blob\Models\GetBlobResult                       $getBlobResult
     */
    public function it_should_read_file($blobProxyFactory, $blobProxy, $getBlobResult)
    {
        $getBlobResult
            ->getContentStream()
            ->shouldBeCalled()
            //azure blob content is handled as stream so we need to fake it
            ->willReturn(fopen('data://text/plain,some content','r'));

        $blobProxy
            ->getBlob('containerName', 'filename')
            ->shouldBeCalled()
            ->willReturn($getBlobResult);

        $blobProxyFactory
            ->create()
            ->shouldBeCalled()
            ->willReturn($blobProxy);

        $this->read('filename')->shouldReturn('some content');
    }

    /**
     * @param \Gaufrette\Adapter\AzureBlobStorage\BlobProxyFactoryInterface $blobProxyFactory
     * @param \WindowsAzure\Blob\Internal\IBlob                             $blobProxy
     */
    public function it_should_return_false_when_cannot_read($blobProxyFactory, $blobProxy)
    {
        $blobProxy
            ->getBlob('containerName', 'filename')
            ->shouldBeCalled()
            ->willThrow(new ServiceException(500));

        $blobProxyFactory
            ->create()
            ->shouldBeCalled()
            ->willReturn($blobProxy);

        $this->read('filename')->shouldReturn(false);
    }

    /**
     * @param \Gaufrette\Adapter\AzureBlobStorage\BlobProxyFactoryInterface $blobProxyFactory
     * @param \WindowsAzure\Blob\Internal\IBlob                             $blobProxy
     */
    public function it_should_not_mask_exception_when_read($blobProxyFactory, $blobProxy)
    {
        $blobProxy
            ->getBlob('containerName', 'filename')
            ->shouldBeCalled()
            ->willThrow(new \RuntimeException('read'));

        $blobProxyFactory
            ->create()
            ->shouldBeCalled()
            ->willReturn($blobProxy);

        $this->shouldThrow(new \RuntimeException('read'))->duringRead('filename');
    }

    /**
     * @param \Gaufrette\Adapter\AzureBlobStorage\BlobProxyFactoryInterface $blobProxyFactory
     * @param \WindowsAzure\Blob\Internal\IBlob                             $blobProxy
     */
    public function it_should_rename_file($blobProxyFactory, $blobProxy)
    {
        $blobProxy
            ->copyBlob('containerName', 'filename2', 'containerName', 'filename1')
            ->shouldBeCalled();

        $blobProxy
            ->deleteBlob('containerName', 'filename1')
            ->shouldBeCalled();

        $blobProxyFactory
            ->create()
            ->shouldBeCalled()
            ->willReturn($blobProxy);

        $this->rename('filename1', 'filename2')->shouldReturn(true);
    }

    /**
     * @param \Gaufrette\Adapter\AzureBlobStorage\BlobProxyFactoryInterface $blobProxyFactory
     * @param \WindowsAzure\Blob\Internal\IBlob                             $blobProxy
     */
    public function it_should_return_false_when_cannot_rename($blobProxyFactory, $blobProxy)
    {
        $blobProxy
            ->copyBlob('containerName', 'filename2', 'containerName', 'filename1')
            ->shouldBeCalled()
            ->willThrow(new ServiceException(500));

        $blobProxyFactory
            ->create()
            ->shouldBeCalled()
            ->willReturn($blobProxy);

        $this->rename('filename1', 'filename2')->shouldReturn(false);
    }

    /**
     * @param \Gaufrette\Adapter\AzureBlobStorage\BlobProxyFactoryInterface $blobProxyFactory
     * @param \WindowsAzure\Blob\Internal\IBlob                             $blobProxy
     */
    public function it_should_not_mask_exception_when_rename($blobProxyFactory, $blobProxy)
    {
        $blobProxy
            ->copyBlob('containerName', 'filename2', 'containerName', 'filename1')
            ->shouldBeCalled()
            ->willThrow(new \RuntimeException('rename'));

        $blobProxyFactory
            ->create()
            ->shouldBeCalled()
            ->willReturn($blobProxy);

        $this->shouldThrow(new \RuntimeException('rename'))->duringRename('filename1', 'filename2');
    }

    /**
     * @param \Gaufrette\Adapter\AzureBlobStorage\BlobProxyFactoryInterface $blobProxyFactory
     * @param \WindowsAzure\Blob\Internal\IBlob                             $blobProxy
     */
    public function it_should_write_file($blobProxyFactory, $blobProxy)
    {
        $blobProxy
            ->createBlockBlob('containerName', 'filename', 'some content',
                \Mockery::type('\WindowsAzure\Blob\Models\CreateBlobOptions'))
            ->shouldBeCalled();

        $blobProxyFactory
            ->create()
            ->shouldBeCalled()
            ->willReturn($blobProxy);

        $this->write('filename', 'some content')->shouldReturn(12);
    }

    /**
     * @param \Gaufrette\Adapter\AzureBlobStorage\BlobProxyFactoryInterface $blobProxyFactory
     * @param \WindowsAzure\Blob\Internal\IBlob                             $blobProxy
     */
    public function it_should_return_false_when_cannot_write($blobProxyFactory, $blobProxy)
    {
        $blobProxy
            ->createBlockBlob('containerName', 'filename', 'some content',
                \Mockery::type('\WindowsAzure\Blob\Models\CreateBlobOptions'))
            ->willThrow(new ServiceException(500));

        $blobProxyFactory
            ->create()
            ->shouldBeCalled()
            ->willReturn($blobProxy);

        $this->write('filename', 'some content')->shouldReturn(false);
    }

    /**
     * @param \Gaufrette\Adapter\AzureBlobStorage\BlobProxyFactoryInterface $blobProxyFactory
     * @param \WindowsAzure\Blob\Internal\IBlob                             $blobProxy
     */
    public function it_should_not_mask_exception_when_write($blobProxyFactory, $blobProxy)
    {
        $blobProxy
            ->createBlockBlob('containerName', 'filename', 'some content',
                \Mockery::type('\WindowsAzure\Blob\Models\CreateBlobOptions'))
            ->willThrow(new \RuntimeException('write'));

        $blobProxyFactory
            ->create()
            ->shouldBeCalled()
            ->willReturn($blobProxy);

        $this->shouldThrow(new \RuntimeException('write'))->duringWrite('filename', 'some content');
    }

    /**
     * @param \Gaufrette\Adapter\AzureBlobStorage\BlobProxyFactoryInterface $blobProxyFactory
     * @param \WindowsAzure\Blob\Internal\IBlob                             $blobProxy
     * @param \WindowsAzure\Blob\Models\GetBlobResult                       $getBlobResult
     */
    public function it_should_check_if_file_exists($blobProxyFactory, $blobProxy, $getBlobResult)
    {
        $blobProxyFactory
            ->create()
            ->shouldBeCalled()
            ->willReturn($blobProxy);

        $blobProxy
            ->getBlob('containerName', 'filename')
            ->shouldBeCalled()
            ->willThrow(new ServiceException(404));

        $this->exists('filename')->shouldReturn(false);

        $blobProxy
            ->getBlob('containerName', 'filename2')
            ->shouldBeCalled()
            ->willReturn($getBlobResult);

        $this->exists('filename2')->shouldReturn(true);
    }

    /**
     * @param \Gaufrette\Adapter\AzureBlobStorage\BlobProxyFactoryInterface $blobProxyFactory
     * @param \WindowsAzure\Blob\Internal\IBlob                             $blobProxy
     */
    public function it_should_not_mask_exception_when_check_if_file_exists($blobProxyFactory, $blobProxy)
    {
        $blobProxyFactory
            ->create()
            ->shouldBeCalled()
            ->willReturn($blobProxy);

        $blobProxy
            ->getBlob('containerName', 'filename')
            ->shouldBeCalled()
            ->willThrow(new \RuntimeException('exists'));

        $this->shouldThrow(new \RuntimeException('exists'))->duringExists('filename');
    }

    /**
     * @param \Gaufrette\Adapter\AzureBlobStorage\BlobProxyFactoryInterface $blobProxyFactory
     * @param \WindowsAzure\Blob\Internal\IBlob                             $blobProxy
     * @param \WindowsAzure\Blob\Models\GetBlobPropertiesResult             $getBlobPropertiesResult
     * @param \WindowsAzure\Blob\Models\BlobProperties                      $blobProperties
     */
    public function it_should_get_file_mtime($blobProxyFactory, $blobProxy, $getBlobPropertiesResult, $blobProperties)
    {
        $blobProxyFactory
            ->create()
            ->shouldBeCalled()
            ->willReturn($blobProxy);

        $blobProxy
            ->getBlobProperties('containerName', 'filename')
            ->shouldBeCalled()
            ->willReturn($getBlobPropertiesResult);

        $getBlobPropertiesResult
            ->getProperties()
            ->shouldBeCalled()
            ->willReturn($blobProperties);

        $blobProperties
            ->getLastModified()
            ->shouldBeCalled()
            ->willReturn(new \DateTime('1987-12-28 20:00:00'));

        $this->mtime('filename')->shouldReturn(strtotime('1987-12-28 20:00:00'));
    }

    /**
     * @param \Gaufrette\Adapter\AzureBlobStorage\BlobProxyFactoryInterface $blobProxyFactory
     * @param \WindowsAzure\Blob\Internal\IBlob                             $blobProxy
     */
    public function it_should_return_false_when_cannot_mtime($blobProxyFactory, $blobProxy)
    {
        $blobProxyFactory
            ->create()
            ->shouldBeCalled()
            ->willReturn($blobProxy);

        $blobProxy
            ->getBlobProperties('containerName', 'filename')
            ->shouldBeCalled()
            ->willThrow(new ServiceException(500));

        $this->mtime('filename')->shouldReturn(false);
    }

    /**
     * @param \Gaufrette\Adapter\AzureBlobStorage\BlobProxyFactoryInterface $blobProxyFactory
     * @param \WindowsAzure\Blob\Internal\IBlob                             $blobProxy
     */
    public function it_should_not_mask_exception_when_get_mtime($blobProxyFactory, $blobProxy)
    {
        $blobProxyFactory
            ->create()
            ->shouldBeCalled()
            ->willReturn($blobProxy);

        $blobProxy
            ->getBlobProperties('containerName', 'filename')
            ->shouldBeCalled()
            ->willThrow(new \RuntimeException('mtime'));

        $this->shouldThrow(new \RuntimeException('mtime'))->duringMtime('filename');
    }

    /**
     * @param \Gaufrette\Adapter\AzureBlobStorage\BlobProxyFactoryInterface $blobProxyFactory
     * @param \WindowsAzure\Blob\Internal\IBlob                             $blobProxy
     */
    public function it_should_delete_file($blobProxyFactory, $blobProxy)
    {
        $blobProxyFactory
            ->create()
            ->shouldBeCalled()
            ->willReturn($blobProxy);

        $blobProxy
            ->deleteBlob('containerName', 'filename')
            ->shouldBeCalled();

        $this->delete('filename')->shouldReturn(true);
    }

    /**
     * @param \Gaufrette\Adapter\AzureBlobStorage\BlobProxyFactoryInterface $blobProxyFactory
     * @param \WindowsAzure\Blob\Internal\IBlob                             $blobProxy
     */
    public function it_should_return_false_when_cannot_delete_file($blobProxyFactory, $blobProxy)
    {
        $blobProxyFactory
            ->create()
            ->shouldBeCalled()
            ->willReturn($blobProxy);

        $blobProxy
            ->deleteBlob('containerName', 'filename')
            ->shouldBeCalled()
            ->willThrow(new ServiceException(500));

        $this->delete('filename')->shouldReturn(false);
    }

    /**
     * @param \Gaufrette\Adapter\AzureBlobStorage\BlobProxyFactoryInterface $blobProxyFactory
     * @param \WindowsAzure\Blob\Internal\IBlob                             $blobProxy
     */
    public function it_should_not_mask_exception_when_delete($blobProxyFactory, $blobProxy)
    {
        $blobProxyFactory
            ->create()
            ->shouldBeCalled()
            ->willReturn($blobProxy);

        $blobProxy
            ->deleteBlob('containerName', 'filename')
            ->shouldBeCalled()
            ->willThrow(new \RuntimeException('delete'));

        $this->shouldThrow(new \RuntimeException('delete'))->duringDelete('filename');
    }

    /**
     * @param \Gaufrette\Adapter\AzureBlobStorage\BlobProxyFactoryInterface $blobProxyFactory
     * @param \WindowsAzure\Blob\Internal\IBlob                             $blobProxy
     * @param \WindowsAzure\Blob\Models\ListBlobsResult                     $listBlobResult
     */
    public function it_should_get_keys($blobProxyFactory, $blobProxy, $listBlobResult)
    {
        $fileNames = array('aaa', 'aaa/filename', 'filename1', 'filename2');
        $blobs = array();
        foreach ($fileNames as $fileName) {
            $blob = new Blob();
            $blob->setName($fileName);
            $blobs[] = $blob;
        }

        $blobProxyFactory
            ->create()
            ->shouldBeCalled()
            ->willReturn($blobProxy);

        $blobProxy
            ->listBlobs('containerName')
            ->shouldBeCalled()
            ->willReturn($listBlobResult);

        $listBlobResult
            ->getBlobs()
            ->shouldBeCalled()
            ->willReturn($blobs);

        $this->keys()->shouldReturn(array('aaa', 'aaa/filename', 'filename1', 'filename2'));
    }

    /**
     * @param \Gaufrette\Adapter\AzureBlobStorage\BlobProxyFactoryInterface $blobProxyFactory
     * @param \WindowsAzure\Blob\Internal\IBlob                             $blobProxy
     */
    public function it_should_not_mask_exception_when_get_keys($blobProxyFactory, $blobProxy)
    {
        $blobProxyFactory
            ->create()
            ->shouldBeCalled()
            ->willReturn($blobProxy);

        $blobProxy
            ->listBlobs('containerName')
            ->shouldBeCalled()
            ->willThrow(new \RuntimeException('keys'));

        $this->shouldThrow(new \RuntimeException('keys'))->duringKeys();
    }

    /**
     * @param \Gaufrette\Adapter\AzureBlobStorage\BlobProxyFactoryInterface $blobProxyFactory
     * @param \WindowsAzure\Blob\Internal\IBlob                             $blobProxy
     */
    public function it_should_handle_dirs($blobProxyFactory, $blobProxy)
    {
        $blobProxyFactory
            ->create()
            ->shouldBeCalled()
            ->willReturn($blobProxy);

        $blobProxy
            ->getBlob('containerName', 'filename')
            ->shouldNotBeCalled();
        $blobProxy
            ->getBlob('containerName', 'filename/')
            ->shouldBeCalled()
            ->willThrow(new ServiceException(404));
        $blobProxy
            ->getBlob('containerName', 'dirname/')
            ->shouldBeCalled();

        $this->isDirectory('filename')->shouldReturn(false);
        $this->isDirectory('dirname')->shouldReturn(true);
    }

    /**
     * @param \Gaufrette\Adapter\AzureBlobStorage\BlobProxyFactoryInterface $blobProxyFactory
     * @param \WindowsAzure\Blob\Internal\IBlob                             $blobProxy
     */
    public function it_should_create_container($blobProxyFactory, $blobProxy)
    {
        $blobProxyFactory
            ->create()
            ->shouldBeCalled()
            ->willReturn($blobProxy);

        $blobProxy
            ->createContainer('containerName', null)
            ->shouldBeCalled();

        $this->createContainer('containerName');
    }

    /**
     * @param \Gaufrette\Adapter\AzureBlobStorage\BlobProxyFactoryInterface $blobProxyFactory
     * @param \WindowsAzure\Blob\Internal\IBlob                             $blobProxy
     */
    public function it_should_fail_when_cannot_create_container($blobProxyFactory, $blobProxy)
    {
        $blobProxyFactory
            ->create()
            ->shouldBeCalled()
            ->willReturn($blobProxy);

        $blobProxy
            ->createContainer('containerName', null)
            ->shouldBeCalled()
            ->willThrow(new ServiceException(500));

        $this->shouldThrow(new \RuntimeException('Failed to create the configured container "containerName": 0 ().', null))->duringCreateContainer('containerName');
    }

}