Yiisoft\Yii\Cycle\Logger\StdoutQueryLogger

Complexity

Total Complexity

29

Size/Duplication

Total Lines	113
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	countWriteQueries()	0	3	1
A	print()	0	12	4
A	cleanBuffer()	0	3	1
A	display()	0	3	1
A	isPostgresSystemQuery()	0	10	6
C	log()	0	34	12
A	__construct()	0	6	1
A	hide()	0	3	1
A	countReadQueries()	0	3	1
A	getBuffer()	0	3	1

<?php

declare(strict_types=1);

namespace Yiisoft\Yii\Cycle\Logger;

use Psr\Log\LoggerInterface;
use Psr\Log\LoggerTrait;
use Psr\Log\LogLevel;

/**
 * Temporary LoggerInterface class
 * Slightly adapted for SQL queries
 *
 * @package Yiisoft\Yii\Cycle\Logger
 *
 * @deprecated In the future StdoutLogger will be removed (when we will have debug-tools)
 */
class StdoutQueryLogger implements LoggerInterface
{
    use LoggerTrait;

    private bool $display;

    private int $countWrites;
    private int $countReads;
    private array $buffer = [];
    /** @var false|resource */
    private $fp;

    public function __construct()
    {
        $this->display = true;
        $this->countWrites = 0;
        $this->countReads = 0;
        $this->fp = fopen('php://stdout', 'w');
    }

    public function countWriteQueries(): int
    {
        return $this->countWrites;
    }

    public function countReadQueries(): int
    {
        return $this->countReads;
    }

    public function log($level, $message, array $context = []): void
    {
        if (!empty($context['elapsed'])) {
            $sql = strtolower($message);
            if (
                strpos($sql, 'insert') === 0 ||
                strpos($sql, 'update') === 0 ||
                strpos($sql, 'delete') === 0
            ) {
                $this->countWrites++;
            } elseif (!$this->isPostgresSystemQuery($sql)) {
                ++$this->countReads;
            }
        }

        if ($level === LogLevel::ERROR) {
            $this->print(" ! \033[31m" . $message . "\033[0m");
        } elseif ($level === LogLevel::ALERT) {
            $this->print(" ! \033[35m" . $message . "\033[0m");
        } elseif (strpos($message, 'SHOW') === 0) {
            $this->print(" > \033[34m" . $message . "\033[0m");
        } else {
            if ($this->isPostgresSystemQuery($message)) {
                $this->print(" > \033[90m" . $message . "\033[0m");

                return;
            }

            if (strpos($message, 'SELECT') === 0) {
                $this->print(" > \033[32m" . $message . "\033[0m");
            } elseif (strpos($message, 'INSERT') === 0) {
                $this->print(" > \033[36m" . $message . "\033[0m");
            } else {
                $this->print(" > \033[33m" . $message . "\033[0m");
            }
        }
    }

    private function print(string $str): void
    {
        $this->buffer[] = $str;
        if (!$this->display || $this->fp === false) {
            return;
        }
        try {
            fwrite($this->fp, "{$str}\n");

It seems like $this->fp can also be of type true; however, parameter $handle of fwrite() does only seem to accept resource, maybe add an additional type check?

        } catch (\Throwable $e) {
            /** @psalm-suppress InvalidPropertyAssignmentValue */
            fclose($this->fp);

It seems like $this->fp can also be of type true; however, parameter $handle of fclose() does only seem to accept resource, maybe add an additional type check?

            $this->fp = false;
        }
    }

    public function display(): void
    {
        $this->display = true;
    }

    public function hide(): void
    {
        $this->display = false;
    }

    public function getBuffer(): array
    {
        return $this->buffer;
    }

    public function cleanBuffer(): void
    {
        $this->buffer = [];
    }

    protected function isPostgresSystemQuery(string $query): bool
    {
        $query = strtolower($query);
        return (bool) (
            strpos($query, 'tc.constraint_name') ||
            strpos($query, 'pg_indexes') ||
            strpos($query, 'tc.constraint_name') ||
            strpos($query, 'pg_constraint') ||
            strpos($query, 'information_schema') ||
            strpos($query, 'pg_class')
        )



         ;
    }
}