87 lines
2.7 KiB
PHP
87 lines
2.7 KiB
PHP
<?php
|
|
|
|
namespace KupShop\KupShopBundle\Command;
|
|
|
|
use KupShop\KupShopBundle\Event\CronEvent;
|
|
use KupShop\KupShopBundle\Util\Event\LoggingEventDispatcher;
|
|
use KupShop\KupShopBundle\Util\Logging\SentryLogger;
|
|
use Symfony\Component\Console\Attribute\AsCommand;
|
|
use Symfony\Component\Console\Command\Command;
|
|
use Symfony\Component\Console\Helper\Table;
|
|
use Symfony\Component\Console\Input\InputArgument;
|
|
use Symfony\Component\Console\Input\InputInterface;
|
|
use Symfony\Component\Console\Input\InputOption;
|
|
use Symfony\Component\Console\Output\OutputInterface;
|
|
|
|
#[AsCommand(name: 'kupshop:run_cron', description: 'Run cron job')]
|
|
class RunCronCommand extends Command
|
|
{
|
|
/** @var LoggingEventDispatcher */
|
|
private $eventDispatcher;
|
|
|
|
/** @var SentryLogger */
|
|
private $sentryLogger;
|
|
|
|
/**
|
|
* @required
|
|
*/
|
|
public function setLoggingEventDispatcher(LoggingEventDispatcher $eventDispatcher): void
|
|
{
|
|
$this->eventDispatcher = $eventDispatcher;
|
|
}
|
|
|
|
/**
|
|
* @required
|
|
*/
|
|
public function setSentryLogger(SentryLogger $sentryLogger): void
|
|
{
|
|
$this->sentryLogger = $sentryLogger;
|
|
}
|
|
|
|
protected function configure()
|
|
{
|
|
$this
|
|
->addArgument('type', InputArgument::OPTIONAL, 'Type of cron to run. One of [FREQUENT, NORMAL, EXPENSIVE]', 'NORMAL')
|
|
->addOption('method', 'm', InputOption::VALUE_OPTIONAL, 'Call specific cron method - write just method, f.e.: "-m activatePoints"', false);
|
|
}
|
|
|
|
protected function execute(InputInterface $input, OutputInterface $output)
|
|
{
|
|
try {
|
|
$event = new CronEvent($input->getArgument('type'));
|
|
$eventName = constant('KupShop\KupShopBundle\Event\CronEvent::RUN_'.$input->getArgument('type'));
|
|
|
|
if ($input->hasOption('method')) {
|
|
$method = $input->getOption('method');
|
|
|
|
if ($method === null) {
|
|
// List all available handlers and exit
|
|
$table = new Table($output);
|
|
$table
|
|
->setHeaders(['Handler']);
|
|
|
|
foreach ($this->eventDispatcher->getListeners($eventName) as $listener) {
|
|
$table->addRow([sprintf('%s::%s', get_class($listener[0]), $listener[1])]);
|
|
}
|
|
|
|
$table->render();
|
|
|
|
return 0;
|
|
}
|
|
|
|
$this->eventDispatcher->setSpecificMethod($input->getOption('method'));
|
|
}
|
|
|
|
$this->eventDispatcher->dispatch(
|
|
$event,
|
|
$eventName,
|
|
);
|
|
} catch (\Throwable $e) {
|
|
$this->sentryLogger->setChannel(SentryLogger::CHANNEL_CRON)->captureException($e);
|
|
throw $e;
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
}
|