Sirius\Orm\Relation\Relation

Complexity

Total Complexity

45

Size/Duplication

Total Lines	297
Duplicated Lines	0 %

Importance

Changes	6
Bugs	1	Features	0

24 Methods

Rating	Name	Duplication	Size	Complexity
A	getOption()	0	7	2
A	setOptionIfMissing()	0	4	2
A	applyDefaults()	0	4	1
A	__construct()	0	8	1
A	getKeyPairs()	0	3	1
A	addActions()	0	6	4
A	applyForeignGuards()	0	8	2
A	getEntityId()	0	7	2
A	getRemainingRelations()	0	14	3
A	computeKeyPairs()	0	10	2
A	isEagerLoad()	0	3	1
A	applyQueryCallback()	0	8	3
A	newSyncAction()	0	20	2
A	getExtraColumnsForAction()	0	14	4
A	getJoinOnForSubselect()	0	7	1
A	getKeyColumn()	0	12	3
A	indexQueryResults()	0	13	3
A	relationWasChanged()	0	5	2
A	isCascade()	0	3	1
A	attachLazyRelationToEntity()	0	4	1
A	getNativeMapper()	0	3	1
A	getForeignMapper()	0	3	1
A	getQuery()	0	14	1
A	isLazyLoad()	0	3	1

<?php
declare(strict_types=1);

namespace Sirius\Orm\Relation;

use Sirius\Orm\Action\AttachEntities;
use Sirius\Orm\Action\BaseAction;
use Sirius\Orm\Action\Delete;
use Sirius\Orm\Action\DetachEntities;
use Sirius\Orm\Action\Update;
use Sirius\Orm\Entity\EntityInterface;
use Sirius\Orm\Entity\LazyRelation;
use Sirius\Orm\Entity\Tracker;
use Sirius\Orm\Helpers\Arr;
use Sirius\Orm\Helpers\QueryHelper;
use Sirius\Orm\Mapper;
use Sirius\Orm\Query;
use Sirius\Sql\Select;

abstract class Relation
{
    /**
     * Name of the relation (used to infer defaults)
     * @var
     */
    protected $name;

    /**
     * @var Mapper
     */
    protected $nativeMapper;

    /**
     * @var Mapper
     */
    protected $foreignMapper;

    /**
     * @var array
     */
    protected $options = [];

    /**
     * Stores the nativeColumn-foreignColumn pairs to be used on queries
     * @var array
     */
    protected $keyPairs;

    public function __construct($name, Mapper $nativeMapper, Mapper $foreignMapper, array $options = [])
    {
        $this->name          = $name;
        $this->nativeMapper  = $nativeMapper;
        $this->foreignMapper = $foreignMapper;
        $this->options       = $options;
        $this->applyDefaults();
        $this->keyPairs = $this->computeKeyPairs();
    }

    protected function applyDefaults(): void
    {
        $this->setOptionIfMissing(RelationConfig::LOAD_STRATEGY, RelationConfig::LOAD_LAZY);
        $this->setOptionIfMissing(RelationConfig::CASCADE, false);
    }

    protected function setOptionIfMissing($name, $value)
    {
        if (! isset($this->options[$name])) {
            $this->options[$name] = $value;
        }
    }

    public function getOption($name)
    {
        if ($name == 'name') {
            return $this->name;
        }

        return $this->options[$name] ?? null;
    }

    /**
     * @return array
     */
    public function getKeyPairs(): array
    {
        return $this->keyPairs;
    }

    public function isEagerLoad()
    {
        return $this->options[RelationConfig::LOAD_STRATEGY] == RelationConfig::LOAD_EAGER;
    }

    public function isLazyLoad()
    {
        return $this->options[RelationConfig::LOAD_STRATEGY] == RelationConfig::LOAD_LAZY;
    }

    public function isCascade()
    {
        return $this->options[RelationConfig::CASCADE] === true;
    }

    protected function getKeyColumn($name, $column)
    {
        if (!is_array($column)) {
            return $name . '_' . $column;
        }

        $keyColumn = [];
        foreach ($column as $col) {
            $keyColumn[] = $name . '_' . $col;
        }

        return $keyColumn;
    }

    public function addActions(BaseAction $action)
    {
        if ($action instanceof Delete) {
            $this->addActionOnDelete($action);
        } elseif ($action instanceof Insert || $action instanceof Update) {

The type Sirius\Orm\Relation\Insert was not found. Maybe you did not declare it correctly or list all dependencies?

            $this->addActionOnSave($action);
        }
    }

    abstract protected function addActionOnSave(BaseAction $action);

    abstract protected function addActionOnDelete(BaseAction $action);

    abstract public function attachMatchesToEntity(EntityInterface $nativeEntity, array $queryResult);

    abstract public function attachEntities(EntityInterface $nativeEntity, EntityInterface $foreignEntity);

