Artprima\PrometheusMetricsBundle\EventListener\RequestCounterListener

Complexity

Total Complexity

17

Size/Duplication

Total Lines	80
Duplicated Lines	0 %

Test Coverage

Coverage

96.67%

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	onKernelRequest()	0	19	6
A	onKernelTerminate()	0	15	5
A	onKernelRequestPre()	0	14	5

<?php

declare(strict_types=1);

namespace Artprima\PrometheusMetricsBundle\EventListener;

use Artprima\PrometheusMetricsBundle\Metrics\MetricsGeneratorRegistry;
use Psr\Log\LoggerAwareInterface;
use Psr\Log\LoggerAwareTrait;
use Symfony\Component\HttpKernel\Event\RequestEvent;
use Symfony\Component\HttpKernel\Event\TerminateEvent;

/**
 * Class RequestCounterListener.
 */
class RequestCounterListener implements LoggerAwareInterface
{
    use LoggerAwareTrait;

    /**
     * @var MetricsGeneratorRegistry
     */
    private $metricsGenerators;

    /**
     * @var array
     */
    private $ignoredRoutes;

    public function __construct(MetricsGeneratorRegistry $metricsGenerators, array $ignoredRoutes = ['prometheus_bundle_prometheus'])
    {
        $this->metricsGenerators = $metricsGenerators;
        $this->ignoredRoutes = $ignoredRoutes;
    }

    public function onKernelRequestPre(RequestEvent $event): void
    {
        if (!$event->isMasterRequest()) {
            return;
        }

        foreach ($this->metricsGenerators->getMetricsGenerators() as $generator) {
            try {
                $generator->collectStart($event);
            } catch (\Exception $e) {
                if ($this->logger) {
                    $this->logger->error(
                        $e->getMessage(),
                        ['from' => 'request_collector', 'class' => get_class($generator)]
                    );
                }
            }
        }
    }

    public function onKernelRequest(RequestEvent $event): void
    {
        if (!$event->isMasterRequest()) {
            return;
        }

        $requestRoute = $event->getRequest()->attributes->get('_route');
        if (in_array($requestRoute, $this->ignoredRoutes, true)) {
            return;
        }

        foreach ($this->metricsGenerators->getMetricsGenerators() as $generator) {
            try {
                $generator->collectRequest($event);
            } catch (\Exception $e) {
                if ($this->logger) {
                    $this->logger->error(
                        $e->getMessage(),
                        ['from' => 'request_collector', 'class' => get_class($generator)]
                    );
                }
            }
        }
    }

    public function onKernelTerminate(TerminateEvent $event): void
    {
        $requestRoute = $event->getRequest()->attributes->get('_route');
        if (in_array($requestRoute, $this->ignoredRoutes, true)) {
            return;
        }

        foreach ($this->metricsGenerators->getMetricsGenerators() as $generator) {
            try {
                $generator->collectResponse($event);
            } catch (\Exception $e) {
                if ($this->logger) {
                    $this->logger->error(
                        $e->getMessage(),
                        ['from' => 'response_collector', 'class' => get_class($generator)]
                    );
                }
            }
        }
    }
}