vendor/league/tactician-bundle/src/DependencyInjection/Compiler/BusBuilder/BusBuilders.php line 11

Open in your IDE?
  1. <?php
  2. declare(strict_types=1);
  4. namespace League\Tactician\Bundle\DependencyInjection\Compiler\BusBuilder;
  6. use League\Tactician\Bundle\DependencyInjection\DuplicatedCommandBusId;
  7. use League\Tactician\Bundle\DependencyInjection\HandlerMapping\Routing;
  8. use League\Tactician\Bundle\DependencyInjection\InvalidCommandBusId;
  9. use ArrayIterator;
  11. final class BusBuilders implements \IteratorAggregate
  12. {
  13.     /**
  14.      * @var BusBuilder[]
  15.      */
  16.     private $busBuilders = [];
  18.     /**
  19.      * @var string
  20.      */
  21.     private $defaultBusId;
  23.     public function __construct(array $busBuilders, string $defaultBusId)
  24.     {
  25.         foreach ($busBuilders as $builder) {
  26.             $this->add($builder);
  27.         }
  29.         $this->assertValidBusId($defaultBusId);
  30.         $this->defaultBusId = $defaultBusId;
  31.     }
  33.     public function createBlankRouting(): Routing
  34.     {
  35.         return new Routing(array_keys($this->busBuilders));
  36.     }
  38.     public function defaultBus(): BusBuilder
  39.     {
  40.         return $this->get($this->defaultBusId);
  41.     }
  43.     private function get(string $busId): BusBuilder
  44.     {
  45.         $this->assertValidBusId($busId);
  47.         return $this->busBuilders[$busId];
  48.     }
  50.     /**
  51.      * @return ArrayIterator|BusBuilder[]
  52.      */
  53.     public function getIterator()
  54.     {
  55.         return new ArrayIterator($this->busBuilders);
  56.     }
  58.     private function assertValidBusId($busId)
  59.     {
  60.         if (!isset($this->busBuilders[$busId])) {
  61.             throw InvalidCommandBusId::ofName($busId, array_keys($this->busBuilders));
  62.         }
  63.     }
  65.     private function add(BusBuilder $builder)
  66.     {
  67.         $id = $builder->id();
  69.         if (isset($this->busBuilders[$id])) {
  70.             throw DuplicatedCommandBusId::withId($id);
  71.         }
  73.         $this->busBuilders[$id] = $builder;
  74.     }
  75. }