    abstract public function detachEntities(EntityInterface $nativeEntity, EntityInterface $foreignEntity);

    abstract public function joinSubselect(Query $query, string $reference);

    public function attachLazyRelationToEntity(EntityInterface $entity, Tracker $tracker)
    {
        $valueLoader = new LazyRelation($entity, $tracker, $this);
        $this->nativeMapper->setEntityAttribute($entity, $this->name, $valueLoader);
    }

    public function getQuery(Tracker $tracker)
    {
        $nativeKey = $this->options[RelationConfig::NATIVE_KEY];
        $nativePks = $tracker->pluck($nativeKey);

        $query = $this->foreignMapper
            ->newQuery()
            ->where($this->foreignMapper->getPrimaryKey(), $nativePks);

        $query = $this->applyQueryCallback($query);

        $query = $this->applyForeignGuards($query);

        return $query;
    }

    public function indexQueryResults(array $entities)
    {
        $result = [];

        foreach ($entities as $entity) {
            $entityId = $this->getEntityId($this->foreignMapper, $entity, array_values($this->keyPairs));
            if (!isset($result[$entityId])) {
                $result[$entityId] = [];
            }
            $result[$entityId][] = $entity;
        }

        return $result;
    }

    protected function getEntityId(Mapper $mapper, EntityInterface $entity, array $keyColumns)
    {
        $entityKeys = [];
        foreach ($keyColumns as $col) {
            $entityKeys[] = $mapper->getEntityAttribute($entity, $col);
        }
        return implode('-', $entityKeys);
    }

    /**
     * Method used by `entitiesBelongTogether` to check
     * if a foreign entity belongs to the native entity
     * @return array
     */
    protected function computeKeyPairs()
    {
        $pairs      = [];
        $nativeKey  = (array)$this->options[RelationConfig::NATIVE_KEY];
        $foreignKey = (array)$this->options[RelationConfig::FOREIGN_KEY];
        foreach ($nativeKey as $k => $v) {
            $pairs[$v] = $foreignKey[$k];
        }

        return $pairs;
    }

    /**
     * Computes the $withRelations value to be passed on to the next related entities
     * If an entity receives on delete/save $withRelations = ['category', 'category.images']
     * the related 'category' is saved with $withRelations = ['images']
     *
     * @param $relations
     *
     * @return array
     */
    protected function getRemainingRelations($relations)
    {
        if (! is_array($relations)) {
            return $relations;
        }

        $arr = array_combine($relations, $relations);
        if (is_array($arr)) {
            $children = Arr::getChildren($arr, $this->name);

            return array_keys($children);
        }

        return [];
    }

    protected function getExtraColumnsForAction()
    {
        $cols   = [];
        $guards = $this->getOption(RelationConfig::FOREIGN_GUARDS);
        if (is_array($guards)) {
            foreach ($guards as $col => $val) {
                // guards that are strings (eg: 'deleted_at is null') can't be used as extra columns
                if (! is_int($col)) {
                    $cols[$col] = $val;
                }
            }
        }

        return $cols;
    }

    protected function newSyncAction(EntityInterface $nativeEntity, EntityInterface $foreignEntity, string $actionType)
    {
        if ($actionType == 'delete') {
            return new DetachEntities(
                $this->nativeMapper,
                $nativeEntity,
                $this->foreignMapper,
                $foreignEntity,
                $this,
                'save'
            );
        }

        return new AttachEntities(
            $this->nativeMapper,
            $nativeEntity,
            $this->foreignMapper,
            $foreignEntity,
            $this,
            'save'
        );
    }

    protected function relationWasChanged(EntityInterface $entity)
    {
        $changes = $entity->getChanges();

        return isset($changes[$this->name]) && $changes[$this->name];
    }

    protected function applyQueryCallback(Select $query)
    {
        $queryCallback = $this->getOption(RelationConfig::QUERY_CALLBACK);
        if ($queryCallback && is_callable($queryCallback)) {
            $query = $queryCallback($query);
        }

        return $query;
    }

    protected function applyForeignGuards(Select $query)
    {
        $guards = $this->getOption(RelationConfig::FOREIGN_GUARDS);
        if ($guards) {
            $query->setGuards($guards);
        }

        return $query;
    }

    protected function getJoinOnForSubselect()
    {
        return QueryHelper::joinCondition(
            $this->nativeMapper->getTableAlias(true),
            $this->getOption(RelationConfig::NATIVE_KEY),
            $this->name,
            $this->getOption(RelationConfig::FOREIGN_KEY)
        );
    }

    /**
     * @return Mapper
     */
    public function getNativeMapper(): Mapper
    {
        return $this->nativeMapper;
    }

    /**
     * @return Mapper
     */
    public function getForeignMapper(): Mapper
    {
        return $this->foreignMapper;
    }
}