symfony · everzet · Mar 25, 2011 · Mar 25, 2011 · Mar 25, 2011 · Mar 25, 2011
diff --git a/src/Symfony/Component/Config/Resource/DirectoryResource.php b/src/Symfony/Component/Config/Resource/DirectoryResource.php
@@ -16,7 +16,7 @@
  *
  * @author Fabien Potencier <fabien@symfony.com>
  */
-class DirectoryResource implements ResourceInterface, \Serializable
+class DirectoryResource implements ResourceInterface
 {
     private $resource;
     private $pattern;
@@ -33,6 +33,73 @@ public function __construct($resource, $pattern = null)
         $this->pattern = $pattern;
     }
 
+    /**
+     * Returns the list of filtered file and directory childs of directory resource.
+     *
+     * @return array An array of files
+     */
+    public function getFilteredChilds()
+    {
+        $childs = array();
+        foreach (new \RecursiveIteratorIterator(new \RecursiveDirectoryIterator($this->resource), \RecursiveIteratorIterator::SELF_FIRST) as $file) {
+            // if regex filtering is enabled only return matching files
+            if ($file->isFile() && !$this->hasFile($file)) {
+                continue;
+            }
+
+            // always monitor directories for changes, except the .. entries
+            // (otherwise deleted files wouldn't get detected)
+            if ($file->isDir() && '/..' === substr($file, -3)) {
+                continue;
+            }
+
+            $childs[] = $file;
+        }
+
+        return $childs;
+    }
+
+    /**
+     * Returns child resources that matches directory filters.
+     *
+     * @return array
+     */
+    public function getFilteredResources()
+    {
+        if (!$this->exists()) {
+            return array();
+        }
+
+        $iterator = new \DirectoryIterator($this->resource);
+
+        $resources = array();
+        foreach ($iterator as $file) {
+            // if regex filtering is enabled only return matching files
+            if ($file->isFile() && !$this->hasFile($file)) {
+                continue;
+            }
+
+            // always monitor directories for changes, except the .. entries
+            // (otherwise deleted files wouldn't get detected)
+            if ($file->isDir() && '/..' === substr($file, -3)) {
+                continue;
+            }
+
+            // if file is dot - continue
+            if ($file->isDot()) {
+                continue;
+            }
+
+            if ($file->isFile()) {
+                $resources[] = new FileResource($file->getRealPath());
+            } elseif ($file->isDir()) {
+                $resources[] = new DirectoryResource($file->getRealPath());
+            }
+        }
+
+        return $resources;
+    }
+
     /**
      * Returns a string representation of the Resource.
      *
@@ -53,11 +120,62 @@ public function getResource()
         return $this->resource;
     }
 
+    /**
+     * Returns check pattern.
+     *
+     * @return mixed
+     */
     public function getPattern()
     {
         return $this->pattern;
     }
 
