feat(normalization): support enabling specific processors via manager constructor

Author: N3XT0R

src/Config/migration-generator.php

@@ -5,6 +5,13 @@
 use N3XT0R\MigrationGenerator\Service\Generator\Normalization\Processors\PivotProcessor;
 
 return [
+    'config' => [
+        'defaults' => [
+            'normalizer' => [
+                'enabled' => ['pivot'],
+            ],
+        ],
+    ],
     'definitions' => [
         'table' => [
             'class' => Definition\TableDefinition::class,

src/Providers/MigrationGeneratorServiceProvider.php

@@ -14,6 +14,8 @@
 use N3XT0R\MigrationGenerator\Service\Generator\Compiler\MigrationCompilerInterface;
 use N3XT0R\MigrationGenerator\Service\Generator\MigrationGenerator;
 use N3XT0R\MigrationGenerator\Service\Generator\MigrationGeneratorInterface;
+use N3XT0R\MigrationGenerator\Service\Generator\Normalization\SchemaNormalizationManager;
+use N3XT0R\MigrationGenerator\Service\Generator\Normalization\SchemaNormalizationManagerInterface;
 use N3XT0R\MigrationGenerator\Service\Generator\Resolver\DefinitionResolver;
 use N3XT0R\MigrationGenerator\Service\Generator\Resolver\DefinitionResolverInterface;
 use N3XT0R\MigrationGenerator\Service\Parser\SchemaParserFactory;
@@ -52,6 +54,7 @@ public function register(): void
         $this->registerCompilerEngine();
         $this->registerCompiler();
         $this->registerDefinitionResolver();
+        $this->registerNormalizer();
         $this->registerGenerator();
         $this->registerCommands();
     }
@@ -95,23 +98,15 @@ function (Application $app, array $params = []) {
         );
     }
 
-    protected function getDefinitions(): array
+    protected function getConfigSection(string $key): array
     {
-        return (array)app('config')->get('migration-generator.definitions');
-    }
-
-    protected function getMapper(): array
-    {
-        return (array)app('config')->get('migration-generator.mapper');
+        return (array)app('config')->get('migration-generator.' . $key);
     }
 
     protected function registerDefinitionResolver(): void
     {
-        $definitions = $this->getDefinitions();
-
-        foreach ($definitions as $definition) {
-            $this->app->bind($definition['class'], $definition['class']);
-        }
+        $definitions = $this->getConfigSection('definitions');
+        $this->bindClasses($definitions);
 
         $this->app->bind(
             DefinitionResolverInterface::class,
@@ -168,10 +163,6 @@ static function (Application $app, array $params) {
         );
     }
 
-    protected function registerNormalizer(): void
-    {
-    }
-
     protected function registerCompilerEngine(): void
     {
         $this->app->bind(ReplaceEngine::class, ReplaceEngine::class);
@@ -193,10 +184,8 @@ static function () use ($app) {
 
     protected function registerCompiler(): void
     {
-        $mapper = $this->getMapper();
-        foreach ($mapper as $map) {
-            $this->app->bind($map['class'], $map['class']);
-        }
+        $mapper = $this->getConfigSection('mapper');
+        $this->bindClasses($mapper);
 
         $this->app->bind(
             MigrationCompilerInterface::class,
@@ -214,4 +203,29 @@ static function (Application $app) use ($mapper) {
             }
         );
     }
+
+    protected function bindClasses(array $classes): void
+    {
+        foreach ($classes as $map) {
+            $this->app->bind($map['class'], $map['class']);
+        }
+    }
+
+
+    protected function registerNormalizer(): void
+    {
+        $normalizer = $this->getConfigSection('normalizer');
+        $this->bindClasses($normalizer);
+
+        $this->app->bind(
+            SchemaNormalizationManagerInterface::class,
+            static function (Application $app, array $params) use ($normalizer) {
+                $enabledProcessors = null;
+                if (array_key_exists('enabled', $params)) {
+                    $enabledProcessors = (array)$params['enabled'];
+                }
+                return new SchemaNormalizationManager($normalizer, $enabledProcessors);
+            }
+        );
+    }
 }

src/Service/Generator/Normalization/Processors/PivotProcessor.php

@@ -9,6 +9,12 @@
 
 class PivotProcessor implements ProcessorInterface
 {
+
+    public function getKey(): string
+    {
+        return 'pivot';
+    }
+
     public function process(NormalizationContext $context): ResultEntity
     {
         $result = $context->getCurrent();

src/Service/Generator/Normalization/Processors/ProcessorInterface.php

@@ -8,4 +8,6 @@
 interface ProcessorInterface
 {
     public function process(NormalizationContext $context): ResultEntity;
+
+    public function getKey(): string;
 }

src/Service/Generator/Normalization/SchemaNormalizationManager.php

@@ -5,6 +5,7 @@
 use N3XT0R\MigrationGenerator\Service\Generator\Definition\Entity\ResultEntity;
 use N3XT0R\MigrationGenerator\Service\Generator\Normalization\Context\NormalizationContext;
 use N3XT0R\MigrationGenerator\Service\Generator\Normalization\Processors\ProcessorInterface;
+use N3XT0R\MigrationGenerator\Service\Generator\Sort\TopSort;
 
 /**
  * Coordinates the execution of schema normalization processors.
@@ -22,10 +23,15 @@ class SchemaNormalizationManager implements SchemaNormalizationManagerInterface
      */
     protected array $processors = [];
 
+    /**
+     * @var string[]|null
+     */
+    protected ?array $enabledProcessors = null;
+
     /**
      * @param iterable<ProcessorInterface> $processors
      */
-    public function __construct(iterable $processors = [])
+    public function __construct(iterable $processors = [], ?array $enabledProcessors = null)
     {
         foreach ($processors as $processor) {
             $this->addProcessor($processor);
@@ -37,6 +43,12 @@ public function __construct(iterable $processors = [])
      */
     public function addProcessor(ProcessorInterface $processor): void
     {
+        if (is_array($this->getEnabledProcessors())) {
+            $key = $processor->getKey();
+            if (!in_array($key, $this->getEnabledProcessors(), true)) {
+                return;
+            }
+        }
         $this->processors[] = $processor;
     }
 
@@ -60,6 +72,16 @@ public function setProcessors(iterable $processors = []): void
         }
     }
 
+    public function getEnabledProcessors(): ?array
+    {
+        return $this->enabledProcessors;
+    }
+
+    public function setEnabledProcessors(?array $enabledProcessors): void
+    {
+        $this->enabledProcessors = $enabledProcessors;
+    }
+
     /**
      * Executes all processors on the given schema result using a shared context.
      *
@@ -70,8 +92,9 @@ public function normalize(ResultEntity $result): ResultEntity
     {
         $context = new NormalizationContext($result);
         $processors = $this->getProcessors();
+        $sortedProcessors = TopSort::sort($processors);
 
-        foreach ($processors as $processor) {
+        foreach ($sortedProcessors as $processor) {
             $updated = $processor->process($context);
             $context->update($updated);
         }