Vaimo\ComposerChangelogs\Loaders\ChangelogLoader

Complexity

Total Complexity

9

Size/Duplication

Total Lines	73
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	load()	0	32	4
A	walkRecursiveRemove()	0	11	4
A	__construct()	0	6	1

<?php
/**
 * Copyright © Vaimo Group. All rights reserved.
 * See LICENSE_VAIMO.txt for license details.
 */
namespace Vaimo\ComposerChangelogs\Loaders;

class ChangelogLoader
{
    /**
     * @var \Vaimo\ComposerChangelogs\Resolvers\ChangelogConfigResolver
     */
    private $configResolver;

    /**
     * @var \Vaimo\ComposerChangelogs\Readers\JsonFileReader
     */
    private $jsonFileReader;
    
    /**
     * @var array
     */
    private $cache = array();

    /**
     * @param \Vaimo\ComposerChangelogs\Resolvers\ChangelogConfigResolver $configResolver
     */
    public function __construct(
        \Vaimo\ComposerChangelogs\Resolvers\ChangelogConfigResolver $configResolver
    ) {
        $this->configResolver = $configResolver;
        
        $this->jsonFileReader = new \Vaimo\ComposerChangelogs\Readers\JsonFileReader();
    }

    public function load(\Composer\Package\PackageInterface $package)
    {
        $packageName = $package->getName();

        if (!isset($this->cache[$packageName])) {
            $sourcePath = $this->configResolver->resolveSourcePath($package);
            
            if (!$sourcePath) {
                throw new \Vaimo\ComposerChangelogs\Exceptions\LoaderException(
                    sprintf('Changelog source path not defined for: %s', $package->getName())
                );
            }
            
            $dataUtils = new \Vaimo\ComposerChangelogs\Utils\DataUtils();

            $changelogData = $this->jsonFileReader->readToArray($sourcePath);
            
            $groups = $dataUtils->walkArrayNodes(
                $changelogData,
                function (array $value) use ($dataUtils) {
                    return $dataUtils->removeKeysByPrefix($value, '_');
                }
            );
            
            foreach (array_keys($groups) as $version) {
                $groups[$version]['version'] = $version;
            }

            $this->cache[$packageName] = $groups;
        }

        return $this->cache[$packageName];
    }

    public function walkRecursiveRemove(array $array, $callback)
    {
        foreach ($array as $key => $value) {
            if (is_array($value)) {
                $array[$key] = $this->walkRecursiveRemove($value, $callback);
            } elseif ($callback($value, $key)) {
                unset($array[$key]);
            }
        }

        return $array;
    }
}