JK\SamBundle\Command\WatchCommand

Complexity

Total Complexity

10

Size/Duplication

Total Lines	122
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	8

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	configure()	0	7	1
A	execute()	0	57	4
A	stopWatch()	0	7	1
B	collectSources()	0	24	4

<?php

namespace JK\SamBundle\Command;

use Exception;
use JK\SamBundle\Watcher\Indexer\FileIndexer;
use Symfony\Component\Console\Input\ArrayInput;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Style\SymfonyStyle;

class WatchCommand extends AbstractAssetsCommand
{
    /**
     * Indicate if the watching loop should continue.
     *
     * @var bool
     */
    protected $shouldStop = false;

    /**
     *
     */
    protected function configure()
    {
        $this
            ->setName('jk:assets:watch')
            ->setDescription('Watch the assets according to your tasks configuration ("jk_assets")')
        ;
    }

    /**
     * @param InputInterface $input
     * @param OutputInterface $output
     * @return int|null|void
     * @throws Exception
     */
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $this->io = new SymfonyStyle($input, $output);
        $this
            ->io
            ->title('Symfony PHP Assets Manager');
        $this
            ->io
            ->section('Watch assets changes');

        // get debug mode
        $this->debug = $this
            ->container
            ->getParameter('jk.assets.debug');

        if ($this->debug) {
            $this->io->note('Debug Mode...');
        }

        // on Ctrl+C, we must stop to watch files
        pcntl_signal(SIGTERM, [$this, 'stopWatch']);
        pcntl_signal(SIGINT, [$this, 'stopWatch']);

        $indexer = new FileIndexer();
        $sources = $this->collectSources($input);

        // start watching sources
        $this
            ->io
            ->text('Watching...');

        while (!$this->shouldStop) {
            $indexer->index($sources);

            if ($indexer->hasChangedEntries()) {
                $this
                    ->io
                    ->note('Sources has been modified...');

                $runCommand = new RunCommand();
                $runCommand->setContainer($this->container);
                $runCommand->run(new ArrayInput([]), $output);

                $this
                    ->io
                    ->text('Watching...');
            }

            pcntl_signal_dispatch();
            sleep(1);
        }

        // display end message
        $this->io->success('Assets watching end');

        return;
    }

    public function stopWatch()
    {
        $this->shouldStop = true;
        $this
            ->io
            ->note('Stop watching changes');
    }

    /**
     * @param InputInterface $input
     *
     * @return array
     */
    protected function collectSources(InputInterface $input)
    {
        $sources = [];
        $directories = [];
        $tasks = $this->buildTasks($input);

$input is of type object<Symfony\Component\Console\Input\InputInterface>, but the function expects a array.

        foreach ($tasks as $task) {
            $sources = array_merge($sources, $task->getSources());
        }
        foreach ($sources as $source) {

            if (is_dir($source)) {
                $directory = $source;
            } else {
                $directory = dirname($source);
            }
            $this
                ->io
                ->text('Found new directory : '.$directory);
            $directories[] = $directory;
        }

        return $directories;
    }
}