Algatux\InfluxDbBundle\Events\Listeners\InfluxDbEventListener

Complexity

Total Complexity

5

Size/Duplication

Total Lines	42
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

85.71%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	onInfluxDbEventDispatched()	0	20	4

<?php

For compatibility and reusability of your code, PSR1 recommends that a file should introduce either new symbols (like classes, functions, etc.) or have side-effects (like outputting something, or including other files), but not both at the same time. The first symbol is defined on line 12 and the first side effect is on line 2.

declare(strict_types=1);
namespace Algatux\InfluxDbBundle\Events\Listeners;
use Algatux\InfluxDbBundle\Events\InfluxDbEvent;
use Algatux\InfluxDbBundle\Services\Clients\Contracts\ClientInterface;
use Algatux\InfluxDbBundle\Services\Clients\WriterClient;

/**
 * Class InfluxDbEventListener
 * @package Algatux\InfluxDbBundle\Events\Listeners
 */
class InfluxDbEventListener
{

    /** @var WriterClient  */
    private $httpWriter;

    /** @var WriterClient  */
    private $udpWriter;

    /**
     * InfluxDbEventListener constructor.
     * @param WriterClient $httpWriter
     * @param WriterClient $udpWriter
     */
    public function __construct(WriterClient $httpWriter, WriterClient $udpWriter)
    {
        $this->httpWriter = $httpWriter;
        $this->udpWriter = $udpWriter;
    }

    public function onInfluxDbEventDispatched(InfluxDbEvent $event): bool
    {

        if ($event->isPropagationStopped()) {
            return false;
        }

        if ($event->getWriteClient() === ClientInterface::UDP_CLIENT) {
            $this->udpWriter->write($event->getPoints(), ClientInterface::UDP_CLIENT);
            return true;
        }

        if ($event->getWriteClient() === ClientInterface::HTTP_CLIENT) {
            $this->httpWriter->write($event->getPoints(), ClientInterface::HTTP_CLIENT);
            return true;
        }

        return false;

    }

}