<?php

namespace App\Validator;

use App\Service\WorkflowService;
use Symfony\Component\Workflow\Definition;
use Symfony\Component\Workflow\Exception\InvalidDefinitionException;
use Symfony\Component\Workflow\Validator\DefinitionValidatorInterface;

class WorkflowValidator implements DefinitionValidatorInterface
{
    private const VALID_PLACE_TYPES = [
        'Information',
        'UserChoice',
        'Print',
        'Modification',
        'ChooseRepair',
        'DoneRepair',
        'ReasonAndPhoto',
        'Photo',
        'ProductInformation',
        'Conditional',
        'Final',
    ];

    public function validate(Definition $definition, string $name): void
    {
        $metadataStore = $definition->getMetadataStore();
        foreach ($definition->getPlaces() as $place) {
            $transitions = $this->getForwardTransitionsByPlace($definition, $place);
            $placeMetadata = $metadataStore->getPlaceMetadata($place);

            if (! key_exists('type', $placeMetadata)) {
                throw new InvalidDefinitionException(sprintf('[%s] place "%s" has no type - %s', $name, $place, json_encode($placeMetadata)));
            }

            if (! \in_array($placeMetadata['type'], self::VALID_PLACE_TYPES, true)) {
                throw new InvalidDefinitionException(sprintf('[%s] place "%s" has a unknow type "%s"', $name, $place, $placeMetadata['type']));
            }

            switch ($placeMetadata['type']) {
                case 'Information':
                case 'Modification':
                case 'ChooseRepair':
                case 'ReasonAndPhoto':
                case 'Photo':
                case 'Print':
                    if (\count($transitions) !== 1) {
                        throw new InvalidDefinitionException(sprintf('workflow: "%s" place "%s" of type "%s" should have one outgoing transitions. found: "%s"', $name, $place, $placeMetadata['type'], $this->display($transitions)));
                    }
                    break;
                case 'UserChoice':
                    if (\count($transitions) === 0) {
                        throw new InvalidDefinitionException(sprintf('workflow: "%s" place "%s" of type "%s" should have at least one outgoing transition.', $name, $place, $placeMetadata['type']));
                    }
                    foreach ($transitions as $transition) {
                        $transitionMeta = $metadataStore->getTransitionMetadata($transition);
                        if (! \array_key_exists('text', $transitionMeta)) {
                            throw new InvalidDefinitionException(sprintf('workflow: "%s" transition "%s" should have a text', $name, $transition->getName()));
                        }
                        if (! \array_key_exists('type', $transitionMeta)) {
                            throw new InvalidDefinitionException(sprintf('workflow: "%s" transition "%s" should have a type', $name, $transition->getName()));
                        }
                    }
                    break;
                case 'Conditional':
                    if (\count($transitions) === 0) {
                        throw new InvalidDefinitionException(sprintf('workflow: "%s" place "%s" of type "%s" should have at least one outgoing transition.', $name, $place, $placeMetadata['type']));
                    }
                    break;
            }
        }
    }

    private function getForwardTransitionsByPlace(Definition $definition, string $place): array
    {
        return array_filter($definition->getTransitions(), function ($transition) use ($place) {
            return \in_array($place, $transition->getFroms(), true) && $transition->getName() !== WorkflowService::CANCEL_TRANSITION;
        });
    }

    private function display(array $transitions): string
    {
        return implode(',', array_map(function ($transition) {
            return $transition->getName();
        }, $transitions));
    }
}

class Kernel extends BaseKernel implements CompilerPassInterface
{
    use MicroKernelTrait;

    public function process(ContainerBuilder $container): void
    {
        // Validate all workflows
        foreach ($container->findTaggedServiceIds('workflow') as $id => $_) {
            $workflowDefinition = $container->getDefinition($id);

            $definitionArgument = $workflowDefinition->getArgument(0);
            if (! $definitionArgument instanceof Reference) {
                throw new RuntimeException('The first argument of the workflow service must be a reference.');
            }

            // warning: usually, one should not use the container to get a
            // service during the compilation phase But i'm an engineer, i know
            // what i'm doing
            $definition = $container->get((string) $definitionArgument);
            $name = $workflowDefinition->getArgument(3);

            (new WorkflowValidator())->validate($definition, $name);
        }
    }
}