Http\HttplugBundle\Collector\ProfilePlugin

Complexity

Total Complexity

2

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	handleRequest()	0	19	1

<?php

namespace Http\HttplugBundle\Collector;

use Exception;
use Http\Client\Common\Plugin;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;

class ProfilePlugin implements Plugin
{
    /**
     * @var Plugin
     */
    private $plugin;

    /**
     * @var Collector
     */
    private $collector;

    /**
     * @var Formatter
     */
    private $formatter;

    /**
     * @var ProfileFactory
     */
    private $factory;

    /**
     * @var string
     */
    private $pluginName;

    /**
     * @param Plugin         $plugin
     * @param Collector      $collector
     * @param Formatter      $formatter
     * @param ProfileFactory $factory
     * @param string         $pluginName
     */
    public function __construct(Plugin $plugin, Collector $collector, Formatter $formatter, ProfileFactory $factory, $pluginName)
    {
        $this->plugin = $plugin;
        $this->collector = $collector;
        $this->formatter = $formatter;
        $this->factory = $factory;
        $this->pluginName = $pluginName;
    }

    /**
     * {@inheritdoc}
     */
    public function handleRequest(RequestInterface $request, callable $next, callable $first)
    {
        $profile = $this->factory->createProfile();
        $profile->setPlugin($this->pluginName);
        $profile->setRequest($this->formatter->formatRequest($request));

        $this->collector->getCurrentStack()->addProfile($profile);

        return $this->plugin->handleRequest($request, $next, $first)->then(function (ResponseInterface $response) use ($profile) {
            $profile->setResponse($this->formatter->formatResponse($response));

            return $response;
        }, function (Exception $exception) use ($profile) {
            $profile->setFailed(true);
            $profile->setResponse($this->formatter->formatException($exception));

            throw $exception;
        });
    }
}