Merge pull request #5 from legalthings/nodes

Added nodes

.gitignore

@@ -1,3 +1,4 @@
 /vendor
 /composer.lock
 /build
+/nbproject/*

src/DataEnricher.php

@@ -2,6 +2,9 @@
 
 namespace LegalThings;
 
+use LegalThings\DataEnricher\Node;
+use LegalThings\DataEnricher\Processor;
+
 /**
  * Enrich objects by processing special properties.
  */
@@ -12,12 +15,12 @@ class DataEnricher
      * @var array
      */
     public static $defaultProcessors = [
-        '_ref' => 'Reference',
-        '_switch' => 'SwitchChoose',
-        '_src' => 'Http',
-        '_merge' => 'Merge',
-        '_jmespath' => 'JmesPath',
-        '_tpl' => 'Mustache'
+        '_ref' => Processor\Reference::class,
+        '_switch' => Processor\SwitchChoose::class,
+        '_src' => Processor\Http::class,
+        '_merge' => Processor\Merge::class,
+        '_jmespath' => Processor\JmesPath::class,
+        '_tpl' => Processor\Mustache::class
     ];
 
 
@@ -49,7 +52,7 @@ public function __construct($source)
 
         foreach (static::$defaultProcessors as $property => $processor) {
             if (is_string($processor)) {
-                $class = $processor[0] === '\\' ? substr($processor, 1) : __CLASS__ . '\\' . $processor;
+                $class = $processor;
                 $processor = new $class($this, $property);
             }
 
@@ -75,13 +78,75 @@ public function getSource()
      */
     public function applyTo($target)
     {
-        if (is_string($target)) $target = \DotKey::on($this->source)->get($target);
+        if (is_string($target)) {
+            $target = \DotKey::on($this->source)->get($target);
+        }
+
+        $nodes = $this->findNodes($target);
 
         foreach ($this->processors as $processor) {
-            $processor->applyTo($target);
+            $processor->applyTo($nodes);
         }
+
+        $this->applyNodeResults($target);
     }
 
+    /**
+     * Find nodes that have processing instructions
+     * 
+     * @param array|object $target
+     * @return array
+     */
+    public function findNodes(&$target)
+    {
+        $nodes = [];
+
+        foreach ($target as $key => &$value) {
+            if (is_array($value) || (is_object($value) && !$value instanceof Node)) {
+                $nodes = array_merge($nodes, $this->findNodes($value));
+            }
+
+            if ($value instanceof \stdClass && $this->hasProcessorProperty($value)) {
+                $value = new Node($value);
+                $nodes[] = $value;
+            }
+        }
+
+        return $nodes;
+    }
+
+    /**
+     * Check if object has at leas one process property
+     * 
+     * @param \stdClass $value
+     * @return boolean
+     */
+    protected function hasProcessorProperty($value)
+    {
+        $processorProps = array_map(function ($processor) {
+            return $processor->getProperty();
+        }, $this->processors);
+
+        $valueProps = array_keys(get_object_vars($value));
+
+        return count(array_intersect($valueProps, $processorProps)) > 0;
+    }
+
+    /**
+     * Replace nodes with their results
+     * 
+     * @param array|object $target
+     */
+    public function applyNodeResults(&$target)
+    {
+        foreach ($target as &$value) {
+            if ($value instanceof Node) {
+                $value = $value->getResult();
+            } elseif (is_array($value) || is_object($value)) {
+                $this->applyNodeResults($value);
+            }
+        }
+    }
 
     /**
      * Enrich object