Updated to Drupal 8.5. Core Media not yet in use.

[yaffs-website] / vendor / consolidation / robo / src / Task / Base / Watch.php

diff --git a/vendor/consolidation/robo/src/Task/Base/Watch.php b/vendor/consolidation/robo/src/Task/Base/Watch.php
new file mode 100644 (file)
index 0000000..d7940ac
--- /dev/null
+++ b/vendor/consolidation/robo/src/Task/Base/Watch.php
@@ -0,0 +1,89 @@
+<?php
+namespace Robo\Task\Base;
+
+use Lurker\Event\FilesystemEvent;
+use Lurker\ResourceWatcher;
+use Robo\Result;
+use Robo\Task\BaseTask;
+
+/**
+ * Runs task when specified file or dir was changed.
+ * Uses Lurker library.
+ *
+ * ``` php
+ * <?php
+ * $this->taskWatch()
+ *  ->monitor('composer.json', function() {
+ *      $this->taskComposerUpdate()->run();
+ * })->monitor('src', function() {
+ *      $this->taskExec('phpunit')->run();
+ * })->run();
+ * ?>
+ * ```
+ */
+class Watch extends BaseTask
+{
+    /**
+     * @var \Closure
+     */
+    protected $closure;
+
+    /**
+     * @var array
+     */
+    protected $monitor = [];
+
+    /**
+     * @var object
+     */
+    protected $bindTo;
+
+    /**
+     * @param $bindTo
+     */
+    public function __construct($bindTo)
+    {
+        $this->bindTo = $bindTo;
+    }
+
+    /**
+     * @param string|string[] $paths
+     * @param \Closure $callable
+     *
+     * @return $this
+     */
+    public function monitor($paths, \Closure $callable)
+    {
+        if (!is_array($paths)) {
+            $paths = [$paths];
+        }
+        $this->monitor[] = [$paths, $callable];
+        return $this;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function run()
+    {
+        if (!class_exists('Lurker\\ResourceWatcher')) {
+            return Result::errorMissingPackage($this, 'ResourceWatcher', 'henrikbjorn/lurker');
+        }
+
+        $watcher = new ResourceWatcher();
+
+        foreach ($this->monitor as $k => $monitor) {
+            /** @var \Closure $closure */
+            $closure = $monitor[1];
+            $closure->bindTo($this->bindTo);
+            foreach ($monitor[0] as $i => $dir) {
+                $watcher->track("fs.$k.$i", $dir, FilesystemEvent::MODIFY);
+                $this->printTaskInfo('Watching {dir} for changes...', ['dir' => $dir]);
+                $watcher->addListener("fs.$k.$i", $closure);
+            }
+        }
+
+        $watcher->start();
+        return Result::success($this);
+    }
+}