AbacaphiliacTest\Doctrine\PsrSqlLoggerTest

Complexity

Total Complexity

7

Size/Duplication

Total Lines	159
Duplicated Lines	35.22 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	setUp()	0	6	1
A	getRecordByIndex()	0	8	1
A	testLogsQuery()	0	24	1
A	testLogsDuration()	27	27	1
A	testSharedQueryId()	29	29	1
A	testQueryIdChanges()	0	36	1
A	testInvalidLogLevel()	0	4	1

<?php

namespace AbacaphiliacTest\Doctrine;

use Abacaphiliac\Doctrine\PsrSqlLogger;
use Gamez\Psr\Log\Record;
use Gamez\Psr\Log\TestLogger;
use PHPUnit\Framework\TestCase;
use Psr\Log\LogLevel;
use Psr\Log\NullLogger;

/**
 * @covers \Abacaphiliac\Doctrine\PsrSqlLogger
 */
class PsrSqlLoggerTest extends TestCase
{
    /** @var PsrSqlLogger */
    private $sut;

    /** @var TestLogger */
    private $logger;

    /** @var string */
    private $sql = 'SELECT * FROM users WHERE id = :id';

    protected function setUp()
    {
        $this->logger = new TestLogger();

        $this->sut = new PsrSqlLogger($this->logger);
    }

    /**
     * @param integer $index
     * @return Record
     */
    private function getRecordByIndex($index)
    {
        $record = $this->logger->log[$index];

        self::assertInstanceOf(Record::class, $record);

        return $record;
    }

    public function testLogsQuery()
    {
        self::assertCount(0, $this->logger->log);

        $this->sut->startQuery(
            $this->sql,
            [
                ':id' => 1234,
            ],
            [
                ':id' => \PDO::PARAM_INT,
            ]
        );

        self::assertCount(1, $this->logger->log);

        $log = $this->getRecordByIndex(0);

        self::assertSame(LogLevel::INFO, (string) $log->level);
        self::assertSame('Query started', (string) $log->message);
        self::assertNotEmpty($log->context->get('query_id'));
        self::assertSame($this->sql, $log->context->get('sql'));
        self::assertSame([':id' => \PDO::PARAM_INT], $log->context->get('types'));
    }

    public function testLogsDuration()

This method seems to be duplicated in your project.

    {
        self::assertCount(0, $this->logger->log);

        $this->sut->startQuery(
            $this->sql,
            [
                ':id' => 1234,
            ],
            [
                ':id' => \PDO::PARAM_INT,
            ]
        );

        $this->sut->stopQuery();

        self::assertCount(2, $this->logger->log);

        $log = $this->getRecordByIndex(1);

        self::assertSame(LogLevel::INFO, (string) $log->level);
        self::assertSame('Query finished', (string) $log->message);
        self::assertNotEmpty($log->context->get('query_id'));
        self::assertInternalType('float', $log->context->get('start'));
        self::assertInternalType('float', $log->context->get('stop'));
        self::assertInternalType('float', $log->context->get('duration_s'));
    }

    public function testSharedQueryId()

This method seems to be duplicated in your project.

    {
        self::assertCount(0, $this->logger->log);

        $this->sut->startQuery(
            $this->sql,
            [
                ':id' => 1234,
            ],
            [
                ':id' => \PDO::PARAM_INT,
            ]
        );

        $this->sut->stopQuery();

        self::assertCount(2, $this->logger->log);

        $startLog = $this->getRecordByIndex(0);

        self::assertInstanceOf(Record::class, $startLog);

        $queryId = $startLog->context->get('query_id');
        self::assertNotEmpty($queryId);

        $stopLog = $this->getRecordByIndex(1);

        self::assertSame($queryId, $stopLog->context->get('query_id'));
    }

    public function testQueryIdChanges()
    {
        self::assertCount(0, $this->logger->log);

        $this->sut->startQuery(
            $this->sql,
            [
                ':id' => 1234,
            ],
            [
                ':id' => \PDO::PARAM_INT,
            ]
        );

        $this->sut->startQuery(
            $this->sql,
            [
                ':id' => 2345,
            ],
            [
                ':id' => \PDO::PARAM_INT,
            ]
        );

        self::assertCount(2, $this->logger->log);

        $firstLog = $this->getRecordByIndex(0);

        $queryId = $firstLog->context->get('query_id');
        self::assertNotEmpty($queryId);

        $secondLog = $this->getRecordByIndex(1);

        self::assertNotEmpty($secondLog->context->get('query_id'));
        self::assertNotEquals($queryId, $secondLog->context->get('query_id'));
    }

    /**
     * @expectedException \InvalidArgumentException
     */
    public function testInvalidLogLevel()
    {
        new PsrSqlLogger(new NullLogger(), 'InvalidLevel');
    }
}