Speicher210\FastbillBundle\DataCollector\TransportCollector

Complexity

Total Complexity

5

Size/Duplication

Total Lines	84
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	1

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	setCredentials()	0	6	1
A	getCredentials()	0	4	1
A	sendRequest()	0	17	1
A	getRequests()	0	4	1

<?php

namespace Speicher210\FastbillBundle\DataCollector;

use Speicher210\Fastbill\Api\ApiCredentials;
use Speicher210\Fastbill\Api\Transport\TransportInterface;
use Symfony\Component\Stopwatch\Stopwatch;

/**
 * Transport data collector.
 */
class TransportCollector implements TransportInterface
{
    /**
     * The inner service.
     *
     * @var TransportInterface
     */
    protected $service;

    /**
     * The stopwatch.
     *
     * @var Stopwatch
     */
    protected $stopwatch;

    /**
     * The made requests.
     *
     * @var array
     */
    protected $requests = array();

    /**
     * Constructor.
     *
     * @param TransportInterface $service The inner transport.
     * @param Stopwatch $stopwatch The stopwatch.
     */
    public function __construct(TransportInterface $service, Stopwatch $stopwatch)
    {
        $this->service = $service;
        $this->stopwatch = $stopwatch;
    }

    /**
     * {@inheritdoc}
     */
    public function setCredentials(ApiCredentials $credentials)
    {
        $this->service->setCredentials($credentials);

        return $this;
    }

    /**
     * {@inheritdoc}
     */
    public function getCredentials()
    {
        return $this->service->getCredentials();
    }

    /**
     * {@inheritdoc}
     */
    public function sendRequest($body)
    {
        $stopwatchId = uniqid('speicher210_fastbill.collector.transport.');
        $this->stopwatch->start($stopwatchId);

        $return = $this->service->sendRequest($body);

        $stop = $this->stopwatch->stop($stopwatchId);

        $this->requests[] = array(
            'time' => $stop->getDuration(),
            'request' => json_decode($body, true),
            'response' => json_decode($return, true),
        );

        return $return;
    }

    /**
     * Get the requests.
     *
     * @return array
     */
    public function getRequests()
    {
        return $this->requests;
    }
}