Aoe\Varnish\System\Varnish

Complexity

Total Complexity

11

Size/Duplication

Total Lines	87
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

93.94%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	shutdown()	0	14	4
A	banByTag()	0	8	2
A	banAll()	0	5	1
A	request()	0	10	3

<?php
namespace Aoe\Varnish\System;

use Aoe\Varnish\Domain\Model\TagInterface;
use Aoe\Varnish\TYPO3\Configuration\ExtensionConfiguration;
use TYPO3\CMS\Core\Log\LogManager;
use TYPO3\CMS\Core\SingletonInterface;

class Varnish implements SingletonInterface
{
    /**
     * @var Http
     */
    private $http;

    /**
     * @var ExtensionConfiguration
     */
    private $extensionConfiguration;

    /**
     * @var LogManager
     */
    private $logManager;

    /**
     * @param Http $http
     * @param ExtensionConfiguration $extensionConfiguration
     * @param LogManager $logManager
     */
    public function __construct(Http $http, ExtensionConfiguration $extensionConfiguration, LogManager $logManager)
    {
        $this->http = $http;
        $this->extensionConfiguration = $extensionConfiguration;
        $this->logManager = $logManager;

        register_shutdown_function([$this, 'shutdown']);
    }

    /**
     * @return array
     */
    public function shutdown()
    {
        $phrases = $this->http->wait();
        if (is_array($phrases)) {
            foreach ($phrases as $phrase) {
                if ($phrase['success']) {
                    $this->logManager->getLogger(__CLASS__)->info($phrase['reason']);
                } else {
                    $this->logManager->getLogger(__CLASS__)->alert($phrase['reason']);
                }
            }
        }
        return $phrases;
    }

    /**
     * @param TagInterface $tag
     * @return Varnish
     */
    public function banByTag(TagInterface $tag)
    {
        if (false === $tag->isValid()) {
            throw new \RuntimeException('Tag is not valid', 1435159558);
        }
        $this->request('BAN', ['X-Ban-Tags' => $tag->getIdentifier()], $this->extensionConfiguration->getBanTimeout());
        return $this;
    }

    /**
     * @return Varnish
     */
    public function banAll()
    {
        $this->request('BAN', ['X-Ban-All' => '1'], $this->extensionConfiguration->getBanTimeout());
        return $this;
    }

    /**
     * @param string $method
     * @param array $headers
     * @param integer $timeout
     */
    private function request($method, $headers = [], $timeout = null)
    {
        if ($timeout === null) {
            $timeout = $this->extensionConfiguration->getDefaultTimeout();
        }

        foreach ($this->extensionConfiguration->getHosts() as $host) {
            $this->http->request($method, $host, $headers, $timeout);
        }
    }
}