added purge command

This commit is contained in:
Lukas Kahwe Smith 2013-04-26 14:15:57 +02:00
parent a161b0657a
commit 813f57e3d0
4 changed files with 81 additions and 3 deletions

78
Command/PurgeCommand.php Executable file
View file

@ -0,0 +1,78 @@
<?php
namespace FOS\ElasticaBundle\Command;
use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Output\Output;
use FOS\ElasticaBundle\IndexManager;
use FOS\ElasticaBundle\Resetter;
/**
* Purge search indexes
*/
class PurgeCommand extends ContainerAwareCommand
{
/**
* @var IndexManager
*/
private $indexManager;
/**
* @var Resetter
*/
private $resetter;
/**
* @see Symfony\Component\Console\Command\Command::configure()
*/
protected function configure()
{
$this
->setName('fos:elastica:purge')
->addOption('index', null, InputOption::VALUE_OPTIONAL, 'The index to purge')
->addOption('type', null, InputOption::VALUE_OPTIONAL, 'The type to purge')
->setDescription('Purge search indexes')
;
}
/**
* @see Symfony\Component\Console\Command\Command::initialize()
*/
protected function initialize(InputInterface $input, OutputInterface $output)
{
$this->indexManager = $this->getContainer()->get('fos_elastica.index_manager');
$this->resetter = $this->getContainer()->get('fos_elastica.resetter');
}
/**
* @see Symfony\Component\Console\Command\Command::execute()
*/
protected function execute(InputInterface $input, OutputInterface $output)
{
$index = $input->getOption('index');
$type = $input->getOption('type');
if (null === $index && null !== $type) {
throw new \InvalidArgumentException('Cannot specify type option without an index.');
}
if (null !== $type) {
$output->writeln(sprintf('Resetting: %s/%s', $index, $type));
$this->resetter->resetIndex($index, $type);
} else {
$indexes = null === $index
? array_keys($this->indexManager->getAllIndexes())
: array($index)
;
foreach ($indexes as $index) {
$output->writeln(sprintf('<info>Resetting</info> <comment>%s</comment>', $index));
$this->resetter->resetIndex($index);
}
}
}
}

View file

@ -28,7 +28,7 @@ class RepositoryManager extends BaseManager
* Return repository for entity
*
* Returns custom repository if one specified otherwise
* returns a basic respository.
* returns a basic repository.
*/
public function getRepository($entityName)
{

View file

@ -33,7 +33,7 @@ class RepositoryManager implements RepositoryManagerInterface
* Return repository for entity
*
* Returns custom repository if one specified otherwise
* returns a basic respository.
* returns a basic repository.
*/
public function getRepository($entityName)
{

View file

@ -7,7 +7,7 @@ use FOS\ElasticaBundle\Finder\PaginatedFinderInterface;
/**
* @author Richard Miller <info@limethinking.co.uk>
*
* Basic respoitory to be extended to hold custom queries to be run
* Basic repository to be extended to hold custom queries to be run
* in the finder.
*/
class Repository