Sludio\HelperBundle\Script\Command\RedisFlushCommand

Complexity

Total Complexity

10

Size/Duplication

Total Lines	36
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	configure()	0	4	1
D	execute()	0	26	9

<?php

namespace Sludio\HelperBundle\Script\Command;

use Predis\Client;
use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputDefinition;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;

class RedisFlushCommand extends ContainerAwareCommand
{
    protected function configure()
    {
        $this->setName('sludio:redis:flush')->setDefinition(new InputDefinition([
            new InputArgument('clients', InputArgument::IS_ARRAY | InputArgument::OPTIONAL),
        ]))
        ;
    }

    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $clients = [];
        $ids = $this->getContainer()->getServiceIds();
        /** @var $ids array */
        foreach ($ids as $id) {
            if (0 === strpos($id, 'snc_redis') && $this->getContainer()->get($id) instanceof Client) {
                $clients[] = $id;
            }
        }

        if (!empty($clients)) {
            $allowed = $clients;
            $clientsInput = $input->getArgument('clients');
            if (!empty($clientsInput)) {
                /** @var $clientsInput array */
                foreach ($clientsInput as &$client) {
                    $client = 'snc_redis.'.$client;
                }
                unset($client);
                $allowed = array_intersect($clients, $clientsInput);
            }
            foreach ($clients as $snc) {
                if (\in_array($snc, $allowed, true)) {
                    $this->getContainer()->get($snc)->flushdb();
                    $output->writeln('redis database '.$snc.' flushed');
                }
            }
        }
    }
}