Inotify\InotifyProxy

Complexity

Total Complexity

12

Size/Duplication

Total Lines	72
Duplicated Lines	0 %

Test Coverage

Coverage

91.43%

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	closeWatchers()	0	4	2
A	__destruct()	0	4	2
A	__construct()	0	3	1
A	havePendingEvents()	0	3	1
A	read()	0	23	4
A	addWatch()	0	13	2

<?php

declare(strict_types=1);

namespace Inotify;

use Generator;
use InvalidArgumentException;

class InotifyProxy implements InotifyProxyInterface
{
    private $inotify;
    /**
     * @var WatchedResource[]
     */
    private array $watchedResources;

    public function __construct()
    {
        $this->inotify = inotify_init();
    }

    /**
     * @return Generator|InotifyEvent[]
     */
    public function read(): Generator
    {
        $events = inotify_read($this->inotify);
        if (false !== $events) {
            foreach ($events as $event) {
                $event = new InotifyEvent(
                    $event['wd'],
                    InotifyEventCodeEnum::createFromMask($event['mask']),
                    $event['cookie'],
                    $event['name'],
                    $this->watchedResources[$event['wd']],
                    time()
                );

                // if file is removed we need clean watchedResources
                if ($event->getInotifyEventCode() === InotifyEventCodeEnum::ON_IGNORED()->getValue()) {
                    unset($this->watchedResources[$event->getId()]);
                }

                yield $event;
            }
        }
        unset($events);
    }

    public function addWatch(WatchedResource $watchedResource): void
    {
        if (!is_readable($watchedResource->getPathname())) {
            throw new InvalidArgumentException('Resource not exists: "' . $watchedResource->getPathname() . '""');
        }

        $id = inotify_add_watch(
            $this->inotify,
            $watchedResource->getPathname(),
            $watchedResource->getWatchOnChangeFlags()
        );

        $this->watchedResources[$id] = $watchedResource;
    }

    public function closeWatchers(): void
    {
        foreach ($this->watchedResources as $id => $resource) {
            inotify_rm_watch($this->inotify, $id);
        }
    }

    public function havePendingEvents(): bool
    {
        return inotify_queue_len($this->inotify) > 1;
    }

    public function __destruct()
    {
        if (is_resource($this->inotify)) {
            fclose($this->inotify);
        }
    }
}