getJobManager()->willReturn($entityManager); $entityManager->getRepository($jobInstanceClass)->willReturn($jobInstanceRepository); $this->beConstructedWith( $publishJobToQueue, $jobRepository, $jobRegistry, $jobParametersFactory, $jobInstanceClass ); } function it_has_a_name() { $this->getName()->shouldReturn('akeneo:batch:publish-job-to-queue'); } function it_is_a_command() { $this->shouldBeAnInstanceOf(Command::class); } public function it_publishes_a_job_to_the_job_queue( InputInterface $input, OutputInterface $output, Application $application, HelperSet $helperSet, InputDefinition $definition, PublishJobToQueue $publishJobToQueue, JobInstanceRepository $jobInstanceRepository, JobInstance $jobInstance ) { $definition->getOptions()->willReturn([]); $definition->getArguments()->willReturn([]); $application->getHelperSet()->willReturn($helperSet); $application->getDefinition()->willReturn($definition); $this->setApplication($application); $input->bind(Argument::any())->shouldBeCalled(); $input->isInteractive()->shouldBeCalled(); $input->hasArgument(Argument::any())->shouldBeCalled(); $input->validate()->shouldBeCalled(); $inputCode = 'the_job_instance_code'; $inputConfig = '{"key": "data", "superkey": 50}'; $inputNoLog = null; $inputUsername = 'admin'; $inputEmail = null; $input->getArgument('code')->willReturn($inputCode); $input->getOption('config')->willReturn($inputConfig); $input->getOption('no-log')->willReturn($inputNoLog); $input->getOption('username')->willReturn($inputUsername); $input->getOption('email')->willReturn($inputEmail); $publishJobToQueue->publish( $inputCode, json_decode($inputConfig, true), false, $inputUsername, $inputEmail )->shouldBeCalled(); $jobInstanceRepository->findOneBy(['code' => $inputCode])->willReturn($jobInstance); $jobInstance->getType()->willReturn('jobType'); $jobInstance->getCode()->willReturn($inputCode); $output->writeln('JobType the_job_instance_code has been successfully pushed into the queue.')->shouldBeCalled(); $this->run($input, $output); } public function it_throws_an_exception_if_the_config_string_is_malformed( InputInterface $input, OutputInterface $output, Application $application, HelperSet $helperSet, InputDefinition $definition ) { $definition->getOptions()->willReturn([]); $definition->getArguments()->willReturn([]); $application->getHelperSet()->willReturn($helperSet); $application->getDefinition()->willReturn($definition); $this->setApplication($application); $input->bind(Argument::any())->shouldBeCalled(); $input->isInteractive()->shouldBeCalled(); $input->hasArgument(Argument::any())->shouldBeCalled(); $input->validate()->shouldBeCalled(); $inputCode = 'the_job_instance_code'; $inputConfig = '{{invalid_config}'; $inputNoLog = null; $inputUsername = 'admin'; $inputEmail = null; $input->getArgument('code')->willReturn($inputCode); $input->getOption('config')->willReturn($inputConfig); $input->getOption('no-log')->willReturn($inputNoLog); $input->getOption('username')->willReturn($inputUsername); $input->getOption('email')->willReturn($inputEmail); $this->shouldThrow(\InvalidArgumentException::class)->during( 'run', [$input, $output] ); } }