BrainExe\Core\Stats\Controller

Complexity

Total Complexity

4

Size/Duplication

Total Lines	58
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

87.5%

Importance

Changes	10
Bugs	0	Features	3

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	index()	0	16	2
A	resetStats()	0	7	1

<?php

namespace BrainExe\Core\Stats;

use BrainExe\Annotations\Annotations\Inject;
use BrainExe\Core\Annotations\Controller as ControllerAnnotation;
use BrainExe\Core\Annotations\Route;
use BrainExe\Core\MessageQueue\Gateway as MessageQueueGateway;
use BrainExe\Core\Traits\RedisTrait;
use Predis\PredisException;
use Symfony\Component\HttpFoundation\Request;

/**
 * @ControllerAnnotation("Stats.Controller")
 */
class Controller
{
    use RedisTrait;

    /**
     * @var MessageQueueGateway
     */
    private $messageQueue;

    /**
     * @var Stats
     */
    private $stats;

    /**
     * @Inject({"@Stats.Stats", "@MessageQueue.Gateway"})
     * @param Stats $stats
     * @param MessageQueueGateway $gateway
     */
    public function __construct(Stats $stats, MessageQueueGateway $gateway)
    {
        $this->messageQueue = $gateway;
        $this->stats        = $stats;
    }

    /**
     * @Route("/stats/", name="status.index")
     */
    public function index()
    {
        $stats = $this->stats->getAll();

        try {
            $redisStats = $this->getRedis()->info();
        } catch (PredisException $e) {
            $redisStats = [];
        }

        return [
            'jobs'  => $this->messageQueue->getEventsByType(),
            'stats' => $stats,
            'redis' => $redisStats
        ];
    }

    /**
     * @Route("/stats/reset/", methods="POST", name="stats.reset")
     * @param Request $request
     * @return bool
     */
    public function resetStats(Request $request)
    {
        $key = $request->request->get('key');
        $this->stats->set([$key => 0]);

        return true;
    }
}