Files.php

<?php

namespace Jh\Import\Type;

use Jh\Import\Config;
use Jh\Import\Import\ImporterFactory;
use Illuminate\Support\Collection;
use Magento\Framework\App\Filesystem\DirectoryList;
use Magento\Framework\Filesystem\Directory\WriteFactory;
use Magento\Framework\ObjectManagerInterface;

/**
 * @author Aydin Hassan <aydin@wearejh.com>
 */
class Files implements Type
{
    /**
     * @var DirectoryList
     */
    private $directoryList;

    /**
     * @var WriteFactory
     */
    private $writeFactory;

    /**
     * @var ObjectManagerInterface
     */
    private $objectManager;

    /**
     * @var ImporterFactory
     */
    private $importerFactory;

    /**
     * @var FileMatcher
     */
    private $filesMatcher;

    public function __construct(
        DirectoryList $directoryList,
        WriteFactory $writeFactory,
        ObjectManagerInterface $objectManager,
        ImporterFactory $importerFactory,
        FileMatcher $filesMatcher
    ) {
        $this->directoryList = $directoryList;
        $this->writeFactory = $writeFactory;
        $this->objectManager = $objectManager;
        $this->importerFactory = $importerFactory;
        $this->filesMatcher = $filesMatcher;
    }

    public function run(Config $config)
    {
        $filesToProcess = $this->getFilesToProcess($config);

        $specification = $this->objectManager->get($config->getSpecificationService());
        $writer        = $this->objectManager->get($config->getWriterService());

        $lastFileIndex = $filesToProcess->count() - 1;
        $filesToProcess->each(function ($file, $index) use ($config, $specification, $writer, $lastFileIndex) {
            $source = $this->objectManager->create($config->getSourceService(), [
                'file' => $file
            ]);

            $importer = $this->importerFactory->create($source, $specification, $writer);

            if ($config->get('process_only_last_file') && $index < $lastFileIndex) {
                $importer->skip($config);
            } else {
                $importer->process($config);
            }
        });
    }

    private function getFilesToProcess(Config $config): Collection
    {
        $directoryWriter = $this->writeFactory->create(
            sprintf(
                '%s/%s',
                $this->directoryList->getPath(DirectoryList::VAR_DIR),
                $config->get('incoming_directory')
            )
        );

        //ensure directory is created
        $directoryWriter->create();

        return $this->filesMatcher->matched(
            $config->get('match_files'),
            array_map(
                function (string $file) use ($directoryWriter) {
                    return $directoryWriter->getAbsolutePath($file);
                },
                $directoryWriter->read()
            )
        );
    }
}