Suricate\PivotTable

Complexity

Total Complexity

13

Size/Duplication

Total Lines	109
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	12
Bugs	2	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	2
B	loadFor()	0	61	6
A	getTargetForRelation()	0	10	2
A	getSourceFieldForRelation()	0	10	2
A	getCollectionClass()	0	3	1

<?php

declare(strict_types=1);

namespace Suricate;

class PivotTable extends DBObject
{
    protected $references = [];
    protected $collectionClass = DBCollection::class;

    public function __construct()
    {
        parent::__construct();

        foreach ($this->references as $referenceName => $referenceData) {
            $this->relations[$referenceName] = [
                'type' => self::RELATION_ONE_ONE,
                'source' => $referenceData['key'],
                'target' => $referenceData['type']
            ];
        }
    }

    public function getCollectionClass()
    {
        return $this->collectionClass;
    }

    public static function loadFor(
        $relation,
        $parentId,
        $target = null,
        $validate = null
    ) {
        $pivot = new static();
        $pivot->connectDB();

        $items = [];
        if ($target !== null) {
            $className = $pivot->getTargetForRelation($target);
            $targetClass = $className;
            $sourceField = $pivot->getSourceFieldForRelation($target);

            $query = "SELECT t.* FROM " . $className::tableName() . " t";
            $query .= " LEFT JOIN " . $pivot->getTableName() . " p";
            $query .=
                "     ON p.`" .
                $sourceField .
                "`=t." .
                $className::tableIndex();
            $query .= " WHERE";
            $query .=
                "     `" .
                $pivot->getSourceFieldForRelation($relation) .
                "` =  :id";
            $query .= " GROUP BY t." . $targetClass::tableIndex();
        } else {
            $query = "SELECT *";
            $query .= " FROM `" . $pivot->getTableName() . "`";
            $query .= " WHERE";
            $query .=
                "     `" .
                $pivot->getSourceFieldForRelation($relation) .
                "` =  :id";

            $targetClass = $pivot;
        }

        $params = ['id' => $parentId];

        $results = $pivot->dbLink
            ->query($query, $params)
            ->fetchAll(\PDO::FETCH_ASSOC);

        foreach ($results as $result) {
            $add = true;

            $itemToAdd = $targetClass::instanciate($result);

            if ($validate !== null && is_callable($validate)) {
                $add = $validate($itemToAdd);
            }
            if ($add) {
                $items[] = $itemToAdd;
            }
        }

        $collectionClass = $pivot->getCollectionClass();
        return new $collectionClass($items);
    }

    public function getSourceFieldForRelation($relationName)
    {
        if (isset($this->relations[$relationName])) {
            return $this->relations[$relationName]['source'];
        }

        throw new \InvalidArgumentException(
            'Cannot get field for relation "' .
                $relationName .
                '" : Unknown relation'
        );
    }

    public function getTargetForRelation($relationName)
    {
        if (isset($this->relations[$relationName])) {
            return $this->relations[$relationName]['target'];
        }

        throw new \InvalidArgumentException(
            'Cannot get target for relation "' .
                $relationName .
                '" : Unknown relation'
        );
    }
}