* @copyright 2017 Akeneo SAS (http://www.akeneo.com) * @license http://opensource.org/licenses/osl-3.0.php Open Software License (OSL 3.0) */ class PublishJobToQueueCommand extends Command { protected static $defaultName = 'akeneo:batch:publish-job-to-queue'; public const EXIT_SUCCESS_CODE = 0; /** @var PublishJobToQueue */ private $publishJobToQueue; /** @var JobRepositoryInterface */ private $jobRepository; /** @var JobRegistry */ private $jobRegistry; /** @var JobParametersFactory */ private $jobParametersFactory; /** @var string */ private $jobInstanceClass; public function __construct( PublishJobToQueue $publishJobToQueue, JobRepositoryInterface $jobRepository, JobRegistry $jobRegistry, JobParametersFactory $jobParametersFactory, string $jobInstanceClass ) { parent::__construct(); $this->publishJobToQueue = $publishJobToQueue; $this->jobRepository = $jobRepository; $this->jobRegistry = $jobRegistry; $this->jobParametersFactory = $jobParametersFactory; $this->jobInstanceClass = $jobInstanceClass; } /** * {@inheritdoc} */ protected function configure() { $this ->setDescription('Publish a registered job instance to execute into the job execution queue') ->addArgument('code', InputArgument::REQUIRED, 'Job instance code') ->addOption( 'config', 'c', InputOption::VALUE_REQUIRED, 'Override job configuration (formatted as json. ie: ' . 'php bin/console publish-job-to-queue -c "{\"filePath\":\"/tmp/foo.csv\"}" acme_product_import)' ) ->addOption( 'username', null, InputOption::VALUE_REQUIRED, 'Username to launch the job instance with' ) ->addOption( 'email', null, InputOption::VALUE_REQUIRED | InputOption::VALUE_IS_ARRAY, 'The email to notify at the end of the job execution' ) ->addOption( 'no-log', null, InputOption::VALUE_NONE, 'Don\'t display logs' ); } /** * {@inheritdoc} */ protected function execute(InputInterface $input, OutputInterface $output): int { $jobInstanceCode = $input->getArgument('code'); $config = $input->getOption('config') ? $this->decodeConfiguration($input->getOption('config')) : []; $noLog = $input->getOption('no-log') ? true : false; $username = $input->getOption('username'); $email = $input->getOption('email'); $this->publishJobToQueue->publish( $jobInstanceCode, $config, $noLog, $username, $email ); $jobInstance = $this->getJobManager()->getRepository($this->jobInstanceClass)->findOneBy(['code' => $jobInstanceCode]); $output->writeln( sprintf( '%s %s has been successfully pushed into the queue.', ucfirst($jobInstance->getType()), $jobInstance->getCode() ) ); return self::EXIT_SUCCESS_CODE; } /** * @param JobInstance $jobInstance * @param InputInterface $input * * @return JobParameters */ protected function createJobParameters(JobInstance $jobInstance, InputInterface $input): JobParameters { $job = $this->$this->jobRegistry->get($jobInstance->getJobName()); $rawParameters = $jobInstance->getRawParameters(); $config = $input->getOption('config') ? $this->decodeConfiguration($input->getOption('config')) : []; $rawParameters = array_merge($rawParameters, $config); $jobParameters = $this->jobParametersFactory->create($job, $rawParameters); return $jobParameters; } /** * @param string $data * * @throws \InvalidArgumentException * * @return array */ private function decodeConfiguration($data): array { $config = json_decode($data, true); switch (json_last_error()) { case JSON_ERROR_DEPTH: $error = 'Maximum stack depth exceeded'; break; case JSON_ERROR_STATE_MISMATCH: $error = 'Underflow or the modes mismatch'; break; case JSON_ERROR_CTRL_CHAR: $error = 'Unexpected control character found'; break; case JSON_ERROR_SYNTAX: $error = 'Syntax error, malformed JSON'; break; case JSON_ERROR_UTF8: $error = 'Malformed UTF-8 characters, possibly incorrectly encoded'; break; default: return $config; } throw new \InvalidArgumentException($error); } /** * @return EntityManagerInterface */ private function getJobManager(): EntityManagerInterface { return $this->jobRepository->getJobManager(); } }