Administration\Infrastructure\Finders\Doctrine\DoctrineFamilyLogFinder

Complexity

Total Complexity

3

Size/Duplication

Total Lines	51
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	findAll()	0	22	1
A	__construct()	0	3	1
A	findBySlug()	0	12	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\Finders\Doctrine;

use Administration\Application\FamilyLog\ReadModel\FamilyLog as FamilyLogReadModel;
use Administration\Application\FamilyLog\ReadModel\FamilyLogs;
use Administration\Application\Protocol\Finders\FamilyLogFinderProtocol;
use Administration\Infrastructure\FamilyLog\Mapper\FamilyLogModelMapper;
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 DoctrineFamilyLogFinder implements FamilyLogFinderProtocol
{
    private Connection $connection;

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

    /**
     * @throws \Doctrine\DBAL\Exception
     */
    public function findBySlug(string $slug): FamilyLogReadModel
    {
        $result = $this->connection->createQueryBuilder()
            ->select('uuid', 'parent_id', 'label', 'slug', 'level', 'path')
            ->from('family_log')
            ->where('slug = :slug')
            ->setParameter('slug', $slug)
            ->execute()
            ->fetchAssociative()
        ;

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

    /**
     * @throws \Doctrine\DBAL\Exception|Exception
     */
    public function findAll(): FamilyLogs
    {
        $query = <<<'SQL'
WITH RECURSIVE cte (uuid, parent_id, label, level, path, slug, dir) AS (
    SELECT uuid, parent_id, label, level, path, slug, CAST(null as CHAR(10)) as dir
    FROM family_log
    UNION
    SELECT f1.uuid, f1.parent_id, f1.label, f1.level, f1.path, f1.slug, IFNULL(f2.dir, 'down')
    FROM family_log f1
        INNER JOIN cte f2 ON f1.parent_id = f2.uuid AND IFNULL(f2.dir, 'down')='down'
    UNION
    SELECT f1.uuid, f1.parent_id, f1.label, f1.level, f1.path, f1.slug, IFNULL(f2.dir, 'up')
    FROM family_log f1
            INNER JOIN cte f2 ON f1.parent_id = f2.uuid AND IFNULL(f2.dir, 'up')='up'
)
SELECT DISTINCT uuid, parent_id, label, level, path, slug FROM cte
ORDER BY level DESC
SQL;

        $results = $this->connection->executeQuery($query)->fetchAllAssociative();

        return (new FamilyLogModelMapper())->getFamilyLogsFromArray($results);
    }
}