midgard_collector

Complexity

Total Complexity

27

Size/Duplication

Total Lines	172
Duplicated Lines	0 %

Test Coverage

Coverage

92.54%

Importance

Changes	7
Bugs	0	Features	0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	get()	0	3	1
A	build_property_select()	0	20	5
A	set_key_property()	0	9	2
A	__construct()	0	5	2
A	list_keys()	0	6	2
A	_has_results()	0	4	1
B	execute()	0	45	9
A	add_value_property()	0	14	4
A	get_subkey()	0	3	1

<?php
/**
 * @author CONTENT CONTROL http://www.contentcontrol-berlin.de/
 * @copyright CONTENT CONTROL http://www.contentcontrol-berlin.de/
 * @license http://www.gnu.org/licenses/gpl.html GNU General Public License
 */

use midgard\portable\api\error\exception;

This use statement conflicts with another class in this namespace, exception. Consider defining an alias.

use midgard\portable\storage\connection;

class midgard_collector extends midgard_query_builder
{
    /**
     * the results determined by execute
     *
     * @var array
     */
    private $_results = null;

    /**
     *
     * @var string
     */
    private $key_property = "guid";

    private $value_properties = [];

    public function __construct($class, $field = null, $value = null)
    {
        parent::__construct($class);
        if ($field) {
            $this->add_constraint($field, '=', $value);
        }
    }

    /**
     * @param string $property
     * @return boolean
     */
    public function set_key_property($property)
    {
        // after execute there is no sense in changing the key property
        if ($this->_results !== null) {
            return false;
        }
        $this->key_property = $property;

        return true;
    }

    /**
     * @param string $property
     * @return boolean
     */
    public function add_value_property($property)
    {
        if ($this->_results !== null) {
            return false;
        }

        if (!isset($this->value_properties[$property])) {
            try {
                $this->value_properties[$property] = $this->build_property_select($property);
            } catch (exception $e) {
                return false;
            }
        }
        return true;
    }

    protected function build_property_select($property)
    {
        $parsed = $this->parse_constraint_name($property);

        // for properties like up.name
        if (   strpos($property, ".") !== false
            && !(strpos($property, "metadata") === 0)) {
            return $parsed['name'] . " as " . str_replace(".", "_", $property);
        }

        $cm = connection::get_em()->getClassMetadata($this->classname);
        if (array_key_exists($property, $cm->midgard['field_aliases'])) {
            return $parsed['name'] . " as " . str_replace(".", "_", $property);
        }

        if ($cm->hasAssociation($property)) {
            return 'IDENTITY(' . $parsed['name'] . ") as " . $property;
        }

        return $parsed['name'];
    }

    /**
     * @return boolean
     */
    public function execute()
    {
        if ($this->_results !== null) {
            return false;
        }
        $this->check_groups();
        $properties = $this->value_properties;
        if (!isset($this->value_properties[$this->key_property])) {
            try {
                $properties[] = $this->build_property_select($this->key_property);
            } catch (exception $e) {
                throw new exception('Property "' . $this->key_property . '" not found in "' . $this->classname . '"', exception::INVALID_PROPERTY, $e);
            }
        }

        $this->qb->addSelect(implode(", ", $properties));
        $this->pre_execution();
        $results = $this->qb->getQuery()->getArrayResult();
        $this->post_execution();

        $cm = connection::get_em()->getClassMetadata($this->classname);
        // map results by current key property
        $results_map = [];
        foreach ($results as $result) {
            foreach ($result as $key => &$value) {
                // for metadata fields remove the "metadata_" prefix
                if (strpos($key, "metadata_") !== false) {
                    $result[str_replace("metadata_", "", $key)] = $value;
                    unset($result[$key]);
                }
                // TODO: find out why Doctrine doesn't do this on its own
                if ($cm->hasAssociation($key)) {
                    $value = (int) $value;
                }
            }
            $key = $result[$this->key_property];
            if (!isset($this->value_properties[$this->key_property])) {
                unset($result[$this->key_property]);
            }

            $results_map[$key] = $result;
        }

        $this->_results = $results_map;
        return true;
    }

    /**
     *
     * @param string $key
     * @return array
     */
    public function get($key)
    {
        return $this->_results[$key] ?? false;
    }

    /**
     *
     * @param string $key
     * @param string $property
     */
    public function get_subkey($key, $property)
    {
        return $this->_results[$key][$property] ?? false;
    }

    /**
     * check whether we got any results to work on
     *
     * @return boolean
     */
    private function _has_results()
    {
        // execute was not called or we got an empty resultset
        return !empty($this->_results);
    }

    /**
     * @return array
     */
    public function list_keys()
    {
        if (!$this->_has_results()) {
            return [];
        }
        return array_fill_keys(array_keys($this->_results), '');
    }
}