Ndrx\Profiler\DataSources\File

Complexity

Total Complexity

19

Size/Duplication

Total Lines	191
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

97.37%

Importance

Changes	15
Bugs	3	Features	4

11 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	getProcess()	0	16	3
A	clear()	0	5	1
A	deleteProcess()	0	4	1
A	save()	0	8	1
A	initializeFolder()	0	6	2
A	getProcessFolder()	0	10	2
B	all()	0	27	3
A	count()	0	10	1
A	saveSummary()	0	16	3
A	getFolder()	0	4	1

<?php
/**
 * Created by PhpStorm.
 * User: arnaud
 * Date: 01/11/15
 * Time: 19:46
 */

namespace Ndrx\Profiler\DataSources;

use Ndrx\Profiler\DataSources\Contracts\DataSourceInterface;
use Ndrx\Profiler\Process;
use Symfony\Component\Filesystem\Exception\IOException;
use Symfony\Component\Filesystem\Filesystem;
use Symfony\Component\Finder\Finder;
use Symfony\Component\Finder\SplFileInfo;

/**
 * Class File
 * @package Ndrx\Profiler\DataSources
 */
class File implements DataSourceInterface
{
    const SUMMARY_FILENAME = 'summary.json';

    /**
     * @var string
     */
    protected $folder;

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

    /**
     * File constructor.
     */
    public function __construct($outputFolder)
    {
        $this->folder = $outputFolder;

        $this->filesystem = new Filesystem();
        $this->initializeFolder();
    }

    /**
     * @param $processId
     * @return \Generator
     * @throws \InvalidArgumentException
     */
    public function getProcess($processId)
    {
        $finder = new Finder();
        $iterator = $finder
            ->name('*.json')
            ->sortByName()
            ->in($this->getProcessFolder($processId));

        /** @var SplFileInfo $file */
        foreach ($iterator as $file) {
            if (self::SUMMARY_FILENAME === $file->getFilename()) {
                continue;
            }
            yield file_get_contents($file->getPath() . DIRECTORY_SEPARATOR . $file->getFilename());
        }
    }

    /**
     * @throws IOException
     * @throws \InvalidArgumentException
     */
    public function clear()
    {
        $finder = new Finder();
        $this->filesystem->remove($finder->in($this->folder));
    }

    /**
     * @throws IOException
     * @throws \InvalidArgumentException
     */
    public function deleteProcess($processId)
    {
        $this->filesystem->remove($this->getProcessFolder($processId));
    }

    /**
     * @param Process $process
     * @param array $item
     * @throws IOException
     * @return bool
     */
    public function save(Process $process, array $item)
    {
        $fileName = $this->getProcessFolder($process->getId())
            . DIRECTORY_SEPARATOR . microtime(true)
            . '-' . rand() . '.json';

        return file_put_contents($fileName, json_encode($item)) !== false;
    }

    /**
     * @return string
     * @throws IOException
     */
    protected function initializeFolder()
    {
        if (!is_dir($this->folder)) {
            $this->filesystem->mkdir($this->folder, 0777);
        }
    }

    /**
     * @param $processId
     * @return string
     * @throws IOException
     */
    protected function getProcessFolder($processId)
    {
        $processFolder = $this->folder . DIRECTORY_SEPARATOR . $processId;

        if (!is_dir($processFolder)) {
            $this->filesystem->mkdir($processFolder, 0777);
        }

        return $processFolder;
    }

    /**
     * @param int $offset
     * @param int $limit
     * @throws IOException
     * @throws \InvalidArgumentException
     * @throws \LogicException
     * @return array
     */
    public function all($offset = 0, $limit = 15)
    {
        $finder = new Finder();
        $iterator = $finder
            ->directories()
            ->depth(0)
            ->sortByModifiedTime()
            ->in($this->folder)
            ->getIterator();


        $processFiles = array_slice(iterator_to_array($iterator), $offset, $limit);

        $process = [];
        /** @var SplFileInfo $current */
        foreach ($processFiles as $current) {
            $summaryFile = $current->getPath() . DIRECTORY_SEPARATOR
                . $current->getFilename() . DIRECTORY_SEPARATOR
                . self::SUMMARY_FILENAME;

            if ($this->filesystem->exists($summaryFile)) {
                $process[] = json_decode(file_get_contents($summaryFile));
            }
        }

        return $process;
    }

    /**
     * @return int
     * @throws IOException
     * @throws \InvalidArgumentException
     */
    public function count()
    {
        $finder = new Finder();

        return $finder
            ->directories()
            ->depth(0)
            ->in($this->folder)
            ->count();
    }

    /**
     * @param Process $process
     * @param array $item
     * @return mixed
     * @throws IOException
     */
    public function saveSummary(Process $process, array $item)
    {
        $fileName = $this->getProcessFolder($process->getId())
            . DIRECTORY_SEPARATOR . self::SUMMARY_FILENAME;

        if ($this->filesystem->exists($fileName)) {
            $content = json_decode(file_get_contents($fileName));
            if (is_bool($content)) {
                $content = [];
            }

            $item = array_merge((array) $content, $item);
        }

        return file_put_contents($fileName, json_encode($item)) !== false;
    }

    /**
     * @return string
     */
    public function getFolder()
    {
        return $this->folder;
    }
}