WebHemi\Data\Coupler\AbstractDataCoupler

Complexity

Total Complexity

8

Size/Duplication

Total Lines	99
Duplicated Lines	8.08 %

Coupling/Cohesion

Components	2
Dependencies	2

Test Coverage

Coverage

0%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	10	2
A	getDataAdapter()	0	4	1
	getEntityDependencies()	0	1	?
A	getNewEntityInstance()	8	8	2
B	getEntityDataSet()	0	28	3

<?php
/**
 * WebHemi.
 *
 * PHP version 5.6
 *
 * @copyright 2012 - 2016 Gixx-web (http://www.gixx-web.com)
 * @license   https://opensource.org/licenses/MIT The MIT License (MIT)
 *
 * @link      http://www.gixx-web.com
 */
namespace WebHemi\Data\Coupler;

use RuntimeException;
use WebHemi\Adapter\Data\DataAdapterInterface;
use WebHemi\Data\Entity\DataEntityInterface;

/**
 * Class AbstractDataCoupler.
 */
abstract class AbstractDataCoupler implements DataCouplerInterface
{
    /** @var DataAdapterInterface */
    private $defaultAdapter;
    /** @var array<DataEntityInterface> */
    protected $dataEntityPrototypes = [];
    /** @var string */
    protected $connectorIdKey;
    /** @var string */
    protected $connectorDataGroup;
    /** @var array */
    protected $dependentDataGroups;

    /**
     * DataCouplerInterface constructor.
     *
     * @param DataAdapterInterface $defaultAdapter
     * @param DataEntityInterface[] ...$dataEntityPrototypes
     */
    final public function __construct(
        DataAdapterInterface $defaultAdapter,
        DataEntityInterface ...$dataEntityPrototypes
    ) {
        $this->defaultAdapter = $defaultAdapter;

        foreach ($dataEntityPrototypes as $entityPrototype) {
            $this->dataEntityPrototypes[get_class($entityPrototype)] = $entityPrototype;
        }
    }

    /**
     * Returns the DataAdapter instance.
     *
     * @return DataAdapterInterface
     */
    final public function getDataAdapter()
    {
        return $this->defaultAdapter;
    }

    /**
     * Gets all the entities those are depending from the given entity.
     *
     * @param DataEntityInterface $entity
     * @return array<DataEntityInterface>
     */
    abstract public function getEntityDependencies(DataEntityInterface $entity);

    /**
     * Returns a new instance of the required entity.
     *
     * @param string $entityClassName
     * @throws RuntimeException
     * @return DataEntityInterface
     */
    protected function getNewEntityInstance($entityClassName)

This method seems to be duplicated in your project.

    {
        if (!isset($this->dataEntityPrototypes[$entityClassName])) {
            throw new RuntimeException(sprintf('Class %s is not defined in this Coupler.', $entityClassName));
        }

        return clone $this->dataEntityPrototypes[$entityClassName];
    }

    /**
     * Gets raw depending entity data list for the given entity.
     *
     * @param DataEntityInterface $entity
     * @return array
     */
    protected function getEntityDataSet(DataEntityInterface $entity)
    {
        $entityClassName = get_class($entity);
        $entityDataSet = [];
        $identifiers = [];

        $this->getDataAdapter()->setDataGroup($this->connectorDataGroup)
            ->setIdKey($this->connectorIdKey);

        $dataList = $this->getDataAdapter()->getDataSet([
            $this->dependentDataGroups[$entityClassName]['source_key'].' = ?' => $entity->getKeyData()
        ]);

        foreach ($dataList as $rowData) {
            $identifiers[] = $rowData[$this->dependentDataGroups[$entityClassName]['connector_key']];
        }

        if (!empty($identifiers)) {
            $this->getDataAdapter()->setDataGroup($this->dependentDataGroups[$entityClassName]['depending_group'])
                ->setIdKey($this->dependentDataGroups[$entityClassName]['depending_id_key']);

            $entityDataSet = $this->getDataAdapter()->getDataSet([
                $this->dependentDataGroups[$entityClassName]['depending_id_key'].' IN (?)' => $identifiers
            ]);
        }

        return $entityDataSet;
    }
}