Oliverde8\PhpEtlBundle\Services\ChainWorkDirManager

Complexity

Total Complexity

6

Size/Duplication

Total Lines	45
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	getWorkDir()	0	6	1
A	__construct()	0	4	1
A	listFiles()	0	13	4

<?php


namespace Oliverde8\PhpEtlBundle\Services;


use Oliverde8\PhpEtlBundle\Entity\EtlExecution;
use Symfony\Component\Filesystem\Exception\IOException;
use Symfony\Component\Filesystem\Filesystem;

class ChainWorkDirManager
{
    /** @var string  */
    protected $baseDir;

    /** @var Filesystem */
    protected $fileSystem;

    /**
     * ChainWorkDirManager constructor.
     * @param string $directory
     */
    public function __construct(string $baseDir, Filesystem $filesystem)
    {
        $this->baseDir = $baseDir;
        $this->fileSystem = $filesystem;
    }

    /**
     * @param EtlExecution $execution
     * @return string
     *
     * @throws IOException if directory can't be created.
     */
    public function getWorkDir(EtlExecution $execution): string
    {
        $dir = $this->baseDir . "/" . $execution->getStartTime()->format("y/m/d") . "/id-" . $execution->getId() . "/";
        $this->fileSystem->mkdir($dir);

        return $dir;
    }

    public function listFiles(EtlExecution $execution): array
    {
        $files = [];
        $dir = $this->getWorkDir($execution);

        $handle = opendir($dir);
        while (false !== ($entry = readdir($handle))) {
            if ($entry != "." && $entry != "..") {
                $files[] = $entry;
            }
        }

        return $files;
    }
}