Triadev\Leopard\Business\Mapping\Mapper

Complexity

Total Complexity

9

Size/Duplication

Total Lines	81
Duplicated Lines	0 %

Test Coverage

Coverage

89.66%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	getMappingFiles()	0	7	1
A	run()	0	27	5
A	isMappingAlreadyRun()	0	7	2
A	__construct()	0	8	1

<?php
namespace Triadev\Leopard\Business\Mapping;

use Illuminate\Filesystem\Filesystem;
use Triadev\Leopard\Contract\Repository\MappingLogRepositoryContract;

class Mapper
{
    /** @var Filesystem */
    private $filesystem;
    
    /** @var MappingLogRepositoryContract */
    private $mappingLogRepository;
    
    /** @var array */
    private $mappingLogs;
    
    /**
     * Mapper constructor.
     * @param Filesystem $filesystem
     * @param MappingLogRepositoryContract $mappingLogRepository
     */
    public function __construct(Filesystem $filesystem, MappingLogRepositoryContract $mappingLogRepository)
    {
        $this->filesystem = $filesystem;
        $this->mappingLogRepository = $mappingLogRepository;
    
        $this->mappingLogs = array_map(function ($log) {
            return $log['mapping'];
        }, $this->mappingLogRepository->all());
    }
    
    /**
     * Run mappings
     *
     * @param string $path
     * @param string|null $index
     * @param string|null $type
     *
     * @throws \Throwable
     */
    public function run(string $path, ?string $index = null, ?string $type = null)
    {
        $mappingFiles = $this->getMappingFiles($path);
        
        sort($mappingFiles);
        
        foreach ($mappingFiles as $mappingFile) {
            if ($this->isMappingAlreadyRun($mappingFile)) {
                continue;
            }
            
            $this->filesystem->requireOnce($path . DIRECTORY_SEPARATOR . $mappingFile . '.php');
            
            /** @var Mapping $mapping */
            $mapping = new $mappingFile();
            
            if ($index) {
                $mapping->setDocumentIndex($index);
            }
            
            if ($type) {
                $mapping->setDocumentType($type);
            }
            
            $mapping->map();
            
            $this->mappingLogRepository->add($mappingFile);
        }
    }
    
    private function getMappingFiles(string $path): array
    {
        $files = $this->filesystem->glob($path . DIRECTORY_SEPARATOR . '*.php');
        
        return array_map(function (string $file) {
            return str_replace('.php', '', basename($file));
        }, $files);
    }
    
    private function isMappingAlreadyRun(string $mapping) : bool
    {
        if (in_array($mapping, $this->mappingLogs)) {
            return true;
        }
        
        return false;
    }
}