+    /**
+     * Checks that passed file exists in resource and matches resource filters.
+     *
+     * @param  SplFileInfo|string   $file
+     *
+     * @return Boolean
+     */
+    public function hasFile($file)
+    {
+        if (!$file instanceof \SplFileInfo) {
+            $file = new \SplFileInfo($file);
+        }
+
+        if (0 !== strpos($file->getRealPath(), realpath($this->resource))) {
+            return false;
+        }
+
+        if ($this->pattern) {
+            return (bool) preg_match($this->pattern, $file->getBasename());
+        }
+
+        return true;
+    }
+
+    /**
+     * Returns resource mtime.
+     *
+     * @return integer
+     */
+    public function getModificationTime()
+    {
+        if (!$this->exists()) {
+            return -1;
+        }
+
+        clearstatcache(true, $this->resource);
+        $newestMTime = filemtime($this->resource);
+
+        foreach ($this->getFilteredChilds() as $file) {
+            clearstatcache(true, (string) $file);
+            $newestMTime = max($file->getMTime(), $newestMTime);
+        }
+
+        return $newestMTime;
+    }
+
     /**
      * Returns true if the resource has not been updated since the given timestamp.
      *
@@ -67,27 +185,31 @@ public function getPattern()
      */
     public function isFresh($timestamp)
     {
-        if (!is_dir($this->resource)) {
+        if (!$this->exists()) {
             return false;
         }
 
-        $newestMTime = filemtime($this->resource);
-        foreach (new \RecursiveIteratorIterator(new \RecursiveDirectoryIterator($this->resource), \RecursiveIteratorIterator::SELF_FIRST) as $file) {
-            // if regex filtering is enabled only check matching files
-            if ($this->pattern && $file->isFile() && !preg_match($this->pattern, $file->getBasename())) {
-                continue;
-            }
-
-            // always monitor directories for changes, except the .. entries
-            // (otherwise deleted files wouldn't get detected)
-            if ($file->isDir() && '/..' === substr($file, -3)) {
-                continue;
-            }
+        return $this->getModificationTime() < $timestamp;
+    }
 
-            $newestMTime = max($file->getMTime(), $newestMTime);
-        }
+    /**
+     * Returns true if the resource exists in the filesystem.
+     *
+     * @return Boolean
+     */
+    public function exists()
+    {
+        return is_dir($this->resource);
+    }
 
-        return $newestMTime < $timestamp;
+    /**
+     * Returns unique resource ID.
+     *
+     * @return string
+     */
+    public function getId()
+    {
+        return md5($this->resource.$this->pattern);
     }
 
     public function serialize()

diff --git a/src/Symfony/Component/Config/Resource/FileResource.php b/src/Symfony/Component/Config/Resource/FileResource.php
@@ -18,7 +18,7 @@
  *
  * @author Fabien Potencier <fabien@symfony.com>
  */
-class FileResource implements ResourceInterface, \Serializable
+class FileResource implements ResourceInterface
 {
     private $resource;
 
@@ -29,7 +29,7 @@ class FileResource implements ResourceInterface, \Serializable
      */
     public function __construct($resource)
     {
-        $this->resource = realpath($resource);
+        $this->resource = file_exists($resource) ? realpath($resource) : $resource;
     }
 
     /**
@@ -52,6 +52,22 @@ public function getResource()
         return $this->resource;
     }
 
+    /**
+     * Returns resource mtime.
+     *
+     * @return integer
+     */
+    public function getModificationTime()
+    {
+        if (!$this->exists()) {
+            return -1;
+        }
+
+        clearstatcache(true, $this->resource);
+
+        return filemtime($this->resource);
+    }
+
     /**
      * Returns true if the resource has not been updated since the given timestamp.
      *
@@ -61,11 +77,31 @@ public function getResource()
      */
     public function isFresh($timestamp)
     {
-        if (!file_exists($this->resource)) {
+        if (!$this->exists()) {
             return false;
         }
 
-        return filemtime($this->resource) < $timestamp;
+        return $this->getModificationTime() <= $timestamp;
+    }
+
+    /**
+     * Returns true if the resource exists in the filesystem.
+     *
+     * @return Boolean
+     */
+    public function exists()
+    {
+        return file_exists($this->resource);
+    }
+
+    /**
+     * Returns unique resource ID.
+     *
+     * @return string
+     */
+    public function getId()
+    {
+        return md5($this->resource);
     }
 
     public function serialize()

diff --git a/src/Symfony/Component/Config/Resource/ResourceInterface.php b/src/Symfony/Component/Config/Resource/ResourceInterface.php
@@ -16,7 +16,7 @@
  *
  * @author Fabien Potencier <fabien@symfony.com>
  */
-interface ResourceInterface
+interface ResourceInterface extends \Serializable
 {
     /**
      * Returns a string representation of the Resource.
@@ -34,10 +34,31 @@ function __toString();
      */
     function isFresh($timestamp);
 
+    /**
+     * Returns resource mtime.
+     *
+     * @return integer
+     */
+    function getModificationTime();
+
+    /**
+     * Returns true if the resource exists in the filesystem.
+     *
+     * @return Boolean
+     */
+    function exists();
+
     /**
      * Returns the resource tied to this Resource.
      *
      * @return mixed The resource
      */
     function getResource();
+
+    /**
+     * Returns unique resource ID.
+     *
+     * @return string
+     */
+    function getId();
 }
diff --git a/src/Symfony/Component/ResourceWatcher/Event/Event.php b/src/Symfony/Component/ResourceWatcher/Event/Event.php
@@ -0,0 +1,87 @@
+<?php
+
+/*
+ * This file is part of the Symfony package.
+ *
+ * (c) Fabien Potencier <fabien@symfony.com>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Symfony\Component\ResourceWatcher\Event;
+
+use Symfony\Component\Config\Resource\ResourceInterface;
+
+/**
+ * Resource change event.
+ *
+ * @author Konstantin Kudryashov <ever.zet@gmail.com>
+ */
+class Event
+{
+    const CREATED  = 1;
+    const MODIFIED = 2;
+    const DELETED  = 4;
+    const ALL      = 7;
+
+    private $trackingId;
+    private $resource;
+    private $type;
+    private $time;
+
+    /**
+     * Initializes resource event.
+     *
+     * @param   mixed               $trackingId     id of resource inside tracker
+     * @param   ResourceInterface   $resource       resource instance
+     * @param   integer             $type           event type bit
+     */
+    public function __construct($trackingId, ResourceInterface $resource, $type)
+    {
+        $this->trackingId   = $trackingId;
+        $this->resource     = $resource;
+        $this->type         = $type;
+        $this->time         = time();
+    }
+
+    /**
+     * Returns id of resource inside tracker.
+     *
+     * @return  integer
+     */
+    public function getTrackingId()
+    {
+        return $this->trackingId;
+    }
+
+    /**
+     * Returns changed resource.
+     *
+     * @return  ResourceInterface
+     */
+    public function getResource()
+    {
+        return $this->resource;
+    }
+
+    /**
+     * Returns event type.
+     *
+     * @return  integer
+     */
+    public function getType()
+    {
+        return $this->type;
+    }
+
+    /**
+     * Returns time on which event occured.
+     *
+     * @return  integer
+     */
+    public function getTime()
+    {
+        return $this->time;
+    }
+}