Eole\Sandstone\Push\Debug\DataCollector\PushServerDataCollector

Complexity

Total Complexity

8

Size/Duplication

Total Lines	82
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	collect()	0	6	2
A	updateMessages()	0	17	2
A	getData()	0	4	1
A	getName()	0	4	1
A	reset()	0	8	1

<?php

namespace Eole\Sandstone\Push\Debug\DataCollector;

use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\HttpKernel\DataCollector\DataCollector;
use Eole\Sandstone\Push\Debug\TraceablePushServerInterface;
use Eole\Sandstone\Push\PushServerInterface;

class PushServerDataCollector extends DataCollector
{
    /**
     * @var string
     */
    const NAME = 'sandstone.push_server';

    /**
     * @var PushServerInterface
     */
    private $pushServer;

    /**
     * @param PushServerInterface $pushServer
     */
    public function __construct(PushServerInterface $pushServer)
    {
        $this->pushServer = $pushServer;
        $this->updateMessages(array());
    }

    /**
     * {@InheritDoc}
     */
    public function collect(Request $request, Response $response, \Exception $exception = null)
    {
        if ($this->pushServer instanceof TraceablePushServerInterface) {
            $this->updateMessages($this->pushServer->getSentMessages());
        }
    }

    /**
     * Update data collector data with messages.
     *
     * @param string[] $messages
     */
    private function updateMessages(array $messages)
    {
        $this->reset();

        foreach ($messages as $message) {
            $messageSize = strlen($message);

            $this->data['messages_size'] += $messageSize;
            $this->data['messages_count']++;

            $this->data['messages'] []= array(
                'content' => $message,
                'size' => $messageSize,
                'decoded' => unserialize($message),
            );
        }
    }

    /**
     * @return array
     */
    public function getData()
    {
        return $this->data;
    }

    /**
     * {@InheritDoc}
     */
    public function getName()
    {
        return self::NAME;
    }

    /**
     * {@InheritDoc}
     */
    public function reset()
    {
        $this->data = array(
            'messages_size' => 0,
            'messages_count' => 0,
            'messages' => array(),
        );
    }
}