PHPSocialNetwork/phpfastcache-bundle

<?php

/**
 *
 * This file is part of phpFastCache.
 *
 * @license MIT License (MIT)
 *
 * For full copyright and license information, please see the docs/CREDITS.txt file.
 *
 * @author Georges.L (Geolim4)  <contact@geolim4.com>
 * @author PastisD https://github.com/PastisD
 * @author Khoa Bui (khoaofgod)  <khoaofgod@gmail.com> http://www.phpfastcache.com
 *
 */
declare(strict_types=1);

namespace Phpfastcache\Bundle\Command;

use Phpfastcache\Bundle\Service\Phpfastcache;
use Phpfastcache\Exceptions\PhpfastcacheDriverCheckException;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Style\SymfonyStyle;

class PhpfastcacheClearCommand extends Command
{
    /**
     * @var \Phpfastcache\Bundle\Service\Phpfastcache
     */
    protected $phpfastcache;

    /**
     * @var
     */
    protected $parameters;

    /**
     * PhpfastcacheCommand constructor.
     * @param \Phpfastcache\Bundle\Service\Phpfastcache $phpfastcache
     * @param $parameters
     */
    public function __construct(Phpfastcache $phpfastcache, $parameters)
    {
        $this->phpfastcache = $phpfastcache;
        $this->parameters = $parameters;

        parent::__construct();
    }

    protected function configure()
    {
        $this
          ->setName('phpfastcache:clear')
          ->setAliases(['phpfastcache:clean', 'phpfastcache:flush'])
          ->setDescription('Clear phpfastcache cache')
          ->addArgument(
            'driver',
            InputArgument::OPTIONAL,
            'Cache name to clear'
          );
    }

    /**
     * @param \Symfony\Component\Console\Input\InputInterface $input
     * @param \Symfony\Component\Console\Output\OutputInterface $output
     * @return int|null|void
     */
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $failedInstances = [];
        $io = new SymfonyStyle($input, $output);

        $driver = $input->getArgument('driver');

        $output->writeln('<bg=yellow;fg=red>Clearing cache operation can take a while, please be patient...</>');

        $callback = function ($name) use ($output, &$failedInstances) {
            try {
                if (OutputInterface::VERBOSITY_VERBOSE <= $output->getVerbosity()) {
                    $output->writeln("<fg=yellow>Clearing instance {$name} cache...</>");
                }
                $this->phpfastcache->get($name)->clear();
                if (OutputInterface::VERBOSITY_VERBOSE <= $output->getVerbosity()) {
                    $output->writeln("<fg=green>Cache instance {$name} cleared</>");
                }
            } catch (PhpfastcacheDriverCheckException $e) {
                $failedInstances[] = $name;
                if (OutputInterface::VERBOSITY_VERBOSE <= $output->getVerbosity()) {
                    $output->writeln("<fg=red>Cache instance {$name} not cleared, got exception: " . '<bg=red;options=bold>' . $e->getMessage() . '</>');
                } else {
                    $output->writeln("<fg=red>Cache instance {$name} not cleared (increase verbosity to get more information).</>");
                }
            }
        };

        $caches = $this->parameters;

        if ($driver) {
            if (\array_key_exists($driver, $caches[ 'drivers' ])) {
                $callback($driver);
                if (!\count($failedInstances)) {
                    $io->success("Cache instance {$driver} cleared");
                } else {
                    $io->error("Cache instance {$driver} not cleared");
                }
            } else {
                $io->error("Cache instance {$driver} does not exists");
            }
        } else {
            foreach ($caches[ 'drivers' ] as $name => $parameters) {
                $callback($name);
            }
            if (!\count($failedInstances)) {
                $io->success('All caches instances got cleared');
            } else {
                $io->success('Almost all caches instances got cleared, except these: ' . \implode(', ', $failedInstances));
            }
        }
    }
}