, timestamps: list, columnDefaults: array}> */ private array $filterRecordFieldsSetupCache = []; protected bool $saveFilesOutsideExportFile = false; protected bool $includeSiteConfigurations = false; protected string $exportFileName = ''; protected string $exportFileType = self::FILETYPE_XML; protected array $supportedFileTypes = []; /** * Cache for checks if page is in user web mounts. */ protected array $pageInWebMountCache = []; public function __construct( protected readonly ConnectionPool $connectionPool, protected readonly Locales $locales, protected readonly Typo3Version $typo3Version, protected readonly ReferenceIndex $referenceIndex, protected readonly SiteConfiguration $siteConfiguration, protected readonly Context $context, ) {} /** * Process configuration */ public function process(): void { $this->initializeExport(); $this->setHeader(); // Configure which records to export foreach ($this->record as $ref) { $rParts = explode(':', $ref); $table = $rParts[0]; $record = BackendUtility::getRecord($rParts[0], (int)$rParts[1]); if (is_array($record)) { $this->exportAddRecord($table, $record); } } // Configure which tables to export foreach ($this->list as $ref) { $rParts = explode(':', $ref); $table = $rParts[0]; $pid = (int)$rParts[1]; if ($this->getBackendUser()->check('tables_select', $table)) { $statement = $this->execListQueryPid($pid, $table); while ($record = $statement->fetchAssociative()) { $this->exportAddRecord($table, $record); } } } // Configure which page tree to export if ($this->pid !== -1) { $pageTree = null; if ($this->levels === self::LEVELS_RECORDS_ON_THIS_PAGE) { $this->addRecordsForPid($this->pid, $this->tables); } else { /** @var ExportPageTreeView $pageTreeView */ $pageTreeView = GeneralUtility::makeInstance(ExportPageTreeView::class); $initClause = $this->getExcludePagesClause(); if ($this->excludeDisabledRecords) { $initClause .= BackendUtility::BEenableFields('pages'); } $pageTreeView->init($initClause); $pageTreeView->buildTreeByLevels($this->pid, $this->levels); $this->treeHTML = $pageTreeView->printTree(); $pageTree = $pageTreeView->buffer_idH; } // In most cases, we should have a multi-level array, $pageTree, with the page tree // structure here (and the HTML code loaded into memory for a nice display...) if (is_array($pageTree)) { $pageList = []; $this->removeExcludedPagesFromPageTree($pageTree); $this->setPageTree($pageTree); $this->flatInversePageTree($pageTree, $pageList); $pagesSchema = $this->tcaSchemaFactory->get('pages'); $transOrigPointerFieldName = null; $languageFieldName = null; $languageCapability = null; if ($pagesSchema->isLanguageAware()) { $languageCapability = $pagesSchema->getCapability(TcaSchemaCapability::Language); $transOrigPointerFieldName = $languageCapability->getTranslationOriginPointerField()->getName(); $languageFieldName = $languageCapability->getLanguageField()->getName(); } foreach ($pageList as $pageUid => $_) { $record = BackendUtility::getRecord('pages', $pageUid); if (is_array($record)) { $this->exportAddRecord('pages', $record); foreach ($this->getTranslationForPage($languageCapability, (int)$record['uid'], $this->excludeDisabledRecords) as $pageTranslation) { // Export l10n translations // All exported records need to be considered within "insidePageTree", not "outsidePageTree", // because they actually ARE part of the page tree. To achieve this, their UID index is // added into $this->dat['header']['pagetree']. $this->exportAddRecord('pages', $pageTranslation); // Be sure to not overwrite existing parts of the pagetree // Integrate the extra record into the internal pagetree array $this->dat['header']['pagetree'][(int)$pageTranslation['uid']]['uid'] = (int)$pageTranslation['uid']; } // Translated pages can also be directly exported; in that case the pageList may // point to the UID of a translated page, and not the root page. Since tt_content // records are bound to the default page UID, those records would be missing. // So we use the page ID of the default language, and then attach all records // for that page ID, which also match the selected page's language. if (($record[$transOrigPointerFieldName] ?? 0) > 0) { $this->addRecordsForPid( (int)$record[$transOrigPointerFieldName], $this->tables, [$record[$languageFieldName]] ); } } $this->addRecordsForPid((int)$pageUid, $this->tables); } } } // After adding ALL records we add records from database relations for ($l = 0; $l < 10; $l++) { if ($this->exportAddRecordsFromRelations($l) === 0) { break; } } // Files must be added after the database relations are added, // so that files from ALL added records are included! $this->exportAddFilesFromSysFilesRecords(); if ($this->includeSiteConfigurations) { $this->exportAddSiteConfigurations(); } } /** * Add page translations to list of pages */ protected function getTranslationForPage( ?LanguageAwareSchemaCapability $languageCapability, int $defaultLanguagePageUid, bool $considerHiddenPages, array $limitToLanguageIds = [] ): array { if ($languageCapability === null) { return []; } $queryBuilder = $this->connectionPool->getQueryBuilderForTable('pages'); $queryBuilder->getRestrictions() ->removeAll() ->add(GeneralUtility::makeInstance(WorkspaceRestriction::class)) ->add(GeneralUtility::makeInstance(DeletedRestriction::class)); if (!$considerHiddenPages) { $queryBuilder->getRestrictions()->add(GeneralUtility::makeInstance(HiddenRestriction::class)); } $constraints = [ $queryBuilder->expr()->eq( $languageCapability->getTranslationOriginPointerField()->getName(), $queryBuilder->createNamedParameter($defaultLanguagePageUid, Connection::PARAM_INT) ), ]; if (!empty($limitToLanguageIds)) { $constraints[] = $queryBuilder->expr()->in( $languageCapability->getLanguageField()->getName(), $queryBuilder->createNamedParameter($limitToLanguageIds, ArrayParameterType::INTEGER) ); } else { // Ensure consistency by only fetching pages where not only l10n_parent matches, but also a // sys_language_uid > 0 exists. $constraints[] = $queryBuilder->expr()->gt($languageCapability->getLanguageField()->getName(), 0); } return $queryBuilder ->select('*') ->from('pages') ->where(...$constraints) ->orderBy('uid', 'ASC') ->executeQuery() ->fetchAllAssociative(); } /** * Initialize all settings for the export */ protected function initializeExport(): void { $this->dat = [ 'header' => [], 'records' => [], ]; } protected function setHeader(): void { // Initializing: foreach ($this->softrefCfg as $key => $value) { if (!($value['mode'] ?? false)) { unset($this->softrefCfg[$key]); } } // Version of file format $this->dat['header']['XMLversion'] = '1.0'; $this->dat['header']['charset'] = 'utf-8'; // Meta data (overridable for testing) $this->setMetaData(); // Add list of tables to consider static if ($this->relStaticTables !== []) { $this->dat['header']['relStaticTables'] = $this->relStaticTables; } // The list of excluded records if ($this->excludeMap !== []) { $this->dat['header']['excludeMap'] = $this->excludeMap; } // Soft reference mode for elements if ($this->softrefCfg !== []) { $this->dat['header']['softrefCfg'] = $this->softrefCfg; } // List of extensions the import depends on. if ($this->extensionDependencies !== []) { $this->dat['header']['extensionDependencies'] = $this->extensionDependencies; } } protected function setMetaData(): void { $user = $this->getBackendUser(); if ($user->user['lang'] ?? false) { $locale = $this->locales->createLocale($user->user['lang']); } else { $locale = new Locale(); } /** @var DateTimeAspect $dateAspect */ $dateAspect = $this->context->getAspect('date'); $meta = array_filter([ 'title' => $this->title, 'description' => $this->description, 'notes' => $this->notes, 'packager_username' => $this->getBackendUser()->user['username'], 'packager_name' => $this->getBackendUser()->user['realName'], 'packager_email' => $this->getBackendUser()->user['email'], 'TYPO3_version' => (string)$this->typo3Version, 'created' => (new DateFormatter())->format($dateAspect->getDateTime(), 'EEE d. MMMM y', $locale), ], static fn(string $value): bool => $value !== ''); if ($meta !== []) { $this->dat['header']['meta'] = $meta; } } /** * Sets the page-tree array in the export header * * @param array $pageTree Hierarchy of ids, the page tree: array([uid] => array("uid" => [uid], "subrow" => array(.....)), [uid] => ....) */ public function setPageTree(array $pageTree): void { $this->dat['header']['pagetree'] = $pageTree; } /** * Removes entries in the page tree which are found in ->excludeMap[] * * @param array $pageTree Hierarchy of ids, the page tree */ protected function removeExcludedPagesFromPageTree(array &$pageTree): void { foreach ($pageTree as $pid => $value) { if ($this->isRecordExcluded('pages', (int)($pageTree[$pid]['uid'] ?? 0))) { unset($pageTree[$pid]); } elseif (is_array($pageTree[$pid]['subrow'] ?? null)) { $this->removeExcludedPagesFromPageTree($pageTree[$pid]['subrow']); } } } /** * Filter page IDs by traversing the exclude map, finding all * excluded pages (if any) and making an AND NOT IN statement for the select clause. * * @return string AND where clause part to filter out page uids. */ protected function getExcludePagesClause(): string { $pageIds = []; foreach ($this->excludeMap as $tableAndUid => $isExcluded) { [$table, $uid] = explode(':', $tableAndUid); if ($table === 'pages') { $pageIds[] = (int)$uid; } } if (!empty($pageIds)) { return ' AND uid NOT IN (' . implode(',', $pageIds) . ')'; } return ''; } /** * Adds records to the export object for a specific page id. * * @param int $pid Page id for which to select records to add * @param array $tables Array of table names to select from * @param array $restrictToLanguageIds Array of sys_language_uid IDs to allow records for. */ protected function addRecordsForPid(int $pid, array $tables, array $restrictToLanguageIds = []): void { $isRestrictToLanguageIds = $restrictToLanguageIds !== []; /** * @var string $table * @var TcaSchema $schema */ foreach ($this->tcaSchemaFactory->all() as $table => $schema) { if ($table === 'pages') { continue; } if (!$this->getBackendUser()->check('tables_select', $table)) { continue; } if (!in_array($table, $tables, true) && !in_array('_ALL', $tables, true)) { continue; } $languageField = null; if ($schema->isLanguageAware()) { $languageField = $schema->getCapability(TcaSchemaCapability::Language)->getLanguageField()->getName(); } $statement = $this->execListQueryPid($pid, $table); while ($record = $statement->fetchAssociative()) { // Skip the record, when languageId restrictions are enabled, and the record's language is not requested if ($isRestrictToLanguageIds && $schema->isLanguageAware() && isset($record[$languageField]) && !in_array($record[$languageField], $restrictToLanguageIds, true)) { continue; } $this->exportAddRecord($table, $record); } } } /** * Selects records from table / pid * * @param int $pid Page ID to select from * @param string $table Table to select from * @return Result Query statement */ protected function execListQueryPid(int $pid, string $table): Result { $queryBuilder = $this->connectionPool->getQueryBuilderForTable($table); $schema = $this->tcaSchemaFactory->get($table); $orderBy = ''; if ($schema->hasCapability(TcaSchemaCapability::SortByField)) { $orderBy = $schema->getCapability(TcaSchemaCapability::SortByField)->getFieldName(); } elseif ($schema->hasCapability(TcaSchemaCapability::DefaultSorting)) { $orderBy = $schema->getCapability(TcaSchemaCapability::DefaultSorting)->getValue(); } if ($this->excludeDisabledRecords === false) { $queryBuilder->getRestrictions() ->removeAll() ->add(GeneralUtility::makeInstance(DeletedRestriction::class)) ->add(GeneralUtility::makeInstance(WorkspaceRestriction::class, 0)); } else { $queryBuilder->getRestrictions() ->add(GeneralUtility::makeInstance(WorkspaceRestriction::class, 0)); } $queryBuilder->select('*') ->from($table) ->where( $queryBuilder->expr()->eq( 'pid', $queryBuilder->createNamedParameter($pid, Connection::PARAM_INT) ) ); $orderBys = QueryHelper::parseOrderBy((string)$orderBy); foreach ($orderBys as $orderPair) { [$field, $order] = $orderPair; $queryBuilder->addOrderBy($field, $order); } // Ensure deterministic sorting if (!in_array('uid', array_column($orderBys, 0))) { $queryBuilder->addOrderBy('uid', 'ASC'); } return $queryBuilder->executeQuery(); } /** * Adds the record $row from $table. * No checking for relations done here. Pure data. * * @param string $table Table name * @param array $row Record row. * @param int $relationLevel (Internal) if the record is added as a relation, this is set to the "level" it was on. */ public function exportAddRecord(string $table, array $row, int $relationLevel = 0): void { BackendUtility::workspaceOL($table, $row); $recordUid = (int)$row['uid']; if ($table === '' || $recordUid === 0 || $this->isRecordExcluded($table, $recordUid) || $this->excludeDisabledRecords && $this->isRecordDisabled($table, $recordUid)) { return; } $recordPid = (int)$row['pid']; $recordIdentifier = $table . ':' . $recordUid; if ($this->isPageInWebMount($table === 'pages' ? $recordUid : $recordPid)) { if (!isset($this->dat['records'][$recordIdentifier])) { // Prepare header info $headerInfo = [ 'uid' => $recordUid, 'pid' => $recordPid, 'title' => GeneralUtility::fixed_lgd_cs(BackendUtility::getRecordTitle($table, $row), 40), ]; $sanitizedRow = $this->filterRecordFields($table, $row); if ($relationLevel) { $headerInfo['relationLevel'] = $relationLevel; } // Set the header summary: $this->dat['header']['records'][$table][$recordUid] = $headerInfo; // Create entry in the PID lookup: $this->dat['header']['pid_lookup'][$recordPid][$table][$recordUid] = 1; // @todo: Using getRelations() from Refindex for this operation is a misuse, the method should // be protected. It would be better to use softref parser and RelationHandler here directly, // or fetch the relations using a sys_refindex query. Note with recent changes, 'itemArray' // with MM contain 'sorting', 'sorting_foreign', 'fieldname' as well, which could be removed // from export again if needed, since they are currently irrelevant during import. // Note 'fieldname' could be handy during import, though: When a category is for instance bound // to two different fields in a target table (e.g. 'pages'), that field indicates to which // of those a relation is bound. This is currently most likely not handled during import and // should have more test coverage. $relations = $this->referenceIndex->getRelations($table, $row, 0); // Data: $this->dat['records'][$recordIdentifier] = ['data' => $sanitizedRow]; // There are no refindex entries for l10n_source of pages and tt_content, so we have to add them here manually for now. // @todo can be removed, when this can come from ReferenceIndex. if (($table === 'pages' || $table === 'tt_content')) { $schema = $this->tcaSchemaFactory->get($table); $translationSourceFieldName = null; if ($schema->isLanguageAware()) { $languageCapability = $schema->getCapability(TcaSchemaCapability::Language); $translationSourceFieldName = $languageCapability->getTranslationSourceField()?->getName(); } if ($translationSourceFieldName && ((int)($row[$translationSourceFieldName] ?? 0)) > 0) { $relations[$translationSourceFieldName]['type'] = 'db'; $relations[$translationSourceFieldName]['itemArray'][0] = [ 'id' => $row[$translationSourceFieldName], 'table' => $table, ]; } } if ($relations !== []) { $this->dat['records'][$recordIdentifier]['rels'] = $relations; } // Add information about the relations in the record in the header: $flatDbRelations = $this->flatDbRelations($relations); if ($flatDbRelations !== []) { $this->dat['header']['records'][$table][$recordUid]['rels'] = $flatDbRelations; } // Add information about the softrefs to header: $flatSoftRefs = $this->flatSoftRefs($relations); if ($flatSoftRefs !== []) { $this->dat['header']['records'][$table][$recordUid]['softrefs'] = $flatSoftRefs; } } else { $this->addError('Record ' . $recordIdentifier . ' already added.'); } } else { $this->addError('Record ' . $recordIdentifier . ' was outside your database mounts!'); } } /** * Checking if a page is in the web mounts of the user * * @param int $pid Page ID to check * @return bool TRUE if OK */ protected function isPageInWebMount(int $pid): bool { if (!isset($this->pageInWebMountCache[$pid])) { $this->pageInWebMountCache[$pid] = (bool)$this->getBackendUser()->isInWebMount($pid); } return $this->pageInWebMountCache[$pid]; } /** * Reduces the exported row to the values a re-import actually needs. * * Strips DataHandler-managed timestamps and columns whose value equals * the effective default. Always preserves uid, pid, the disabled field * and the record-type field. */ protected function filterRecordFields(string $table, array $row): array { if (!$this->tcaSchemaFactory->has($table)) { return $row; } $setup = $this->getFilterRecordFieldsSetup($table); $schema = $this->tcaSchemaFactory->get($table); $alwaysKeep = $setup['alwaysKeep']; $timestamps = $setup['timestamps']; $columnDefaults = $setup['columnDefaults']; $newRow = []; foreach ($row as $fieldName => $value) { if (in_array($fieldName, $timestamps, true)) { continue; } if (!in_array($fieldName, $alwaysKeep, true) && $this->valueMatchesEffectiveDefault($schema, $columnDefaults, $fieldName, $value) ) { continue; } $newRow[$fieldName] = $value; } return $newRow; } /** * @return array{alwaysKeep: list, timestamps: list, columnDefaults: array} */ private function getFilterRecordFieldsSetup(string $table): array { if (array_key_exists($table, $this->filterRecordFieldsSetupCache)) { return $this->filterRecordFieldsSetupCache[$table]; } $schema = $this->tcaSchemaFactory->get($table); $alwaysKeep = $this->defaultRecordIncludeFields; if ($schema->hasCapability(TcaSchemaCapability::RestrictionDisabledField)) { $disabledCapability = $schema->getCapability(TcaSchemaCapability::RestrictionDisabledField); $alwaysKeep[] = $disabledCapability->getFieldName(); } if ($schema->supportsSubSchema()) { $alwaysKeep[] = $schema->getSubSchemaTypeInformation()->getFieldName(); } if ($schema->isLanguageAware()) { $languageCapability = $schema->getCapability(TcaSchemaCapability::Language); $alwaysKeep[] = $languageCapability->getLanguageField()->getName(); $alwaysKeep[] = $languageCapability->getTranslationOriginPointerField()->getName(); $sourceField = $languageCapability->getTranslationSourceField()?->getName(); if ($sourceField !== null) { $alwaysKeep[] = $sourceField; } $diffSourceField = $languageCapability->getDiffSourceField()?->getName(); if ($diffSourceField !== null) { $alwaysKeep[] = $diffSourceField; } } $timestamps = []; foreach ([TcaSchemaCapability::CreatedAt, TcaSchemaCapability::UpdatedAt] as $capability) { if (!$schema->hasCapability($capability)) { continue; } $timestamps[] = $schema->getCapability($capability)->getFieldName(); } return $this->filterRecordFieldsSetupCache[$table] = [ 'alwaysKeep' => $alwaysKeep, 'timestamps' => $timestamps, 'columnDefaults' => $this->getColumnDefaults($table), ]; } /** * TCA is authoritative: only columns without a TCA default fall back to * the Doctrine-reported database default. */ private function valueMatchesEffectiveDefault( TcaSchema $schema, array $columnDefaults, string $fieldName, mixed $value, ): bool { if ($schema->hasField($fieldName)) { $field = $schema->getField($fieldName); if ($field->hasDefaultValue()) { return $this->valueMatchesDefault($value, $field->getDefaultValue()); } } if (array_key_exists($fieldName, $columnDefaults)) { return $this->valueMatchesDefault($value, $columnDefaults[$fieldName]); } return false; } /** * @return array */ private function getColumnDefaults(string $table): array { $defaults = []; $schemaInformation = $this->connectionPool->getConnectionForTable($table)->getSchemaInformation(); $columnInfos = $schemaInformation->listTableColumnInfos($table); foreach ($columnInfos as $columnInfo) { $defaults[$columnInfo->name] = $columnInfo->default; } return $defaults; } /** * Drivers hand defaults back as strings or ints, * so "" never matches an int 0 default, and vice versa. */ private function valueMatchesDefault(mixed $value, mixed $default): bool { if ($value === null || $default === null) { return $value === $default; } if (is_int($value) && MathUtility::canBeInterpretedAsInteger($default)) { return $value === (int)$default; } if (MathUtility::canBeInterpretedAsInteger($value) && is_int($default)) { return (int)$value === $default; } return $value === $default; } /** * Database relations flattened to 1-dimensional array. * The list will be unique, no table/uid combination will appear twice. * * @param array $relations 2-dimensional array of database relations organized by table key * @return array 1-dimensional array where entries are table:uid and keys are array with table/id */ protected function flatDbRelations(array $relations): array { $list = []; foreach ($relations as $relation) { if (isset($relation['type'])) { if ($relation['type'] === 'db') { foreach ($relation['itemArray'] as $dbRelationData) { $list[$dbRelationData['table'] . ':' . $dbRelationData['id']] = $dbRelationData; } } elseif ($relation['type'] === 'flex' && is_array($relation['flexFormRels']['db'] ?? null)) { foreach ($relation['flexFormRels']['db'] as $subList) { foreach ($subList as $dbRelationData) { $list[$dbRelationData['table'] . ':' . $dbRelationData['id']] = $dbRelationData; } } } } } return $list; } /** * Soft references flattened to 1-dimensional array. * * @param array $relations 2-dimensional array of database relations organized by table key * @return array 1-dimensional array where entries are arrays with properties of the soft link found and * keys are a unique combination of field, spKey, structure path if applicable and token ID */ protected function flatSoftRefs(array $relations): array { $list = []; foreach ($relations as $field => $relation) { foreach ($relation['softrefs']['keys'] ?? [] as $spKey => $elements) { foreach ($elements as $subKey => $el) { $lKey = $field . ':' . $spKey . ':' . $subKey; $list[$lKey] = array_merge(['field' => $field, 'spKey' => $spKey], $el); } } if (($relation['type'] ?? '') === 'flex' && is_array($relation['flexFormRels']['softrefs'] ?? null)) { foreach ($relation['flexFormRels']['softrefs'] as $structurePath => &$subList) { foreach ($subList['keys'] ?? [] as $spKey => $elements) { foreach ($elements as $subKey => $el) { $lKey = $field . ':' . $structurePath . ':' . $spKey . ':' . $subKey; $list[$lKey] = array_merge([ 'field' => $field, 'spKey' => $spKey, 'structurePath' => $structurePath, ], $el); } } } } } return $list; } /** * This analyzes the existing added records, finds all database relations to records and adds these records to the * export file. * This function can be called repeatedly until it returns zero added records. * In principle it should not allow to infinite recursion, but you better set a limit... * * @param int $relationLevel Recursion level * @return int number of records from relations found and added */ protected function exportAddRecordsFromRelations(int $relationLevel = 0): int { if (!isset($this->dat['records'])) { $this->addError('There were no records available.'); return 0; } $addRecords = []; foreach ($this->dat['records'] as $record) { if (!is_array($record)) { continue; } foreach ($record['rels'] ?? [] as $relation) { if (isset($relation['type'])) { if ($relation['type'] === 'db') { foreach ($relation['itemArray'] as $dbRelationData) { $this->exportAddRecordsFromRelationsPushRelation($dbRelationData, $addRecords); } } if ($relation['type'] === 'flex') { // Database relations in flex form fields: if (is_array($relation['flexFormRels']['db'] ?? null)) { foreach ($relation['flexFormRels']['db'] as $subList) { foreach ($subList as $dbRelationData) { $this->exportAddRecordsFromRelationsPushRelation($dbRelationData, $addRecords); } } } // Database oriented soft references in flex form fields: if (is_array($relation['flexFormRels']['softrefs'] ?? null)) { foreach ($relation['flexFormRels']['softrefs'] as $subList) { foreach ($subList['keys'] as $elements) { foreach ($elements as $el) { if ($el['subst']['type'] === 'db' && $this->isSoftRefIncluded($el['subst']['tokenID'])) { [$referencedTable, $referencedUid] = explode(':', $el['subst']['recordRef']); $dbRelationData = [ 'table' => $referencedTable, 'id' => $referencedUid, ]; $this->exportAddRecordsFromRelationsPushRelation($dbRelationData, $addRecords, $el['subst']['tokenID']); } } } } } } } // In any case, if there are soft refs: if (is_array($relation['softrefs']['keys'] ?? null)) { foreach ($relation['softrefs']['keys'] as $elements) { foreach ($elements as $el) { if (($el['subst']['type'] ?? '') === 'db' && $this->isSoftRefIncluded($el['subst']['tokenID'])) { [$referencedTable, $referencedUid] = explode(':', $el['subst']['recordRef']); $dbRelationData = [ 'table' => $referencedTable, 'id' => $referencedUid, ]; $this->exportAddRecordsFromRelationsPushRelation($dbRelationData, $addRecords, $el['subst']['tokenID']); } } } } } } if (!empty($addRecords)) { foreach ($addRecords as $recordData) { $record = BackendUtility::getRecord($recordData['table'], $recordData['id']); if (is_array($record)) { // Depending on db driver, int fields may or may not be returned as integer or as string. The // loop aligns that detail and forces strings for everything to have exports more db agnostic. foreach ($record as $fieldName => $fieldValue) { $record[$fieldName] = $fieldValue === null ? $fieldValue : (string)$fieldValue; } $this->exportAddRecord($recordData['table'], $record, $relationLevel + 1); } // Set status message // Relation pointers always larger than zero except certain "select" types with // negative values pointing to uids - but that is not supported here. if ($recordData['id'] > 0) { $recordRef = $recordData['table'] . ':' . $recordData['id']; if (!isset($this->dat['records'][$recordRef])) { $this->dat['records'][$recordRef] = 'NOT_FOUND'; $this->addError('Relation record ' . $recordRef . ' was not found!'); } } } } return count($addRecords); } /** * Helper function for exportAddRecordsFromRelations() * * @param array $recordData Record of relation with table/id key to add to $addRecords * @param array $addRecords Records of relations which are already marked as to be added to the export * @param string $tokenID Soft reference token ID, if applicable. */ protected function exportAddRecordsFromRelationsPushRelation(array $recordData, array &$addRecords, string $tokenID = ''): void { // @todo: Remove by-reference and return final array $recordRef = $recordData['table'] . ':' . $recordData['id']; if ( $this->tcaSchemaFactory->has($recordData['table']) && !$this->isTableStatic($recordData['table']) && !$this->isRecordExcluded($recordData['table'], (int)$recordData['id']) && (!$tokenID || $this->isSoftRefIncluded($tokenID)) && $this->inclRelation($recordData['table']) && !isset($this->dat['records'][$recordRef]) ) { $addRecords[$recordRef] = $recordData; } } /** * Returns TRUE if the input table name is to be included as relation * * @param string $table Table name * @return bool TRUE, if table is marked static */ protected function inclRelation(string $table): bool { return $this->tcaSchemaFactory->has($table) && (in_array($table, $this->relOnlyTables, true) || in_array('_ALL', $this->relOnlyTables, true)) && $this->getBackendUser()->check('tables_select', $table); } /** * This adds all files from sys_file records */ protected function exportAddFilesFromSysFilesRecords(): void { foreach ($this->dat['header']['records']['sys_file'] ?? [] as $sysFileUid => $_) { $this->exportAddSysFile($sysFileUid); } } /** * This adds the file from a sys_file record to the export * - either as content or external file */ protected function exportAddSysFile(int $sysFileUid): void { try { $file = $this->resourceFactory->getFileObject($sysFileUid); $file->checkActionPermission('read'); } catch (\Exception $e) { $this->addError('Error when trying to add file with UID ' . $sysFileUid . ': ' . $e->getMessage()); return; } $fileUid = $file->getUid(); $fileSha1 = $file->getStorage()->hashFile($file, 'sha1'); if ($fileSha1 !== $file->getProperty('sha1')) { $this->dat['records']['sys_file:' . $fileUid]['data']['sha1'] = $fileSha1; $this->addError( 'The SHA-1 file hash of ' . $file->getCombinedIdentifier() . ' is not up-to-date in the index! ' . 'The file was added based on the current file hash.' ); } // Build unique id based on the storage and the file identifier $fileId = md5($file->getStorage()->getUid() . ':' . $file->getProperty('identifier_hash')); $fileInfo = []; $fileInfo['filename'] = $file->getProperty('name'); $fileInfo['filemtime'] = $file->getProperty('modification_date'); // Setting this data in the header $this->dat['header']['files_fal'][$fileId] = $fileInfo; if (!$this->saveFilesOutsideExportFile) { $fileInfo['content'] = $file->getContents(); } else { GeneralUtility::upload_copy_move( $file->getForLocalProcessing(false), $this->getOrCreateTemporaryFolderName() . '/' . $fileSha1 ); } $fileInfo['content_sha1'] = $fileSha1; $this->dat['files_fal'][$fileId] = $fileInfo; } /** * Add site configurations whose root page is part of the export to the export header. */ protected function exportAddSiteConfigurations(): void { $exportedPageIds = array_map('intval', array_keys($this->dat['header']['records']['pages'] ?? [])); if ($exportedPageIds === []) { return; } $siteConfigurations = []; foreach ($this->siteConfiguration->resolveAllExistingSites(false) as $site) { if (in_array($site->getRootPageId(), $exportedPageIds, true)) { $siteConfigurations[$site->getIdentifier()] = $this->siteConfiguration->load($site->getIdentifier()); } } if ($siteConfigurations !== []) { $this->dat['header']['site_configurations'] = $siteConfigurations; } } /** * This compiles and returns the data content for an exported file * - "xml" gives xml * - "t3d" and "t3d_compressed" gives serialized array, possibly compressed * * @return string The output file stream */ public function render(): string { if ($this->exportFileType === self::FILETYPE_XML) { $out = $this->createXML(); } else { $out = ''; // adding header: $out .= $this->addFilePart(serialize($this->dat['header'])); // adding records: $out .= $this->addFilePart(serialize($this->dat['records'])); // adding files: $out .= $this->addFilePart(serialize($this->dat['files'] ?? null)); // adding files_fal: $out .= $this->addFilePart(serialize($this->dat['files_fal'] ?? null)); } return $out; } /** * Creates XML string from input array * * @return string XML content */ protected function createXML(): string { // Options: $options = [ 'alt_options' => [ '/header' => [ 'disableTypeAttrib' => true, 'clearStackPath' => true, 'parentTagMap' => [ 'files' => 'file', 'files_fal' => 'file', 'records' => 'table', 'table' => 'rec', 'rec:rels' => 'relations', 'relations' => 'element', 'filerefs' => 'file', 'pid_lookup' => 'page_contents', 'header:relStaticTables' => 'static_tables', 'static_tables' => 'tablename', 'excludeMap' => 'item', 'softrefCfg' => 'softrefExportMode', 'extensionDependencies' => 'extkey', 'softrefs' => 'softref_element', ], 'alt_options' => [ '/pagetree' => [ 'disableTypeAttrib' => true, 'useIndexTagForNum' => 'node', 'parentTagMap' => [ 'node:subrow' => 'node', ], ], '/pid_lookup/page_contents' => [ 'disableTypeAttrib' => true, 'parentTagMap' => [ 'page_contents' => 'table', ], 'grandParentTagMap' => [ 'page_contents/table' => 'item', ], ], ], ], '/records' => [ 'disableTypeAttrib' => true, 'parentTagMap' => [ 'records' => 'tablerow', 'tablerow:data' => 'fieldlist', 'tablerow:rels' => 'related', 'related' => 'field', 'field:itemArray' => 'relations', 'field:flexFormRels' => 'flexform', 'relations' => 'element', 'filerefs' => 'file', 'flexform:db' => 'db_relations', 'flexform:softrefs' => 'softref_relations', 'softref_relations' => 'structurePath', 'db_relations' => 'path', 'path' => 'element', 'keys' => 'softref_key', 'softref_key' => 'softref_element', ], 'alt_options' => [ '/records/tablerow/fieldlist' => [ 'useIndexTagForAssoc' => 'field', ], ], ], '/files' => [ 'disableTypeAttrib' => true, 'parentTagMap' => [ 'files' => 'file', ], ], '/files_fal' => [ 'disableTypeAttrib' => true, 'parentTagMap' => [ 'files_fal' => 'file', ], ], ], ]; // Creating XML file from $outputArray: $charset = $this->dat['header']['charset'] ?: 'utf-8'; $XML = '' . LF; $XML .= (new Typo3XmlSerializer())->encodeWithReturningExceptionAsString( $this->dat, new Typo3XmlParserOptions([Typo3XmlParserOptions::ROOT_NODE_NAME => 'T3RecordDocument']), $options ); // POSIX text-file convention: files end with a newline. return rtrim($XML, "\r\n") . LF; } /** * Returns a content part for a filename being build. * * @param string $data Data to store in part * @return string Content stream. */ protected function addFilePart(string $data): string { $compress = $this->exportFileType === self::FILETYPE_T3DZ; if ($compress) { $data = (string)gzcompress($data); } return md5($data) . ':' . ($compress ? '1' : '0') . ':' . str_pad((string)strlen($data), 10, '0', STR_PAD_LEFT) . ':' . $data . ':'; } public function saveToFile(): File { $saveFolder = $this->getOrCreateDefaultImportExportFolder(); $fileName = $this->getOrGenerateExportFileNameWithFileExtension(); $filesFolderName = $fileName . '.files'; $fileContent = $this->render(); if (!($saveFolder?->checkActionPermission('write'))) { throw new InsufficientFolderWritePermissionsException( 'You are not allowed to write to the target folder "' . $saveFolder->getPublicUrl() . '"', 1602432207 ); } if ($saveFolder->hasFolder($filesFolderName)) { $saveFolder->getSubfolder($filesFolderName)->delete(); } $temporaryFileName = GeneralUtility::tempnam('export'); GeneralUtility::writeFile($temporaryFileName, $fileContent, true); $this->skipResourceConsistencyCheckForCommands($saveFolder->getStorage(), $temporaryFileName, $fileName); $file = $saveFolder->addFile($temporaryFileName, $fileName, DuplicationBehavior::REPLACE); if ($this->saveFilesOutsideExportFile) { $filesFolder = $saveFolder->createFolder($filesFolderName); $temporaryFilesForExport = GeneralUtility::getFilesInDir($this->getOrCreateTemporaryFolderName(), '', true); foreach ($temporaryFilesForExport as $temporaryFileForExport) { $this->skipResourceConsistencyCheckForCommands($filesFolder->getStorage(), $temporaryFileForExport); $filesFolder->addFile($temporaryFileForExport); } $this->removeTemporaryFolderName(); } return $file; } public function getExportFileName(): string { return $this->exportFileName; } public function setExportFileName(string $exportFileName): void { $exportFileName = trim((string)preg_replace('/[^[:alnum:]._-]*/', '', $exportFileName)); $this->exportFileName = $exportFileName; } public function getOrGenerateExportFileNameWithFileExtension(): string { if (!empty($this->exportFileName)) { $exportFileName = $this->exportFileName; } else { $exportFileName = $this->generateExportFileName(); } $exportFileName .= $this->getFileExtensionByFileType(); return $exportFileName; } protected function generateExportFileName(): string { if ($this->pid !== -1) { $exportFileName = 'tree_PID' . $this->pid . '_L' . $this->levels; } elseif (!empty($this->getRecord())) { $exportFileName = 'recs_' . implode('-', $this->getRecord()); $exportFileName = str_replace(':', '_', $exportFileName); } elseif (!empty($this->getList())) { $exportFileName = 'list_' . implode('-', $this->getList()); $exportFileName = str_replace(':', '_', $exportFileName); } else { $exportFileName = 'export'; } $exportFileName = substr(trim((string)preg_replace('/[^[:alnum:]_-]/', '-', $exportFileName)), 0, 20); return 'T3D_' . $exportFileName . '_' . date('Y-m-d_H-i'); } public function getExportFileType(): string { return $this->exportFileType; } public function setExportFileType(string $exportFileType): void { $supportedFileTypes = $this->getSupportedFileTypes(); if (!in_array($exportFileType, $supportedFileTypes, true)) { throw new \InvalidArgumentException( sprintf( 'File type "%s" is not valid. Supported file types are %s.', $exportFileType, implode(', ', array_map(static function ($fileType) { return '"' . $fileType . '"'; }, $supportedFileTypes)) ), 1602505264 ); } $this->exportFileType = $exportFileType; } public function getSupportedFileTypes(): array { if (empty($this->supportedFileTypes)) { $supportedFileTypes = []; $supportedFileTypes[] = self::FILETYPE_XML; $supportedFileTypes[] = self::FILETYPE_T3D; if (function_exists('gzcompress')) { $supportedFileTypes[] = self::FILETYPE_T3DZ; } $this->supportedFileTypes = $supportedFileTypes; } return $this->supportedFileTypes; } protected function getFileExtensionByFileType(): string { return match ($this->exportFileType) { self::FILETYPE_XML => '.xml', self::FILETYPE_T3D => '.t3d', default => '-z.t3d', }; } public function getTitle(): string { return $this->title; } public function setTitle(string $title): void { $this->title = $title; } public function getDescription(): string { return $this->description; } public function setDescription(string $description): void { $this->description = $description; } public function setNotes(string $notes): void { $this->notes = $notes; } public function getRecord(): array { return $this->record; } public function setRecord(array $record): void { $this->record = $record; } public function getList(): array { return $this->list; } public function setList(array $list): void { $this->list = $list; } public function getLevels(): int { return $this->levels; } public function setLevels(int $levels): void { $this->levels = $levels; } public function setTables(array $tables): void { $this->tables = $tables; } public function setRelOnlyTables(array $relOnlyTables): void { $this->relOnlyTables = $relOnlyTables; } public function getTreeHTML(): string { return $this->treeHTML; } /** * Option to enable having the files not included in the export file. * The files are saved to a temporary folder instead. */ public function setSaveFilesOutsideExportFile(bool $saveFilesOutsideExportFile): void { $this->saveFilesOutsideExportFile = $saveFilesOutsideExportFile; } public function setIncludeSiteConfigurations(bool $includeSiteConfigurations): void { $this->includeSiteConfigurations = $includeSiteConfigurations; } }