SimpleCrud\Queries\Traits\HasRelatedWith

Complexity

Total Complexity

15

Size/Duplication

Total Lines	109
Duplicated Lines	10.09 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	relatedWith()	0	14	4
A	applyTableRelation()	11	42	4
B	applyRowRelation()	0	44	7

<?php
declare(strict_types = 1);

namespace SimpleCrud\Queries\Traits;

use InvalidArgumentException;
use RuntimeException;
use SimpleCrud\Row;
use SimpleCrud\RowCollection;
use SimpleCrud\Table;

trait HasRelatedWith
{
    /**
     * @param Row|RowCollection|Table
     * @param mixed $related
     */
    public function relatedWith($related): self
    {
        if ($related instanceof Row || $related instanceof RowCollection) {
            return $this->applyRowRelation($related);
        }

        if ($related instanceof Table) {
            return $this->applyTableRelation($related);
        }

        throw new InvalidArgumentException(
            'Invalid argument type. Only instances of Row, Table and RowCollection are allowed'
        );
    }

    private function applyTableRelation(Table $table2): self
    {
        $table1 = $this->table;

The property table does not exist. Did you maybe forget to declare it?

        //Has one
        if ($field = $table1->getJoinField($table2)) {
            return $this->where("{$field} IS NOT NULL");

It seems like where() must be provided by classes using this trait. How about adding it as abstract method to this trait?

        }

        //Has many
        if ($field = $table2->getJoinField($table1)) {

This code seems to be duplicated across your project.

            $this->query

The property query does not exist. Did you maybe forget to declare it?

                ->join(
                    'LEFT',
                    (string) $table2,
                    sprintf('%s = %s', $field, $table1->id)
                )
                ->where(sprintf('%s IS NOT NULL', $field));

            return $this;
        }

        //Has many to many
        if ($joinTable = $table1->getJoinTable($table2)) {
            $field1 = $joinTable->getJoinField($table1);
            $field2 = $joinTable->getJoinField($table2);

            $this->query
                ->join(
                    'LEFT',
                    (string) $joinTable,
                    sprintf('%s = %s', $field1, $table1->id)
                )
                ->where(sprintf('%s IS NOT NULL', $field2));

            return $this;
        }

        throw new RuntimeException(
            sprintf('The tables %s and %s are not related', $table1, $table2)
        );
    }

    private function applyRowRelation($row): self
    {
        $table1 = $this->table;
        $table2 = $row->getTable();

        //Has one
        if ($field = $table1->getJoinField($table2)) {
            $this->query->whereEquals([(string) $field => $row->id ?: null]);
            return $this;
        }

        //Has many
        if ($field = $table2->getJoinField($table1)) {
            $this->query
                ->join(
                    'LEFT',
                    (string) $table2,
                    sprintf('%s = %s', $field, $table1->id)
                );

            $this->query->whereEquals([(string) $table2->id => $row->id ?: null]);
            return $this;
        }

        //Has many to many
        if ($joinTable = $table1->getJoinTable($table2)) {
            $field1 = $joinTable->getJoinField($table1);
            $field2 = $joinTable->getJoinField($table2);

            $this->query
                ->join(
                    'LEFT',
                    (string) $joinTable,
                    sprintf('%s = %s', $field1, $table1->id)
                );

            $this->query->whereEquals([(string) $field2 => $row->id ?: null]);
            return $this;
        }

        throw new RuntimeException(
            sprintf('The tables %s and %s are not related', $table1, $table2)
        );
    }
}