vendor/crea/process-bundle/src/Provider/ProcessStepProvider.php line 23

Open in your IDE?
  1. <?php
  3. namespace Crea\ProcessBundle\Provider;
  5. use Crea\ProcessBundle\Model\AbstractProcessStep;
  6. use Crea\ProcessBundle\Model\ProcessStepInterface;
  7. use Crea\ProcessBundle\ProcessConfiguration\ProcessConfigurationSpecificValuesTrait;
  8. use RuntimeException;
  10. class ProcessStepProvider implements ProcessStepProviderInterface
  11. {
  12.     use ProcessConfigurationSpecificValuesTrait;
  14.     /** @var ProcessStepInterface[] */
  15.     private array $processStepServices;
  17.     /** @var ProcessStepInterface[] */
  18.     private array $processSteps = [];
  20.     public function __construct(iterable $processSteps,
  21.                                 iterable $processConfigurationSpecificProviders)
  22.     {
  23.         $this->processStepServices = $processSteps instanceof \Traversable ? iterator_to_array($processSteps) : $processSteps;
  24.         $this->processConfigurationSpecificProviders = $processConfigurationSpecificProviders instanceof \Traversable ? iterator_to_array($processConfigurationSpecificProviders) : $processConfigurationSpecificProviders;
  25.     }
  27.     public function getStep(string $index, string $processType, string $specificValue): ?ProcessStepInterface
  28.     {
  29.         $this->buildProcessSteps($this->processStepServices);
  31.         if (array_key_exists($index, $this->processSteps)) {
  32.             //process type and specific value are defined
  33.             foreach ($this->processSteps[$index] as $processStep) {
  34.                 if ($processType === $processStep->getProcessType() && $specificValue === $processStep->getSpecificValue()) {
  35.                     return $processStep;
  36.                 }
  37.             }
  39.             //only process type is defined
  40.             foreach ($this->processSteps[$index] as $processStep) {
  41.                 if ($processType === $processStep->getProcessType() && null === $processStep->getSpecificValue()) {
  42.                     return $processStep;
  43.                 }
  44.             }
  46.             //only specific value is defined
  47.             foreach ($this->processSteps[$index] as $processStep) {
  48.                 if (null === $processStep->getProcessType() && $specificValue === $processStep->getSpecificValue()) {
  49.                     return $processStep;
  50.                 }
  51.             }
  53.             //process type and specific value are not defined
  54.             foreach ($this->processSteps[$index] as $processStep) {
  55.                 if (null === $processStep->getProcessType() && null === $processStep->getSpecificValue()) {
  56.                     return $processStep;
  57.                 }
  58.             }
  59.         }
  61.         return null;
  62.     }
  64.     public function getSteps(string $processType, string $specificValue): array
  65.     {
  66.         $this->buildProcessSteps($this->processStepServices);
  68.         $steps = [];
  70.         foreach ($this->processSteps as $index => $processSteps) {
  71.             //process type and specific value are defined
  72.             foreach ($processSteps as $processStep) {
  73.                 if ($processType === $processStep->getProcessType() && $specificValue === $processStep->getSpecificValue()) {
  74.                     $steps[$index] = $processStep;
  75.                     break;
  76.                 }
  77.             }
  79.             //only process type is defined
  80.             foreach ($processSteps as $processStep) {
  81.                 if ($processType === $processStep->getProcessType() && null === $processStep->getSpecificValue()) {
  82.                     $steps[$index] = $processStep;
  83.                     break;
  84.                 }
  85.             }
  87.             //only specific value is defined
  88.             foreach ($processSteps as $processStep) {
  89.                 if (null === $processStep->getProcessType() && $specificValue === $processStep->getSpecificValue()) {
  90.                     $steps[$index] = $processStep;
  91.                     break;
  92.                 }
  93.             }
  95.             //process type and specific value are not defined
  96.             foreach ($processSteps as $processStep) {
  97.                 if (null === $processStep->getProcessType() && null === $processStep->getSpecificValue()) {
  98.                     $steps[$index] = $processStep;
  99.                     break;
  100.                 }
  101.             }
  102.         }
  104.         return $steps;
  105.     }
  107.     public function getStepsIndexes(): array
  108.     {
  109.         $this->buildProcessSteps($this->processStepServices);
  111.         $processStepsIndexes = [];
  112.         foreach ($this->processSteps as $index => $processStep) {
  113.             if (!in_array($index, $processStepsIndexes)) {
  114.                 $processStepsIndexes[] = $index;
  115.             }
  116.         }
  117.         return $processStepsIndexes;
  118.     }
  120.     private function buildProcessSteps(array $processSteps): void
  121.     {
  122.         if (count($this->processSteps) === 0) {
  123.             //hydrate with AbstractProcessStep class
  124.             foreach ($processSteps as $processStep) {
  125.                 if (!$processStep instanceof AbstractProcessStep) {
  126.                     throw new RuntimeException(get_Class($processStep).' must implement abstract class "AbstractProcessStep"');
  127.                 }
  128.                 if (!array_key_exists($processStep->getIndex(), $this->processSteps)) {
  129.                     $this->processSteps[$processStep->getIndex()] = [];
  130.                 }
  131.                 $this->processSteps[$processStep->getIndex()][] = $processStep;
  132.             }
  134.             //check
  135.             $combinations = [];
  136.             $specificValues = $this->getProcessConfigurationSpecificValues();
  137.             foreach ($this->processSteps as $processSteps) {
  138.                 foreach ($processSteps as $processStep) {
  139.                     //check specific values in process steps
  140.                     if ($processStep->getSpecificValue() !== null && !in_array($processStep->getSpecificValue(), $specificValues)) {
  141.                         throw new RuntimeException('Specific value "'.$processStep->getSpecificValue().'" does not exist in step class "'.get_class($processStep).'". Available values are : '.implode(", ", $specificValues).'.');
  142.                     }
  144.                     //check duplicate combination of index, process type and specific value
  145.                     $combination = $processStep->getIndex()."-".($processStep->getProcessType() !== null ? $processStep->getProcessType() : "")."-".($processStep->getSpecificValue() !== null ? $processStep->getSpecificValue() : "");
  146.                     if (!in_array($combination, $combinations)) {
  147.                         $combinations[] = $combination;
  148.                     }
  149.                     else {
  150.                         throw new RuntimeException('Duplicate combination of index "'.$processStep->getIndex().'", process type "'.$processStep->getProcessType().'" and specific value "'.$processStep->getSpecificValue().'" in step class.');
  151.                     }
  152.                 }
  153.             }
  154.         }
  155.     }
  156. }