Spiral\ORM\Entities\Nodes\PivotedNode

Complexity

Total Complexity

6

Size/Duplication

Total Lines	96
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	3

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	14	1
A	pushData()	0	19	3
A	fetchData()	0	10	1
A	duplicateCriteria()	0	7	1

<?php
/**
 * components
 *
 * @author    Wolfy-J
 */
namespace Spiral\ORM\Entities\Nodes;

use Spiral\ORM\Entities\Nodes\Traits\DuplicateTrait;
use Spiral\ORM\Exceptions\NodeException;
use Spiral\ORM\ORMInterface;

/**
 * Provides ability to parse columns of target table and map table all together.
 */
class PivotedNode extends AbstractNode implements ArrayInterface
{
    use DuplicateTrait;

    /**
     * @invisible
     * @var int
     */
    private $countPivot = 0;

    /**
     * @var string
     */
    protected $innerPivotKey;

    /**
     * @var string
     */
    protected $outerPivotKey;

    /**
     * @param array  $columns
     * @param array  $pivotColumns
     * @param string $outerKey
     * @param string $innerPivotKey
     * @param string $outerPivotKey
     */
    public function __construct(
        array $columns = [],
        array $pivotColumns = [],
        string $outerKey,
        string $innerPivotKey,
        string $outerPivotKey
    ) {
        //Pivot columns are always prior to table columns
        parent::__construct(array_merge($pivotColumns, $columns), $outerKey);
        $this->countPivot = count($pivotColumns);

        $this->innerPivotKey = $innerPivotKey;
        $this->outerPivotKey = $outerPivotKey;
    }

    /**
     * {@inheritdoc}
     */
    protected function pushData(array &$data)
    {
        if (empty($this->parent)) {
            throw new NodeException("Unable to register data tree, parent is missing");
        }

        if (is_null($data[ORMInterface::PIVOT_DATA][$this->outerPivotKey])) {
            //No data was loaded
            return;
        }

        //Mounting parsed data into parent under defined container
        $this->parent->mountArray(
            $this->container,
            $this->outerKey,
            $data[ORMInterface::PIVOT_DATA][$this->innerPivotKey],
            $data
        );
    }

    /**
     * {@inheritdoc}
     *
     * Method fetches pivot data into sub-array with key "@pivot".
     */
    protected function fetchData(int $dataOffset, array $line): array
    {
        $data = parent::fetchData($dataOffset, $line);

        //Forming pivot data presence
        return array_merge(
            [ORMInterface::PIVOT_DATA => array_slice($data, 0, $this->countPivot)],
            array_slice($data, $this->countPivot)
        );
    }

    /**
     * De-duplication in pivot tables based on values in pivot table.
     *
     * @param array $data
     *
     * @return string
     */
    protected function duplicateCriteria(array &$data)
    {
        $pivotData = $data[ORMInterface::PIVOT_DATA];

        //Unique row criteria
        return $pivotData[$this->innerPivotKey] . '.' . $pivotData[$this->outerPivotKey];
    }
}