Administration\Infrastructure\Persistence\DoctrineOrm\Repositories\DoctrineFamilyLogRepository

Complexity

Total Complexity

7

Size/Duplication

Total Lines	84
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

5 Methods

Rating	Name	Duplication	Size	Complexity
A	findParent()	0	25	2
A	getData()	0	13	2
A	add()	0	9	1
A	existWithLabel()	0	13	1
A	__construct()	0	3	1

<?php

declare(strict_types=1);

/*
 * This file is part of the G.L.S.R. Apps package.
 *
 * (c) Dev-Int Création <info@developpement-interessant.com>.
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Administration\Infrastructure\Persistence\DoctrineOrm\Repositories;

use Administration\Domain\FamilyLog\Model\FamilyLog;
use Administration\Domain\Protocol\Repository\FamilyLogRepositoryProtocol;
use Administration\Infrastructure\FamilyLog\Mapper\FamilyLogModelMapper;
use Administration\Infrastructure\Finders\Exceptions\FamilyLogNotFound;
use Doctrine\DBAL\Connection;

The type Doctrine\DBAL\Connection was not found. Maybe you did not declare it correctly or list all dependencies?

use Doctrine\DBAL\Driver\Exception;

The type Doctrine\DBAL\Driver\Exception was not found. Maybe you did not declare it correctly or list all dependencies?

class DoctrineFamilyLogRepository implements FamilyLogRepositoryProtocol
{
    protected Connection $connection;

    public function __construct(Connection $connection)
    {
        $this->connection = $connection;
    }

    /**
     * @throws \Doctrine\DBAL\Exception
     */
    public function existWithLabel(string $label, ?string $parentUuid): bool
    {
        $statement = $this->connection->createQueryBuilder()
            ->select('label')
            ->from('family_log')
            ->where('label = :label')
            ->andWhere('parent_id = :parent_id')
            ->setParameters(['label' => $label, 'parent_id' => $parentUuid])
            ->execute()
            ->fetchOne()
        ;

        return false !== $statement;
    }

    /**
     * @throws \Doctrine\DBAL\Exception|Exception
     */
    public function findParent(string $uuid): FamilyLog
    {
        $parent = null;

The assignment to $parent is dead and can be removed.

        $query = <<<'SQL'
WITH RECURSIVE cte (uuid, parent_id, label, slug, level, dir) AS (
    SELECT uuid, parent_id, label, slug, level, CAST(null as CHAR(10)) as dir
    FROM family_log
    WHERE uuid = :uuid
    UNION
    SELECT f1.uuid, f1.parent_id, f1.label, f1.slug, f1.level, IFNULL(f2.dir, 'up')
    FROM family_log f1
        INNER JOIN cte f2 ON f2.parent_id = f1.uuid AND IFNULL(f2.dir, 'up')='up'
)
SELECT DISTINCT uuid, parent_id, label, slug, level FROM cte
ORDER BY level
SQL;

        // Get parents
        $result = $this->connection->executeQuery($query, ['uuid' => $uuid])->fetchAllAssociative();

        if ([] === $result) {
            throw new FamilyLogNotFound();
        }

        return (new FamilyLogModelMapper())->createParentTreeFromArray($result);
    }

    /**
     * @throws \Doctrine\DBAL\Exception|Exception
     */
    public function add(FamilyLog $familyLog): void
    {
        $data = $this->getData($familyLog);

        $statement = $this->connection->prepare(
            'INSERT INTO family_log
(uuid, parent_id, label, slug, level) VALUES (:uuid, :parent_id, :label, :slug, :level)'
        );
        $statement->execute($data);
    }

    private function getData(FamilyLog $familyLog): array
    {
        $parent = null;
        if (null !== $familyLog->parent()) {
            $parent = $familyLog->parent()->uuid();
        }

        return [
            'uuid' => $familyLog->uuid(),
            'parent_id' => $parent,
            'label' => $familyLog->label(),
            'slug' => $familyLog->slug(),
            'level' => (int) $familyLog->level(),
        ];
    }
}