entitiesAreImportedViaTheJobWithOptions($entities, $jobName, new TableNode([])); } /** * @When /^the (.*) are imported via the job ([\w\_]+) with options:$/ */ public function entitiesAreImportedViaTheJobWithOptions(string $entities, string $jobName, TableNode $jobOptions) { $newJobOptions = new TableNode( array_merge( $jobOptions->getTable(), [['storage', json_encode(['type' => 'local', 'file_path' => self::$placeholderValues['%file to import%']])]] ) ); $this->launchJob($jobName, $newJobOptions); } /** * @When /^the (.*) are exported via the job ([\w\_]+)$/ */ public function entitiesAreExportedViaTheJob(string $entities, string $jobName) { $this->launchJob($jobName, new TableNode([])); } /** * @Then there should be :number product(s) skipped because there is no difference */ public function thereShouldBeProductSkippedBecauseThereIsNoDifference(string $number) { $importStep = current(array_filter( $this->jobExecution->getStepExecutions()->toArray(), static fn (StepExecution $stepExecution) => 'import' === $stepExecution->getStepName(), )); Assert::assertEquals($number, $importStep->getSummaryInfo('product_skipped_no_diff')); } /** * @Then /^I should have the error "(?P(?:[^"]|\\")*)"$/ */ public function iShouldHaveTheError(string $error) { foreach ($this->jobExecution->getStepExecutions() as $stepExecution) { foreach ($stepExecution->getWarnings() as $warning) { if (str_replace('\\"', '"', $error) === trim($warning->getReason())) { return true; } } } throw new \Exception(sprintf('Cannot find the error "%s"', $error)); } private function launchJob(string $jobName, TableNode $newJobOptions) { $this->jobInstance = $this->mainContext ->getSubcontext('job') ->theFollowingJobConfiguration($jobName, $newJobOptions); $user = $this->getFixturesContext()->getUser(self::USERNAME_FOR_JOB_LAUNCH); $launcher = $this->getService('akeneo_batch_queue.launcher.queue_job_launcher'); $launcher->launch($this->jobInstance, $user); $this->jobExecution = $this->waitForJobToFinish($this->jobInstance); } private function waitForJobToFinish(JobInstance $jobInstance): JobExecution { $jobExecutionRepository = $this->getService('pim_enrich.repository.job_execution'); $this->spin(function () use ($jobInstance, $jobExecutionRepository) { $jobExecutionRepository->clear(); $jobExecution = $jobExecutionRepository->findOneBy( ['jobInstance' => $jobInstance], ['createTime' => 'desc'] ); return $jobExecution && !$jobExecution->isRunning(); }, sprintf('The job execution of "%s" was too long', $jobInstance->getJobName())); return $jobExecutionRepository->findOneBy( ['jobInstance' => $jobInstance], ['createTime' => 'desc'] ); } }