PSFS\services\GeneratorService::createModuleMigrations()

Complexity

Conditions	19
Paths	1277

Size

Total Lines	122
Code Lines	76

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	380

Importance

Changes

0

<?php
    private function createModuleMigrations($module, $path)
    {
        $migrationService = MigrationService::getInstance();
        list($manager, $generatorConfig) = $migrationService->getConnectionManager($module, $path);

        if ($manager->hasPendingMigrations()) {
            throw new ApiException(t(sprintf('Módulo %s generado correctamente. Hay una migración pendiente de aplicar, ejecute comando `psfs:migrate` o elimine el fichero generado en el módulo', $module)), 400);
        }

        $totalNbTables = 0;
        $reversedSchema = new Schema();
        $debugLogger = Config::getParam('log.level') === 'DEBUG';

        foreach ($manager->getDatabases() as $appDatabase) {
            $name = $appDatabase->getName();
            $params = $connections[$name] ?? [];

The variable $connections seems to never exist and therefore isset should always be false.

            if (!$params) {
                Logger::log(sprintf('<info>No connection configured for database "%s"</info>', $name));
            }

            if ($debugLogger) {
                Logger::log(sprintf('Connecting to database "%s" using DSN "%s"', $name, $params['dsn']));
            }

            $conn = $manager->getAdapterConnection($name);
            $platform = $generatorConfig->getConfiguredPlatform($conn, $name);

            $appDatabase->setPlatform($platform);

            if ($platform && !$platform->supportsMigrations()) {
                Logger::log(sprintf('Skipping database "%s" since vendor "%s" does not support migrations', $name, $platform->getDatabaseType()));
                continue;
            }

            $additionalTables = [];
            foreach ($appDatabase->getTables() as $table) {
                if ($table->getSchema() && $table->getSchema() != $appDatabase->getSchema()) {
                    $additionalTables[] = $table;
                }
            }

            $database = new Database($name);
            $database->setPlatform($platform);
            $database->setSchema($appDatabase->getSchema());
            $database->setDefaultIdMethod(IdMethod::NATIVE);

            $parser = $generatorConfig->getConfiguredSchemaParser($conn, $name);
            $nbTables = $parser->parse($database, $additionalTables);

            $reversedSchema->addDatabase($database);
            $totalNbTables += $nbTables;

            if ($debugLogger) {
                Logger::log(sprintf('%d tables found in database "%s"', $nbTables, $name), Output::VERBOSITY_VERBOSE);
            }
        }

        if ($totalNbTables) {
            Logger::log(sprintf('%d tables found in all databases.', $totalNbTables));
        } else {
            Logger::log('No table found in all databases');
        }

        // comparing models
        Logger::log('Comparing models...');
        $migrationsUp = [];
        $migrationsDown = [];
        $configManager = new ConfigurationManager($generatorConfig->getSection('paths')['phpConfDir']);
        $excludedTables = (array)$configManager->getSection('exclude_tables');

        foreach ($reversedSchema->getDatabases() as $database) {
            $name = $database->getName();

            if ($debugLogger) {
                Logger::log(sprintf('Comparing database "%s"', $name));
            }

            $appDataDatabase = $manager->getDatabase($name);
            if (!$appDataDatabase) {
                Logger::log(sprintf('<error>Database "%s" does not exist in schema.xml. Skipped.</error>', $name));
                continue;
            }

            $databaseDiff = DatabaseComparator::computeDiff($database, $appDataDatabase, true, false, false, $excludedTables);

            if (!$databaseDiff) {
                if ($debugLogger) {
                    Logger::log(sprintf('Same XML and database structures for datasource "%s" - no diff to generate', $name));
                }
                continue;
            }

            Logger::log(sprintf('Structure of database was modified in datasource "%s": %s', $name, $databaseDiff->getDescription()));

            foreach ($databaseDiff->getPossibleRenamedTables() as $fromTableName => $toTableName) {
                Logger::log(sprintf(
                    '<info>Possible table renaming detected: "%s" to "%s". It will be deleted and recreated. Use --table-renaming to only rename it.</info>',
                    $fromTableName,
                    $toTableName,
                ));
            }

            $conn = $manager->getAdapterConnection($name);
            /** @var \Propel\Generator\Platform\DefaultPlatform $platform */
            $platform = $generatorConfig->getConfiguredPlatform($conn, $name);
            $migrationsUp[$name] = $platform->getModifyDatabaseDDL($databaseDiff);
            $migrationsDown[$name] = $platform->getModifyDatabaseDDL($databaseDiff->getReverseDiff());
        }
        if (!$migrationsUp) {
            Logger::log('Same XML and database structures for all datasource - no diff to generate');
            return true;
        }

        $timestamp = time();
        $migrationFileName = $manager->getMigrationFileName($timestamp);
        $migrationClassBody = $manager->getMigrationClassBody($migrationsUp, $migrationsDown, $timestamp);

        $file = $generatorConfig->getSection('paths')['migrationDir'] . DIRECTORY_SEPARATOR . $migrationFileName;
        file_put_contents($file, $migrationClassBody);

        Logger::log(sprintf('"%s" file successfully created.', $file));
        return true;
    }