Storeman\Operation\DownloadOperation

Complexity

Total Complexity

5

Size/Duplication

Total Lines	52
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	execute()	0	17	2
A	__toString()	0	6	2

<?php

namespace Storeman\Operation;

use Storeman\StorageAdapter\StorageAdapterInterface;

class DownloadOperation implements OperationInterface
{
    /**
     * @var string
     */
    protected $relativePath;

    /**
     * @var string
     */
    protected $blobId;

    /**
     * @var array
     */
    protected $streamFilterConfigMap;

    public function __construct(string $relativePath, string $blobId, array $streamFilterConfigMap = [])
    {
        $this->relativePath = $relativePath;
        $this->blobId = $blobId;
        $this->streamFilterConfigMap = $streamFilterConfigMap;
    }

    public function execute(string $localBasePath, StorageAdapterInterface $storageAdapter): bool
    {
        $localStream = fopen($localBasePath . $this->relativePath, 'wb');
        $remoteStream = $storageAdapter->getReadStream($this->blobId);

        foreach ($this->streamFilterConfigMap as $filterName => $filterParams)
        {
            stream_filter_append($remoteStream, $filterName, STREAM_FILTER_READ, $filterParams);
        }

        $bytesCopied = stream_copy_to_stream($remoteStream, $localStream);

        fclose($remoteStream);
        fclose($localStream);

        return $bytesCopied !== false;
    }

    /**
     * @codeCoverageIgnore
     */
    public function __toString(): string
    {
        $filterNames = implode(',', array_keys($this->streamFilterConfigMap)) ?: '-';

        return sprintf('Download %s (blobId %s, filters: %s)', $this->relativePath, $this->blobId, $filterNames);
    }
}