Merge pull request #27 from michaelpetri/add-interval

added interval to prevent polling filesystem
michaelpetri · May 12, 2023 · 94d4ba5 · 94d4ba5
2 parents 2083008 + c90ed24
commit 94d4ba5
Showing 1 changed file with 13 additions and 1 deletion.
diff --git a/src/Infrastructure/Transport/EventReceiver.php b/src/Infrastructure/Transport/EventReceiver.php
@@ -17,16 +17,24 @@
 use Symfony\Component\Messenger\Transport\SetupableTransportInterface;
 use Symfony\Component\Messenger\Transport\TransportInterface;
 
+use function usleep;
+
 final class EventReceiver implements TransportInterface, SetupableTransportInterface
 {
+    /** @psalm-param positive-int $intervalInMilliSeconds */
     public function __construct(
-        public readonly GitRepositoryInterface $repository
+        public readonly GitRepositoryInterface $repository,
+        public readonly int $intervalInMilliSeconds = 1
     ) {
     }
 
     public function get(): iterable
     {
+        $needToSleep = true;
+
         foreach ($this->repository->status()->toArray() as $change) {
+            $needToSleep = false;
+
             switch ($change->index) {
                 case Status::ADDED:
                 case Status::MODIFIED:
@@ -88,6 +96,10 @@ public function get(): iterable
                     );
             }
         }
+
+        if ($needToSleep) {
+            usleep($this->intervalInMilliSeconds);
+        }
     }
 
     public function ack(Envelope $envelope): void