midgard_storage

Complexity

Total Complexity

21

Size/Duplication

Total Lines	144
Duplicated Lines	0 %

Test Coverage

Coverage

90.7%

Importance

Changes	4
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	get_cm()	0	19	4
A	create_class_storage()	0	17	3
A	generate_proxyfile()	0	10	2
A	create_base_storage()	0	40	5
A	class_storage_exists()	0	7	2
A	update_class_storage()	0	31	5

<?php
/**
 * @author CONTENT CONTROL http://www.contentcontrol-berlin.de/
 * @copyright CONTENT CONTROL http://www.contentcontrol-berlin.de/
 * @license http://www.gnu.org/licenses/gpl.html GNU General Public License
 */

use Doctrine\Persistence\Mapping\ClassMetadata;
use Doctrine\Common\Proxy\ProxyGenerator;
use Doctrine\DBAL\Schema\Comparator;
use Doctrine\ORM\Tools\SchemaTool;
use Doctrine\ORM\Mapping\MappingException;
use midgard\portable\storage\connection;
use Doctrine\ORM\EntityManager;

class midgard_storage
{
    public static function create_base_storage() : bool
    {
        $em = connection::get_em();
        $ns = $em->getConfiguration()->getEntityNamespace("midgard");

        $cm_repligard = $em->getClassMetadata($ns . '\\midgard_repligard');
        if (!self::create_class_storage($cm_repligard->getName())) {
            return false;
        }
        $cm_person = $em->getClassMetadata($ns . '\\midgard_person');
        if (!self::create_class_storage($cm_person->getName())) {
            return false;
        }
        $cm_user = $em->getClassMetadata($ns . '\\midgard_user');
        if (!self::create_class_storage($cm_user->getName())) {
            return false;
        }

        $admin = $em->find('midgard:midgard_user', 1);

        if ($admin === null) {
            $fqcn = $cm_person->getName();
            $person = new $fqcn;
            $person->firstname = 'Midgard';
            $person->lastname = 'Administrator';
            $person->create();

            $fqcn = $cm_user->getName();
            $admin = new $fqcn;
            $admin->authtype = 'Legacy';
            $admin->authtypeid = 2;
            $admin->login = 'admin';
            $admin->password = password_hash('password', PASSWORD_DEFAULT);
            $admin->active = true;
            $admin->usertype = 2;
            $admin->set_person($person);
            $admin->create();
        }

        return true;
    }

    public static function create_class_storage(string $classname) : bool
    {
        $em = connection::get_em();

        $cm = self::get_cm($em, $classname);
        if ($cm === null) {
            return false;
        }

        if (!$em->getConnection()->getSchemaManager()->tablesExist([$cm->getTableName()])) {
            $tool = new SchemaTool($em);
            $tool->createSchema([$cm]);
        }

        self::generate_proxyfile($cm);

        return true;
    }

    private static function generate_proxyfile(ClassMetadata $cm)
    {
        $em = connection::get_em();
        $generator = new ProxyGenerator($em->getConfiguration()->getProxyDir(), $em->getConfiguration()->getProxyNamespace());

The function Doctrine\ORM\Configuration::getProxyDir() has been deprecated: 2.7 We're switch to `ocramius/proxy-manager` and this method isn't applicable any longer

The function Doctrine\ORM\Configuration::getProxyNamespace() has been deprecated: 2.7 We're switch to `ocramius/proxy-manager` and this method isn't applicable any longer

        $generator->setPlaceholder('baseProxyInterface', 'Doctrine\ORM\Proxy\Proxy');
        $filename = $generator->getProxyFileName($cm->getName());
        if (file_exists($filename)) {
            unlink($filename);
        }
        $generator->generateProxyClass($cm, $filename);
    }

    private static function get_cm(EntityManager $em, string $classname) : ?\Doctrine\ORM\Mapping\ClassMetadata
    {
        if (!class_exists($classname)) {
            // if the class doesn't exist (e.g. for some_random_string), there is really nothing we could do
            return null;
        }

        $factory = $em->getMetadataFactory();
        try {
            return $factory->getMetadataFor($classname);
        } catch (MappingException $e) {
            // add namespace
            $classname = $em->getConfiguration()->getEntityNamespace("midgard") . '\\' . $classname;
            try {
                return $factory->getMetadataFor($classname);
            } catch (MappingException $e) {
                // check for merged classes (duplicate tablenames)
                $classname = get_class(new $classname);
                return $factory->getMetadataFor($classname);
            }
        }
    }

    /**
     * Update DB table according to MgdSchema information.
     *
     * this does not use SchemaTool's updateSchema, since this would delete columns that are no longer
     * in the MgdSchema definition
     */
    public static function update_class_storage(string $classname) : bool
    {
        $em = connection::get_em();
        $cm = self::get_cm($em, $classname);
        if ($cm === null) {
            return false;
        }
        $sm = $em->getConnection()->getSchemaManager();
        if ($sm->tablesExist([$cm->getTableName()])) {
            $tool = new SchemaTool($em);
            $conn = $em->getConnection();
            $from = $sm->createSchema();
            $to = $tool->getSchemaFromMetadata([$cm]);

            $comparator = new Comparator;
            $diff = $comparator->compare($from, $to);
            if (!empty($diff->changedTables[$cm->getTableName()]->removedColumns)) {
                $diff->changedTables[$cm->getTableName()]->removedColumns = [];
            }
            $sql = $diff->toSaveSql($conn->getDatabasePlatform());


            foreach ($sql as $sql_line) {
                $conn->executeQuery($sql_line);
            }

            self::generate_proxyfile($cm);

            return true;
        }
        return false;
    }

    public static function class_storage_exists(string $classname) : bool
    {
        $em = connection::get_em();
        if ($cm = self::get_cm($em, $classname)) {
            return $em->getConnection()->getSchemaManager()->tablesExist([$cm->getTableName()]);
        }
        return false;
    }
}