Zicht\Bundle\UrlBundle\Command\ImportUrlAliasesCommand::execute()

Complexity

Conditions	11
Paths	14

Size

Total Lines	64
Code Lines	38

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $defaultRedirectType = self::REDIRECT_TYPE_MAPPING[$input->getOption('default-redirect-type')];
        $defaultConflictingPublicUrlStrategy = self::DEFAULT_CONFLICTING_PUBLIC_URL_STRATEGY_MAPPING[$input->getOption('default-conflicting-public-url-strategy')];
        $defaultConflictingInternalUrlStrategy = self::DEFAULT_CONFLICTING_INTERNAL_URL_STRATEGY_MAPPING[$input->getOption('default-conflicting-internal-url-strategy')];
        $csvDelimiter = $input->getOption('csv-delimiter');
        $csvEnclosure = $input->getOption('csv-enclosure');

        $aliasingService = $this->getContainer()->get('zicht_url.aliasing');
        $flush = $aliasingService->setIsBatch(true);

        $handle = fopen($input->getArgument('file'), 'r');
        if (false === $handle) {
            throw new \Exception('Can not open input file');
        }

        $lineNumber = 0;

        if ($input->getOption('skip-header')) {
            $lineNumber++;
            $data = fgetcsv($handle, null, $csvDelimiter, $csvEnclosure);
            if (false === $data) {
                throw new \Exception(sprintf('Can not read line %s in input file', $lineNumber));
            }
        }

        while ($data = fgetcsv($handle, null, $csvDelimiter, $csvEnclosure)) {
            $lineNumber++;

            if (false === $data) {
                throw new \Exception(sprintf('Can not read line %s in input file', $lineNumber));
            }

            if (null === $data || [null] === $data) {
                // skip empty line
                continue;
            }

            if (sizeof($data) < 2) {
                throw new \Exception('Every line in the file must have at least the publicUrl and internalUrl');
            }

            $publicUrl = trim($data[0]);
            $internalUrl = trim($data[1]);
            $type = $this->parseInputToMapping(self::REDIRECT_TYPE_MAPPING, $data, 2, $defaultRedirectType);
            $conflictingPublicUrlStrategy = $this->parseInputToMapping(self::DEFAULT_CONFLICTING_PUBLIC_URL_STRATEGY_MAPPING, $data, 3, $defaultConflictingPublicUrlStrategy);
            $conflictingInternalUrlStrategy = $this->parseInputToMapping(self::DEFAULT_CONFLICTING_INTERNAL_URL_STRATEGY_MAPPING, $data, 3, $defaultConflictingInternalUrlStrategy);

            $realInternalUrl = $aliasingService->hasInternalAlias($internalUrl);
            if (null !== $realInternalUrl && $internalUrl !== $realInternalUrl) {
                // the $internalUrl given in the csv is actually known as a public url in our system.
                // the $publicUrl given in the csv should redirect directly to this known public url.
                $redirectDescription = sprintf('%s -> %s -> %s', $publicUrl, $internalUrl, $realInternalUrl);
                $internalUrl = $realInternalUrl;
            } else {
                $redirectDescription = sprintf('%s -> %s', $publicUrl, $internalUrl);
            }

            // perform aliasing
            $aliasingService->addAlias($publicUrl, $internalUrl, $type, $conflictingPublicUrlStrategy, $conflictingInternalUrlStrategy);
            $output->writeln(sprintf('%s  %s  %s', $lineNumber, $type, $redirectDescription));
        }

        $flush();
    }