executeStreamRequest('PATCH', 'api/rest/v1/families/familyA/variants', [], [], [], $data); $httpResponse = $response['http_response']; $this->assertSame(Response::HTTP_OK, $httpResponse->getStatusCode()); $this->assertSame($expectedContent, $response['content']); $this->assertArrayHasKey('content-type', $httpResponse->headers->all()); $this->assertSame(StreamResourceResponse::CONTENT_TYPE, $httpResponse->headers->get('content-type')); $expectedFamilies = [ 'newFamilyVariant' => [ 'code' => 'newFamilyVariant', 'labels' => [], 'family' => 'familyA', 'variant_attribute_sets' => [ [ 'level' => 1, 'axes' => ['a_ref_data_simple_select'], 'attributes' => ['a_ref_data_simple_select', 'sku'], ] ], ], 'familyVariantA1' => [ 'code' => 'familyVariantA1', 'labels' => [ 'en_US' => 'US label', 'fr_FR' => 'FR label', ], 'family' => 'familyA', 'variant_attribute_sets' => [ [ 'level' => 1, 'axes' => ['a_simple_select'], 'attributes' => ['a_simple_select', 'a_text'], ], [ 'level' => 2, 'axes' => ['a_yes_no'], 'attributes' => ['sku', 'a_text_area', 'a_yes_no'], ], ], ], ]; $this->assertSameFamilyVariants($expectedFamilies['newFamilyVariant'], 'newFamilyVariant'); $this->assertSameFamilyVariants($expectedFamilies['familyVariantA1'], 'familyVariantA1'); } public function testPartialUpdateListWithMaxNumberOfResourcesAllowed() { $maxNumberResources = $this->getMaxNumberResources(); $json = '{"code": "my_code_%s", "variant_attribute_sets": [{"level": 1, "axes": ["a_simple_select"], "attributes": ["a_simple_select"]}]}'; for ($i = 0; $i < $maxNumberResources; $i++) { $data[] = sprintf($json, $i); } $data = implode(PHP_EOL, $data); for ($i = 0; $i < $maxNumberResources; $i++) { $expectedContent[] = sprintf('{"line":%s,"code":"my_code_%s","status_code":201}', $i + 1, $i); } $expectedContent = implode(PHP_EOL, $expectedContent); $response = $this->executeStreamRequest('PATCH', 'api/rest/v1/families/familyA/variants', [], [], [], $data); $httpResponse = $response['http_response']; $this->assertSame(Response::HTTP_OK, $httpResponse->getStatusCode()); $this->assertSame($expectedContent, $response['content']); } public function testPartialUpdateListWithTooManyResources() { $client = $this->createAuthenticatedClient(); $client->setServerParameter('CONTENT_TYPE', StreamResourceResponse::CONTENT_TYPE); $maxNumberResources = $this->getMaxNumberResources(); for ($i = 0; $i < $maxNumberResources + 1; $i++) { $data[] = sprintf('{"code": "my_code_%s"}', $i); } $data = implode(PHP_EOL, $data); $expectedContent = <<request('PATCH', 'api/rest/v1/families', [], [], [], $data); $response = $client->getResponse(); $this->assertJsonStringEqualsJsonString($expectedContent, $response->getContent()); $this->assertSame(Response::HTTP_REQUEST_ENTITY_TOO_LARGE, $response->getStatusCode()); } public function testPartialUpdateListWithInvalidAndTooLongLines() { $line = [ 'invalid_json_1' => str_repeat('a', $this->getBufferSize() - 1), 'invalid_json_2' => str_repeat('a', $this->getBufferSize()), 'invalid_json_3' => '', 'line_too_long_1' => '{"code":"foo"}' . str_repeat('a', $this->getBufferSize()), 'line_too_long_2' => '{"code":"foo"}' . str_repeat(' ', $this->getBufferSize()), 'line_too_long_3' => str_repeat('a', $this->getBufferSize() + 1), 'line_too_long_4' => str_repeat('a', $this->getBufferSize() + 2), 'line_too_long_5' => str_repeat('a', $this->getBufferSize() * 2), 'line_too_long_6' => str_repeat('a', $this->getBufferSize() * 5), 'invalid_json_4' => str_repeat('a', $this->getBufferSize()), ]; $data = <<executeStreamRequest('PATCH', 'api/rest/v1/families', [], [], [], $data); $httpResponse = $response['http_response']; $this->assertSame($expectedContent, $response['content']); $this->assertSame(Response::HTTP_OK, $httpResponse->getStatusCode()); } public function testErrorWhenIdentifierIsMissing() { $data = <<executeStreamRequest('PATCH', 'api/rest/v1/families/familyA/variants', [], [], [], $data); $httpResponse = $response['http_response']; $this->assertSame(Response::HTTP_OK, $httpResponse->getStatusCode()); $this->assertSame($expectedContent, $response['content']); } public function testUpdateFamilyWhenUpdaterFailed() { $data = <<executeStreamRequest('PATCH', 'api/rest/v1/families/familyA/variants', [], [], [], $data); $httpResponse = $response['http_response']; $this->assertSame(Response::HTTP_OK, $httpResponse->getStatusCode()); $this->assertSame($expectedContent, $response['content']); } public function testUpdateFamilyWhenValidationFailed() { $data = <<executeStreamRequest('PATCH', 'api/rest/v1/families/familyA/variants', [], [], [], $data); $httpResponse = $response['http_response']; $this->assertSame(Response::HTTP_OK, $httpResponse->getStatusCode()); $this->assertSame($expectedContent, $response['content']); } public function testPartialUpdateListWithBadContentType() { $data = <<createAuthenticatedClient(); $client->setServerParameter('CONTENT_TYPE', 'application/json'); $client->request('PATCH', 'api/rest/v1/families/familyA/variants', [], [], [], $data); $response = $client->getResponse(); $this->assertSame(Response::HTTP_UNSUPPORTED_MEDIA_TYPE, $response->getStatusCode()); $this->assertJsonStringEqualsJsonString($expectedContent, $response->getContent()); } protected function getBufferSize() { return $this->getParameter('api_input_buffer_size'); } protected function getMaxNumberResources() { return $this->getParameter('api_input_max_resources_number'); } /** * @param array $expectedFamily normalized data of the family variant that should be created * @param string $code code of the family variant that should be created */ protected function assertSameFamilyVariants(array $expectedFamily, $code): void { $familyVariant = $this->get('pim_catalog.repository.family_variant')->findOneByIdentifier($code); $normalizer = $this->get('pim_catalog.normalizer.standard.family_variant'); $standardizedFamilyVariant = $normalizer->normalize($familyVariant); $this->assertSame($expectedFamily, $standardizedFamilyVariant); } /** * {@inheritdoc} */ protected function getConfiguration() { return $this->catalog->useTechnicalCatalog(); } }