SwooleTW\Http\HotReload\FSProcess

Complexity

Total Complexity

8

Size/Duplication

Total Lines	83
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	configure()	0	10	2
A	__construct()	0	6	1
A	make()	0	14	5

<?php

namespace SwooleTW\Http\HotReload;

use Swoole\Process as SwooleProcess;
use Symfony\Component\Process\Process as AppProcess;

/**
 * Class FSProcess
 */
class FSProcess
{
    /**
     * Observed files.
     *
     * @var array
     */
    protected $filter;

    /**
     * Watch recursively.
     *
     * @var bool
     */
    protected $recursively;

    /**
     * Watch directory.
     *
     * @var string
     */
    protected $directory;

    /**
     * When locked event cannot do anything.
     *
     * @var bool
     */
    protected $locked;

    /**
     * FSProcess constructor.
     *
     * @param string $filter
     * @param bool $recursively
     * @param string $directory
     */
    public function __construct(string $filter, bool $recursively, string $directory)
    {
        $this->filter = $filter;

It seems like $filter of type string is incompatible with the declared type array of property $filter.

        $this->recursively = $recursively;
        $this->directory = $directory;
        $this->locked = false;
    }

    /**
     * Make swoole process.
     *
     * @param callable|null $callback
     *
     * @return \Swoole\Process
     */
    public function make(?callable $callback = null)
    {
        $mcb = function ($type, $buffer) use ($callback) {
            if (! $this->locked && AppProcess::OUT === $type && $event = FSEventParser::toEvent($buffer)) {
                $this->locked = true;
                ($callback) ? $callback($event) : null;
                $this->locked = false;
                unset($event);
            }
        };

        return new SwooleProcess(function () use ($mcb) {
            (new AppProcess($this->configure()))->setTimeout(0)->run($mcb);
        }, false, false);
    }

    /**
     * Configure process.
     *
     * @return array
     */
    protected function configure(): array
    {
        return [
            'fswatch',
            $this->recursively ? '-rtx' : '-tx',
            '-e',
            '.*',
            '-i',
            "\\{$this->filter}$",
            $this->directory,
        ];
    }
}