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

<?php
class InfluxDbEventListenerTest extends \PHPUnit_Framework_TestCase
{

    public function test_listening_for_udp_infuxdb_event()
    {
        $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()
    {
        $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);
    }

}