Maba\DatabaseInconsistencyFinder\Service\InconsistencySeeker

Complexity

Total Complexity

5

Size/Duplication

Total Lines	40
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	seekForInconsistencies()	0	28	4

<?php
declare(strict_types=1);

namespace Maba\DatabaseInconsistencyFinder\Service;

use Maba\DatabaseInconsistencyFinder\Database\QueryExecutor;
use Maba\DatabaseInconsistencyFinder\Entity\InconsistenciesResult;
use Maba\DatabaseInconsistencyFinder\Entity\Interval;
use Maba\DatabaseInconsistencyFinder\Entity\ReferencesConfiguration;

class InconsistencySeeker
{
    private $referencesConfiguration;
    private $queryExecutor;

    public function __construct(ReferencesConfiguration $referencesConfiguration, QueryExecutor $queryExecutor)
    {
        $this->referencesConfiguration = $referencesConfiguration;
        $this->queryExecutor = $queryExecutor;
    }

    public function seekForInconsistencies(Interval $interval): InconsistenciesResult
    {
        $result = new InconsistenciesResult();

        $expected = $this->queryExecutor->findAllReferencedByInterval(
            $this->referencesConfiguration->getReferencedColumn(),
            $interval
        );

        $actual = $this->queryExecutor->aggregateReferencesByInterval(
            $this->referencesConfiguration->getTableReferencesList(),
            $interval
        );

        foreach ($expected as $id => $number) {
            if (!isset($actual[$id])) {
                $result->addOrphanedRecordId($id);
            } elseif ($actual[$id] !== $expected[$id]) {
                $result->addInvalidReferenceCount($id, $actual[$id]);
            }

            unset($actual[$id]);
        }

        $result->setMissingReferenceCounts($actual);

        return $result;
    }
}