executeStreamRequest('PATCH', 'api/rest/v1/families', [], [], [], $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 = [ 'familyA1' => [ 'code' => 'familyA1', 'attributes' => ['a_date', 'a_file', 'a_localizable_image', 'sku'], 'attribute_as_label' => 'sku', 'attribute_as_image' => null, 'attribute_requirements' => [ 'ecommerce' => ['a_date', 'a_file', 'sku'], 'ecommerce_china' => ['sku'], 'tablet' => ['a_file', 'a_localizable_image', 'sku'] ], 'labels' => [ 'en_US' => 'family A1' ] ], 'familyC' => [ 'code' => 'familyC', 'attributes' => ['a_yes_no', 'sku'], 'attribute_as_label' => 'sku', 'attribute_as_image' => null, 'attribute_requirements' => [ 'ecommerce' => ['sku'], 'ecommerce_china' => ['sku'], 'tablet' => ['sku'] ], 'labels' => [] ] ]; $this->assertSameFamilies($expectedFamilies['familyA1'], 'familyA1'); $this->assertSameFamilies($expectedFamilies['familyC'], 'familyC'); } public function testCreateAndUpdateSameFamily() { $data = <<executeStreamRequest('PATCH', 'api/rest/v1/families', [], [], [], $data); $httpResponse = $response['http_response']; $this->assertSame(Response::HTTP_OK, $httpResponse->getStatusCode()); $this->assertSame($expectedContent, $response['content']); } public function testPartialUpdateListWithMaxNumberOfResourcesAllowed() { $maxNumberResources = $this->getMaxNumberResources(); for ($i = 0; $i < $maxNumberResources; $i++) { $data[] = sprintf('{"code": "my_code_%s"}', $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', [], [], [], $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('{"identifier": "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', [], [], [], $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', [], [], [], $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', [], [], [], $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', [], [], [], $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 that should be created * @param string $code code of the family that should be created */ protected function assertSameFamilies(array $expectedFamily, $code) { $family = $this->get('pim_catalog.repository.family')->findOneByIdentifier($code); $normalizer = $this->get('pim_catalog.normalizer.standard.family'); $standardizedFamily = $normalizer->normalize($family); $this->assertSame($expectedFamily, $standardizedFamily); } /** * {@inheritdoc} */ protected function getConfiguration() { return $this->catalog->useTechnicalCatalog(); } }