Cecil\Step\DataLoad::process()

Complexity

Conditions	9
Paths	13

Size

Total Lines	76
Code Lines	53

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

<?php
    public function process()
    {
        call_user_func_array($this->builder->getMessageCb(), ['DATA', 'Loading data']);

        $files = Finder::create()
            ->files()
            ->in($this->builder->getConfig()->getDataPath())
            ->name('/\.('.implode('|', $this->builder->getConfig()->get('data.ext')).')$/')

It seems like $this->builder->getConfig()->get('data.ext') can also be of type null; however, parameter $pieces of implode() does only seem to accept array, maybe add an additional type check?

            ->sortByName(true);
        $max = count($files);

        if ($max <= 0) {
            $message = 'No files';
            call_user_func_array($this->builder->getMessageCb(), ['DATA_PROGRESS', $message]);

            return;
        }

        // YAML
        $serializerYaml = new Serializer([new ObjectNormalizer()], [new YamlEncoder()]);
        // JSON
        $serializerJson = new Serializer([new ObjectNormalizer()], [new JsonEncoder()]);
        // CSV
        $serializerCsv = new Serializer([new ObjectNormalizer()], [new CsvEncoder()]);
        // XML
        $serializerXml = new Serializer([new ObjectNormalizer()], [new XmlEncoder()]);

        $count = 0;

        /* @var $file \Symfony\Component\Finder\SplFileInfo */
        foreach ($files as $file) {
            $count++;
            set_error_handler(
                function ($severity, $message, $file, $line) {
                    throw new \ErrorException($message, 0, $severity, $file, $line, null);
                }
            );
            $data = $file->getContents();
            restore_error_handler();

            switch ($file->getExtension()) {
                case 'yml':
                case 'yaml':
                    $dataArray = $serializerYaml->decode($data, 'yaml');
                    break;
                case 'json':
                    $dataArray = $serializerJson->decode($data, 'json');
                    break;
                case 'csv':
                    $dataArray = $serializerCsv->decode($data, 'csv');
                    break;
                case 'xml':
                    $dataArray = $serializerXml->decode($data, 'xml');
                    break;
                default:
                    return;
            }

            $basename = $file->getBasename('.'.$file->getExtension());
            $subpath = \Cecil\Util::getFS()->makePathRelative(
                $file->getPath(),
                $this->builder->getConfig()->getDataPath()
            );
            $subpath = trim($subpath, './');
            $array = [];
            $path = $subpath ? $subpath.'/'.$basename : $basename;
            $this->pathToArray($array, $path, $dataArray);

            $dataArray = array_merge_recursive(
                $this->builder->getData(),
                $array
            );
            $this->builder->setData($dataArray);

            $message = sprintf('"%s" loaded', $path);
            call_user_func_array($this->builder->getMessageCb(), ['DATA_PROGRESS', $message, $count, $max]);
        }