Gocobachi\Compressy\Resource\Reader\Guzzle\LegacyGuzzleReaderFactory

Complexity

Total Complexity

3

Size/Duplication

Total Lines	33
Duplicated Lines	0 %

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	getReader()	0	3	1
A	__construct()	0	14	2

<?php

namespace Gocobachi\Compressy\Resource\Reader\Guzzle;

use Gocobachi\Compressy\Resource\Resource as ZippyResource;
use Gocobachi\Compressy\Resource\ResourceReader;
use Gocobachi\Compressy\Resource\ResourceReaderFactory;
use Guzzle\Http\Client;

The type Guzzle\Http\Client was not found. Maybe you did not declare it correctly or list all dependencies?

use Guzzle\Http\ClientInterface;

The type Guzzle\Http\ClientInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use Guzzle\Plugin\Backoff\BackoffPlugin;

The type Guzzle\Plugin\Backoff\BackoffPlugin was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\EventDispatcher\Event;

The type Symfony\Component\EventDispatcher\Event was not found. Maybe you did not declare it correctly or list all dependencies?

class LegacyGuzzleReaderFactory implements ResourceReaderFactory
{
    /**
     * @var ClientInterface|null
     */
    private $client = null;

    public function __construct(ClientInterface $client = null)
    {
        $this->client = $client;

        if (!$this->client) {
            $this->client = new Client();

            $this->client->getEventDispatcher()->addListener('request.error', function(Event $event) {
                // override guzzle default behavior of throwing exceptions
                // when 4xx & 5xx responses are encountered
                $event->stopPropagation();
            }, -254);

            $this->client->addSubscriber(BackoffPlugin::getExponentialBackoff(5, array(500, 502, 503, 408)));
        }
    }

    /**
     * @param ZippyResource $resource
     * @param string        $context
     *
     * @return ResourceReader
     */
    public function getReader(ZippyResource $resource, $context)
    {
        return new LegacyGuzzleReader($resource, $this->client);
    }
}