Algatux / influxdb-bundle

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()

    {

        $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);

    }

}