SavinMikhail\CommentsDensity\BaselineManager

Complexity

Total Complexity

8

Size/Duplication

Total Lines	61
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	isUniqueConstraintViolation()	0	3	1
A	set()	0	22	4
A	__construct()	0	3	1
A	getAllComments()	0	8	1
A	getCommentsByFilePath()	0	10	1

<?php

declare(strict_types=1);

namespace SavinMikhail\CommentsDensity;

use Doctrine\DBAL\Connection;
use Doctrine\DBAL\Exception;
use SavinMikhail\CommentsDensity\DTO\Output\OutputDTO;

The type SavinMikhail\CommentsDensity\DTO\Output\OutputDTO was not found. Maybe you did not declare it correctly or list all dependencies?

final class BaselineManager
{
    public function __construct(
        private Connection $connection
    ) {
    }

    /**
     * @throws Exception
     */
    public function set(OutputDTO $outputDTO): void
    {
        foreach ($outputDTO->comments as $comment) {
            try {
                $this->connection->insert('comments', [
                    'file_path' => $comment->file,
                    'line_number' => $comment->line,
                    'comment' => $comment->content,
                    'type' => $comment->commentType,
                ]);
            } catch (Exception $e) {
                if ($this->isUniqueConstraintViolation($e)) {
                    $this->connection->update('comments', [
                        'comment' => $comment->content,
                        'type' => $comment->commentType,
                    ], [
                        'file_path' => $comment->file,
                        'line_number' => $comment->line,
                    ]);
                    continue;
                }
                throw $e;
            }
        }
    }

    private function isUniqueConstraintViolation(Exception $e): bool
    {
        return str_contains($e->getMessage(), 'UNIQUE constraint failed');
    }

    public function getAllComments(): array
    {
        $query = $this->connection->createQueryBuilder()
            ->select('*')
            ->from('comments')
            ->executeQuery();

        return $query->fetchAllAssociative();
    }

    public function getCommentsByFilePath(string $filePath): array
    {
        $query = $this->connection->createQueryBuilder()
            ->select('*')
            ->from('comments')
            ->where('file_path = :file_path')
            ->setParameter('file_path', $filePath)
            ->executeQuery();

        return $query->fetchAllAssociative();
    }
}