Spiral\ORM\Entities\RecordSource

Complexity

Total Complexity

12

Size/Duplication

Total Lines	141
Duplicated Lines	9.93 %

Coupling/Cohesion

Components	2
Dependencies	5

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	14	14	3
A	create()	0	5	1
A	findByPK()	0	4	1
A	findOne()	0	4	1
A	find()	0	4	1
A	count()	0	4	1
A	selector()	0	5	1
A	setSelector()	0	4	1
A	container()	0	8	2

<?php
/**
 * Spiral Framework.
 *
 * @license   MIT
 * @author    Anton Titov (Wolfy-J)
 */

namespace Spiral\ORM\Entities;

use Spiral\Core\Component;
use Spiral\Core\Exceptions\SugarException;
use Spiral\Core\Traits\SaturateTrait;
use Spiral\Models\SourceInterface;
use Spiral\ORM\Exceptions\SourceException;
use Spiral\ORM\ORM;
use Spiral\ORM\ORMInterface;
use Spiral\ORM\RecordEntity;

/**
 * Source class associated to one or multiple (default implementation) ORM models. Source can be
 * used to write your own custom find method or change default selection.
 */
class RecordSource extends Component implements SourceInterface, \Countable
{
    use SaturateTrait;

    /**
     * Linked document model. ORM can automatically index and link user sources to models based on
     * value of this constant.
     */
    const RECORD = null;

    /**
     * Associated document class.
     *
     * @var string
     */
    private $class = null;

    /**
     * @var RecordSelector
     */
    private $selector = null;

    /**
     * @invisible
     *
     * @var ORM
     */
    protected $orm = null;

    /**
     * @param string       $class
     * @param ORMInterface $orm
     *
     * @throws SugarException
     */
    public function __construct($class = null, ORMInterface $orm = null)

This method seems to be duplicated in your project.

    {
        if (empty($class)) {
            if (empty(static::RECORD)) {
                throw new SourceException('Unable to create source without associated class');
            }

            $class = static::RECORD;
        }

        $this->class = $class;
        $this->orm = $this->saturate($orm, ORMInterface::class);
        $this->setSelector($this->orm->selector($this->class));
    }

    /**
     * Create new Record based on set of provided fields.
     *
     * @final Change static method of entity, not this one.
     *
     * @param array $fields
     *
     * @return RecordEntity
     */
    final public function create($fields = [])
    {
        //Letting entity to create itself (needed
        return call_user_func([$this->class, 'create'], $fields, $this->orm);
    }

    /**
     * Find record by it's primary key.
     *
     * @see findOne()
     *
     * @param string|int $id Primary key value.
     *
     * @return RecordEntity|null
     */
    public function findByPK($id)
    {
        return $this->find()->findByPK($id);
    }

    /**
     * Select one record from mongo collection.
     *
     * @param array $where   Where conditions in array form.
     * @param array $orderBy In a form of [key => direction].
     *
     * @return RecordEntity|null
     */
    public function findOne(array $where = [], array $orderBy = [])
    {
        return $this->find()->orderBy($orderBy)->findOne($where);
    }

    /**
     * Get associated record selection with pre-configured query (if any).
     *
     * @param array $where Where conditions in array form.
     *
     * @return RecordSelector
     */
    public function find(array $where = [])
    {
        return $this->selector()->where($where);
    }

    /**
     * {@inheritdoc}
     */
    public function count()
    {
        return $this->find()->count();
    }

    /**
     * @return RecordSelector
     */
    final protected function selector()
    {
        //Has to be cloned every time to prevent query collisions
        return clone $this->selector;
    }

    /**
     * @param RecordSelector $selector
     */
    protected function setSelector(RecordSelector $selector)
    {
        $this->selector = $selector;
    }

    /**
     * {@inheritdoc}
     */
    protected function container()
    {
        if ($this->orm instanceof Component) {
            return $this->orm->container();

The method container() cannot be called from this context as it is declared protected in class Spiral\Core\Component.

        }

        return parent::container();
    }
}