Algatux\InfluxDbBundle\unit\Events\Listeners\InfluxDbEventListenerTest

Complexity

Total Complexity

2

Size/Duplication

Total Lines	38
Duplicated Lines	84.21 %

Coupling/Cohesion

Components	0
Dependencies	6

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	test_listening_for_udp_infuxdb_event()	16	16	1
A	test_listening_for_http_infuxdb_event()	16	16	1

<?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 13 and the first side effect is on line 2.

declare(strict_types=1);
namespace Algatux\InfluxDbBundle\unit\Events\Listeners;

use Algatux\InfluxDbBundle\Events\InfluxDbEvent;
use Algatux\InfluxDbBundle\Events\Listeners\InfluxDbEventListener;
use Algatux\InfluxDbBundle\Model\PointsCollection;
use Algatux\InfluxDbBundle\Services\Clients\Contracts\ClientInterface;
use Algatux\InfluxDbBundle\Services\Clients\WriterClient;
use InfluxDB\Database;
use Prophecy\Argument;

class InfluxDbEventListenerTest extends \PHPUnit_Framework_TestCase
{

    public function test_listening_for_udp_infuxdb_event()

This method seems to be duplicated in your project.

    {
        $event = new InfluxDbEvent(new PointsCollection(), Database::PRECISION_SECONDS, ClientInterface::UDP_CLIENT);

        $httpWriter = $this->prophesize(WriterClient::class);
        $httpWriter->write(Argument::cetera())
            ->shouldNotBeCalled();

        $udpWriter = $this->prophesize(WriterClient::class);
        $udpWriter->write(Argument::type(PointsCollection::class), Database::PRECISION_SECONDS)
            ->shouldBeCalledTimes(1)
            ->willReturn(true);

        $listener = new InfluxDbEventListener($httpWriter->reveal(), $udpWriter->reveal());
        $listener->onInfluxDbEventDispatched($event);
    }

    public function test_listening_for_http_infuxdb_event()

This method seems to be duplicated in your project.

    {
        $event = new InfluxDbEvent(new PointsCollection(), Database::PRECISION_SECONDS, ClientInterface::HTTP_CLIENT);

        $udpWriter = $this->prophesize(WriterClient::class);
        $udpWriter->write(Argument::cetera())
            ->shouldNotBeCalled();

        $httpWriter = $this->prophesize(WriterClient::class);
        $httpWriter->write(Argument::type(PointsCollection::class), Database::PRECISION_SECONDS)
            ->shouldBeCalledTimes(1)
            ->willReturn(true);

        $listener = new InfluxDbEventListener($httpWriter->reveal(), $udpWriter->reveal());
        $listener->onInfluxDbEventDispatched($event);
    }

}