Yiisoft\Yii\Cycle\Helper\CycleOrmHelper

Complexity

Total Complexity

7

Size/Duplication

Total Lines	60
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	4
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	dropCurrentSchemaCache()	0	3	1
A	generateMigrations()	0	13	2
A	getCurrentSchemaArray()	0	16	3
A	__construct()	0	8	1

<?php

namespace Yiisoft\Yii\Cycle\Helper;

use Cycle\Migrations\GenerateMigrations;
use Cycle\Schema\Compiler;
use Cycle\Schema\Generator;
use Cycle\Schema\Registry;
use Spiral\Database\DatabaseManager;
use Spiral\Migrations\Config\MigrationConfig;
use Spiral\Migrations\Migrator;
use Psr\SimpleCache\CacheInterface;

The type Psr\SimpleCache\CacheInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use Yiisoft\Yii\Cycle\SchemaConveyorInterface;

class CycleOrmHelper
{
    /** @var DatabaseManager $dbal */
    private $dbal;

    /** @var CacheInterface */
    private $cache;

    /** @var string */
    private $cacheKey = 'Cycle-ORM-Schema';

    /** @var SchemaConveyorInterface */
    private $schemaConveyor;

    public function __construct(
        DatabaseManager $dbal,
        CacheInterface $cache,
        SchemaConveyorInterface $schemaConveyor
    ) {
        $this->dbal = $dbal;
        $this->cache = $cache;
        $this->schemaConveyor = $schemaConveyor;
    }

    public function dropCurrentSchemaCache(): void
    {
        $this->cache->delete($this->cacheKey);
    }

    public function generateMigrations(Migrator $migrator, MigrationConfig $config, array $generators = []): void
    {
        // add migrations generator
        $migrate = new GenerateMigrations($migrator->getRepository(), $config);
        $this->schemaConveyor->addGenerator($this->schemaConveyor::STAGE_USERLAND, $migrate);
        // add custom generators
        foreach ($generators as $generator) {
            $this->schemaConveyor->addGenerator($this->schemaConveyor::STAGE_USERLAND, $generator);
        }

        $conveyor = $this->schemaConveyor->getGenerators();

        (new Compiler())->compile(new Registry($this->dbal), $conveyor);
    }

    public function getCurrentSchemaArray($fromCache = true): array
    {
        if ($fromCache) {
            $schema = $this->cache->get($this->cacheKey);
            if (is_array($schema)) {
                return $schema;
            }
        }
        // sync table changes to database
        $this->schemaConveyor->addGenerator($this->schemaConveyor::STAGE_RENDER, Generator\SyncTables::class);
        // compile schema array
        $conveyor = $this->schemaConveyor->getGenerators();
        $schema = (new Compiler())->compile(new Registry($this->dbal), $conveyor);

        $this->cache->set($this->cacheKey, $schema);
        return $schema;
    }
}