Inotify::_watch() - Code Metrics - hhxsv5/laravel-s - Measure and Improve Code Quality continuously with Scrutinizer

Inotify::_watch() B
last analyzed 2025-06-13 04:39 UTC

↳ Parent: Inotify

Complexity

Conditions	10
Paths	5

Size

Total Lines	29
Code Lines	19

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	10
eloc	19
nc	5
nop	1
dl	0
loc	29
rs	7.6666
c	0
b	0
f	0

How to fix Complexity

<?php


namespace Hhxsv5\LaravelS\Swoole;

use Swoole\Event;
use Swoole\Timer;

class Inotify

{
    private $fd;

    private $watchPath;

    private $watchMask;

    private $watchHandler;

    private $doing        = false;

    private $fileTypes    = [];

    private $excludedDirs = [];

    private $wdPath       = [];

    private $pathWd       = [];


    public function __construct($watchPath, $watchMask, callable $watchHandler)

    {
        $this->fd = inotify_init();
        $this->watchPath = $watchPath;
        $this->watchMask = $watchMask;
        $this->watchHandler = $watchHandler;
    }

    public function addFileType($type)

    {
        $type = '.' . trim($type, '.');
        $this->fileTypes[$type] = true;
    }

    public function addFileTypes(array $types)

    {
        foreach ($types as $type) {
            $this->addFileType($type);
        }
    }

    public function addExcludedDir($dir)

    {
        $dir = realpath($dir);
        $this->excludedDirs[$dir] = $dir;
    }

    public function addExcludedDirs(array $dirs)

    {
        foreach ($dirs as $dir) {
            $this->addExcludedDir($dir);
        }
    }

    public function isExcluded($path)

    {
        foreach ($this->excludedDirs as $excludedDir) {
            if ($excludedDir === $path || strpos($path, $excludedDir . '/') === 0) {
                return true;
            }
        }
        return false;
    }

    public function watch()

    {
        $this->_watch($this->watchPath);
    }

    protected function _watch($path)

    {
        if ($this->isExcluded($path)) {
            return false;
        }
        $wd = inotify_add_watch($this->fd, $path, $this->watchMask);
        if ($wd === false) {
            return false;
        }
        $this->bind($wd, $path);

        if (is_dir($path)) {
            $wd = inotify_add_watch($this->fd, $path, $this->watchMask);
            if ($wd === false) {
                return false;
            }
            $this->bind($wd, $path);
            $files = scandir($path);
            foreach ($files as $file) {
                if ($file === '.' || $file === '..' || $this->isExcluded($file)) {
                    continue;
                }
                $file = $path . DIRECTORY_SEPARATOR . $file;
                if (is_dir($file)) {
                    $this->_watch($file);
                }
            }
        }
        return true;
    }

    protected function clearWatch()

    {
        foreach ($this->wdPath as $wd => $path) {
            @inotify_rm_watch($this->fd, $wd);
            /** @scrutinizer ignore-unhandled */ @inotify_rm_watch($this->fd, $wd);
        }
        $this->wdPath = [];
        $this->pathWd = [];
    }

    protected function bind($wd, $path)

    {
        $this->pathWd[$path] = $wd;
        $this->wdPath[$wd] = $path;
    }

    protected function unbind($wd, $path = null)

    {
        unset($this->wdPath[$wd]);
        if ($path !== null) {
            unset($this->pathWd[$path]);
        }
    }

    public function start()

    {
        Event::add($this->fd, function ($fp) {

            $events = inotify_read($fp);
            foreach ($events as $event) {
                if ($event['mask'] == IN_IGNORED) {
                    continue;
                }

                $fileType = strchr($event['name'], '.');
                if (!isset($this->fileTypes[$fileType])) {
                    continue;
                }

                if ($this->doing) {
                    continue;
                }

                Timer::after(100, function () use ($event) {

                    call_user_func_array($this->watchHandler, [$event]);
                    $this->doing = false;
                });
someFunctionCall(
    $firstArgument,
    $secondArgument,
    $thirdArgument
); // Closing parenthesis on a new line.
                $this->doing = true;
                break;
            }
        });
someFunctionCall(
    $firstArgument,
    $secondArgument,
    $thirdArgument
); // Closing parenthesis on a new line.
        Event::wait();
    }

    public function stop()

    {
        Event::del($this->fd);
        fclose($this->fd);
    }

    public function getWatchedFileCount()

    {
        return count($this->wdPath);
    }

    public function __destruct()

    {
        $this->stop();
    }
}


hhxsv5 / laravel-s

Inotify::_watch() B last analyzed 2025-06-13 04:39 UTC

Complexity

Size

Duplication

Importance

How to fix Complexity

Long Method

Duplication Side-by-Side

Filter issues like

Inotify::_watch() B
last analyzed 2025-06-13 04:39 UTC