ImportCommand.php

Go to the documentation of this file.

<?php
 
declare(strict_types=1);
 
/*
 * This file is part of the TYPO3 CMS project.
 *
 * It is free software; you can redistribute it and/or modify it under
 * the terms of the GNU General Public License, either version 2
 * of the License, or any later version.
 *
 * For the full copyright and license information, please read the
 * LICENSE.txt file that was distributed with this source code.
 *
 * The TYPO3 project - inspiring people to share!
 */
 
namespace ‪TYPO3\CMS\Impexp\Command;
 
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Style\SymfonyStyle;
use ‪TYPO3\CMS\Core\Core\Bootstrap;
use ‪TYPO3\CMS\Core\Utility\GeneralUtility;
use ‪TYPO3\CMS\Impexp\Import;
 
class ‪ImportCommand extends Command
{
    public function ‪__construct(protected readonly ‪Import $import)
    {
        parent::__construct();
    }
 
    protected function ‪configure(): void
    {
        $this
            ->addArgument(
                'file',
                InputArgument::REQUIRED,
                'The file path to import from (.t3d or .xml).'
            )
            ->addArgument(
                'pid',
                InputArgument::OPTIONAL,
                'The page to import to.',
                0
            )
            ->addOption(
                'update-records',
                null,
                InputOption::VALUE_NONE,
                'If set, existing records with the same UID will be updated instead of inserted.'
            )
            ->addOption(
                'ignore-pid',
                null,
                InputOption::VALUE_NONE,
                'If set, page IDs of updated records are not corrected (only works in conjunction with --update-records).'
            )
            ->addOption(
                'force-uid',
                null,
                InputOption::VALUE_NONE,
                'If set, UIDs from file will be forced.'
            )
            ->addOption(
                'import-mode',
                null,
                InputOption::VALUE_OPTIONAL | InputOption::VALUE_IS_ARRAY,
                sprintf(
                    'Set the import mode of this specific record. ' . PHP_EOL .
                        'Pattern is "{table}:{record}={mode}". ' . PHP_EOL .
                        'Available modes for new records are "%1$s" and "%3$s" ' .
                        'and for existing records "%2$s", "%4$s", "%5$s" and "%3$s".' . PHP_EOL .
                        'Examples are "pages:987=%1$s", "tt_content:1=%2$s", etc.',
                    ‪Import::IMPORT_MODE_FORCE_UID,
                    ‪Import::IMPORT_MODE_AS_NEW,
                    ‪Import::IMPORT_MODE_EXCLUDE,
                    ‪Import::IMPORT_MODE_IGNORE_PID,
                    ‪Import::IMPORT_MODE_RESPECT_PID
                )
            )
            ->addOption(
                'enable-log',
                null,
                InputOption::VALUE_NONE,
                'If set, all database actions are logged.'
            )
        ;
    }
 
    protected function ‪execute(InputInterface $input, OutputInterface ‪$output): int
    {
        // Ensure the _cli_ user is authenticated
        ‪Bootstrap::initializeBackendAuthentication();
 
        $io = new SymfonyStyle($input, ‪$output);
 
        try {
            $this->import->setPid((int)$input->getArgument('pid'));
            $this->import->setUpdate($input->getOption('update-records'));
            $this->import->setGlobalIgnorePid($input->getOption('ignore-pid'));
            $this->import->setForceAllUids($input->getOption('force-uid'));
            $this->import->setEnableLogging($input->getOption('enable-log'));
            $this->import->setImportMode($this->‪parseAssociativeArray($input, 'import-mode', '='));
            $this->import->loadFile((string)$input->getArgument('file'), true);
            $this->import->checkImportPrerequisites();
            $this->import->importData();
            $io->success('Importing ' . $input->getArgument('file') . ' to page ' . $input->getArgument('pid') . ' succeeded.');
            return Command::SUCCESS;
        } catch (\‪Exception $e) {
            // Since impexp triggers core and DataHandler with potential hooks, and exception could come from "everywhere".
            $io->error('Importing ' . $input->getArgument('file') . ' to page ' . $input->getArgument('pid') . ' failed.');
            if ($io->isVerbose()) {
                $io->writeln($e->getMessage());
                $io->writeln($this->import->getErrorLog());
            }
            return Command::FAILURE;
        }
    }
 
    protected function ‪parseAssociativeArray(InputInterface &$input, string $optionName, string $separator): array
    {
        $array = [];
 
        foreach ($input->getOption($optionName) as &$value) {
            $parts = GeneralUtility::trimExplode($separator, $value, true, 2);
            if (count($parts) === 2) {
                $array[$parts[0]] = $parts[1];
            } else {
                throw new \InvalidArgumentException(
                    sprintf('Command line option "%s" has invalid entry "%s".', $optionName, $value),
                    1610464090
                );
            }
        }
 
        return $array;
    }
}