* @copyright 2021 Akeneo SAS (http://www.akeneo.com) * @license http://opensource.org/licenses/osl-3.0.php Open Software License (OSL 3.0) */ abstract class AbstractMassEditEndToEnd extends InternalApiTestCase { use AssertEventCountInTransportTrait; protected JobLauncher $jobLauncher; protected Connection $dbalConnection; /** * {@inheritdoc} */ public function setUp(): void { parent::setUp(); $this->jobLauncher = $this->get('akeneo_integration_tests.launcher.job_launcher'); $this->dbalConnection = $this->get('database_connection'); $this->authenticate($this->getAdminUser()); $this->clearMessengerTransport(); $this->jobLauncher->flushJobQueue(); } protected function executeMassEdit(array $data): void { $this->client->request( 'POST', '/rest/mass_edit/', [], [], [ 'HTTP_X-Requested-With' => 'XMLHttpRequest', ], json_encode($data) ); $response = $this->client->getResponse(); $this->assertSame(Response::HTTP_OK, $response->getStatusCode()); $this->launchAndWaitForJob($data['jobInstanceCode']); } protected function launchAndWaitForJob(string $jobInstanceCode): void { $this->jobLauncher->launchConsumerUntilQueueIsEmpty(); $query = <<dbalConnection->prepare($query); while (!$isCompleted) { if ($timeout > 30) { throw new \RuntimeException( sprintf( 'Timeout: last job execution from "%s" job instance is not complete.', $jobInstanceCode ) ); } $stmt->bindValue('instance_code', $jobInstanceCode); $stmt->execute(); $result = $stmt->fetch(); $isCompleted = isset($result['status']) && BatchStatus::COMPLETED === (int) $result['status']; $timeout++; sleep(1); } } protected function findESIdFor(string $identifier, string $type): string { switch ($type) { case 'product': $idFromDatabase = $this->getProductUuid($identifier)->toString(); break; case 'product_model': $idFromDatabase = $this->getProductModelId($identifier); break; default: throw new \InvalidArgumentException( 'Only "product" or "product_model" types are allowed. Product variant is a product.' ); } return sprintf('%s_%s', $type, $idFromDatabase); } protected function getProductModelId(string $code): string { $query = <<dbalConnection->prepare($query); $stmt->bindValue('code', $code); $idFromDatabase = $stmt->executeQuery()->fetchOne(); if (false === $idFromDatabase) { throw new \InvalidArgumentException(sprintf( 'Product model with code "%s" does not exist.', $code )); } return $idFromDatabase; } protected function updateProductWithInternalApi(string $identifier, array $data): void { $this->client->request( 'POST', sprintf('/enrich/product/rest/%s', $this->getProductUuid($identifier)->toString()), [], [], [ 'HTTP_X-Requested-With' => 'XMLHttpRequest', ], json_encode($data) ); $response = $this->client->getResponse(); $this->assertSame(Response::HTTP_OK, $response->getStatusCode()); } protected function updateFamilyVariantWithInternalApi(string $identifier, array $data): void { if (isset($data['meta'])) { unset($data['meta']); } $this->client->request( 'PUT', sprintf('/configuration/rest/family-variant/%s', $identifier), [], [], [ 'HTTP_X-Requested-With' => 'XMLHttpRequest', ], json_encode($data) ); $response = $this->client->getResponse(); $this->assertSame( Response::HTTP_OK, $response->getStatusCode(), 'Family variant has not been updated.' ); $this->launchAndWaitForJob('compute_family_variant_structure_changes'); } protected function getFamilyVariantWithInternalApi(string $identifier) { $this->client->request( 'GET', sprintf('/configuration/rest/family/family-variant/%s', $identifier), [], [], [ 'HTTP_X-Requested-With' => 'XMLHttpRequest', ] ); $response = $this->client->getResponse(); $this->assertSame(Response::HTTP_OK, $response->getStatusCode()); return json_decode($response->getContent(), true); } /** * {@inheritdoc} */ protected function getConfiguration() { return $this->catalog->useFunctionalCatalog('catalog_modeling'); } protected function getAdminUser(): UserInterface { return self::getContainer()->get('pim_user.repository.user')->findOneByIdentifier('admin'); } }