ONGR\ElasticsearchBundle\Mapping\MappingTool

Complexity

Total Complexity

21

Size/Duplication

Total Lines	149
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	getRemovedTypes()	0	4	1
A	getUpdatedTypes()	0	4	1
A	countRecursiveScalars()	0	18	4
B	checkMapping()	0	27	6
A	symDifference()	0	7	1
C	recursiveDiff()	0	30	8

<?php

/*
 * This file is part of the ONGR package.
 *
 * (c) NFQ Technologies UAB <info@nfq.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace ONGR\ElasticsearchBundle\Mapping;

/**
 * Mapping tool for comparing.
 */
class MappingTool
{
    /**
     * @var array
     */
    private $removedTypes = [];

    /**
     * @var array
     */
    private $updatedTypes = [];

    /**
     * Compares two mappings and returns true if changes detected.
     *
     * @param array $oldMapping
     * @param array $newMapping
     *
     * @return bool
     */
    public function checkMapping($oldMapping, $newMapping)
    {
        $updated = false;

        // Find out which types don't exist anymore.
        $typeDiff = array_diff_key($oldMapping, $newMapping);
        foreach ($typeDiff as $oldTypeName => $oldType) {
            $this->removedTypes[] = $oldTypeName;
            $updated = true;
        }

        // Search for differences in types.
        foreach ($newMapping as $type => $properties) {
            $diff = null;
            if (array_key_exists($type, $oldMapping)) {
                $diff = $this->symDifference($properties, $oldMapping[$type]);
            }

            // Empty array type properties hasn't changed, NULL - new type.
            if ($diff !== [] || $diff === null) {
                $this->updatedTypes[$type] = $properties;
                $updated = true;
            }
        }

        return $updated;
    }

    /**
     * Returns symmetric difference.
     *
     * @param array $oldMapping
     * @param array $newMapping
     *
     * @return array
     */
    public function symDifference($oldMapping, $newMapping)
    {
        return array_replace_recursive(
            $this->recursiveDiff($oldMapping, $newMapping),
            $this->recursiveDiff($newMapping, $oldMapping)
        );
    }

    /**
     * Returns type name which has been removed.
     *
     * @return array
     */
    public function getRemovedTypes()
    {
        return $this->removedTypes;
    }

    /**
     * Returns type names with new properties which has been updated.
     *
     * @return array
     */
    public function getUpdatedTypes()
    {
        return $this->updatedTypes;
    }

    /**
     * Recursively computes the difference of arrays.
     *
     * @param array $compareFrom
     * @param array $compareAgainst
     *
     * @return array
     */
    private function recursiveDiff($compareFrom, $compareAgainst)
    {
        $out = [];

        foreach ($compareFrom as $mKey => $mValue) {
            if (array_key_exists($mKey, $compareAgainst)) {
                if (is_array($mValue)) {
                    $aRecursiveDiff = $this->recursiveDiff($mValue, $compareAgainst[$mKey]);
                    if (count($aRecursiveDiff)) {
                        $out[$mKey] = $aRecursiveDiff;
                    }
                } else {
                    if ($mValue != $compareAgainst[$mKey]) {
                        $out[$mKey] = $mValue;
                    }
                }
            } else {
                $out[$mKey] = $mValue;
            }
        }

        // Check for empty arrays.
        foreach ($out as $key => $element) {
            if ($this->countRecursiveScalars($element) == 0) {
                unset($out[$key]);
            }
        }

        return $out;
    }

    /**
     * Counts scalar values recursively in array.
     *
     * @param mixed $array
     *
     * @return int
     */
    private function countRecursiveScalars($array)
    {
        $count = 0;

        if (!is_array($array)) {
            return 1;
        }

        foreach ($array as $element) {
            if (is_array($element)) {
                $count += $this->countRecursiveScalars($element);
            } else {
                $count++;
            }
        }

        return $count;
    }
}