Experimental node apply-closures option

Author: dantleech

CHANGELOG.md

@@ -0,0 +1,4 @@
+Changelog
+=========
+
+* **2013-06-15**: [Command] Added `--apply-closure` option to `phpcr:nodes:update` command.

src/PHPCR/Util/Console/Command/BaseCommand.php

@@ -78,5 +78,9 @@ public function configureNodeManipulationInput()
             InputOption::VALUE_REQUIRED | InputOption::VALUE_IS_ARRAY,
             'Remove mixin from the nodes'
         );
+        $this->addOption('apply-closure', null,
+            InputOption::VALUE_REQUIRED | InputOption::VALUE_IS_ARRAY,
+            'Apply a closure to each node, closures are passed PHPCR\Session and PHPCR\NodeInterface'
+        );
     }
 }

src/PHPCR/Util/Console/Command/NodesUpdateCommand.php

@@ -89,6 +89,7 @@ protected function execute(InputInterface $input, OutputInterface $output)
         $removeProp = $input->getOption('remove-prop');
         $addMixins = $input->getOption('add-mixin');
         $removeMixins = $input->getOption('remove-mixin');
+        $applyClosures = $input->getOption('apply-closure');
         $noInteraction = $input->getOption('no-interaction');
         $helper = $this->getPhpcrCliHelper();
         $session = $this->getPhpcrSession();
@@ -129,6 +130,7 @@ protected function execute(InputInterface $input, OutputInterface $output)
                 'removeProp' => $removeProp,
                 'addMixins' => $addMixins,
                 'removeMixins' => $removeMixins,
+                'applyClosures' => $applyClosures,
             ));
         }
 

src/PHPCR/Util/Console/Helper/PhpcrCliHelper.php

@@ -77,6 +77,7 @@ public function processNode(OutputInterface $output, $node, $options)
             'removeProp' => array(),
             'addMixins' => array(),
             'removeMixins' => array(),
+            'applyClosures' => array(),
             'dump' => false,
         ), $options);
 
@@ -115,6 +116,12 @@ public function processNode(OutputInterface $output, $node, $options)
             $node->removeMixin($removeMixin);
         }
 
+        foreach ($options['applyClosures'] as $closureString) {
+            $evalCode = sprintf('$closure = %s;', $closureString);
+            eval($evalCode);
+            $closure($this->session, $node);
+        }
+
         if ($options['dump']) {
             $output->writeln('<info>Node dump: </info>');
             /** @var $property PropertyInterface */

tests/PHPCR/Tests/Util/Console/Command/NodesUpdateCommandTest.php

@@ -40,24 +40,12 @@ public function provideNodeUpdate()
         );
     }
 
-    /**
-     * @dataProvider provideNodeUpdate
-     */
-    public function testNodeUpdate($options)
+    protected function setupQueryManager($options)
     {
         $options = array_merge(array(
-            'query' => null,
-            'setProp' => array(),
-            'removeProp' => array(),
-            'addMixin' => array(),
-            'removeMixin' => array(),
-            'exception' => null,
+            'query' => '',
         ), $options);
 
-        if ($options['exception']) {
-            $this->setExpectedException($options['exception']);
-        }
-
         $this->session->expects($this->any())
             ->method('getWorkspace')
             ->will($this->returnValue($this->workspace));
@@ -69,7 +57,6 @@ public function testNodeUpdate($options)
             ->method('createQuery')
             ->with($options['query'], 'JCR-SQL2')
             ->will($this->returnValue($this->query));
-
         $this->query->expects($this->any())
             ->method('execute')
             ->will($this->returnValue(array(
@@ -78,6 +65,27 @@ public function testNodeUpdate($options)
         $this->row1->expects($this->any())
             ->method('getNode')
             ->will($this->returnValue($this->node1));
+    }
+
+    /**
+     * @dataProvider provideNodeUpdate
+     */
+    public function testNodeUpdate($options)
+    {
+        $options = array_merge(array(
+            'query' => null,
+            'setProp' => array(),
+            'removeProp' => array(),
+            'addMixin' => array(),
+            'removeMixin' => array(),
+            'exception' => null,
+        ), $options);
+
+        if ($options['exception']) {
+            $this->setExpectedException($options['exception']);
+        }
+
+        $this->setupQueryManager($options);
 
         $args = array(
             '--query-language' => null,
@@ -128,4 +136,27 @@ public function testNodeUpdate($options)
 
         $ct = $this->executeCommand('phpcr:nodes:update', $args);
     }
+
+    public function testApplyClosure()
+    {
+        $args = array(
+            '--query' => "SELECT foo FROM bar",
+            '--no-interaction' => true,
+            '--apply-closure' => array(
+                'function ($session, $node) { $session->getNodeByIdentifier("/foo"); $node->setProperty("foo", "bar"); }'
+            ),
+        );
+
+        $this->setupQueryManager(array('query' => 'SELECT foo FROM bar'));
+
+        $this->node1->expects($this->once())
+            ->method('setProperty')
+            ->with('foo', 'bar');
+
+        $this->session->expects($this->once())
+            ->method('getNodeByIdentifier')
+            ->with('/foo');
+
+        $ct = $this->executeCommand('phpcr:nodes:update', $args);
+    }
 }