TechDivision\Import\Cli\Command\AbstractImportCommand::execute()

Complexity

Conditions	5
Paths	9

Size

Total Lines	84
Code Lines	43

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	30

Importance

Changes	2
Bugs	0	Features	0

<?php
    protected function execute(InputInterface $input, OutputInterface $output)
    {

        // initialize the flag, whether the JMS annotations has been loaded or not
        $loaded = false;

        // the possible paths to the JMS annotations
        $annotationDirectories = array(
            dirname(__DIR__) . '/../../../jms/serializer/src',
            dirname(__DIR__) . '/../vendor/jms/serializer/src'
        );

        // register the JMS Serializer annotations
        foreach ($annotationDirectories as $annotationDirectory) {
            if (file_exists($annotationDirectory)) {
                \Doctrine\Common\Annotations\AnnotationRegistry::registerAutoloadNamespace(
                    'JMS\Serializer\Annotation',
                    $annotationDirectory
                );
                $loaded = true;
                break;
            }
        }

        // stop processing, if the JMS annotations can't be loaded
        if (!$loaded) {
            throw new \Exception(
                sprintf(
                    'The JMS annotations can not be found in one of paths %s',
                    implode(', ', $annotationDirectories)
                )
            );
        }

        // load the specified configuration
        $configuration = $this->configurationFactory($input);

        // initialize the PDO connection
        $dsn = $configuration->getDatabase()->getDsn();
        $username = $configuration->getDatabase()->getUsername();
        $password = $configuration->getDatabase()->getPassword();
        $connection = new \PDO($dsn, $username, $password);
        $connection->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);

        // initialize the system logger
        $loggers = array();

        // initialize the default system logger
        $systemLogger = new Logger('techdivision/import');
        $systemLogger->pushHandler(
            new ErrorLogHandler(
                ErrorLogHandler::OPERATING_SYSTEM,
                $configuration->getLogLevel()
            )
        );

        // add it to the array
        $loggers[LoggerKeys::SYSTEM] = $systemLogger;

        // append the configured loggers or override the default one
        foreach ($configuration->getLoggers() as $loggerConfiguration) {
            // load the factory class that creates the logger instance
            $loggerFactory = $loggerConfiguration->getFactory();
            // create the logger instance and add it to the available loggers
            $loggers[$loggerConfiguration->getName()] = $loggerFactory::factory($loggerConfiguration);
        }

        // initialize the registry/import processor
        $registryProcessor = RegistryProcessorFactory::factory($connection, $configuration);
        $importProcessor = ImportProcessorFactory::factory($connection, $configuration);

        // initialize the importer
        $importer = new Simple(
            $registryProcessor,
            $importProcessor,
            $configuration,
            $input,
            $output,
            $loggers
        );

        // start the process
        $importer->process();
    }
}