initial commit for php watcher

Author: cydrickn

composer.json

@@ -0,0 +1,18 @@
+{
+    "name": "cydrickn/php-watcher",
+    "description": "Simple file watcher",
+    "type": "library",
+    "license": "MIT",
+    "autoload": {
+        "psr-4": {
+            "Cydrickn\\PHPWatcher\\": "src/"
+        }
+    },
+    "authors": [
+        {
+            "name": "Cydrick Nonog",
+            "email": "cydrick.dev@gmail.com"
+        }
+    ],
+    "require": {}
+}

src/Enum/ChangeType.php

@@ -0,0 +1,10 @@
+<?php
+
+namespace Cydrickn\PHPWatcher\Enum;
+
+enum ChangeType: int
+{
+    case NEW = 1;
+    case UPDATED = 2;
+    case DELETED = 3;
+}

src/Watcher.php

@@ -0,0 +1,144 @@
+<?php
+
+namespace Cydrickn\PHPWatcher;
+
+use Cydrickn\PHPWatcher\Enum\ChangeType;
+use RecursiveDirectoryIterator;
+use RecursiveTreeIterator;
+use Swoole\Timer;
+
+class Watcher
+{
+    private array $files = [];
+    private array $changes = [];
+    private bool $initialized = false;
+    private bool $checking = false;
+
+    private array $excludeFiles = [];
+    private array $excludeDirs = [];
+    private mixed $handler;
+
+    public function __construct(private array $watchFor, array $excludes, callable $handler, private int $interval = 1000)
+    {
+        foreach ($excludes as $exclude) {
+            if (is_dir($exclude)) {
+                $this->excludeDirs[] = $exclude;
+            } else {
+                $this->excludeFiles[] = $exclude;
+            }
+        }
+        $this->handler = $handler;
+    }
+
+
+    public function addChange(string $filename, ChangeType $type): void
+    {
+        $this->changes[] = ['name' => $filename, 'type' => $type, 'data' => filemtime($filename)];
+    }
+
+    public function checkFile(string $file): void
+    {
+        if (!array_key_exists($file, $this->files) && file_exists($file)) {
+            $this->addChange($file, ChangeType::NEW);
+            return;
+        }
+
+        if (array_key_exists($file, $this->files) && !file_exists($file)) {
+            $this->addChange($file, ChangeType::DELETED);
+            return;
+        }
+
+        if (!(array_key_exists($file, $this->files) && file_exists($file))) {
+            return;
+        }
+
+        $data = $this->files[$file];
+        $checkData = filemtime($file);
+
+        if ($checkData != $data) {
+            $this->addChange($file, ChangeType::UPDATED);
+        }
+    }
+
+    public function clearChanges(): void
+    {
+        $this->changes = [];
+    }
+
+    public function commit(): void
+    {
+        $totalChanges = count($this->changes);
+        foreach ($this->changes as $change) {
+            if ($change['type'] === ChangeType::DELETED) {
+                unset($this->files[$change['name']]);
+                continue;
+            }
+
+            $this->files[$change['name']] = $change['data'];
+        }
+
+        if ($totalChanges > 0 && $this->initialized) {
+            call_user_func($this->handler, $this->changes);
+        }
+
+        $this->clearChanges();
+    }
+
+    public function checkChanges(): void
+    {
+        if ($this->checking) {
+            return;
+        }
+
+        $this->checking = true;
+
+        foreach ($this->watchFor as $watchFor) {
+            if (is_dir($watchFor)) {
+                $allFiles = new RecursiveTreeIterator(new RecursiveDirectoryIterator(__DIR__, RecursiveDirectoryIterator::SKIP_DOTS));
+                foreach ($allFiles as $file) {
+                    $filename = trim(str_replace(['|', ' ', '~', '\\'], '', $file), '-');
+                    $filename = is_dir($filename) ? $filename . '/' : $filename;
+
+                    if ((is_file($filename) && in_array($filename, $this->excludeFiles)) || (is_dir($filename) && in_array($filename, $this->excludeDirs))) {
+                        continue;
+                    }
+
+                    foreach ($this->excludeDirs as $dir) {
+                        if (str_starts_with($filename, $dir)) {
+                            continue 2;
+                        }
+                    }
+                    $this->checkFile($filename);
+                }
+                continue;
+            }
+            $this->checkFile($watchFor);
+        }
+
+        $this->commit();
+
+        $this->checking = false;
+        $this->initialized = true;
+    }
+
+    public function tick(?callable $handler = null): void
+    {
+        if ($handler !== null) {
+            call_user_func($handler, [$this, 'checkChanges'], $this->interval);
+            return;
+        }
+
+        if (class_exists(Timer::class)) {
+            Timer::tick($this->interval, function () {
+                $this->checkChanges();
+            });
+        } else {
+            $this->tick(function ($checkChanges, $interval) {
+                do {
+                    call_user_func($checkChanges);
+                    sleep($interval);
+                } while (true);
+            });
+        }
+    }
+}