Kaliop\eZMigrationBundle\Core\Executor\ContentManager::generateMigration()

Complexity

Conditions	14
Paths	485

Size

Total Lines	131
Code Lines	89

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	67
CRAP Score	14.238

Importance

Changes

0

<?php
    public function generateMigration(array $matchConditions, $mode, array $context = array())
    {
        $data = array();
        $previousUserId = $this->loginUser($this->getAdminUserIdentifierFromContext($context));
        try {
            $contentCollection = $this->contentMatcher->match($matchConditions);
            /// @todo throw if nothing is matched?

            /** @var \eZ\Publish\API\Repository\Values\Content\Content $content */
            foreach ($contentCollection as $content) {

                $location = $this->repository->getLocationService()->loadLocation($content->contentInfo->mainLocationId);
                $contentType = $this->repository->getContentTypeService()->loadContentType(
                    $content->contentInfo->contentTypeId
                );

                $contentData = array(
                    'type' => reset($this->supportedStepTypes),
                    'mode' => $mode
                );

                switch ($mode) {
                    case 'create':
                        $contentData = array_merge(
                            $contentData,
                            array(
                                'content_type' => $contentType->identifier,
                                'parent_location' => $location->parentLocationId,
                                'priority' => $location->priority,
                                'is_hidden' => $location->invisible,
                                'sort_field' => $this->sortConverter->sortField2Hash($location->sortField),
                                'sort_order' => $this->sortConverter->sortOrder2Hash($location->sortOrder),
                                'remote_id' => $content->contentInfo->remoteId,
                                'location_remote_id' => $location->remoteId,
                                'section' => $content->contentInfo->sectionId,
                                'object_states' => $this->getObjectStates($content),
                            )
                        );
                        $locationService = $this->repository->getLocationService();
                        /// @todo for accurate replication, we should express the adding of 2ndary locations as separate steps, and copy over visibility, priority etc
                        $locations = $locationService->loadLocations($content->contentInfo);
                        if (count($locations) > 1) {
                            $otherParentLocations = array();
                            foreach ($locations as $otherLocation) {
                                if ($otherLocation->id != $location->id) {
                                    $otherParentLocations[] = $otherLocation->parentLocationId;
                                }
                            }
                            $contentData['other_parent_locations'] = $otherParentLocations;
                        }
                        break;
                    case 'update':
                        $contentData = array_merge(
                            $contentData,
                            array(
                                'match' => array(
                                    ContentMatcher::MATCH_CONTENT_REMOTE_ID => $content->contentInfo->remoteId
                                ),
                                'new_remote_id' => $content->contentInfo->remoteId,
                                'section' => $content->contentInfo->sectionId,
                                'object_states' => $this->getObjectStates($content),
                            )
                        );
                        break;
                    case 'delete':
                        $contentData = array_merge(
                            $contentData,
                            array(
                                'match' => array(
                                    ContentMatcher::MATCH_CONTENT_REMOTE_ID => $content->contentInfo->remoteId
                                )
                            )
                        );
                        break;
                    default:
                        throw new InvalidStepDefinitionException("Executor 'content' doesn't support mode '$mode'");
                }

                if ($mode != 'delete') {

                    $language = $this->getLanguageCodeFromContext($context);
                    if ($language == 'all') {
                        $languages = $content->versionInfo->languageCodes;
                    } else {
                        $contentData = array_merge(
                            $contentData,
                            array(
                                'lang' => $language,
                            )
                        );
                        $languages = array($language);
                    }

                    $attributes = array();
                    foreach ($languages as $lang) {
                        foreach ($content->getFieldsByLanguage($lang) as $fieldIdentifier => $field) {
                            $fieldDefinition = $contentType->getFieldDefinition($fieldIdentifier);
                            $fieldValue = $this->fieldHandlerManager->fieldValueToHash(
                                $fieldDefinition->fieldTypeIdentifier, $contentType->identifier, $field->value
                            );
                            if ($language == 'all') {
                                $attributes[$field->fieldDefIdentifier][$lang] = $fieldValue;
                            } else {
                                $attributes[$field->fieldDefIdentifier] = $fieldValue;
                            }
                        }
                    }

                    $contentData = array_merge(
                        $contentData,
                        array(
                            'section' => $content->contentInfo->sectionId,
                            'owner' => $content->contentInfo->ownerId,
                            'modification_date' => $content->contentInfo->modificationDate->getTimestamp(),
                            'publication_date' => $content->contentInfo->publishedDate->getTimestamp(),
                            'always_available' => (bool)$content->contentInfo->alwaysAvailable,
                            'attributes' => $attributes
                        )
                    );
                }

                $data[] = $contentData;
            }

            $this->loginUser($previousUserId);
        } catch (\Exception $e) {
            $this->loginUser($previousUserId);
            throw $e;
        }

        return $data;
    }