Merge pull request #17 from dantleech/refresh_command

Refresh command

Author: dbu

AutoRoute/Factory.php

@@ -116,6 +116,16 @@ public function hasMapping($classFqn)
         return isset($this->mapping[$classFqn]);
     }
 
+    /**
+     * Return all the mapping data
+     *
+     * @return array
+     */
+    public function getMappings()
+    {
+        return $this->mapping;
+    }
+
     protected function generateRouteStackChain($classFqn)
     {
         $mapping = $this->getMapping($classFqn);

AutoRoute/RouteMaker/AutoRouteMaker.php

@@ -29,7 +29,7 @@ public function make(RouteStack $routeStack)
 
         $autoRoute = $this->getAutoRouteForDocument($content);
 
-        if (null === $autoRoute) {
+        if (!$autoRoute) {
             $autoRoute = new AutoRoute;
             $autoRoute->setParent($context->getTopRoute());
             $autoRoute->setRouteContent($content);

Command/RefreshCommand.php

@@ -0,0 +1,102 @@
+<?php
+
+namespace Symfony\Cmf\Bundle\RoutingAutoBundle\Command;
+
+use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+use Symfony\Component\Console\Input\InputOption;
+use Doctrine\Bundle\PHPCRBundle\Command\DoctrineCommandHelper;
+
+class RefreshCommand extends ContainerAwareCommand
+{
+    public function configure()
+    {
+        $this
+            ->setName('cmf:routing:auto:refresh')
+            ->setDescription(<<<HERE
+This command iterates over all Documents that are mapped by the auto
+routing system and re-applys the auto routing logic.
+
+You can specify the "--verbose" option to output detail for each created
+route.
+
+Specify the "--dry-run" option to not write any changes to the database.
+
+Use "--class" to only apply the changes to a single class - although beware this
+may cause an error if you persist a class whose auto routing configuration
+relies on the auto routing of another class.
+HERE
+        );
+
+        $this->addOption('dry-run', null, InputOption::VALUE_NONE, 
+            'Do not write any change to the database.'
+        );
+        $this->addOption('class', null, InputOption::VALUE_REQUIRED, 
+            'Only update the given class FQN'
+        );
+        $this->addOption('session', null, InputOption::VALUE_OPTIONAL, 'The session to use for this command');
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    public function execute(InputInterface $input, OutputInterface $output)
+    {
+        $container = $this->getContainer();
+        $dm = $container->get('doctrine_phpcr.odm.default_document_manager');
+        $factory = $container->get('symfony_cmf_routing_auto.factory');
+        $arm = $container->get('symfony_cmf_routing_auto.auto_route_manager');
+        $uow = $dm->getUnitOfWork();
+
+        $session = $input->getOption('session');
+        $dryRun = $input->getOption('dry-run');
+        $class = $input->getOption('class');
+        $verbose = $input->getOption('verbose');
+
+        DoctrineCommandHelper::setApplicationPHPCRSession(
+            $this->getApplication(),
+            $session
+        );
+
+        if ($class) {
+            $mapping = array($class => $class);
+        } else {
+            $mapping = $factory->getMappings();
+        }
+
+        foreach (array_keys($mapping) as $classFqn) {
+
+            $output->writeln(sprintf('<info>Processing class: </info> %s', $classFqn));
+
+            $qb = $dm->createQueryBuilder();
+            $qb->from($classFqn);
+            $q = $qb->getQuery();
+            $result = $q->getResult();
+
+            foreach ($result as $autoRouteableDocument) {
+                $id = $uow->getDocumentId($autoRouteableDocument);
+                $output->writeln('  <info>Refreshing: </info>'.$id);
+                $context = $arm->updateAutoRouteForDocument($autoRouteableDocument);
+
+                foreach ($context->getRoutes() as $route) {
+                    $dm->persist($route);
+                    $routeId = $uow->getDocumentId($route);
+
+                    if ($verbose) {
+                        $output->writeln(sprintf(
+                            '<comment>    - %sPersisting: </comment> %s <comment>%s</comment>',
+                            $dryRun ? '(dry run) ' : '',
+                            $routeId,
+                            '[...]'.substr(get_class($route), -10)
+                        ));
+                    }
+
+                    if (true !== $dryRun) {
+                        $dm->flush();
+                    }
+                }
+            }
+        }
+    }
+}

Tests/Functional/BaseTestCase.php

@@ -5,6 +5,7 @@
 require __DIR__.'/app/AppKernel.php';
 
 use Symfony\Bundle\FrameworkBundle\Test\WebTestCase;
+use Symfony\Bundle\FrameworkBundle\Console\Application;
 
 class BaseTestCase extends WebTestCase
 {
@@ -43,5 +44,11 @@ public function setUp(array $options = array(), $routebase = null)
 
         $session->save();
     }
+
+    public function getApplication()
+    {
+        $application = new Application(self::$kernel);
+        return $application;
+    }
 }
 

Tests/Functional/Command/RefreshCommandTest.php

@@ -0,0 +1,48 @@
+<?php
+
+namespace Symfony\Cmf\Bundle\RoutingAutoBundle\Tests\Functional\Command;
+
+use Symfony\Cmf\Bundle\RoutingAutoBundle\Tests\Functional\app\Document\Blog;
+use Symfony\Cmf\Bundle\RoutingAutoBundle\Tests\Functional\BaseTestCase;
+use Symfony\Cmf\Bundle\RoutingAutoBundle\Tests\Functional\app\Document\Post;
+use Symfony\Component\Console\Input\ArrayInput;
+use Symfony\Component\Console\Output\NullOutput;
+use Symfony\Cmf\Bundle\RoutingAutoBundle\Command\RefreshCommand;
+use Symfony\Component\Console\Output\StreamOutput;
+
+class RefreshCommandTest extends BaseTestCase
+{
+    protected function createBlog($withPosts = false)
+    {
+        $blog = new Blog;
+        $blog->path = '/test/test-blog';
+        $blog->title = 'Unit testing blog';
+
+        $this->getDm()->persist($blog);
+
+        if ($withPosts) {
+            $post = new Post;
+            $post->title = 'This is a post title';
+            $post->blog = $blog;
+            $this->getDm()->persist($post);
+        }
+
+        $this->getDm()->flush();
+        $this->getDm()->clear();
+    }
+
+    public function testCommand()
+    {
+        $this->createBlog(true);
+
+        $application = $this->getApplication();
+        $input = new ArrayInput(array(
+            'foo:bar'
+        ));
+        $output = new NullOutput();
+        //$output = new StreamOutput(fopen('php://stdout', 'w'));
+        $command = new RefreshCommand();
+        $command->setApplication($application);
+        $command->run($input, $output);
+    }
+}