Sirius\Orm\Action\AttachEntities

Complexity

Total Complexity

13

Size/Duplication

Total Lines	115
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	revert()	0	2	1
A	onSuccess()	0	2	1
A	run()	0	7	1
A	__construct()	0	14	1
B	maybeUpdatePivotRow()	0	52	9

<?php
declare(strict_types=1);

namespace Sirius\Orm\Action;

use Sirius\Orm\Entity\EntityInterface;
use Sirius\Orm\Mapper;
use Sirius\Orm\Relation\ManyToMany;
use Sirius\Orm\Relation\Relation;
use Sirius\Orm\Relation\RelationConfig;

class AttachEntities implements ActionInterface
{
    /**
     * @var EntityInterface
     */
    protected $nativeEntity;
    /**
     * @var EntityInterface
     */
    protected $foreignEntity;
    /**
     * @var Relation
     */
    protected $relation;
    /**
     * @var string
     */
    protected $actionType;
    /**
     * @var Mapper
     */
    protected $nativeMapper;
    /**
     * @var Mapper
     */
    protected $foreignMapper;

    public function __construct(
        Mapper $nativeMapper,
        EntityInterface $nativeEntity,
        Mapper $foreignMapper,
        EntityInterface $foreignEntity,
        Relation $relation,
        string $actionType
    ) {
        $this->nativeMapper  = $nativeMapper;
        $this->nativeEntity  = $nativeEntity;
        $this->foreignMapper = $foreignMapper;
        $this->foreignEntity = $foreignEntity;
        $this->relation      = $relation;
        $this->actionType    = $actionType;
    }

    public function revert()
    {
        /**
         * @todo restore previous values
         */
    }

    public function run()
    {
        /**
         * @todo store current attribute values
         */
        $this->relation->attachEntities($this->nativeEntity, $this->foreignEntity);
        $this->maybeUpdatePivotRow();
    }

    public function onSuccess()
    {
    }

    protected function maybeUpdatePivotRow()
    {
        if (!$this->relation instanceof ManyToMany) {
            return;
        }

        $conn = $this->relation->getNativeMapper()->getWriteConnection();
        $throughTable = (string)$this->relation->getOption(RelationConfig::THROUGH_TABLE);

        $throughNativeColumns = (array) $this->relation->getOption(RelationConfig::THROUGH_NATIVE_COLUMN);
        $throughForeignColumns = (array) $this->relation->getOption(RelationConfig::THROUGH_FOREIGN_COLUMN);
        $nativeKey = (array) $this->nativeMapper->getEntityPk($this->nativeEntity);
        $foreignKey = (array) $this->foreignMapper->getEntityPk($this->foreignEntity);

        $delete = new \Sirius\Sql\Delete($conn);
        $delete->from($throughTable);
        foreach ($throughNativeColumns as $k => $col) {
            $delete->where($col, $nativeKey[$k]);
            $delete->where($throughForeignColumns[$k], $foreignKey[$k]);
        }
        foreach ((array)$this->relation->getOption(RelationConfig::THROUGH_GUARDS) as $col => $value) {
            if (!is_int($col)) {
                $delete->where($col, $value);
            } else {
                $delete->where($value);
            }
        }
        $delete->perform();

        $insertColumns = [];
        foreach ($throughNativeColumns as $k => $col) {
            $insertColumns[$col] = $nativeKey[$k];
            $insertColumns[$throughForeignColumns[$k]] = $foreignKey[$k];
        }

        $throughColumnPrefix = $this->relation->getOption(RelationConfig::THROUGH_COLUMNS_PREFIX);
        foreach ((array)$this->relation->getOption(RelationConfig::THROUGH_COLUMNS) as $col) {
            $insertColumns[$col] = $this->relation
                ->getForeignMapper()
                ->getEntityAttribute($this->foreignEntity, "{$throughColumnPrefix}{$col}");
        }

        foreach ((array)$this->relation->getOption(RelationConfig::THROUGH_GUARDS) as $col => $value) {
            if (!is_int($col)) {
                $insertColumns[$col] = $value;
            }
        }

        $insert = new \Sirius\Sql\Insert($conn);
        $insert->into($throughTable)
               ->columns($insertColumns)
               ->perform();
    }
}